retry_deposit.rb

handle Deposit do |deposit|
  account_id = deposit.account_id
  sequence = deposit.metadata.global_position

  # Retry once if an expected version error is raised by the write
  Retry.(MessageStore::ExpectedVersion::Error) do
    account, version = store.fetch(account_id, include: :version)

    # Idempotence protection using sequence numbers
    unless sequence > account.sequence 
      logger.info(tag: :ignored) { "Command ignored (Command: #{deposit.message_type}, Account ID: #{account_id}, Account Sequence: #{account.sequence}, Deposit Sequence: #{sequence})" }
      return
    end

    time = clock.iso8601

    deposited = Deposited.follow(deposit)
    deposited.processed_time = time
    deposited.sequence = sequence

    stream_name = stream_name(account_id)

    # Write with concurrency protection using expected version
    write.(deposited, stream_name, expected_version: version)
  end
end