cfc/_dispatch_251.cjs

// 189 派发客户端（修正版）—— 修复 B-56 客户端侧缺陷，使 189 通道在凭证就绪后即可用
//
// 根因之一（客户端）：旧脚本（_dispatch_r91.cjs 等）在 POST /api/session 时把 prompt 嵌进 body
//   并假设 opencode 建会话后自动运行 agent。实测 189 的 opencode 不会自动运行（session 创建后
//   outcome 停在初始态，无 assistant 产出）。正确触发流程是：
//     ① POST /api/session            建会话（返回 data.id）
//     ② POST /api/session/{id}/prompt 经 {text:"..."} 触发 agent 运行（注意字段是 text，不是 prompt）
//     ③ 轮询 GET /api/session/{id}   取 outcome（success / failed）
//
// 用法：
//   OPENCODE_SERVER_PASSWORD='IwinTrue@123' node _dispatch_189.cjs "在此写要执行的命令/任务"
//
// 注意：189 当前（R93 实测）opencode 所有模型调用均 outcome=failed，根因是 189 节点
//   C:\Users\Administrator\.config\opencode\opencode.json 中 agnes/sensenova/axon 均无 apiKey，
//   且 opencode-free 模型需账号授权 —— 即无任一可用 LLM 后端。该问题需运维在 189 本机
//   配置 API Key 并重启 opencode 后方可解决（SSH 22 当前 refused，无法远程处置）。
//   本客户端只负责把「触发流程」修对；凭证就绪后本文件即可直接派发 admin 浏览器套件。

const BASE = process.env.OPENCODE_251_BASE || 'http://192.168.16.251:4096';
const AUTH = 'Basic ' + Buffer.from('opencode:' + (process.env.OPENCODE_SERVER_PASSWORD || '')).toString('base64');
const MODEL = {
  id: process.env.OPENCODE_MODEL || 'deepseek3.2',
  providerID: process.env.OPENCODE_PROVIDER || 'axon',
};
const PROJECT_ID = '527b7036bd8d16188784528603a9b79a1d95c9fb';

async function dispatch(promptText, timeoutMs = 20 * 60 * 1000) {
  // ① 建会话
  const cr = await fetch(BASE + '/api/session', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', 'Authorization': AUTH },
    body: JSON.stringify({ title: 'dispatch-' + Date.now(), model: MODEL, projectID: PROJECT_ID }),
  });
  const cj = await cr.json().catch(() => ({}));
  const sid = (cj.data && cj.data.id) || cj.id;
  if (!sid) throw new Error('create session failed: ' + JSON.stringify(cj).slice(0, 200));
  console.log('SESSION_ID', sid);

  // ② 正确触发 agent：POST /prompt，body 字段是 text
  const pr = await fetch(BASE + '/api/session/' + sid + '/prompt', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', 'Authorization': AUTH },
    body: JSON.stringify({ text: promptText }),
  });
  console.log('PROMPT', pr.status, (await pr.text()).slice(0, 200));

  // ③ 轮询 outcome
  const start = Date.now();
  let last = '?';
  while (Date.now() - start < timeoutMs) {
    await new Promise(r => setTimeout(r, 5000));
    const q = await fetch(BASE + '/api/session/' + sid, { headers: { 'Authorization': AUTH } });
    const j = await q.json().catch(() => null);
    const outcome = (j && (j.data && j.data.outcome || j.outcome)) || '?';
    if (outcome !== last) { console.log('OUTCOME', outcome); last = outcome; }
    if (outcome === 'success' || outcome === 'succeeded') {
      // 拉取会话消息，取最后一条 assistant 文本作为结果
      let resultText = '';
      try {
        const m = await fetch(BASE + '/api/session/' + sid + '/message', { headers: { 'Authorization': AUTH } });
        const mj = await m.json().catch(() => null);
        const list = (mj && (mj.data || mj)) || [];
        const asst = list.filter(x => x.type === 'assistant');
        const lastAsst = asst[asst.length - 1];
        if (lastAsst) {
          const parts = lastAsst.content || [];
          resultText = parts.map(p => p.text || p.content || '').filter(Boolean).join('\n');
        }
      } catch (e) { resultText = 'msg-fetch-err:' + e.message; }
      return { sid, outcome: 'succeeded', resultText };
    }
    if (outcome === 'failed') return { sid, outcome: 'failed' };
  }
  return { sid, outcome: 'timeout' };
}

(async () => {
  const prompt = process.argv[2] || '请只执行命令 `node -v` 并把 stdout 原样返回。';
  if (!process.env.OPENCODE_SERVER_PASSWORD) {
    console.error('ERROR: 需设置环境变量 OPENCODE_SERVER_PASSWORD');
    process.exit(2);
  }
  try {
    const r = await dispatch(prompt);
    console.log('RESULT', JSON.stringify(r));
    if (r && r.resultText) console.log('RESULT_TEXT_START\n' + r.resultText + '\nRESULT_TEXT_END');
  } catch (e) {
    console.error('DISPATCH_ERROR', e.message);
    process.exit(1);
  }
})();