CQRS (Command Query Responsibility Segregation)

// Command side: recebe intenção, valida e persiste
interface Command { tipo: string; }
class CriarPedido implements Command {
  readonly tipo = "CriarPedido";
  constructor(public itens: string[]) {}
}

class CommandHandler {
  constructor(private writeStore: WriteStore, private bus: EventBus) {}
  async handle(cmd: CriarPedido): Promise<void> {
    const pedido = Pedido.novo(cmd.itens);      // regras de negócio
    await this.writeStore.salvar(pedido);
    this.bus.publicar({ tipo: "PedidoCriado", pedido });
  }
}

// Query side: lê de um read model desnormalizado
class ConsultaPedidos {
  constructor(private readStore: ReadStore) {}
  porCliente(clienteId: string) {
    return this.readStore.listar(clienteId);    // sem regras, só leitura
  }
}

// Command side
record CriarPedido(List<String> itens) {}

class CommandHandler {
    private final WriteStore writeStore;
    private final EventBus bus;
    CommandHandler(WriteStore ws, EventBus bus) { this.writeStore = ws; this.bus = bus; }
    void handle(CriarPedido cmd) {
        Pedido pedido = Pedido.novo(cmd.itens());   // regras de negócio
        writeStore.salvar(pedido);
        bus.publicar(new PedidoCriado(pedido));
    }
}

// Query side: lê read model otimizado
class ConsultaPedidos {
    private final ReadStore readStore;
    ConsultaPedidos(ReadStore rs) { this.readStore = rs; }
    List<PedidoView> porCliente(String clienteId) {
        return readStore.listar(clienteId);         // só leitura
    }
}