module AchClient
  class ICheckGateway
    # Poll ICheckGateway for status of processed or processing Ach transactions.
    class AchStatusChecker < Abstract::AchStatusChecker

      # These responses aren't documented anywhere, so we have to add them as
      #   they are discovered
      KNOWN_ERROR_STRINGS = [
        # ICheckGateway has a rate limit of 20 requests per calendar day
        "ACCESS DENIED: Report Call Limit Exceeded",
        # The date range can't be wider than 15 days
        "ACCESS DENIED: Date Range Exceeds 15 Days",
        # Because so far they all contain ACCESS_DENIED:
        "ACCESS DENIED"
      ]

      ##
      # ICheckGateway does not support this
      def self.most_recent
        # In the future, this might just return the last 24 hours or something
        raise 'ICheckGateway does not have a most_recent bucket'
      end

      # If there are any strings we know are errors in the response, raise an
      #   error
      # Unfortunately the API doesn't really use HTTP status codes, so we have
      #   to resort to this string/pattern matching to find out if something
      #   went wrong.
      def self.check_for_errors(record)
        KNOWN_ERROR_STRINGS.each do |error_string|
          if record.include?(error_string)
            raise "Couldnt process ICheckGateway Response: #{record}"
          end
        end
      end

      # Wrapper for the range response endpoint
      # @return [Hash{String => [AchClient::AchResponse]}] Hash with
      # confirmation number as the key, lists of AchResponse objects as values
      def self.in_range(start_date:, end_date:)
        Helpers::Utils.hashlist_merge(
          AchClient::ICheckGateway.wrap_request(
            method: :pull_transaction_report,
            message: AchClient::ICheckGateway::CompanyInfo.build.to_hash.merge({
              startDate: start_date,
              endDate: end_date
            })
          ).split("\n").select do |record|
            check_for_errors(record)
            # Ignore credit card swipes if there are any
            record.start_with?('ICHECK')
          end.map do |record|
            {
              record.split('|')[3] =>
                [
                  AchClient::ICheckGateway::ResponseRecordProcessor
                    .process_response_record(record)
                ]
            }
          end
        )
      end
    end
  end
end