class ShopifyAPI::Webhooks::Registration
def build_check_query; end
def build_check_query; end
def build_register_query(webhook_id: nil)
def build_register_query(webhook_id: nil) identifier = webhook_id ? "id: \"#{webhook_id}\"" : "topic: #{@topic}" subscription_args_string = subscription_args.map do |k, v| "#{k}: #{[:includeFields, :metafieldNamespaces].include?(k) ? v : %("#{v}")}" end.join(", ") <<~QUERY mutation webhookSubscription { #{mutation_name(webhook_id)}(#{identifier}, webhookSubscription: {#{subscription_args_string}}) { userErrors { field message } webhookSubscription { #{subscription_response_attributes.join("\n ")} } } } QUERY end
def callback_address; end
def callback_address; end
def initialize(topic:, path:, handler: nil, fields: nil, metafield_namespaces: nil)
def initialize(topic:, path:, handler: nil, fields: nil, metafield_namespaces: nil) @topic = T.let(topic.gsub("/", "_").upcase, String) @path = path @handler = handler fields_array = fields.is_a?(String) ? fields.split(FIELDS_DELIMITER) : fields @fields = T.let(fields_array&.map(&:strip)&.compact, T.nilable(T::Array[String])) @metafield_namespaces = T.let(metafield_namespaces&.map(&:strip)&.compact, T.nilable(T::Array[String])) end
def mutation_name(webhook_id); end
def mutation_name(webhook_id); end
def parse_check_result(body); end
def parse_check_result(body); end
def subscription_args; end
def subscription_args; end
def subscription_response_attributes
def subscription_response_attributes attributes = ["id"] attributes << "includeFields" if @fields attributes << "metafieldNamespaces" if @metafield_namespaces attributes end