Class: ShopifyClient::CreateAllWebhooks
- Inherits:
-
Object
- Object
- ShopifyClient::CreateAllWebhooks
- Defined in:
- lib/shopify-client/create_all_webhooks.rb
Instance Method Summary collapse
-
#call(client) ⇒ Array<String>
Create all registered webhooks for a shop.
Instance Method Details
#call(client) ⇒ Array<String>
Create all registered webhooks for a shop.
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 |
# File 'lib/shopify-client/create_all_webhooks.rb', line 10 def call(client) raise ConfigError, 'webhook_uri is not set' unless ShopifyClient.config.webhook_uri webhooks_with_index = ShopifyClient.webhooks.each_with_index return [] unless webhooks_with_index.any? client.graphql(%( mutation webhookSubscriptionCreate( #{webhooks_with_index.map { |_, i| %( $topic#{i}: WebhookSubscriptionTopic! $webhookSubscription#{i}: WebhookSubscriptionInput! )}.join("\n")} ) { #{webhooks_with_index.map { |_, i| %( webhookSubscriptionCreate#{i}: webhookSubscriptionCreate( topic: $topic#{i} webhookSubscription: $webhookSubscription#{i} ) { userErrors { field message } webhookSubscription { id } } )}.join("\n")} } ), webhooks_with_index.each_with_object({}) do |((topic, ), i), variables| variables["topic#{i}"] = topic_to_graphql(topic) variables["webhookSubscription#{i}"] = {}.tap do |subscription| subscription['callbackUrl'] = ShopifyClient.config.webhook_uri subscription['includeFields'] = [:fields] unless [:fields].empty? end end).data['data'].map do |_, mutation| mutation['webhookSubscription']['id'] end end |