module Hyrax
  module Arkivo
    class SubscriptionError < RuntimeError
    end

    class CreateSubscriptionJob < Hyrax::ApplicationJob
      attr_reader :user

      def perform(user_key)
        @user = ::User.find_by_user_key(user_key)
        validate_user!

        # post json to API
        response = post_to_api
        # parse results
        subscription_path = response.headers['Location']
        # create subscription
        user.arkivo_subscription = subscription_path
        user.save
      end

      private

        def logger
          Hyrax.logger
        end

        def validate_user!
          log_and_raise('User not found') if user.blank?
          log_and_raise('User does not have an Arkivo token') if user.arkivo_token.blank?
          log_and_raise('User has not yet connected with Zotero') if user.zotero_userid.blank?
          log_and_raise('User already has a subscription') if user.arkivo_subscription.present?
        end

        def log_and_raise(message)
          logger.error "*** Arkivo error: #{message}: #{user}"
          raise SubscriptionError, message
        end

        def post_to_api
          Faraday.new(url: Hyrax::Arkivo.config[:url]).post do |request|
            request.url Hyrax::Arkivo.new_subscription_url
            request.headers['Content-Type'] = 'application/json'
            request.body = new_subscription_json
          end
        end

        def new_subscription_json
          {
            url: Hyrax::Zotero.publications_url(@user.zotero_userid),
            plugins: [
              {
                name: "hyrax",
                options: { token: @user.arkivo_token }
              }
            ]
          }.to_json
        end
    end
  end
end