Class: Midnight::Rails::StateAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/midnight/rails/state_adapter.rb

Instance Method Summary collapse

Constructor Details

#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) ⇒ StateAdapter

Returns a new instance of StateAdapter.



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
# 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

Instance Method Details

#hook_commit(&block) ⇒ Object 



49
50
51
52
53
 
# File 'lib/midnight/rails/state_adapter.rb', line 49

def hook_commit(&block)
  @model.connection.add_transaction_record(
    CommitHooker.new(&block)
  )
end

#load(key:, **_) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# 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) ⇒ Object 



45
46
47
 
# File 'lib/midnight/rails/state_adapter.rb', line 45

def transaction(&block)
  @model.transaction(&block)
end