class GraphQL::Subscriptions::DefaultSubscriptionResolveExtension

# File lib/graphql/subscriptions/default_subscription_resolve_extension.rb, line 45
def self.write_subscription(field, value, arguments, context)
  if value.is_a?(GraphQL::ExecutionError)
    value
  elsif field.resolver&.method_defined?(:subscription_written?) &&
    (subscription_namespace = context.namespace(:subscriptions)) &&
    (subscriptions_by_path = subscription_namespace[:subscriptions])
    (subscription_instance = subscriptions_by_path[context.current_path])
    # If it was already written, don't append this event to be written later
    if !subscription_instance.subscription_written?
      events = context.namespace(:subscriptions)[:events]
      events << subscription_instance.event
    end
    value
  elsif (exec_next_update_event = context.namespace(:subscriptions)[:update_event])
    if context.query.subscription_topic == exec_next_update_event.topic
      value
    else
      context.skip
    end
  elsif (events = context.namespace(:subscriptions)[:events])
    # This is the first execution, so gather an Event
    # for the backend to register:
    event = Subscriptions::Event.new(
      name: field.name,
      arguments: arguments,
      context: context,
      field: field,
    )
    events << event
    value
  elsif context.query.subscription_topic == Subscriptions::Event.serialize(
      field.name,
      arguments,
      field,
      scope: (field.subscription_scope ? context[field.subscription_scope] : nil),
    )
    # This is a subscription update. The resolver returned `skip` if it should be skipped,
    # or else it returned an object to resolve the update.
    value
  else
    # This is a subscription update, but this event wasn't triggered.
    context.skip
  end
end

# File lib/graphql/subscriptions/default_subscription_resolve_extension.rb, line 35
def after_resolve(values: nil, value: nil, context:, objects: nil, object: nil, arguments:, **rest)
  if values
    values.map do |value|
      self.class.write_subscription(@field, value, arguments, context)
    end
  else
    self.class.write_subscription(@field, value, arguments, context)
  end
end

# File lib/graphql/subscriptions/default_subscription_resolve_extension.rb, line 6
def resolve(context:, object: nil, objects: nil,  arguments:)
  if objects
    has_override_implementation = @field.execution_mode != :direct_send

    if !has_override_implementation
      if context.query.subscription_update?
        objects
      else
        objects.map { |o| context.skip }
      end
    else
      yield(objects, arguments)
    end
  else
    has_override_implementation = @field.resolver ||
      object.respond_to?(@field.resolver_method)

    if !has_override_implementation
      if context.query.subscription_update?
        object.object
      else
        context.skip
      end
    else
      yield(object, arguments)
    end
  end
end