btrc-hub/backend/app/services/version_recorder.rb

class VersionRecorder
  EVENT_TYPES = ['create', 'update', 'discard', 'restore'].freeze

  def initialize record:, event_type:, created_by_user:
    @record = record
    @event_type = event_type.to_s
    @created_by_user = created_by_user

    validate_event_type!
  end

  def record!
    raise "#{ record_class.name } must be persisted" unless @record.persisted?

    ApplicationRecord.transaction do
      @record = record_class.unscoped.lock.find(@record.id)
      latest = latest_version

      if !(latest) && @event_type != 'create'
        raise "#{ version_class.name } first event must be create"
      end

      if @event_type == 'create' && latest
        raise "#{ version_class.name } create event already exists"
      end

      attrs = snapshot_attributes

      return latest if @event_type == 'update' && latest && same_snapshot?(latest, attrs)

      version_class.create!(base_attributes(latest).merge(record_key => @record).merge(attrs))
    end
  end

  private

  def latest_version = versions.order(version_no: :desc).first

  def versions = @record.public_send(version_association)

  def base_attributes latest
    { version_no: (latest&.version_no || 0) + 1,
      event_type: @event_type,
      created_at: Time.current,
      created_by_user: @created_by_user }
  end

  def same_snapshot?(version, attrs) = attrs.all? { |k, v| version.public_send(k) == v }

  def validate_event_type!
    return if EVENT_TYPES.include?(@event_type)

    raise ArgumentError, "Invalid event_type: #{ @event_type }"
  end

  def version_class = raise NotImplementedError
  def version_association = raise NotImplementedError
  def record_key = raise NotImplementedError
  def snapshot_attributes = raise NotImplementedError

  def record_class = @record.class
end