Event Sourcing

Em vez de guardar o estado atual, guarda cada fato que mudou o estado num log append-only e imutável; o estado é sempre derivado pelo replay dos eventos. Dá auditoria completa de cada centavo, reconstrução de qualquer momento passado e várias projeções sobre os mesmos fatos. Use quando o histórico tem valor regulatório ou de negócio.

passos: 6
arquivos: 8
testes: 2
tecnologias: 4

Infraestrutura realTypeScriptBunPostgreSQLDocker

Cenário Relações Comparar

Baixar cartão

Cenário

A conta de Alice nasce, recebe um depósito, faz um saque e tem um saque acima do saldo recusado — nada é gravado. Um depósito antigo, gravado no schema v1 (reais em texto), é lido pelo upcaster. O saldo vem do snapshot mais o resto do log; o time travel mostra o saldo na versão 2 e logo depois do depósito. Por fim, dois saques concorrentes disputam a versão 5 e o perdedor recarrega e grava na 6.

Como funciona

6 passos

Estado reconstruído a partir de eventos.

Esconde cada passo: lembre antes de tocar para revelar.

Vocabulário compartilhado

correlationId+7

channel+1

Event Sourcing

accountEventApply+1

Event Sourcing

01
Eventos no passadoAccountOpened, MoneyDeposited, MoneyWithdrawn, AccountFrozen — com payload em centavos e metadata (correlationId, channel)
02
Fold puroaccountEventApply reconstrói o estado sem I/O e nunca recusa um fato já gravado
03
Regras no comandoaccountCommandDecide recusa conta inexistente, congelada, valor inválido ou saldo insuficiente — antes de gravar
04
Concorrência otimistaUNIQUE (aggregate_id, version) rejeita a segunda escrita com 23505; o comando recarrega e decide de novo, nunca repete às cegas
05
SnapshotA cada N versões o estado é salvo; a leitura aplica só os eventos posteriores
06
Evolução e time travelO upcaster converte o payload antigo na leitura, sem reescrever o log; o replay para numa versão ou num instante

apps/patterns/event-sourcing

8 arquivos

sql/

01_schema.sqlschemaTabelas events (append-only, versão única) e snapshots

src/

event_account.tsEventos, fold, decisão do comando e upcaster
store_event.tsAppend com concorrência otimista, carga com snapshot, time travel e execução do comando
config_account.tsLê e valida o ambiente no boot
event_account.test.tstesteFold, fronteira do saldo, recusas e upcaster
store_event.test.tstesteIntegração contra PostgreSQL: conflito, corrida, snapshot, time travel, metadata
demo.tsdemoHistórico, upcast, snapshot, time travel e corrida