# frozen_string_literal: true

require 'active_support/json' # required for serializing time as iso8601

module Dor
  module Services
    class Client
      # API calls that are about retrieving metadata
      class Metadata < VersionedService
        # @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

        # Updates using the legacy SDR/Fedora3 metadata
        # @param [Hash<Symbol,Hash>] opts the options for legacy update
        # @option opts [Hash] :administrative Data for administrative metadata
        # @option opts [Hash] :content Data for structural metadata
        # @option opts [Hash] :descriptive Data for descriptive metadata
        # @option opts [Hash] :geo Data for geographic metadata
        # @option opts [Hash] :identity Data for identity metadata
        # @option opts [Hash] :provenance Data for provenance metadata
        # @option opts [Hash] :relationships Data for RELS-EXT metadata
        # @option opts [Hash] :rights Data for access rights metadata
        # @option opts [Hash] :technical Data for technical metadata
        # @option opts [Hash] :version Data for version metadata
        # @example:
        #  legacy_update(descriptive: { updated: '2001-12-20', content: '<descMetadata />' })
        def legacy_update(opts)
          opts = opts.slice(:administrative, :content, :descriptive, :geo, :identity, :provenance, :relationships, :rights, :technical, :version)
          resp = connection.patch do |req|
            req.url "#{base_path}/legacy"
            req.headers['Content-Type'] = 'application/json'
            req.body = opts.to_json
          end
          return if resp.success?

          raise_exception_based_on_response!(resp, object_identifier)
        end

        # @return [String, NilClass] The Dublin Core XML representation of the object or nil if response is 404
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        def dublin_core
          resp = connection.get do |req|
            req.url "#{base_path}/dublin_core"
          end
          return resp.body if resp.success?
          return if resp.status == 404

          raise_exception_based_on_response!(resp, object_identifier)
        end

        # @return [String, NilClass] The public descriptive metadata XML representation of the object or nil if response is 404
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        def descriptive
          resp = connection.get do |req|
            req.url "#{base_path}/descriptive"
          end
          return resp.body if resp.success?
          return if resp.status == 404

          raise_exception_based_on_response!(resp, object_identifier)
        end

        # @return [String, NilClass] the dor object's source MODS XML or nil if response is 404
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        def mods
          resp = connection.get do |req|
            req.url "#{base_path}/mods"
          end
          return resp.body if resp.success?
          return if resp.status == 404

          raise_exception_based_on_response!(resp, object_identifier)
        end

        # rubocop:disable Lint/StructNewOverride
        Datastream = Struct.new(:label, :dsid, :pid, :size, :mimeType, keyword_init: true)
        # rubocop:enable Lint/StructNewOverride

        # @return [Array] the list of datastreams for the item
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        def datastreams
          resp = connection.get do |req|
            req.url "#{base_path}/datastreams"
          end
          raise_exception_based_on_response!(resp, object_identifier) unless resp.success?

          JSON.parse(resp.body).map { |params| Datastream.new(**params) }
        end

        # @param [String] dsid the identifier for the datastream
        # @return [String] the contents of the specified datastream
        # @raise [UnexpectedResponse] on an unsuccessful response from the server
        def datastream(dsid)
          resp = connection.get do |req|
            req.url "#{base_path}/datastreams/#{dsid}"
          end
          raise_exception_based_on_response!(resp, object_identifier) unless resp.success?

          resp.body
        end

        private

        attr_reader :object_identifier

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