af83/chouette-core

# frozen_string_literal: true

# Used by legacy operations (Import, Merge, Export, ...) to be ran by a Worker
class LegacyOperationJob
  def initialize(operation, method = :perform, *arguments)
    @operation = operation
    @target_method = method
    @arguments = arguments
  end

  attr_reader :operation, :target_method, :arguments

  # Name used by Delayed::Job
  def display_name
    @display_name ||= "#{operation_class}##{operation_id}"
  end

  # Invoked by Delayed::Heartbeat when the Job was performed
  # by a Worker which has been detected as dead
  def dead_worker
    operation.try(:worker_died)
  end

  # The Job must not be restarted after fail
  def max_attempts
    1
  end

  # Start the operation
  def perform
    # current_span = Datadog::Tracing.active_span
    # setup_span(current_span) if current_span

    log

    logger.tagged(display_name) do
      operation.send target_method, *arguments
    end
  end

  def log
    context_description = context.map { |k, v| "#{k}=#{v}" }.join(',')
    logger.info "Start Operation #{display_name} #{context_description}"
  end

  def logger
    Rails.logger
  end

  # Provides information to Datadog
  def setup_span(span)
    span.set_tag 'operation_class', operation_class
    span.set_tag 'operation_id', operation_id

    context.each do |name, value|
      span.set_tag name, value
    end
  end

  # Extracts information from Organisation context (for Datadog, log, etc)

  def context
    @context ||= {
      organisation: organisation_id,
      workgroup: workgroup_id,
      workbench: workbench_id
    }.delete_if { |_, v| v.blank? }
  end

  def workgroup_id
    @workgroup_id ||= operation.try(:workgroup)&.id
  end

  def workbench_id
    @workbench_id ||= operation.try(:workbench)&.id
  end

  def restricted_by_organisation?
    operation.is_a?(Import::Base)
  end

  def organisation_id
    @organisation_id ||= operation.try(:organisation)&.id if restricted_by_organisation?
  end

  def operation_class
    @operation_class ||= operation.class.name
  end

  def operation_id
    operation.try(:id)
  end
end