module GraphQL::Tracing::NotificationsTrace

# File lib/graphql/tracing/notifications_trace.rb, line 80
def initialize(engine:, **rest)
  adapter = if defined?(Dry::Monitor) && engine == Dry::Monitor
    DryMonitoringAdapter
  elsif defined?(ActiveSupport::Notifications) && engine == ActiveSupport::Notifications
    ActiveSupportNotificationsAdapter
  else
    engine
  end
  @notifications = adapter.new
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 110
def begin_analyze_multiplex(multiplex, analyzers)
  begin_notifications_event("analyze.graphql", {multiplex: multiplex, analyzers: analyzers})
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 149
def begin_authorized(type, object, context)
  begin_notifications_event("authorized.graphql", {type: type, object: object, context: context})
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 169
def begin_dataloader_source(source)
  begin_notifications_event("dataloader_source.graphql", { source: source })
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 126
def begin_execute_field(field, object, arguments, query)
  begin_notifications_event("execute_field.graphql", {field: field, object: object, arguments: arguments, query: query})
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 159
def begin_resolve_type(type, object, context)
  begin_notifications_event("resolve_type.graphql", {type: type, object: object, context: context})
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 141
def dataloader_fiber_resume(source)
  prev_ev = Fiber[PREVIOUS_EV_KEY]
  if prev_ev
    begin_notifications_event(prev_ev.name, prev_ev.payload)
  end
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 136
def dataloader_fiber_yield(source)
  Fiber[PREVIOUS_EV_KEY] = finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 115
def end_analyze_multiplex(_multiplex, _analyzers)
  finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 154
def end_authorized(type, object, context, result)
  finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 174
def end_dataloader_source(source)
  finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 131
def end_execute_field(_field, _object, _arguments, _query, _result)
  finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 164
def end_resolve_type(type, object, context, resolved_type)
  finish_notifications_event
  super
end

# File lib/graphql/tracing/notifications_trace.rb, line 120
def execute_multiplex(**payload)
  @notifications.instrument("execute.graphql", payload) do
    super
  end
end

# File lib/graphql/tracing/notifications_trace.rb, line 98
def lex(**payload)
  @notifications.instrument("lex.graphql", payload) do
    super
  end
end

# File lib/graphql/tracing/notifications_trace.rb, line 92
def parse(**payload)
  @notifications.instrument("parse.graphql", payload) do
    super
  end
end

# File lib/graphql/tracing/notifications_trace.rb, line 104
def validate(**payload)
  @notifications.instrument("validate.graphql", payload) do
    super
  end
end