af83/chouette-core

# frozen_string_literal: true

class Destination
  class Ara < ::Destination
    option :ara_url
    option :credentials
    option :force_import, type: :boolean, default_value: true

    validates :ara_url, presence: true
    validates :credentials, presence: true

    def do_transmit(publication, report)
      Rails.logger.tagged("Destination::Ara ##{id}") do
        if (export = publication.export)
          export.file.cache_stored_file!
          send_to_ara export.file, report if export[:file]
        end
      end
    end

    def ara_import_url
      "#{ara_url}/import"
    end

    def uri
      @uri ||= URI(ara_import_url)
    end

    def use_ssl?
      uri.instance_of?(URI::HTTPS)
    end

    def send_to_ara(file, report)
      payload = { "force": force_import }

      request = Net::HTTP::Post.new(uri)
      request['Authorization'] = "Token token=#{credentials}"

      form_data = [['request', payload.to_json], ['data', file]]
      request.set_form form_data, 'multipart/form-data'

      Rails.logger.info "Send file to Ara on #{ara_import_url}"

      response = Net::HTTP.start(uri.hostname, uri.port, use_ssl: use_ssl?) do |http|
        http.request(request)
      end

      Rails.logger.info "Ara response #{response.code} #{response.body.truncate(256)}"

      if response.is_a?(Net::HTTPSuccess) && response['content-type'] == 'application/json'
        import_status = JSON.parse response.body
        unless import_status['Errors'].empty?
          report.failed! message: "Errors returned by Ara API: #{import_status['Errors'].inspect}"
        end
      else
        report.failed! message: "Unexpected response from Ara API: #{response.code}"
      end
    end
  end
end