Function appendTableEvent

apps/sim/lib/table/events.ts:234–277

(event: TableEvent)

 * cell-write.
 */
export async function appendTableEvent(event: TableEvent): Promise<TableEventEntry | null> {
  const redis = getRedisClient()
  if (!redis) {
    if (canUseMemoryBuffer()) {
      try {
        return appendMemory(event)
      } catch (error) {
        logger.warn('appendTableEvent: memory append failed', {
          tableId: event.tableId,
          error: toError(error).message,
        })
        return null
      }
    }
    return null
  }
  try {
    // Build the entry JSON in two halves so Lua can splice the new eventId
    // between them without us needing a round-trip just to mint the id first.
    const tail = `,"tableId":${JSON.stringify(event.tableId)},"event":${JSON.stringify(event)}}`
    const head = `{"eventId":`
    const result = await redis.eval(
      APPEND_EVENT_SCRIPT,
      3,
      getEventsKey(event.tableId),
      getSeqKey(event.tableId),
      getMetaKey(event.tableId),
      TABLE_EVENT_TTL_SECONDS,
      TABLE_EVENT_CAP,
      new Date().toISOString(),
      head,
      tail
    )
    const eventId = typeof result === 'number' ? result : Number(result)
    if (!Number.isFinite(eventId)) return null
    return { eventId, tableId: event.tableId, event }
  } catch (error) {
    logger.warn('appendTableEvent: Redis append failed', {
      tableId: event.tableId,
      error: toError(error).message,
    })
    return null
  }
}

/**
 * Read events for a table where eventId > afterEventId. Returns 'pruned' if