class ShopifyAPI::Webhooks::Registrations::PubSub
Public Instance Methods
Source
# File lib/shopify_api/webhooks/registrations/pub_sub.rb, line 30 def build_check_query <<~QUERY { webhookSubscriptions(first: 1, topics: #{@topic}) { edges { node { id includeFields metafieldNamespaces filter endpoint { __typename ... on WebhookPubSubEndpoint { pubSubProject pubSubTopic } } } } } } QUERY end
Source
# File lib/shopify_api/webhooks/registrations/pub_sub.rb, line 11 def callback_address @path end
Source
# File lib/shopify_api/webhooks/registrations/pub_sub.rb, line 25 def mutation_name(webhook_id) webhook_id ? "pubSubWebhookSubscriptionUpdate" : "pubSubWebhookSubscriptionCreate" end
Source
# File lib/shopify_api/webhooks/registrations/pub_sub.rb, line 63 def parse_check_result(body) edges = body.dig("data", "webhookSubscriptions", "edges") || {} webhook_id = nil fields = [] metafield_namespaces = [] filter = 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"]}" fields = node["includeFields"] || [] metafield_namespaces = node["metafieldNamespaces"] || [] filter = node["filter"].to_s end { webhook_id: webhook_id, current_address: current_address, fields: fields, metafield_namespaces: metafield_namespaces, filter: filter, } end
Source
# File lib/shopify_api/webhooks/registrations/pub_sub.rb, line 16 def subscription_args project_topic_pair = callback_address.gsub(%r{^pubsub://}, "").split(":") project = project_topic_pair[0] topic = project_topic_pair[1] { pubSubProject: project, pubSubTopic: topic, includeFields: fields, metafieldNamespaces: metafield_namespaces, filter: filter, }.compact end