oraclekit/chainlink

class AssignmentSnapshot < ActiveRecord::Base
  COMPLETED = 'completed'
  FAILED = 'failed'
  STARTED = 'started'

  belongs_to :assignment, inverse_of: :snapshots
  has_many :adapter_snapshots, -> {
    includes(:subtask).order("subtasks.index")
  }
  belongs_to :request, polymorphic: true
  belongs_to :requester, class_name: "Subtask"

  validates :assignment, presence: true
  validates :summary, presence: true, if: :fulfilled?
  validates :progress, inclusion: { in: [nil, COMPLETED, FAILED, STARTED] }
  validates :status, inclusion: { in: [nil, Term::IN_PROGRESS, Term::COMPLETED, Term::FAILED] }
  validates :xid, presence: true

  before_validation :set_up, on: :create
  before_validation :check_fulfillment
  before_create :build_adapter_snapshots, if: :unfulfilled?
  after_create :start_adapter_subtasks
  after_save :report_snapshot, if: :report_to_coordinator

  scope :unfulfilled, -> { where fulfilled: false }

  def unfulfilled?
    !fulfilled?
  end

  def details
    JSON.parse(details_json) if details_json.present?
  end

  def details=(new_details)
    self.details_json = new_details.present? ? new_details.to_json : nil
    self.details
  end

  def current_adapter_snapshot
    return if adapter_index.nil? || adapter_snapshots.none?
    adapter_snapshots.find { |adapter| adapter.index == adapter_index }
  end

  def next_adapter_snapshot
    return if adapter_index.nil? || adapter_snapshots.none?
    adapter_snapshots.find { |adapter| adapter.index > adapter_index }
  end

  def adapter_response(adapter_snapshot)
    handler.adapter_response adapter_snapshot
  end


  private

  attr_accessor :report_to_coordinator

  def adapters
    assignment.adapters
  end

  def set_up
    self.progress ||= STARTED
    self.xid ||= SecureRandom.uuid
  end

  def parse_adapter_response(response)
    return unless response.fulfilled

    self.fulfilled = true
    self.status = response.status
    self.summary ||= response.summary
    self.value = response.value
    self.details = response.details
    self.description = response.description
    self.description_url = response.description_url
  end

  def check_fulfillment
    if undoing_fulfilled?
      errors.add(:fulfilled, "cannot be undone")
    elsif new_and_fulfilled? || fulfilled_after?
      self.report_to_coordinator = true
    end
  end

  def new_and_fulfilled?
    new_record? && fulfilled?
  end

  def fulfilled_after?
    persisted? && fulfilled? && changed_attributes[:fulfilled] == false
  end

  def undoing_fulfilled?
    persisted? && unfulfilled? && changed_attributes[:fulfilled]
  end

  def report_snapshot
    coordinator.snapshot id
    self.report_to_coordinator = false
  end

  def coordinator
    assignment.coordinator
  end

  def build_adapter_snapshots
    subtasks.each do |subtask|
      adapter_snapshots.build(subtask: subtask)
    end
    self.adapter_index ||= subtasks.collect(&:index).min
  end

  def handler
    @handler ||= AssignmentSnapshotHandler.new(self)
  end

  def subtasks
    assignment.subtasks
  end

  def start_adapter_subtasks
    handler.start if adapter_snapshots.any?
  end

end