1import { newId } from '@rareindex/shared';2import { events } from '@rareindex/database';3import { db } from './db.ts';45export type EventType =6 | 'page_discovered'7 | 'page_crawled'8 | 'listing_created'9 | 'listing_updated'10 | 'sale_detected'11 | 'entity_matched'12 | 'entity_created'13 | 'valuation_updated'14 | 'index_updated'15 | 'connector_run_finished'16 | 'radar_finding';1718/** Append domain events (§140). Buffered per call site; flush in batches to keep inserts cheap. */19export async function emit(type: EventType, entity: { type?: string; id?: string } = {}, payload: Record<string, unknown> = {}): Promise<void> {20 await db().insert(events).values({ id: newId('event'), type, entityType: entity.type ?? null, entityId: entity.id ?? null, payload });21}2223export async function emitMany(rows: Array<{ type: EventType; entityType?: string; entityId?: string; payload?: Record<string, unknown> }>): Promise<void> {24 if (rows.length === 0) return;25 for (let i = 0; i < rows.length; i += 500) {26 await db()27 .insert(events)28 .values(rows.slice(i, i + 500).map((r) => ({ id: newId('event'), type: r.type, entityType: r.entityType ?? null, entityId: r.entityId ?? null, payload: r.payload ?? {} })));29 }30}31