Method writeEvent

server/src/db/catalog-events-db.ts:51–63

* Write a single event with a generated UUID v7 event_id. * Call this inside an existing transaction by passing the client directly, * or let it run against the pool for standalone writes.

(input: WriteEventInput, client?: { query: (text: string, params?: unknown[]) => Promise<unknown> })

   * or let it run against the pool for standalone writes.
   */
  async writeEvent(input: WriteEventInput, client?: { query: (text: string, params?: unknown[]) => Promise<unknown> }): Promise<string> {
    const eventId = uuidv7();
    const sql = `INSERT INTO catalog_events (event_id, event_type, entity_type, entity_id, payload, actor)
       VALUES ($1, $2, $3, $4, $5, $6)`;
    const params = [eventId, input.event_type, input.entity_type, input.entity_id, JSON.stringify(input.payload ?? {}), input.actor];

    if (client) {
      await client.query(sql, params);
    } else {
      await query(sql, params);
    }
    return eventId;
  }

  /**
   * Write multiple events in a single transaction.