Event Sourcing

type Evento =
  | { tipo: "ContaAberta"; saldoInicial: number }
  | { tipo: "DinheiroDepositado"; valor: number }
  | { tipo: "DinheiroSacado"; valor: number };

class ContaBancaria {
  private constructor(public saldo = 0, private novos: Evento[] = []) {}

  // Replay: o estado atual e derivado da sequencia de eventos
  static deEventos(eventos: Evento[]): ContaBancaria {
    const conta = new ContaBancaria();
    for (const e of eventos) conta.aplicar(e);
    return conta;
  }

  sacar(valor: number): void {
    if (valor > this.saldo) throw new Error("Saldo insuficiente");
    this.registrar({ tipo: "DinheiroSacado", valor });
  }

  private registrar(e: Evento): void {
    this.aplicar(e);
    this.novos.push(e);   // sera anexado ao event store, nunca sobrescrito
  }

  private aplicar(e: Evento): void {
    switch (e.tipo) {
      case "ContaAberta":        this.saldo = e.saldoInicial; break;
      case "DinheiroDepositado": this.saldo += e.valor; break;
      case "DinheiroSacado":     this.saldo -= e.valor; break;
    }
  }

  eventosPendentes(): Evento[] { return this.novos; }
}

const conta = ContaBancaria.deEventos([
  { tipo: "ContaAberta", saldoInicial: 0 },
  { tipo: "DinheiroDepositado", valor: 300 },
]);
conta.sacar(100);   // saldo derivado: 200

from dataclasses import dataclass

@dataclass(frozen=True)
class ContaAberta:        saldo_inicial: int
@dataclass(frozen=True)
class DinheiroDepositado: valor: int
@dataclass(frozen=True)
class DinheiroSacado:     valor: int

class ContaBancaria:
    def __init__(self):
        self.saldo = 0
        self.novos = []

    # Replay: o estado atual e derivado da sequencia de eventos
    @classmethod
    def de_eventos(cls, eventos):
        conta = cls()
        for e in eventos:
            conta._aplicar(e)
        return conta

    def sacar(self, valor: int):
        if valor > self.saldo:
            raise ValueError("Saldo insuficiente")
        self._registrar(DinheiroSacado(valor))

    def _registrar(self, e):
        self._aplicar(e)
        self.novos.append(e)   # anexado ao event store, nunca sobrescrito

    def _aplicar(self, e):
        if isinstance(e, ContaAberta):        self.saldo = e.saldo_inicial
        if isinstance(e, DinheiroDepositado): self.saldo += e.valor
        if isinstance(e, DinheiroSacado):     self.saldo -= e.valor

conta = ContaBancaria.de_eventos([ContaAberta(0), DinheiroDepositado(300)])
conta.sacar(100)   # saldo derivado: 200