Method resetContext

src/node/services/workspaceService.ts:8000–8065

(workspaceId: string)

  }

  async resetContext(workspaceId: string): Promise<Result<"reset" | "noop">> {
    if (this.resettingContextWorkspaces.has(workspaceId)) {
      return Err("Context reset is already in progress for this workspace.");
    }

    this.resettingContextWorkspaces.add(workspaceId);
    try {
      const session = this.sessions.get(workspaceId);
      if (session?.isBusy() || this.aiService.isStreaming(workspaceId)) {
        return Err(
          "Cannot reset context while a turn is active. Press Esc to stop the stream first."
        );
      }

      if (this.hasPendingQueuedOrPreparingTurn(workspaceId)) {
        return Err(
          "Cannot reset context while queued user input is pending. Send or clear the queued message first."
        );
      }

      const historyResult = await this.historyService.getHistoryFromLatestBoundary(workspaceId);
      if (!historyResult.success) {
        return Err(`Failed to read active context before reset: ${historyResult.error}`);
      }

      const activeContextMessages = sliceMessagesForProviderFromLatestContextBoundary(
        historyResult.data
      );
      if (!hasProviderEligibleMessages(activeContextMessages)) {
        return Ok("noop");
      }

      const boundaryMessage = createMuxMessage(
        createContextResetBoundaryMessageId(),
        "assistant",
        "",
        {
          timestamp: Date.now(),
          contextBoundaryKind: CONTEXT_BOUNDARY_KINDS.RESET,
        }
      );

      const appendResult = await this.historyService.appendToHistory(workspaceId, boundaryMessage);
      if (!appendResult.success) {
        return Err(`Failed to append context reset boundary: ${appendResult.error}`);
      }

      const typedBoundaryMessage = { ...boundaryMessage, type: "message" as const };
      if (session) {
        session.emitChatEvent(typedBoundaryMessage);
      } else {
        this.emit("chat", { workspaceId, message: typedBoundaryMessage });
      }

      try {
        await this.workspaceGoalService?.requireUserAcknowledgment(workspaceId);
      } catch (error) {
        log.error("Failed to require goal acknowledgment after context reset:", error);