OpenClaw の返事が途中で切れた会話を、見張りスクリプトで拾って再開させる

#!/usr/bin/env node
// OpenClaw の返事が途中で切れた Discord スレを探して、続きから再開させる（cron から15分おき）
// 普段は LLM を使わない。見つけたときだけ `openclaw agent --deliver` で続きを頼む
// 使い方: node stalled-replies.mjs [--dry-run]
import { DatabaseSync } from 'node:sqlite';
import { readFileSync, writeFileSync, existsSync } from 'node:fs';
import { spawn, execFileSync } from 'node:child_process';
import { homedir } from 'node:os';

const DRY = process.argv.includes('--dry-run');
// プロファイル名（~/.openclaw-<名前> を使っている場合だけ）
const PROFILE = process.env.OPENCLAW_PROFILE;
const OC_HOME = `${homedir()}/.openclaw${PROFILE ? `-${PROFILE}` : ''}`;
// cron は PATH が短いのでフルパスを渡すとよい
const OPENCLAW = process.env.OPENCLAW_BIN || 'openclaw';
// OpenClaw の bot と、話しかける自分の Discord ユーザー ID
const BOT_ID = process.env.BOT_ID;
const OWNER_ID = process.env.OWNER_ID;
// 「再開させた」を書く管理用のチャンネル
const REPORT_TO = process.env.REPORT_CHANNEL_ID;
const STATE = `${OC_HOME}/stalled-replies-state.json`;
// これより古い話は拾わない（時間）
const LOOKBACK_H = 6;
// 呼ばれてから返事が無いまま何分で「切れた」とみなすか
const NO_REPLY_MIN = 10;
// 作業中の表示（🛠️）のまま何分止まっていたら「切れた」とみなすか
const PROGRESS_MIN = 20;
// OpenClaw の失敗・時間切れの決まり文句
const ERROR_RE = /^⚠️|request failed|timed out|Something went wrong|did not produce a visible reply|Agent (run )?failed/i;

const cfg = JSON.parse(readFileSync(`${OC_HOME}/openclaw.json`, 'utf8'));
const dc = cfg.channels.discord;
const TOKEN = dc.token || Object.values(dc.accounts || {})[0]?.token;
const state = existsSync(STATE) ? JSON.parse(readFileSync(STATE, 'utf8')) : { handled: {} };
const now = Date.now();
const profileArgs = PROFILE ? ['--profile', PROFILE] : [];

// 直近に動いた Discord のセッション（= 話しかけたスレ）
const db = new DatabaseSync(`${OC_HOME}/agents/main/agent/openclaw-agent.sqlite`, { readOnly: true });
const sessions = db.prepare(
  `select session_key, status from session_nodes
   where session_key like 'agent:main:discord:channel:%' and coalesce(last_interaction_at,0) > ?`
).all(now - LOOKBACK_H * 3600e3);

const api = (path) => fetch(`https://discord.com/api/v10${path}`, { headers: { Authorization: `Bot ${TOKEN}` } });
const messages = async (ch) => { const r = await api(`/channels/${ch}/messages?limit=15`); return r.ok ? r.json() : []; };
const ts = (m) => Date.parse(m.timestamp);
const ageMin = (m) => (now - ts(m)) / 60e3;
const isBot = (m) => m.author?.id === BOT_ID;
const addressesBot = (m) => m.content?.includes(`<@${BOT_ID}>`) || m.referenced_message?.author?.id === BOT_ID;

const found = [];
for (const s of sessions) {
  // いま動いているものは触らない
  if (s.status === 'running') continue;
  const ch = s.session_key.split(':').pop();
  // 新しい順に並んでいる
  const msgs = (await messages(ch)).filter((m) => ageMin(m) < LOOKBACK_H * 60);
  const lastOwner = msgs.find((m) => m.author?.id === OWNER_ID);
  if (!lastOwner || state.handled[lastOwner.id]) continue;
  const botAfter = msgs.filter((m) => isBot(m) && ts(m) > ts(lastOwner));
  let reason = null;
  if (!botAfter.length) {
    if (addressesBot(lastOwner) && ageMin(lastOwner) >= NO_REPLY_MIN) reason = '呼ばれたのに返事が無い';
  } else {
    const latest = botAfter[0];
    const finals = botAfter.filter((m) => !ERROR_RE.test(m.content) && !m.content.includes('🛠️'));
    if (!finals.length && ERROR_RE.test(latest.content)) reason = '返事がエラーで終わった';
    else if (!finals.length && latest.content.includes('🛠️') && ageMin(latest) >= PROGRESS_MIN) reason = '作業中の表示のまま止まった';
  }
  if (reason) {
    const info = await (await api(`/channels/${ch}`)).json();
    found.push({ ch, guild: info.guild_id, msg: lastOwner, reason, key: s.session_key });
  }
}

for (const f of found) {
  const quote = f.msg.content.replace(/\s+/g, ' ').slice(0, 200);
  const note = `【再開のお願い（見張りスクリプトから）】このスレの発言「${quote}」への返事が途中で切れています（${f.reason}）。` +
    '最初に「途中で切れていた、ごめん」と一言添えて、続きをやって答えてください。すでに答え終わっているなら、その旨を一言だけ書いてください。';
  console.log(`${new Date().toISOString()} stalled ${f.ch} ${f.msg.id} ${f.reason}`);
  if (DRY) continue;
  spawn(OPENCLAW, [...profileArgs, 'agent', '--session-key', f.key, '--message', note,
    '--deliver', '--reply-channel', 'discord', '--reply-to', `channel:${f.ch}`, '--timeout', '1200'],
    { detached: true, stdio: 'ignore' }).unref();
  state.handled[f.msg.id] = now;
}

if (found.length && !DRY && REPORT_TO) {
  const links = found.map((f) => `- <https://discord.com/channels/${f.guild}/${f.ch}/${f.msg.id}>（${f.reason}）`).join('\n');
  execFileSync(OPENCLAW, [...profileArgs, 'message', 'send', '--channel', 'discord',
    '--target', `channel:${REPORT_TO}`, '--message', `途中で切れていたスレを見つけたので、続きから再開させた。\n${links}`],
    { stdio: 'ignore', timeout: 90e3 });
}

// 古い記録は捨てる
for (const [id, t] of Object.entries(state.handled)) if (now - t > 2 * 86400e3) delete state.handled[id];
if (!DRY) writeFileSync(STATE, JSON.stringify(state));
else console.log(`checked ${sessions.length} sessions, found ${found.length}`);