class ShopifyAPI::Webhooks::Registrations::Http

def build_check_query
  <<~QUERY
    {
      webhookSubscriptions(first: 1, topics: #{@topic}) {
        edges {
          node {
            id
            endpoint {
              __typename
              ... on WebhookHttpEndpoint {
                callbackUrl
              }
            }
          }
        }
      }
    }
  QUERY
end

def callback_address
  if @path.match?(%r{^https?://})
    @path
  elsif @path.match?(/^#{Context.host_name}/)
    "#{Context.host_scheme}://#{@path}"
  else
    "#{Context.host}/#{@path}"
  end
end

def mutation_name(webhook_id)
  webhook_id ? "webhookSubscriptionUpdate" : "webhookSubscriptionCreate"
end

def parse_check_result(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 =
      if node.key?("endpoint")
        node["endpoint"]["callbackUrl"].to_s
      else
        node["callbackUrl"].to_s
      end
  end
  { webhook_id: webhook_id, current_address: current_address }
end

def subscription_args
  { callbackUrl: callback_address, includeFields: fields, metafieldNamespaces: metafield_namespaces }.compact
end