mariuszkapcia

module Users
  class ChangeAvatar < Command
    attribute :avatar_url, Types::Strict::String
  end
end

mariuszkapcia

MissingEncryptionKey = Class.new(StandardError)

class EncryptedMapper
  def event_to_serialized_record(domain_event)
    metadata = {}
    domain_event.metadata.each do |k, v|
      metadata[k] = v
    end

    encryption_schema    = domain_event.class.respond_to?(:encryption_schema) && domain_event.class.encryption_schema

mariuszkapcia

def register(cmd)
  ActiveRecord::Base.transaction do
    with_developer(cmd.developer_uuid) do |developer|
      developer.register

      DeveloperRegistered.strict(data: {
        developer_uuid: cmd.developer_uuid,
        fullname:       cmd.fullname,
        email:          cmd.email
      })

mariuszkapcia

class AggregateRepository
  def load
    @event_store.read.stream(@stream_name).forward.each do |event|
      @aggregate.apply(event)
      @version += 1
    end
  end

  def store(events)
    events.each do |event|

mariuszkapcia

class AggregateRepository
  def load(aggregate, stream_name, event_store:)
    events = event_store.read.stream(stream_name).forward.each
    events.each do |event|
      aggregate.apply(event)
    end

    @version = events.size - 1
    aggregate.clear_unpublished_events
  end

mariuszkapcia

class AggregateRepository
  def load(aggregate, stream_name, event_store:)
    events = event_store.read.stream(stream_name).forward.to_a
    events.each do |event|
      aggregate.apply(event)
    end

    aggregate.set_version(events.size - 1)
    aggregate.clear_unpublished_events
  end

mariuszkapcia

module MyAggregateRoot
  MissingEventInApplyStrategy = Class.new(StandardError)
  
  def load(stream_name, event_store:)
    @version = -1
    event_store.read.stream(stream_name).forward.each do |event|
      apply(event)
      @version += 1
    end

mariuszkapcia

module MyAggregateRoot
  def load(stream_name, event_store:)
    @version = -1
    event_store.read.stream(stream_name).forward.each do |event|
      apply(event)
      @version += 1
    end

    @stream_name        = stream_name
    @unpublished_events = []