Method enqueue

apps/sim/lib/copilot/request/session/writer.ts:126–139

(envelope: PersistedStreamEventEnvelope)

  }

  private enqueue(envelope: PersistedStreamEventEnvelope): void {
    if (this._clientDisconnected || !this.controller) return
    try {
      this.controller.enqueue(encodeSSEEnvelope(envelope))
    } catch (error) {
      this._clientDisconnected = true
      logger.warn('Envelope enqueue failed, marking client disconnected', {
        streamId: this.streamId,
        requestId: this.requestId,
        seq: envelope.seq,
        error: toError(error).message,
      })
    }
  }

  private createEnvelope(event: StreamEvent): PersistedStreamEventEnvelope {
    const seq = ++this.nextSeq