# Licensed to Elasticsearch B.V. under one or more contributor
# license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright
# ownership. Elasticsearch B.V. licenses this file to you under
# the Apache License, Version 2.0 (the "License"); you may
# not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

# frozen_string_literal: true

require 'spec_helper'

module ElasticAPM
  module Transport
    module Serializers
      RSpec.describe ErrorSerializer do
        let(:config) { Config.new }
        let(:agent) { Agent.new(config) }
        let(:builder) { ErrorBuilder.new(agent) }

        subject { described_class.new(config) }

        context 'with an exception', :mock_time do
          it 'matches format' do
            error = builder.build_exception(actual_exception)
            result = subject.build(error).fetch(:error)

            expect(result).to include(
              id: be_a(String),
              culprit: be_a(String),
              timestamp: 694_224_000_000_000,
              parent_id: nil,
              trace_id: nil,
              transaction_id: nil,
              transaction: nil
            )

            expect(result.fetch(:exception)).to include(
              message: 'divided by 0',
              type: 'ZeroDivisionError',
              module: '',
              code: nil,
              attributes: nil,
              stacktrace: be_an(Array),
              handled: true,
              cause: nil
            )
          end

          context 'with an exception chain', :mock_time do
            it 'matches format' do
              error = builder.build_exception(actual_chained_exception)
              result = subject.build(error).fetch(:error)

              expect(result).to include(
                id: be_a(String),
                culprit: be_a(String),
                timestamp: 694_224_000_000_000,
                parent_id: nil,
                trace_id: nil,
                transaction_id: nil,
                transaction: nil
              )

              exception = result.fetch(:exception)
              expect(exception).to include(
                message: 'ExceptionHelpers::ChainedErrorOne',
                type: 'ExceptionHelpers::ChainedErrorOne',
                module: 'ExceptionHelpers',
                code: nil,
                attributes: nil,
                stacktrace: be_an(Array),
                handled: true,
                cause: be_an(Array)
              )

              cause1 = exception.fetch(:cause)[0]
              expect(cause1).to include(
                message: 'ExceptionHelpers::ChainedErrorTwo',
                type: 'ExceptionHelpers::ChainedErrorTwo',
                module: 'ExceptionHelpers',
                code: nil,
                attributes: nil,
                stacktrace: eq([]),
                handled: nil,
                cause: be_an(Array)
              )

              cause2 = cause1.fetch(:cause)[0]
              expect(cause2).to include(
                message: 'ExceptionHelpers::ChainedErrorThree',
                type: 'ExceptionHelpers::ChainedErrorThree',
                module: 'ExceptionHelpers',
                code: nil,
                attributes: nil,
                stacktrace: eq([]),
                handled: nil,
                cause: nil
              )
            end
          end

          context 'with a context' do
            it 'includes context' do
              env = Rack::MockRequest.env_for('/')

              context =
                agent.context_builder.build(rack_env: env, for_type: :error)

              error =
                builder.build_exception(actual_exception, context: context)

              context = subject.build(error).fetch(:error).fetch(:context)

              expect(context).to include(
                custom: {},
                tags: {},
                user: nil,
                request: be_a(Hash)
              )
            end
          end

          context 'with a transaction' do
            it 'includes context', :intercept do
              error = with_agent do
                ElasticAPM.with_transaction do
                  ErrorBuilder
                    .new(ElasticAPM.agent)
                    .build_exception(actual_exception)
                end
              end

              transaction =
                subject.build(error).fetch(:error).fetch(:transaction)

              expect(transaction).to match(
                sampled: true,
                type: 'custom'
              )
            end
          end
        end

        context 'with a log', :mock_time do
          let(:error) do
            builder.build_log('oh no!')
          end

          it 'matches format' do
            result = subject.build(error).fetch(:error)

            expect(result).to include(
              id: be_a(String),
              culprit: nil,
              timestamp: 694_224_000_000_000,
              parent_id: nil,
              trace_id: nil,
              transaction_id: nil,
              transaction: nil
            )

            expect(result.fetch(:log)).to include(
              level: nil,
              logger_name: nil,
              message: 'oh no!',
              param_message: nil,
              stacktrace: []
            )
          end
        end
      end
    end
  end
end