Method applyManualUserMessageGoalSafety

src/node/services/agentSession.ts:1267–1310

(input: {
    policy: GoalInterventionPolicy;
  })

  }

  private async applyManualUserMessageGoalSafety(input: {
    policy: GoalInterventionPolicy;
  }): Promise<void> {
    const goalService = this.workspaceGoalService;
    if (!goalService) {
      return;
    }

    assert(
      input.policy === "steer" || input.policy === "pause",
      `invalid goal intervention policy: ${input.policy}`
    );

    // Accepted manual user turns acknowledge / clear crash-recovery gates, but
    // they are no longer goal-continuation turns. The goal mode is locked to the
    // chat tail: a real `goal_continuation` user message means running;
    // anything manually typed by the user pauses until Resume appends a fresh
    // continuation. Legacy clients may still send the old "steer" policy; treat
    // it as pause so the invariant holds at this backend boundary.
    goalService.clearPendingContinuationForManualUserMessage(this.workspaceId);
    const goal = await goalService.acknowledgeUser(this.workspaceId);
    if (goal?.status !== "active") {
      return;
    }

    try {
      const result = await goalService.setGoal({
        workspaceId: this.workspaceId,
        status: "paused",
        initiator: "auto",
      });
      if (!result.success) {
        log.warn("Failed to auto-pause goal for manual user message", {
          workspaceId: this.workspaceId,
          error: result.error,
        });
      }
    } catch (error) {
      log.warn("Failed to auto-pause goal for manual user message", {
        workspaceId: this.workspaceId,
        error: getErrorMessage(error),
      });
    }
  }

  private async getWorkspaceMetadataForRetry(): Promise<WorkspaceMetadata | undefined> {
    const aiService = this.aiService as Partial<Pick<AIService, "getWorkspaceMetadata">>;