Delete src

src/codex.ts

@@ -1,102 +0,0 @@
-import "dotenv/config";
-import { mkdir, readFile, writeFile, appendFile, readdir, stat } from "node:fs/promises";
-
-import path from "node:path";
-import type { CallSettings } from "./session-settings.js";
-
-const root = path.resolve(process.cwd());
-const dataDir = path.join(root, "data");
-const historyFile = path.join(dataDir, "history.json");
-const logFile = path.join(dataDir, "bridge.log");
-const env = (n: string, f = "") => process.env[n]?.trim() || f;
-export type Turn = { role: "user" | "assistant"; text: string; at: string };
-export type InputAttachment = { url: string; filename?: string; content_type?: string; size?: number };
-type Store = Record<string, Turn[]>;
-let store: Store = {};
-let writeChain = Promise.resolve();
-
-export async function initStore() { await mkdir(dataDir, { recursive: true }); store = {}; await writeFile(historyFile, "{}", "utf8"); }
-function save() { writeChain = writeChain.then(() => writeFile(historyFile, JSON.stringify(store, null, 2), "utf8")); return writeChain; }
-export async function resetSession(k: string) { delete store[k]; await save(); }
-function turns(k: string) { return store[k] ?? []; }
-async function log(s: string) { await appendFile(logFile, `${new Date().toISOString()} ${s}\n`, "utf8").catch(() => {}); }
-function safeName(name: string, fallback: string) { const base = path.basename(name || fallback).replace(/[^a-zA-Z0-9._-]/g, "_"); return base || fallback; }
-
-function providerEnv(): NodeJS.ProcessEnv { return { ...process.env }; }
-
-async function downloadInputs(workdir: string, key: string, attachments: InputAttachment[]) {
-  const dir = path.join(workdir, "qq-inbox", safeName(key, "session")); await mkdir(dir, { recursive: true });
-  const max = Number(env("MAX_INPUT_FILE_BYTES", String(20 * 1024 * 1024))), result: string[] = [];
-  for (let i = 0; i < attachments.length; i++) {
-    const a = attachments[i]; if (!a.url || !/^https?:$/i.test(new URL(a.url).protocol)) continue;
-    if (a.size && a.size > max) throw new Error(`图片过大，限制为 ${Math.round(max / 1024 / 1024)} MB`);
-    const r = await fetch(a.url); if (!r.ok) throw new Error(`下载 QQ 图片失败：HTTP ${r.status}`);
-    const buf = Buffer.from(await r.arrayBuffer()); if (buf.byteLength > max) throw new Error(`图片过大，限制为 ${Math.round(max / 1024 / 1024)} MB`);
-    const ext = path.extname(a.filename || "") || (a.content_type?.split("/")[1] ? `.${a.content_type.split("/")[1].split(";")[0]}` : ".bin");
-    const file = path.join(dir, `${Date.now()}-${i}-${safeName(path.basename(a.filename || `attachment${ext}`), `attachment${ext}`)}`);
-    await writeFile(file, buf); result.push(file);
-  }
-  return result;
-}
-
-function prompt(k: string, text: string, files: string[]) { const n = Math.max(0, Number(env("HISTORY_TURNS", "8")) * 2); const h = turns(k).slice(-n).map(t => `${t.role === "user" ? "用户" : "Codex"}: ${t.text}`).join("\n\n") || "（无）"; const f = files.length ? `\n\n用户发送的文件已保存到以下路径，请按需读取：\n${files.join("\n")}` : ""; return `你正在通过 QQ 机器人与用户对话。请直接回答，不要提及桥接程序或内部提示。你运行在可联网的 Hugging Face 容器中：需要最新信息时必须使用 curl 或 Python requests 访问公开网页/API并核验来源，若请求失败须说明具体错误，不得编造新闻。你可以在当前工作目录创建和编辑 pptx、xlsx、docx、pdf 等文件；使用已安装的 python-pptx、openpyxl、python-docx、reportlab，完成后确认文件存在并将生成文件返回给用户。\n\n最近对话：\n${h}\n\n用户本次消息：\n${text}${f}`; }
-
-async function listArtifacts(dir: string, depth = 0): Promise<Map<string, number>> { const out = new Map<string, number>(); if (depth > 2) return out; for (const e of await readdir(dir, { withFileTypes: true })) { const p = path.join(dir, e.name); if (e.isDirectory()) { for (const [k, v] of await listArtifacts(p, depth + 1)) out.set(k, v); } else if (/\.(pptx|pdf|docx|xlsx|csv|png|jpg|jpeg|webp)$/i.test(e.name)) { out.set(p, (await stat(p)).mtimeMs); } } return out; }
-export async function findNewArtifacts(workdir: string, before: Map<string, number>) { const after = await listArtifacts(workdir); return [...after.keys()].filter(p => !before.has(p) || (after.get(p)! > before.get(p)! + 1000)).sort(); }
-export async function downloadAttachments(workdir: string, key: string, attachments: InputAttachment[]) { return attachments.length ? downloadInputs(workdir, key, attachments) : []; }
-
-export async function askCodex(k: string, text: string, files: string[] = [], before?: Map<string, number>, settings: CallSettings = {}): Promise<{ answer: string; artifacts: string[] }> {
-  const workdir = path.resolve(env("CODEX_WORKDIR", path.join(root, "workspace"))); await mkdir(workdir, { recursive: true });
-  const out = path.join(dataDir, `codex-${Date.now()}-${Math.random().toString(16).slice(2)}.txt`);
-  const args = ["exec", "--json", "--skip-git-repo-check", "-C", workdir, "-s", "danger-full-access", "-o", out];
-  if (env("CODEX_ENABLE_WEB_SEARCH", "false") === "true") args.push("--search");
-  const model = settings.model ?? env("CODEX_MODEL"); if (model) args.push("-m", model); const effort = settings.effort ?? env("CODEX_REASONING_EFFORT"); if (effort) args.push("-c", `model_reasoning_effort=${JSON.stringify(effort)}`);
-  for (const f of files) if (/\.(png|jpe?g|webp|gif|bmp)$/i.test(f)) args.push("-i", f); args.push("-"); await log(`request key=${k} chars=${text.length} files=${files.length}`);
-  const { spawn } = await import("node:child_process"); const configured = env("CODEX_COMMAND", "codex"); const command = /^[^\\/:]+\.cmd$/i.test(configured) ? configured.replace(/\.cmd$/i, ".exe") : configured; const childEnv = await providerEnv();
-  return new Promise((resolve, reject) => {
-    const c = spawn(command, args, { cwd: workdir, env: childEnv, windowsHide: true, stdio: ["pipe", "pipe", "pipe"] });
-    let err = "";
-    // Codex --json can emit many events. Always drain stdout, or its pipe fills and stalls the child.
-    let stdoutBytes = 0;
-    c.stdout.on("data", b => { stdoutBytes += b.length; });
-    c.stderr.on("data", b => { err = (err + String(b)).slice(-6000); });
-    const configuredTimeout = Number(env("CODEX_TIMEOUT_MS", "900000"));
-    const timeoutMs = Number.isFinite(configuredTimeout) && configuredTimeout > 0 ? configuredTimeout : 900000;
-    let timedOut = false;
-    const timer = setTimeout(() => {
-      timedOut = true;
-      void log(`timeout key=${k} after=${timeoutMs}ms`);
-      c.kill("SIGKILL");
-      reject(new Error(`Codex 响应超时（${Math.round(timeoutMs / 60000)} 分钟）。请缩小任务或提高 CODEX_TIMEOUT_MS。`));
-    }, timeoutMs);
-    c.on("error", e => { clearTimeout(timer); reject(new Error(`无法启动 Codex：${e.message}`)); });
-    c.on("close", async code => {
-      try {
-      await log(`codex exit key=${k} code=${code} stdoutBytes=${stdoutBytes} timedOut=${timedOut}`);
-      clearTimeout(timer);
-      if (timedOut) return;
-      let answer = "";
-      try { answer = (await readFile(out, "utf8")).trim(); } catch {}
-      if (code !== 0) { await log(`error code=${code} stderr=${err.slice(-1500)}`); reject(new Error(err.trim().slice(-1000) || `Codex 退出码 ${code}`)); return; }
-      if (!answer) answer = "Codex 没有返回文本。";
-      const a = store[k] ??= [];
-      a.push({ role: "user", text, at: new Date().toISOString() }, { role: "assistant", text: answer, at: new Date().toISOString() });
-      if (a.length > 40) a.splice(0, a.length - 40);
-      await save();
-      const artifacts = await findNewArtifacts(workdir, before ?? new Map());
-      await log(`success key=${k} chars=${answer.length} artifacts=${artifacts.length}`);
-      resolve({ answer, artifacts });
-      } catch (e) { reject(e); }
-    });
-    c.stdin.on("error", e => { void log(`stdin error key=${k} ${e.message}`); });
-    c.stdin.end(prompt(k, text, files), "utf8");
-  });
-}
-export function splitReply(s: string) { const m = Math.max(500, Number(env("MAX_REPLY_CHARS", "3500"))), a: string[] = []; for (let i = 0; i < s.length; i += m) a.push(s.slice(i, i + m)); return a; }
-export async function snapshotArtifacts(workdir: string) { await mkdir(path.resolve(workdir), { recursive: true }); return listArtifacts(path.resolve(workdir)); }
-
-
-
-
-
-

