# frozen_string_literal: true

module Preservation
  class Client
    # @abstract API calls to a versioned endpoint
    class VersionedApiService
      def initialize(connection:, api_version: DEFAULT_API_VERSION)
        @connection = connection
        @api_version = api_version
      end

      private

      attr_reader :connection, :api_version

      # @param path [String] path to be appended to connection url (no leading slash)
      def get_json(path, object_id)
        req_url = api_version.present? ? "#{api_version}/#{path}" : path
        resp = connection.get do |req|
          req.url req_url
          req.headers['Content-Type'] = 'application/json'
          req.headers['Accept'] = 'application/json'
        end
        return JSON.parse(resp.body).with_indifferent_access if resp.success?

        errmsg = ResponseErrorFormatter
                 .format(response: resp, object_id: object_id, client_method_name: caller_locations.first.label)
        raise Preservation::Client::UnexpectedResponseError, errmsg
      rescue Faraday::ResourceNotFound
        errmsg = "#{object_id} not found in Preservation at #{connection.url_prefix}#{req_url}"
        raise Preservation::Client::NotFoundError, errmsg
      rescue Faraday::Error => e
        errmsg = "Preservation::Client.#{caller_locations.first.label} for #{object_id} " \
          "got #{e.response[:status]} from Preservation at #{req_url}: #{e.response[:body]}"
        raise Preservation::Client::UnexpectedResponseError, errmsg
      end

      # @param path [String] path to be appended to connection url (no leading slash)
      # @param params [Hash] optional params
      def get(path, params)
        http_response(:get, path, params)
      end

      # @param path [String] path to be appended to connection url (no leading slash)
      # @param params [Hash] optional params
      def post(path, params)
        http_response(:post, path, params)
      end

      # @param method [Symbol] :get or :post
      # @param path [String] path to be appended to connection url (no leading slash)
      # @param params [Hash] optional params
      def http_response(method, path, params)
        req_url = api_version.present? ? "#{api_version}/#{path}" : path
        resp = connection.send(method, req_url, params)
        return resp.body if resp.success?

        errmsg = ResponseErrorFormatter.format(response: resp, client_method_name: caller_locations.first.label)
        raise Preservation::Client::UnexpectedResponseError, errmsg
      rescue Faraday::ResourceNotFound => e
        errmsg = "Preservation::Client.#{caller_locations.first.label} " \
          "got #{e.response[:status]} from Preservation at #{req_url}: #{e.response[:body]}"
        raise Preservation::Client::NotFoundError, errmsg
      rescue Faraday::Error => e
        errmsg = "Preservation::Client.#{caller_locations.first.label} " \
          "got #{e.response[:status]} from Preservation at #{req_url}: #{e.response[:body]}"
        raise Preservation::Client::UnexpectedResponseError, errmsg
      end
    end
  end
end