Function pollTask

ai/ai.ts:1091–1126

(
  fetchJob: TaskFetchFn,
  parseResult: TaskParseFn<T>,
  options: TaskPollOptions = {},
  token?: AbortToken,
)

const pollTask = async <T>(
  fetchJob: TaskFetchFn,
  parseResult: TaskParseFn<T>,
  options: TaskPollOptions = {},
  token?: AbortToken,
): Promise<T> => {
  const maxAttempts = options.maxAttempts ?? 303;
  const intervalMs = options.intervalMs ?? 2000;

  for (let i = 0; i < maxAttempts; i++) {
    token?.throwIfAborted();

    const data = await retryWithFixedDelay(
      () => fetchJob(token),
      2,
      1000,
      token,
    );
    const result = parseResult(data);

    if (result.status === "failed") {
      throw new Error(result.errorMessage || "任务执行失败");
    }

    if (result.status === "succeeded") {
      if (result.result === undefined) {
        throw new Error("任务成功但未返回结果");
      }
      return result.result;
    }

    await sleep(intervalMs, token);
  }

  throw new Error("任务执行超时");
};

interface MessageOptions {
  parseMode?: string;
  linkPreview?: boolean;