Method interruptForCompaction

src/node/services/agentSession.ts:3325–3411

()

  }

  private async interruptForCompaction(): Promise<void> {
    if (this.midStreamCompactionPending || this.disposed) {
      return;
    }

    const streamContext = this.activeStreamContext;
    if (!streamContext?.modelString || !streamContext.options) {
      return;
    }

    const interruptedUserMessageId = this.activeStreamUserMessageId;

    this.midStreamCompactionPending = true;
    try {
      const stopResult = await this.aiService.stopStream(this.workspaceId, {
        abortReason: "system",
      });
      if (!stopResult.success) {
        log.warn("Failed to stop stream for mid-stream compaction", {
          workspaceId: this.workspaceId,
          error: stopResult.error,
        });
        return;
      }

      await this.waitForIdle();
      if (this.disposed) {
        return;
      }

      const followUpContent = this.buildAutoCompactionFollowUp({
        // Keep mid-stream auto-compaction on the shared default sentinel so
        // buildCompactionMessageText can hide the internal resume marker.
        messageText: "Continue",
        options: streamContext.options,
        goalKind: streamContext.goalKind,
        modelForStream: streamContext.modelString,
      });
      const autoCompactionRequest = this.buildAutoCompactionRequest({
        followUpContent,
        baseOptions: streamContext.options,
        reason: "mid-stream",
      });

      const sendResult = await this.sendMessage(
        autoCompactionRequest.messageText,
        {
          ...autoCompactionRequest.sendOptions,
          muxMetadata: autoCompactionRequest.metadata,
        },
        { synthetic: true }
      );
      if (!sendResult.success) {
        log.warn("Failed to dispatch mid-stream compaction request", {
          workspaceId: this.workspaceId,
          error: sendResult.error,
        });