Function appendMemory

apps/sim/lib/table/events.ts:192–206

(event: TableEvent)

}

function appendMemory(event: TableEvent): TableEventEntry {
  const stream = getMemoryStream(event.tableId)
  const entry: TableEventEntry = {
    eventId: stream.nextEventId++,
    tableId: event.tableId,
    event,
  }
  stream.events.push(entry)
  if (stream.events.length > TABLE_EVENT_CAP) {
    stream.events = stream.events.slice(-TABLE_EVENT_CAP)
    stream.earliestEventId = stream.events[0]?.eventId
  }
  stream.expiresAt = Date.now() + TABLE_EVENT_TTL_SECONDS * 1000
  return entry
}

function readMemory(tableId: string, afterEventId: number): TableEventsReadResult {
  pruneExpiredMemoryStreams()