Method executeGoalContinuation

src/node/services/workspaceService.ts:8964–9007

(input: {
    workspaceId: string;
    message: string;
    startStreamInBackground?: boolean;
    kind?: GoalSyntheticMessageKind;
    options: SendMessageOptions;
  })

  }

  async executeGoalContinuation(input: {
    workspaceId: string;
    message: string;
    startStreamInBackground?: boolean;
    kind?: GoalSyntheticMessageKind;
    options: SendMessageOptions;
  }): Promise<boolean> {
    assert(input.workspaceId.trim().length > 0, "executeGoalContinuation requires workspaceId");
    assert(input.message.trim().length > 0, "executeGoalContinuation requires message");

    const goalKind = input.kind ?? GOAL_CONTINUATION_KIND;
    const startStreamInBackground =
      input.startStreamInBackground === true && goalKind !== GOAL_BUDGET_LIMIT_KIND;
    const sendResult = await this.sendMessage(
      input.workspaceId,
      input.message,
      {
        ...input.options,
        editMessageId: undefined,
      },
      {
        skipAutoResumeReset: true,
        synthetic: true,
        agentInitiated: true,
        startStreamInBackground,
        onAcceptedPreStreamFailure: startStreamInBackground
          ? () =>
              this.workspaceGoalService?.requestPendingGoalContinuationDispatch(input.workspaceId)
          : undefined,
        requireIdle: true,
        goalKind,
        goalContinuation: true,
      }
    );

    if (!sendResult.success) {
      log.info("WorkspaceService: goal continuation send skipped", {
        workspaceId: input.workspaceId,
        error: sendResult.error,
      });
      return false;
    }
    return true;
  }

  /**
   * Register the callback that receives terminal idle-compaction outcomes.