Fix: ShopifyAPI::Webhooks::Registry doesn't update webhooks if metafield_namespaces has changed

CHANGELOG.md

@@ -3,6 +3,7 @@
 Note: For changes to the API, see https://shopify.dev/changelog?filter=api
 ## Unreleased
 
+- [#1344](https://github.com/Shopify/shopify-api-ruby/pull/1344) Allow ShopifyAPI::Webhooks::Registry to update a webhook when fields or metafield_namespaces are changed.
 - [#1343](https://github.com/Shopify/shopify-api-ruby/pull/1343) Make ShopifyAPI::Context::scope parameter optional. `scope` defaults to empty list `[]`.
 
 ## 14.6.0

lib/shopify_api/webhooks/registration.rb

@@ -48,8 +48,28 @@ def mutation_name(webhook_id); end
       sig { abstract.returns(String) }
       def build_check_query; end
 
-      sig { abstract.params(body: T::Hash[String, T.untyped]).returns(T::Hash[Symbol, String]) }
-      def parse_check_result(body); end
+      sig do
+        params(body: T::Hash[String, T.untyped]).returns({
+          webhook_id: T.nilable(String),
+          current_address: T.nilable(String),
+          fields: T::Array[String],
+          metafield_namespaces: T::Array[String],
+        })
+      end
+      def parse_check_result(body)
+        edges = body.dig("data", "webhookSubscriptions", "edges") || {}
+        webhook_id = nil
+        fields = []
+        metafield_namespaces = []
+        unless edges.empty?
+          node = edges[0]["node"]
+          webhook_id = node["id"].to_s
+          fields = node["includeFields"] || []
+          metafield_namespaces = node["metafieldNamespaces"] || []
+        end
+        { webhook_id: webhook_id, current_address: nil, fields: fields,
+          metafield_namespaces: metafield_namespaces, }
+      end
 
       sig { params(webhook_id: T.nilable(String)).returns(String) }
       def build_register_query(webhook_id: nil)

lib/shopify_api/webhooks/registrations/event_bridge.rb

@@ -30,6 +30,8 @@ def build_check_query
                 edges {
                   node {
                     id
+                    includeFields
+                    metafieldNamespaces
                     endpoint {
                       __typename
                       ... on WebhookEventBridgeEndpoint {
@@ -43,17 +45,22 @@ def build_check_query
           QUERY
         end
 
-        sig { override.params(body: T::Hash[String, T.untyped]).returns(T::Hash[Symbol, String]) }
+        sig do
+          params(body: T::Hash[String, T.untyped]).returns({
+            webhook_id: T.nilable(String),
+            current_address: T.nilable(String),
+            fields: T::Array[String],
+            metafield_namespaces: T::Array[String],
+          })
+        end
         def parse_check_result(body)
+          parse_results = super(body)
           edges = body.dig("data", "webhookSubscriptions", "edges") || {}
-          webhook_id = nil
-          current_address = nil
           unless edges.empty?
             node = edges[0]["node"]
-            webhook_id = node["id"].to_s
-            current_address = node["endpoint"]["arn"].to_s
+            parse_results[:current_address] = node["endpoint"]["arn"].to_s
           end
-          { webhook_id: webhook_id, current_address: current_address }
+          parse_results
         end
       end
     end

lib/shopify_api/webhooks/registrations/http.rb

@@ -36,6 +36,8 @@ def build_check_query
                 edges {
                   node {
                     id
+                    includeFields
+                    metafieldNamespaces
                     endpoint {
                       __typename
                       ... on WebhookHttpEndpoint {
@@ -49,22 +51,27 @@ def build_check_query
           QUERY
         end
 
-        sig { override.params(body: T::Hash[String, T.untyped]).returns(T::Hash[Symbol, String]) }
+        sig do
+          params(body: T::Hash[String, T.untyped]).returns({
+            webhook_id: T.nilable(String),
+            current_address: T.nilable(String),
+            fields: T::Array[String],
+            metafield_namespaces: T::Array[String],
+          })
+        end
         def parse_check_result(body)
+          parse_results = super(body)
           edges = body.dig("data", "webhookSubscriptions", "edges") || {}
-          webhook_id = nil
-          current_address = nil
           unless edges.empty?
             node = edges[0]["node"]
-            webhook_id = node["id"].to_s
-            current_address =
+            parse_results[:current_address] =
               if node.key?("endpoint")
                 node["endpoint"]["callbackUrl"].to_s
               else
                 node["callbackUrl"].to_s
               end
           end
-          { webhook_id: webhook_id, current_address: current_address }
+          parse_results
         end
       end
     end

lib/shopify_api/webhooks/registrations/pub_sub.rb

@@ -34,6 +34,8 @@ def build_check_query
                 edges {
                   node {
                     id
+                    includeFields
+                    metafieldNamespaces
                     endpoint {
                       __typename
                       ... on WebhookPubSubEndpoint {
@@ -48,17 +50,23 @@ def build_check_query
           QUERY
         end
 
-        sig { override.params(body: T::Hash[String, T.untyped]).returns(T::Hash[Symbol, String]) }
+        sig do
+          params(body: T::Hash[String, T.untyped]).returns({
+            webhook_id: T.nilable(String),
+            current_address: T.nilable(String),
+            fields: T::Array[String],
+            metafield_namespaces: T::Array[String],
+          })
+        end
         def parse_check_result(body)
+          parse_results = super(body)
           edges = body.dig("data", "webhookSubscriptions", "edges") || {}
-          webhook_id = nil
-          current_address = nil
           unless edges.empty?
             node = edges[0]["node"]
-            webhook_id = node["id"].to_s
-            current_address = "pubsub://#{node["endpoint"]["pubSubProject"]}:#{node["endpoint"]["pubSubTopic"]}"
+            parse_results[:current_address] =
+              "pubsub://#{node["endpoint"]["pubSubProject"]}:#{node["endpoint"]["pubSubTopic"]}"
           end
-          { webhook_id: webhook_id, current_address: current_address }
+          parse_results
         end
       end
     end

lib/shopify_api/webhooks/registry.rb

@@ -219,8 +219,14 @@ def webhook_registration_needed?(client, registration)
           check_response = client.query(query: registration.build_check_query, response_as_struct: false)
           raise Errors::WebhookRegistrationError,
             "Failed to check if webhook was already registered" unless check_response.ok?
+
           parsed_check_result = registration.parse_check_result(T.cast(check_response.body, T::Hash[String, T.untyped]))
-          must_register = parsed_check_result[:current_address] != registration.callback_address
+          registration_fields = registration.fields || []
+          registration_metafield_namespaces = registration.metafield_namespaces || []
+
+          must_register = parsed_check_result[:current_address] != registration.callback_address ||
+            parsed_check_result[:fields].sort != registration_fields.sort ||
+            parsed_check_result[:metafield_namespaces].sort != registration_metafield_namespaces.sort
 
           { webhook_id: parsed_check_result[:webhook_id], must_register: must_register }
         end