class ElasticAPM::Transport::Serializers::SpanSerializer::ContextSerializer

def build(context)
  return unless context
  base = {}
  base[:tags] = mixed_object(context.labels) if context.labels.any?
  base[:sync] = context.sync unless context.sync.nil?
  base[:db] = build_db(context.db) if context.db
  base[:http] = build_http(context.http) if context.http
  if context.destination
    base[:destination] = build_destination(context.destination)
  end
  if context.message
    base[:message] = build_message(context.message)
  end
  base
end

def build_db(db)
  {
    instance: db.instance,
    statement: Util.truncate(db.statement, max_length: 10_000),
    type: db.type,
    user: db.user,
    rows_affected: db.rows_affected
  }
end

def build_destination(destination)
  return unless destination
  base = {
    address: keyword_field(destination.address),
    port: destination.port
  }
  unless destination.service&.empty?
    base[:service] = destination.service.to_h
  end
  unless destination.cloud&.empty?
    base[:cloud] = destination.cloud.to_h
  end
  base
end

def build_http(http)
  {
    url: http.url,
    status_code: http.status_code.to_i,
    method: keyword_field(http.method)
  }
end

def build_message(message)
  {
    queue: {
      name: keyword_field(message.queue_name)
    },
    age: {
      ms: message.age_ms.to_i
    }
  }
end