require_dependency "apidae/application_controller"
require 'uri'
require 'net/http'

module Apidae
  class ImportController < ApplicationController
    skip_before_action :verify_authenticity_token
    skip_before_action Rails.application.config.apidae_auth
    skip_before_action :check_user_data!

    # Callback endpoint for Apidae exports
    #
    # projetId : un entier. C’est l’identifiant du projet concerné.
    # statut : une chaine de caractères, ‘SUCCESS’ ou ‘ERROR’. C’est l’issue de l’export.
    # ponctuel : un booléen. Indique si l’export est ponctuel (true) ou périodique (false).
    # reinitialisation : un booléen. Indique si l’export est une réinitialisation (true) ou différentiel (false).
    # urlRecuperation : une chaine de caractères. L’URL de récupération du fichier d’export.
    # urlConfirmation : une chaine de caractères. L’URL de confirmation.
    def callback
      export = Export.new(project_id: params[:projetId], remote_status: params[:statut], oneshot: params[:ponctuel] == 'true',
                          reset: params[:reinitialisation] == 'true', file_url: params[:urlRecuperation],
                          confirm_url: params[:urlConfirmation], status: Export::PENDING)
      if export.save
        if Rails.application.config.respond_to?(:apidae_propagate_callback)
          uri = URI(Rails.application.config.apidae_propagate_callback)
          req = Net::HTTP::Post.new(uri)
          Net::HTTP.start(uri.hostname, uri.port, use_ssl: (uri.scheme == "https")) do |http|
            http.request(req, params.to_unsafe_h.to_query)
          end
        end
        head :ok
      else
        head :internal_server_error
      end
    end

    def run
      success = true
      Export.pending.each do |e|
        logger.info "Running import for Apidae export #{e.id} - Project #{e.project_id}"
        e.update(status: Export::IN_PROGRESS)
        success &&= e.import_data
        logger.info "Apidae export #{e.id} import run complete - Project #{e.project_id}"
      end
      success ? head(:ok) : head(:internal_server_error)
    end

    def new
      @export = Export.new(status: Export::PENDING)
    end

    def create
      @export = Export.new(export_params)
      if @export.save && @export.import_data
        redirect_to apidae.root_url, notice: 'Le fichier a bien été importé.'
      else
        flash.now[:alert] = "Une erreur s'est produite lors de l'import du fichier."
        render :new
      end
    end

    private

    def export_params
      params.require(:export).permit(:project_id, :file_url, :status)
    end
  end
end