DDD 04 戦術的設計②(集約・リポジトリ・ドメインイベント)

┌──────── Order 集約 ────────┐
│ Order(集約ルート)          │ ← 外部はここだけ触る
│   ├─ OrderLine            │
│   ├─ OrderLine            │
│   └─ ShippingAddress (値) │
└───────────────────────────┘
       customerId だけ持つ(Customer 集約は別)

export class Order {
  private lines: OrderLine[] = [];
  private status: 'draft' | 'placed' = 'draft';
  constructor(readonly id: OrderId, readonly customerId: CustomerId) {}
 
  addLine(productId: ProductId, unitPrice: Money, quantity: number) {
    if (this.status !== 'draft') throw new Error('確定済みの注文は変更できません');
    if (this.lines.length >= 50) throw new Error('明細は50件までです');
    this.lines.push(new OrderLine(productId, unitPrice, quantity));
  }
  get total(): Money {
    return this.lines.reduce((sum, l) => sum.add(l.subtotal), Money.of(0));
  }
  place() {
    if (this.lines.length === 0) throw new Error('明細がありません');
    this.status = 'placed';
  }
}
// ✗ order.lines.push(...) や line.quantity = 999 を外から直接できないようにする

// ドメイン層: インターフェースだけ置く(DB を知らない)
export interface OrderRepository {
  findById(id: OrderId): Promise<Order | null>;
  save(order: Order): Promise<void>;
  nextId(): OrderId;
}
 
// インフラ層: 実装(Drizzle / D1 など)
export class DrizzleOrderRepository implements OrderRepository {
  constructor(private db: DrizzleD1Database) {}
  async findById(id: OrderId) {
    const row = await this.db.query.orders.findFirst({ where: eq(orders.id, id.value), with: { lines: true } });
    return row ? OrderMapper.toDomain(row) : null;   // DB の行 → ドメインオブジェクト
  }
  async save(order: Order) {
    // 集約まるごと保存(ルート+明細)。db.batch で1トランザクションに
  }
  nextId() { return OrderId.of(crypto.randomUUID()); }
}

export type OrderPlaced = {
  type: 'OrderPlaced';
  orderId: string;
  customerId: string;
  total: number;
  occurredAt: Date;
};
 
export class Order {
  private events: OrderPlaced[] = [];
  place(now: Date) {
    /* ...ルールチェック... */
    this.status = 'placed';
    this.events.push({ type: 'OrderPlaced', orderId: this.id.value, customerId: this.customerId.value,
                       total: this.total.amount, occurredAt: now });
  }
  pullEvents() { const e = this.events; this.events = []; return e; }
}