Function clearBuffer

apps/sim/lib/copilot/request/session/buffer.ts:101–105

(streamId: string, operation = 'clear_outbox')

}

export async function clearBuffer(streamId: string, operation = 'clear_outbox'): Promise<void> {
  await withRedisRetry({ operation, streamId }, async (redis) => {
    await redis.del(getEventsKey(streamId), getSeqKey(streamId), getAbortKey(streamId))
  })
}

export async function scheduleBufferCleanup(
  streamId: string,