# frozen_string_literal: true

require 'nokogiri'
require 'moab'

module Dor
  module Services
    class Client
      # API calls that are about preserved objects
      class SDR < VersionedService
        extend Deprecation
        self.deprecation_horizon = 'dor-services-client version 4.0'

        # @param object_identifier [String] the pid for the object
        def initialize(connection:, version:, object_identifier:)
          super(connection: connection, version: version)
          @object_identifier = object_identifier
        end

        # Gets the current version number for the object
        # @raise [UnexpectedResponse] when the response is not successful.
        # @raise [MalformedResponse] when the response is not parseable.
        # @return [Integer] the current version
        def current_version
          xml = current_version_response
          begin
            doc = Nokogiri::XML xml
            raise if doc.root.name != 'currentVersion'

            return Integer(doc.text)
          rescue StandardError
            raise MalformedResponse, "Unable to parse XML from current_version API call: #{xml}"
          end
        end
        deprecation_deprecate current_version: 'use preservation-client current_version instead'

        def signature_catalog
          resp = signature_catalog_response

          return Moab::SignatureCatalog.new(digital_object_id: object_identifier, version_id: 0) if resp.status == 404
          raise UnexpectedResponse, ResponseErrorFormatter.format(response: resp, object_identifier: object_identifier) unless resp.success?

          Moab::SignatureCatalog.parse resp.body
        end
        deprecation_deprecate :signature_catalog

        # Retrieves file difference manifest for contentMetadata from SDR
        #
        # @param [String] current_content The contentMetadata xml
        # @param [String] subset ('all') The keyword for file attributes 'shelve', 'preserve', 'publish'.
        # @param [Integer, NilClass] version (nil)
        # @return [Moab::FileInventoryDifference] the differences for the given content and subset (i.e.: cm_inv_diff manifest)
        def content_diff(current_content:, subset: 'all', version: nil)
          raise ArgumentError, "Invalid subset value: #{subset}" unless %w[all shelve preserve publish].include?(subset)

          resp = content_diff_response(current_content: current_content, subset: subset, version: version)

          Moab::FileInventoryDifference.parse(resp)
        end

        # @param [String] datastream The identifier of the metadata datastream
        # @return [String, NilClass] datastream content from previous version of the object (from SDR storage), or nil if response status is 404
        # @raise [UnexpectedResponse] on an unsuccessful, non-404 response from the server
        def metadata(datastream:)
          resp = connection.get do |req|
            req.url "#{base_path}/metadata/#{datastream}.xml"
          end
          return resp.body if resp.success?
          return if resp.status == 404

          raise UnexpectedResponse, ResponseErrorFormatter.format(response: resp, object_identifier: object_identifier)
        end

        private

        attr_reader :object_identifier

        def signature_catalog_response
          connection.get do |req|
            req.url "#{base_path}/manifest/signatureCatalog.xml"
          end
        end

        # make the request to the server for the currentVersion xml
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        # @return [String] the raw xml from the server
        def current_version_response
          resp = connection.get do |req|
            req.url current_version_path
          end
          return resp.body if resp.success?

          raise UnexpectedResponse, ResponseErrorFormatter.format(response: resp, object_identifier: object_identifier)
        end

        def current_version_path
          "#{base_path}/current_version"
        end

        # make the request to the server for the content diff
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        # @return [String] the raw xml from the server
        def content_diff_response(current_content:, subset:, version:)
          resp = connection.post do |req|
            req.url content_diff_path(subset: subset, version: version)
            req.headers['Content-Type'] = 'application/xml'
            req.body = current_content
          end
          raise UnexpectedResponse, ResponseErrorFormatter.format(response: resp, object_identifier: object_identifier) unless resp.success?

          resp.body
        end

        def content_diff_path(subset:, version:)
          query_string = { subset: subset }
          query_string[:version] = version.to_s unless version.nil?
          query_string = URI.encode_www_form(query_string)
          "#{base_path}/cm-inv-diff?#{query_string}"
        end

        def base_path
          "#{api_version}/sdr/objects/#{object_identifier}"
        end
      end
    end
  end
end