Method createStopWhenCondition

src/node/services/streamManager.ts:1459–1513

(
    request: Pick<StreamRequestConfig, "hasQueuedMessages" | "toolPolicy">
  )

  }

  private createStopWhenCondition(
    request: Pick<StreamRequestConfig, "hasQueuedMessages" | "toolPolicy">
  ): Array<ReturnType<typeof stepCountIs>> {
    // Completion-tool stop check: completion/routing tools use explicit
    // success/ok markers (agent_report, propose_plan).
    // When a marker is present, respect it — success:false means the tool
    // should be retried, so don't stop. When no marker is present (e.g.,
    // MCP tools, arbitrary required tools), treat non-null object results
    // as successful completion unless the result is error-shaped.
    const isSuccessfulOutput = (output: unknown): boolean => {
      if (typeof output !== "object" || output === null) {
        return false;
      }
      const parsedOutput = output as Record<string, unknown>;
      if ("success" in parsedOutput) {
        return parsedOutput.success === true;
      }
      if ("ok" in parsedOutput) {
        return parsedOutput.ok === true;
      }
      if (parsedOutput.error != null || parsedOutput.isError === true) {
        return false;
      }
      return true;
    };

    const requiredPatterns = (request.toolPolicy ?? [])
      .filter((filter) => filter.action === "require")
      .map((filter) => {
        // Strip existing anchors to avoid double-anchoring recovery policies
        // (e.g. "^agent_report$" would otherwise become "^^agent_report$$").
        const rawPattern = filter.regex_match.replace(/^\^/, "").replace(/\$$/, "");
        return new RegExp(`^${rawPattern}$`);
      });

    const hasSuccessfulRequiredToolResult: ReturnType<typeof stepCountIs> = ({ steps }) => {
      if (requiredPatterns.length === 0) {
        return false;
      }
      const lastStep = steps[steps.length - 1];
      return (
        lastStep?.toolResults?.some(
          (toolResult) =>
            requiredPatterns.some((pattern) => pattern.test(toolResult.toolName)) &&
            isSuccessfulOutput(toolResult.output)
        ) ?? false
      );
    };

    return [
      stepCountIs(100000),
      () => request.hasQueuedMessages?.("tool-end") ?? false,
      hasSuccessfulRequiredToolResult,
    ];
  }

  private createStreamResult(
    request: StreamRequestConfig,