Function writeCore

apps/sim/lib/execution/event-buffer.ts:903–921

(event: ExecutionEvent)

  }

  const writeCore = async (event: ExecutionEvent): Promise<ExecutionEventEntry> => {
    if (nextEventId === 0 || nextEventId > maxReservedId) {
      await reserveIds(1)
    }
    const eventId = nextEventId++
    const compactEvent = await compactEventForBuffer(event, {
      ...context,
      executionId,
      requireDurablePayloads: true,
    })
    const entry: ExecutionEventEntry = { eventId, executionId, event: compactEvent }
    pending.push(entry)
    if (pending.length >= FLUSH_MAX_BATCH) {
      await flushPending()
    } else {
      scheduleFlush()
    }
    return entry
  }

  const write = (event: ExecutionEvent): Promise<ExecutionEventEntry> => {
    if (closed) return Promise.resolve({ eventId: 0, executionId, event })