require 'faraday'

module VCR
  module Middleware
    class Faraday < ::Faraday::Middleware
      include Common

      class HttpConnectionNotAllowedError < StandardError; end

      def call(env)
        VCR::HttpStubbingAdapters::Faraday.exclusively_enabled do
          VCR.use_cassette(*cassette_arguments(env)) do |cassette|
            request = request_for(env)
            request_matcher = request.matcher(cassette.match_requests_on)

            if VCR::HttpStubbingAdapters::Faraday.uri_should_be_ignored?(request.uri)
              @app.call(env)
            elsif response = VCR::HttpStubbingAdapters::Faraday.stubbed_response_for(request_matcher)
              env.update(
                :status           => response.status.code,
                :response_headers => normalized_headers(response.headers),
                :body             => response.body
              )

              env[:response].finish(env)
            elsif VCR::HttpStubbingAdapters::Faraday.http_connections_allowed?
              response = @app.call(env)

              # Checking #enabled? isn't strictly needed, but conforms
              # the Faraday adapter to the behavior of the other adapters
              if VCR::HttpStubbingAdapters::Faraday.enabled?
                VCR.record_http_interaction(VCR::HTTPInteraction.new(request, response_for(env)))
              end

              response
            else
              raise HttpConnectionNotAllowedError.new(
                "Real HTTP connections are disabled. Request: #{request.method.inspect} #{request.uri}"
              )
            end
          end
        end
      end

      private

        def request_for(env)
          VCR::Request.new(
            env[:method],
            env[:url].to_s,
            env[:body],
            env[:request_headers]
          )
        end

        def response_for(env)
          response = env[:response]

          VCR::Response.new(
            VCR::ResponseStatus.new(response.status, nil),
            response.headers,
            response.body,
            '1.1'
          )
        end

        def normalized_headers(headers)
          hash = {}

          headers.each do |key, values|
            hash[key] = values.join(', ')
          end if headers

          hash
        end
    end
  end
end