class Midnight::Rails::StateAdapter

Public Class Methods

new(\ active_record: DefaultState, serializer: Utilities::JsonSerializer, metadata_adapter: lambda do |record| { next_position: record.next_position, state_id: record.id, aggregate_key: record.aggregate_key, } end, advance_metadata: lambda do |record, events| record.next_position += events.length end ) click to toggle source
# File lib/midnight/rails/state_adapter.rb, line 7
def initialize(\
  active_record: DefaultState,
  serializer: Utilities::JsonSerializer,
  metadata_adapter: lambda do |record|
    {
      next_position: record.next_position,
      state_id: record.id,
      aggregate_key: record.aggregate_key,
    }
  end,
  advance_metadata: lambda do |record, events|
    record.next_position += events.length
  end
)
  @model = active_record
  @serializer = serializer
  @metadata_adapter = metadata_adapter
  @advance_metadata = advance_metadata
end

Public Instance Methods

hook_commit(&block) click to toggle source
# File lib/midnight/rails/state_adapter.rb, line 49
def hook_commit(&block)
  @model.connection.add_transaction_record(
    CommitHooker.new(&block)
  )
end
load(key:, **_) click to toggle source
# File lib/midnight/rails/state_adapter.rb, line 27
def load(key:, **_)
  record = begin
    @model.where(
      aggregate_key: key
    ).first_or_create!
  rescue ::ActiveRecord::RecordNotUnique
    # :nocov:
    retry
    # :nocov:
  end
  ActiveRecordWrapper.new(
    record,
    serializer: @serializer,
    metadata_adapter: @metadata_adapter,
    advance_metadata: @advance_metadata
  )
end
transaction(&block) click to toggle source
# File lib/midnight/rails/state_adapter.rb, line 45
def transaction(&block)
  @model.transaction(&block)
end