Method createEnvelope

apps/sim/lib/copilot/request/session/writer.ts:141–151

(event: StreamEvent)

  }

  private createEnvelope(event: StreamEvent): PersistedStreamEventEnvelope {
    const seq = ++this.nextSeq
    return createEvent({
      ...event,
      streamId: this.streamId,
      chatId: this.chatId,
      cursor: String(seq),
      seq,
      requestId: this.requestId,
    })
  }

  private queuePersistence(envelope: PersistedStreamEventEnvelope): void {
    this.pendingEnvelopes.push(envelope)