Function handleCximg

codex_image/codex_image.ts:333–486

(msg: Api.Message)

      const storedToken = await getStoredToken();
      await msg.edit({
        text: `🔐 当前本地 Token：${maskToken(storedToken)}\n• 设置方式：<code>${mainPrefix}cximg token 你的codex access token（通常在 .codex/auth.json）</code>`,
        parseMode: "html",
      });
      return;
    }

    await setStoredToken(tokenValue);
    await msg.edit({ text: "✅ 已保存 Codex Access Token" });
    return;
  }

  const prompt = argsText;
  if (!prompt) {
    await msg.edit({
      text: `❌ 请输入提示词，例如：<code>${mainPrefix}cximg 一只戴墨镜的柴犬坐在跑车里</code>\n• 设置 Token：<code>${mainPrefix}cximg token 你的codex access token（通常在 .codex/auth.json）</code>`,
      parseMode: "html",
    });
    return;
  }

  let referenceImage: { buffer: Buffer; mimeType: string } | null = null;
  try {
    referenceImage = await downloadReplyImage(msg);
  } catch (error: any) {
    await msg.edit({
      text: `❌ 参考图下载失败：${htmlEscape(error.message || String(error))}`,
      parseMode: "html",
    });
    return;
  }

  const initialStatus = referenceImage
    ? "🖼️ 已检测到参考图，正在生成图片..."
    : "🎨 正在根据提示词生成图片...";
  await msg.edit({
    text: initialStatus,
  });

  const startedAt = Date.now();
  const deadlineAt = startedAt + CODEX_MAX_WAIT_MS;
  let lastStatusUpdateAt = 0;
  let currentPhaseText = initialStatus;
  let heartbeatStopped = false;
  const updateProgressStatus = async (phaseText: string): Promise<void> => {
    currentPhaseText = phaseText;
    const now = Date.now();
    if (now - lastStatusUpdateAt < 1500) return;
    lastStatusUpdateAt = now;
    const elapsed = formatDuration(now - startedAt);
    try {
      await msg.edit({
        text: `${phaseText}\n⏱️ 已耗时：${elapsed}`,
      });
    } catch {}
  };

  const heartbeat = (async () => {
    while (!heartbeatStopped) {