ExisRay

gem "exis_ray"

# 1. Configurar ExisRay (config/initializers/exis_ray.rb)
ExisRay.configure do |config|
  config.log_format     = Rails.env.production? ? :json : :text
  config.current_class  = "Current"
  config.reporter_class = "Reporter"
end

# 2. Crear Current (app/models/current.rb)
class Current < ExisRay::Current
  # ExisRay provee: user_id, isp_id, correlation_id
  # Agregar atributos específicos de la app:
  attribute :permissions
end

# 3. Crear Reporter (app/models/reporter.rb)
class Reporter < ExisRay::Reporter
end

# 4. Hidratar el Current en cada request (app/controllers/application_controller.rb)
class ApplicationController < ActionController::Base
  before_action :set_context

  private

  def set_context
    Current.user = current_user if current_user
    Current.isp_id = request.headers["X-Isp-Id"]
  end
end

# config/initializers/exis_ray.rb
ExisRay.configure do |config|
  # Header entrante (formato Rack). Default: "HTTP_X_AMZN_TRACE_ID"
  config.trace_header = "HTTP_X_AMZN_TRACE_ID"

  # Header saliente (formato HTTP). Default: "X-Amzn-Trace-Id"
  config.propagation_trace_header = "X-Amzn-Trace-Id"

  # Clases de la app host (strings para evitar problemas de autoloading)
  config.current_class  = "Current"    # hereda de ExisRay::Current
  config.reporter_class = "Reporter"   # hereda de ExisRay::Reporter

  # Formato de logs: :text (default) o :json
  config.log_format = Rails.env.production? ? :json : :text

  # Subclase de LogSubscriber para campos HTTP extra (opcional)
  # config.log_subscriber_class = "MyLogSubscriber"
end

# app/models/current.rb
class Current < ExisRay::Current
  # Atributos heredados: user_id, isp_id, correlation_id
  # Helpers heredados: user, user=, isp, isp=, user?, isp?, correlation_id?
  #
  # Agregar atributos específicos de la app:
  attribute :permissions
end

# app/models/reporter.rb
class Reporter < ExisRay::Reporter
  # Hook opcional para contexto adicional en Sentry
  def self.build_custom_context
    add_tags(plan: ExisRay.current_class.isp&.plan)
  end

  # Hook opcional para controlar qué datos del usuario se envían a Sentry.
  # Default: solo { id: current.user_id }
  def self.sentry_user_context(current)
    { id: current.user_id, email: current.user&.email }
  end
end

# Reportar un mensaje
Reporter.report("algo inesperado", context: { order_id: 123 }, tags: { severity: "high" })

# Reportar una excepción
Reporter.exception(error, context: { order_id: 123 }, fingerprint: ["order-failure"])

# Acumular contexto durante el request (se envía con el próximo report/exception)
Reporter.add_context(order: { id: 123, total: 500 })
Reporter.add_tags(feature: "checkout")
Reporter.add_fingerprint("checkout-error")

# BugBunny::Client
client = BugBunny::Client.new(pool: pool) do |stack|
  stack.use ExisRay::BugBunny::PublisherTracing
end

# BugBunny::Resource (se hereda a subclases)
class ApplicationResource < BugBunny::Resource
  client_middleware do |stack|
    stack.use ExisRay::BugBunny::PublisherTracing
  end
end

conn = Faraday.new(url: "https://api.internal") do |f|
  f.use ExisRay::FaradayMiddleware
end

task generate_invoices: :environment do
  ExisRay::TaskMonitor.run("billing:generate_invoices") do
    InvoiceService.process_all
  end
end

Rails.logger.info "component=billing event=invoice_created invoice_id=123 total=45.50"
# => {"time":"...","level":"INFO","service":"...","root_id":"...","component":"billing","event":"invoice_created","invoice_id":123,"total":45.5}

Rails.logger.info "Algo pasó sin formato KV"
# => {"time":"...","level":"INFO","service":"...","body":"Algo pasó sin formato KV"}

# app/subscribers/my_log_subscriber.rb
class MyLogSubscriber < ExisRay::LogSubscriber
  def self.extra_fields(event)
    { user_agent: event.payload[:headers]["HTTP_USER_AGENT"] }
  end
end

# config/initializers/exis_ray.rb
ExisRay.configure do |config|
  config.log_subscriber_class = "MyLogSubscriber"
end

# Hidratar el Tracer (usado internamente por los middlewares)
ExisRay::Tracer.hydrate(trace_id: header_string, source: "http")

# Generar header de propagación para el siguiente servicio
ExisRay::Tracer.generate_trace_header
# => "Root=1-abc123-...;Self=1-def456-...;CalledFrom=wispro_agent;TotalTimeSoFar=42ms"

# Duración del request actual
ExisRay::Tracer.current_duration_s   # => 0.0452 (Float, segundos)
ExisRay::Tracer.current_duration_ms  # => 45 (Integer, milisegundos)

# Formatear duración human-readable
ExisRay::Tracer.format_duration(0.007)   # => "7.0ms"
ExisRay::Tracer.format_duration(1.25)    # => "1.25s"
ExisRay::Tracer.format_duration(125.0)   # => "2 minutes 5 seconds"

# Nombre del servicio (snake_case del module parent de la app Rails)
ExisRay::Tracer.service_name  # => "wispro_agent"

# Correlation ID compuesto
ExisRay::Tracer.correlation_id  # => "wispro_agent;1-65f...abc"

# Sincronizar correlation_id al Current configurado
ExisRay.sync_correlation_id