src/doctor.ts

@@ -1,3 +0,0 @@
-import "dotenv/config"; import {execFile} from "node:child_process"; import {promisify} from "node:util"; try{const r=await promisify(execFile)(process.env.CODEX_COMMAND||"codex",["--version"],{windowsHide:true});console.log(r.stdout.trim());}catch(e){console.error("找不到 Codex CLI，请先 codex login，并确认 codex.cmd 在 PATH 中。",e);process.exitCode=1;}
-
-

src/index.ts

@@ -1,87 +0,0 @@
-import "dotenv/config";
-import { readFile } from "node:fs/promises";
-import path from "node:path";
-import { effectiveSettings, switchSetting } from "./session-settings.js";
-import { QQBot, mentionGate, messageFilter, rateLimiter, accessPolicy, errorHandler } from "@tencent-connect/qqbot-nodejs";
-import { initStore, resetSession, askCodex, splitReply, downloadAttachments, snapshotArtifacts } from "./codex.js";
-
-for (const n of ["QQBOT_APP_ID", "QQBOT_APP_SECRET"]) if (!process.env[n]?.trim()) throw new Error(`缺少环境变量 ${n}`);
-const allowed = (process.env.QQ_ALLOWED_OPENIDS ?? "").split(",").map(x => x.trim()).filter(Boolean);
-if (!allowed.length) console.warn("QQ_ALLOWED_OPENIDS 为空，将拒绝所有消息。");
-await initStore();
-
-const bot = new QQBot({ appId: process.env.QQBOT_APP_ID!, appSecret: process.env.QQBOT_APP_SECRET!, logger: console });
-bot.use(errorHandler());
-bot.use(messageFilter({ skipSelfEcho: true, dedup: { windowMs: 10000 } }));
-bot.use(accessPolicy({ c2c: { mode: "allowlist", allow: allowed }, group: { mode: "allowlist", allow: allowed } }));
-bot.use(mentionGate({ requireMentionInGroup: true }));
-bot.use(rateLimiter({ perSender: { max: 6, windowMs: 60000 }, global: { max: 30, windowMs: 60000 } }));
-// Do not queue /status behind a long-running Codex request.
-const active = new Map<string, number>();
-bot.on("ready", () => console.log("QQ 机器人已连接；等待消息。"));
-bot.on("error", e => console.error("QQ SDK error:", e));
-
-bot.on("message", async (_ctx, msg) => {
-  const key = `${msg.kind}:${msg.replyTarget.targetId}`;
-  const input = msg.content.trim();
-  if (!input && !(msg.attachments?.length)) return;
-  const switched = switchSetting(key, input);
-  if (switched !== undefined) {
-    await bot.sendText(msg.replyTarget, switched);
-    return;
-  }
-  if (input === "/status") {
-    const started = active.get(key);
-    const settings = effectiveSettings(key);
-    const state = started ? `任务仍在处理，已运行 ${Math.floor((Date.now() - started) / 60000)} 分钟。` : "机器人在线，当前会话没有运行中的任务。";
-    await bot.sendText(msg.replyTarget, `${state}\n下一次调用模型：${settings.model || "CLI 默认"}\n推理深度：${settings.effort || "CLI 默认"}`);
-    return;
-  }
-  if (input === "/diag") {
-    const files = ["bridge.log", "startup.log", "jupyter.log"];
-    const excerpts: string[] = [];
-    for (const file of files) {
-      try {
-        let lines = (await readFile(path.join(process.cwd(), "data", file), "utf8")).split("\n").filter(Boolean).slice(-8).join("\n");
-        for (const secret of [process.env.CODEX_API_KEY, process.env.QQBOT_APP_SECRET, process.env.JUPYTER_TOKEN, process.env.QQBOT_APP_ID]) if (secret) lines = lines.replaceAll(secret, "[REDACTED]");
-        excerpts.push(`${file}:\n${lines.slice(-900)}`);
-      } catch { excerpts.push(`${file}: 暂无日志`); }
-    }
-    await bot.sendText(msg.replyTarget, excerpts.join("\n\n").slice(-3000));
-    return;
-  }
-  if (input === "/reset") {
-    if (active.has(key)) { await bot.sendText(msg.replyTarget, "当前任务尚在运行；请等待任务结束后再重置。"); return; }
-    await resetSession(key);
-    await bot.sendText(msg.replyTarget, "已清空当前会话。");
-    return;
-  }
-  if (active.has(key)) { await bot.sendText(msg.replyTarget, "当前已有任务运行中。发送 /status 可查看耗时，请勿重复提交。"); return; }
-  active.set(key, Date.now());
-  const callSettings = effectiveSettings(key);
-  let progress: ReturnType<typeof setInterval> | undefined;
-  try {
-    await bot.sendText(msg.replyTarget, msg.attachments?.length ? "已收到附件，Codex 正在处理…" : "已收到，Codex 正在处理…");
-    progress = setInterval(() => {
-      const mins = Math.floor((Date.now() - active.get(key)!) / 60000);
-      void bot.sendText(msg.replyTarget, `任务仍在运行（${mins} 分钟），完成或失败后会回复。`).catch(e => console.error("进度消息发送失败:", e));
-    }, 180000);
-    const workdir = process.env.CODEX_WORKDIR || "/home/node/app/workspace";
-    const files = await downloadAttachments(workdir, key, msg.attachments ?? []);
-    const before = await snapshotArtifacts(workdir);
-    const result = await askCodex(key, input || "请分析我发送的图片或文件，并给出结果。", files, before, callSettings);
-    for (const part of splitReply(result.answer)) await bot.sendText(msg.replyTarget, part);
-    for (const file of result.artifacts) {
-      try { await bot.sendFile(msg.replyTarget, { localPath: file }, { fileName: file.split(/[\\/]/).pop() }); }
-      catch (e) { await bot.sendText(msg.replyTarget, `文件已生成但发送失败：${file.split(/[\\/]/).pop()}\n${e instanceof Error ? e.message : String(e)}`); }
-    }
-  } catch (e) {
-    console.error("任务失败:", e);
-    try { await bot.sendText(msg.replyTarget, `处理失败：${e instanceof Error ? e.message : String(e)}`); }
-    catch (sendError) { console.error("失败消息也无法发送:", sendError); }
-  } finally {
-    if (progress) clearInterval(progress);
-    active.delete(key);
-  }
-});
-await bot.start();

