af83/chouette-core

module IevInterfaces::Task
  extend ActiveSupport::Concern
  include Rails.application.routes.url_helpers
  include ActionView::Helpers::TagHelper
  include IconHelper
  include OperationsHelper

  included do
    belongs_to :parent, polymorphic: true
    belongs_to :workbench, class_name: "::Workbench"
    has_one :organisation, through: :workbench
    belongs_to :referential

    mount_uploader :file, ImportUploader
    validates_integrity_of :file

    has_many :children, foreign_key: :parent_id, class_name: self.name, dependent: :destroy

    extend Enumerize
    enumerize :status, in: %w(new pending successful warning failed running aborted canceled), scope: true, default: :new

    validates :name, presence: true
    validates_presence_of :creator

    has_many :messages, class_name: messages_class_name, dependent: :delete_all, foreign_key: "#{messages_class_name.split('::').first.downcase}_id"
    has_many :resources, class_name: resources_class_name, dependent: :destroy, foreign_key: "#{resources_class_name.split('::').first.downcase}_id"

    # Scope unused in Chouette
    scope :where_started_at_in, ->(period_range) do
      where('started_at BETWEEN :begin AND :end', begin: period_range.begin, end: period_range.end)
    end
    # Scope unused in Chouette
    scope :for_referential, ->(referential) do
      where(referential_id: referential.id)
    end
    # Scope unused in Chouette
    scope :new_or_pending, -> { where(status: [:new, :pending]) }

    scope :successful, -> { where(status: :successful) }

    before_save :initialize_fields, on: :create

    status.values.each do |s|
      define_method "#{s}!" do
        update_column :status, s
      end

      define_method "#{s}?" do
        status&.to_s == s
      end
    end
  end

  module ClassMethods
    def launched_statuses
      %w(new pending)
    end

    def failed_statuses
      %w(failed aborted canceled)
    end

    def finished_statuses
      %w(successful failed warning aborted canceled)
    end

  end

  def workbench_for_notifications
    workbench || referential.workbench || referential.workgroup&.owner_workbench
  end

  def notify_parent
    return false unless finished?
    return false unless parent.present?
    return false if notified_parent_at

    update_column :notified_parent_at, Time.now
    parent&.child_change

    true
  end


  def children_succeedeed
    children.with_status(:successful, :warning).count
  end

  # Compute and update status (only when it changes)
  # Invokes done! method is defined and status is changed to finished
  def update_status
    Rails.logger.info "#{self.class.name} ##{id}: update_status #{children.reload.map(&:status).inspect}"
    new_status = compute_new_status

    Rails.logger.info "#{self.class.name} ##{id}: status #{self.status} -> #{new_status}"
    return if self.status == new_status

    Rails.logger.info "#{self.class.name} ##{id}: status -> #{new_status}"

    attributes = {
      current_step: children.count, # !?
      status: new_status
    }

    if self.class.finished_statuses.include?(new_status)
      attributes[:ended_at] = Time.now
    end

    update attributes

    if respond_to?(:done!)
      Rails.logger.info "#{self.class.name} ##{id}: done!"
      done! (successful? || warning?)
    end
  end

  def finished?
    self.class.finished_statuses.include?(status)
  end

  def successful?
    status.to_s == "successful"
  end

  def warning?
    status.to_s == "warning"
  end

  def child_change
    Rails.logger.info "Operation ##{id}: child_change"
    return if self.class.finished_statuses.include?(status)
    update_status
  end

  def call_iev_callback
    return if self.class.finished_statuses.include?(status)
    threaded_call_boiv_iev
  end

  private

  def threaded_call_boiv_iev
    return if Rails.env.test?
    Thread.new(&method(:call_boiv_iev))
  end

  def call_boiv_iev
    Rails.logger.error("Begin IEV call for import")

    # Java code expects tasks in NEW status
    # Don't change status before calling iev

    Net::HTTP.get iev_callback_url
    Rails.logger.error("End IEV call for import")
  rescue Exception => e
    aborted!
    referential&.failed!
    Chouette::Safe.capture "IEV server error", e
  end

  private
  def initialize_fields
  end
end