zammad/lib/sequencer/unit/import/common/model/external_sync/integrity.rb

# Copyright (C) 2012-2024 Zammad Foundation, https://zammad-foundation.org/

class Sequencer::Unit::Import::Common::Model::ExternalSync::Integrity < Sequencer::Unit::Base
  uses :instance, :remote_id, :dry_run, :external_sync_source, :model_class

  def process
    return if dry_run
    return if instance.blank?
    return if instance.id.blank?
    return if up_to_date?

    create
  end

  private

  def up_to_date?
    return false if entry.blank?
    return true if entry.source_id == remote_id

    entry.update!(source_id: remote_id)
    true
  end

  def entry
    @entry ||= begin
      ::ExternalSync.find_by(
        source: external_sync_source,
        object: model_class.name,
        o_id:   instance.id
      )
    end
  end

  def create
    ::ExternalSync.create(
      source:    external_sync_source,
      source_id: remote_id,
      object:    model_class.name,
      o_id:      instance.id
    )
  end
end