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