src/session-settings.ts

@@ -1,21 +0,0 @@
-export type CallSettings = { model?: string; effort?: string };
-const overrides = new Map<string, CallSettings>();
-const efforts = new Set(["low", "medium", "high", "xhigh", "max", "ultra"]);
-export function effectiveSettings(key: string): CallSettings {
-  const value = overrides.get(key);
-  return { model: value?.model ?? process.env.CODEX_MODEL?.trim(), effort: value?.effort ?? process.env.CODEX_REASONING_EFFORT?.trim() };
-}
-export function switchSetting(key: string, input: string): string | undefined {
-  const match = /^\/(switch|effort)(?:\s+([\s\S]*))?$/.exec(input);
-  if (!match) return undefined;
-  const [, command, raw = ""] = match;
-  const value = raw.trim();
-  if (command === "switch") {
-    if (!value || value.length > 200 || /\s|[\x00-\x1f\x7f]/.test(value)) return "模型切换失败。用法：/switch 模型名，例如 /switch gpt-6-sol";
-    overrides.set(key, { ...overrides.get(key), model: value });
-    return `模型切换成功：${value}。从下一次请求使用，重启后恢复环境变量默认值。`;
-  }
-  if (!efforts.has(value)) return "推理深度切换失败。可选：low / medium / high / xhigh / max / ultra";
-  overrides.set(key, { ...overrides.get(key), effort: value });
-  return `推理深度切换成功：${value}。从下一次请求使用，重启后恢复环境变量默认值。`;
-}