Update server.js

server.js

@@ -24,6 +24,7 @@ const {
   OPENWEBUI_API_KEY,
   OPENCLAW_WS_URL,
   OPENCLAW_TOKEN,
+
   BOT_USERNAME = 'openman',
   POLL_INTERVAL = 5000,
   DEBUG_LOGS = 'true',
@@ -32,35 +33,15 @@ const {
   MAX_UPLOAD_MB = '30',
   DEFAULT_MESSAGE_LIMIT = '120',
   PUBLIC_URL = '',
+
   STORAGE_EXTERNAL_ENDPOINT,
   STORAGE_PUBLIC_BUCKET,
   STORAGE_REGION,
   STORAGE_ACCESS_KEY_ID,
   STORAGE_SECRET_ACCESS_KEY,
-  STORAGE_S3_FORCE_PATH_STYLE,
-
-  // Optional STT(OpenAI-compatible) endpoint for voice transcription
-  STT_API_URL = '',
-  STT_API_KEY = '',
-  STT_MODEL = 'whisper-1',
-  STT_LANGUAGE = 'zh'
+  STORAGE_S3_FORCE_PATH_STYLE
 } = process.env;
 
-const ALLOWED_UI_PROFILE_KEYS = [
-  'OPENCLAW_WS_URL',
-  'BOT_USERNAME',
-  'FRONT_STREAM_INTERVAL',
-  'MAX_UPLOAD_MB',
-  'DEFAULT_MESSAGE_LIMIT',
-  'DEBUG_LOGS',
-  'STORAGE_EXTERNAL_ENDPOINT',
-  'STORAGE_PUBLIC_BUCKET',
-  'STORAGE_REGION',
-  'STORAGE_ACCESS_KEY_ID',
-  'STORAGE_SECRET_ACCESS_KEY',
-  'STORAGE_S3_FORCE_PATH_STYLE'
-];
-
 const runtimeConfig = {
   botUsername: BOT_USERNAME,
   debugLogs: String(DEBUG_LOGS).toLowerCase() !== 'false',
@@ -68,16 +49,10 @@ const runtimeConfig = {
   defaultMessageLimit: Math.max(parseInt(DEFAULT_MESSAGE_LIMIT, 10) || 120, 20),
   uiProfile: {
     OPENCLAW_WS_URL: OPENCLAW_WS_URL || '',
-    BOT_USERNAME: BOT_USERNAME || '',
-    FRONT_STREAM_INTERVAL: FRONT_STREAM_INTERVAL || '',
-    MAX_UPLOAD_MB: MAX_UPLOAD_MB || '',
-    DEFAULT_MESSAGE_LIMIT: DEFAULT_MESSAGE_LIMIT || '',
-    DEBUG_LOGS: DEBUG_LOGS || '',
+    PUBLIC_URL: PUBLIC_URL || '',
     STORAGE_EXTERNAL_ENDPOINT: STORAGE_EXTERNAL_ENDPOINT || '',
     STORAGE_PUBLIC_BUCKET: STORAGE_PUBLIC_BUCKET || '',
     STORAGE_REGION: STORAGE_REGION || '',
-    STORAGE_ACCESS_KEY_ID: STORAGE_ACCESS_KEY_ID ? '***' : '',
-    STORAGE_SECRET_ACCESS_KEY: STORAGE_SECRET_ACCESS_KEY ? '***' : '',
     STORAGE_S3_FORCE_PATH_STYLE: STORAGE_S3_FORCE_PATH_STYLE || 'false'
   }
 };
@@ -90,14 +65,14 @@ const s3 = new S3Client({
   region: STORAGE_REGION || 'us-east-1',
   endpoint: STORAGE_EXTERNAL_ENDPOINT,
   forcePathStyle: STORAGE_S3_FORCE_PATH_STYLE === 'true',
-  credentials: STORAGE_ACCESS_KEY_ID && STORAGE_SECRET_ACCESS_KEY
-    ? {
-        accessKeyId: STORAGE_ACCESS_KEY_ID,
-        secretAccessKey: STORAGE_SECRET_ACCESS_KEY
-      }
-    : undefined
+  credentials:
+    STORAGE_ACCESS_KEY_ID && STORAGE_SECRET_ACCESS_KEY
+      ? {
+          accessKeyId: STORAGE_ACCESS_KEY_ID,
+          secretAccessKey: STORAGE_SECRET_ACCESS_KEY
+        }
+      : undefined
 });
-
 const S3_PREFIX_CONFIG = 'openclaw/channels.json';
 const S3_PREFIX_UPLOADS = 'openclaw/uploads/';
 
@@ -135,7 +110,6 @@ const webuiApi = axios.create({
   },
   timeout: 10000
 });
-
 const fileDownloader = axios.create({
   baseURL: OPENWEBUI_BASE_URL,
   headers: { Authorization: `Bearer ${OPENWEBUI_API_KEY}` },
@@ -149,7 +123,7 @@ const fileDownloader = axios.create({
 async function streamToString(stream) {
   return new Promise((resolve, reject) => {
     const chunks = [];
-    stream.on('data', (c) => chunks.push(c));
+    stream.on('data', c => chunks.push(c));
     stream.on('error', reject);
     stream.on('end', () => resolve(Buffer.concat(chunks).toString('utf8')));
   });
@@ -167,7 +141,7 @@ async function loadChannelsFromS3() {
     const str = await streamToString(rsp.Body);
     const data = JSON.parse(str);
     if (data && Array.isArray(data.channels)) {
-      data.channels.forEach((ch) => {
+      data.channels.forEach(ch => {
         if (!channelRuntime.has(ch.id)) {
           channelRuntime.set(ch.id, { id: ch.id, name: ch.name, lastMsgId: null, syncing: false });
           initChannelBaseline(ch.id);
@@ -287,6 +261,7 @@ function parseClawContent(content) {
         lines.push(`![图片](${item.url})`);
         result.files.push({ url: item.url, type: 'image' });
       } else if (type === 'audio' && item.url) {
+        // 用 #audio 明确标记，前端不会误判成 video
         lines.push(`[语音](${item.url}#audio)`);
         result.files.push({ url: item.url, type: 'audio' });
       } else if (type === 'video' && item.url) {
@@ -353,10 +328,7 @@ function normalizeClawMessages(rawList = []) {
 async function getClawMessagesByChannel(cid, limit = 120) {
   const payload = await clawRequest(
     'chat.history',
-    {
-      sessionKey: `agent:main:${cid}`,
-      limit: Math.max(10, limit)
-    },
+    { sessionKey: `agent:main:${cid}`, limit: Math.max(10, limit) },
     7000
   );
   const raw = Array.isArray(payload?.messages) ? payload.messages : [];
@@ -377,13 +349,11 @@ function passOK(req) {
   const p = req.headers['x-connect-password'] || req.query.p || '';
   return String(p) === String(CONNECT_PASSWORD);
 }
-
 function apiGuard(req, res, next) {
   if (req.path === '/config') return next();
   if (passOK(req)) return next();
   return res.status(401).json({ error: '连接密码错误或未提供' });
 }
-
 app.use('/api', apiGuard);
 
 app.get('/api/config', (req, res) => {
@@ -391,10 +361,6 @@ app.get('/api/config', (req, res) => {
     needPassword: !!CONNECT_PASSWORD,
     maxUploadMB: uploadMaxMB,
     runtimeConfig,
-    stt: {
-      enabled: !!STT_API_URL,
-      model: STT_MODEL
-    },
     envKeys: [
       'CONNECT_PASSWORD',
       'OPENCLAW_WS_URL',
@@ -408,42 +374,24 @@ app.get('/api/config', (req, res) => {
       'STORAGE_REGION',
       'STORAGE_ACCESS_KEY_ID',
       'STORAGE_SECRET_ACCESS_KEY',
-      'STORAGE_S3_FORCE_PATH_STYLE'
+      'STORAGE_S3_FORCE_PATH_STYLE',
+      'PUBLIC_URL'
     ]
   });
 });
 
-app.get('/api/runtime-settings', (req, res) => {
-  res.json(runtimeConfig);
-});
+app.get('/api/runtime-settings', (req, res) => res.json(runtimeConfig));
 
 app.post('/api/runtime-settings', (req, res) => {
   const body = req.body || {};
-
-  if (typeof body.botUsername === 'string' && body.botUsername.trim()) {
-    runtimeConfig.botUsername = body.botUsername.trim();
-  }
-  if (typeof body.debugLogs === 'boolean') {
-    runtimeConfig.debugLogs = body.debugLogs;
-  }
-  if (Number.isFinite(Number(body.streamInterval))) {
-    runtimeConfig.streamInterval = Math.max(800, parseInt(body.streamInterval, 10));
-  }
-  if (Number.isFinite(Number(body.defaultMessageLimit))) {
-    runtimeConfig.defaultMessageLimit = Math.max(20, parseInt(body.defaultMessageLimit, 10));
-  }
-
+  if (typeof body.botUsername === 'string' && body.botUsername.trim()) runtimeConfig.botUsername = body.botUsername.trim();
+  if (typeof body.debugLogs === 'boolean') runtimeConfig.debugLogs = body.debugLogs;
+  if (Number.isFinite(Number(body.streamInterval))) runtimeConfig.streamInterval = Math.max(800, parseInt(body.streamInterval, 10));
+  if (Number.isFinite(Number(body.defaultMessageLimit))) runtimeConfig.defaultMessageLimit = Math.max(20, parseInt(body.defaultMessageLimit, 10));
   if (body.uiProfile && typeof body.uiProfile === 'object') {
-    const nextProfile = { ...runtimeConfig.uiProfile };
-    for (const k of ALLOWED_UI_PROFILE_KEYS) {
-      if (Object.prototype.hasOwnProperty.call(body.uiProfile, k)) {
-        nextProfile[k] = String(body.uiProfile[k] ?? '');
-      }
-    }
-    runtimeConfig.uiProfile = nextProfile;
+    runtimeConfig.uiProfile = { ...runtimeConfig.uiProfile, ...body.uiProfile };
   }
-
-  log(`⚙️ 运行设置更新: ${JSON.stringify({ ...runtimeConfig, uiProfile: '[omitted]' })}`);
+  log(`⚙️ 运行设置更新`);
   res.json({ success: true, runtimeConfig });
 });
 
@@ -451,17 +399,10 @@ app.get('/api/channels', (req, res) => {
   res.json(Array.from(channelRuntime.values()).map(({ id, name }) => ({ id, name })));
 });
 
-app.post('/api/channels', (req, res) => {
-  res.status(403).json({ error: '频道由S3同步，禁止新增' });
-});
-
-app.delete('/api/channels/:id', (req, res) => {
-  res.status(403).json({ error: '频道由S3同步，禁止删除' });
-});
-
+app.post('/api/channels', (req, res) => res.status(403).json({ error: '频道由S3同步，禁止新增' }));
+app.delete('/api/channels/:id', (req, res) => res.status(403).json({ error: '频道由S3同步，禁止删除' }));
 app.get('/api/logs', (req, res) => res.json(logBuffer));
 
-// Front messages from OpenClaw
 app.get('/api/messages/:cid', async (req, res) => {
   const cid = req.params.cid;
   try {
@@ -474,12 +415,10 @@ app.get('/api/messages/:cid', async (req, res) => {
   }
 });
 
-// SSE stream
 app.get('/api/messages/:cid/stream', async (req, res) => {
   const cid = req.params.cid;
   const limit = Math.max(parseInt(req.query.limit, 10) || runtimeConfig.defaultMessageLimit, 20);
   const interval = Math.max(parseInt(req.query.interval, 10) || runtimeConfig.streamInterval, 800);
-
   if (!passOK(req)) return res.status(401).end('unauthorized');
 
   res.setHeader('Content-Type', 'text/event-stream; charset=utf-8');
@@ -512,7 +451,7 @@ app.get('/api/messages/:cid/stream', async (req, res) => {
         return;
       }
 
-      const idx = sorted.findIndex((m) => m.id === lastSeen);
+      const idx = sorted.findIndex(m => m.id === lastSeen);
       const fresh = idx === -1 ? sorted : sorted.slice(idx + 1);
 
       if (fresh.length > 0) {
@@ -531,15 +470,14 @@ app.get('/api/messages/:cid/stream', async (req, res) => {
     closed = true;
     clearInterval(timer);
     clearInterval(heartbeat);
-    try {
-      res.end();
-    } catch {}
+    try { res.end(); } catch {}
   });
 });
 
 app.post('/api/upload', async (req, res) => {
   const { filename, base64, mimeType } = req.body || {};
   if (!base64 || !filename) return res.status(400).json({ error: '参数缺失' });
+
   try {
     const buffer = Buffer.from(base64, 'base64');
     if (buffer.length > uploadMaxBytes) {
@@ -554,53 +492,6 @@ app.post('/api/upload', async (req, res) => {
   }
 });
 
-// Voice transcription (OpenAI-compatible STT API, optional)
-app.post('/api/transcribe', async (req, res) => {
-  try {
-    if (!STT_API_URL) return res.json({ enabled: false, text: '' });
-
-    const { filename = 'voice.ogg', base64, mimeType = 'audio/ogg' } = req.body || {};
-    if (!base64) return res.status(400).json({ error: '缺少base64' });
-
-    const buffer = Buffer.from(base64, 'base64');
-    if (buffer.length > uploadMaxBytes) {
-      return res.status(413).json({ error: `音频过大，超过 ${uploadMaxMB}MB` });
-    }
-
-    const form = new FormData();
-    form.append('file', new Blob([buffer], { type: mimeType }), filename);
-    form.append('model', STT_MODEL);
-    if (STT_LANGUAGE) form.append('language', STT_LANGUAGE);
-
-    const headers = {};
-    if (STT_API_KEY) headers.Authorization = `Bearer ${STT_API_KEY}`;
-
-    const r = await fetch(STT_API_URL, {
-      method: 'POST',
-      headers,
-      body: form
-    });
-
-    const txt = await r.text();
-    let data = {};
-    try {
-      data = JSON.parse(txt);
-    } catch {
-      data = { text: txt };
-    }
-
-    if (!r.ok) {
-      return res.status(500).json({ error: data.error?.message || data.error || '转写失败' });
-    }
-
-    const text = data.text || data.result?.text || '';
-    return res.json({ enabled: true, text: String(text || '').trim() });
-  } catch (e) {
-    err(`/api/transcribe失败: ${e.message}`);
-    return res.status(500).json({ error: '转写异常' });
-  }
-});
-
 app.post('/api/send/:cid', async (req, res) => {
   const cid = req.params.cid;
   const { text = '' } = req.body || {};
@@ -619,9 +510,7 @@ app.get('/health', (req, res) => {
   res.json({ status: 'ok', wsConnected: isClawReady, channels: channelRuntime.size });
 });
 
-app.get('/', (req, res) => {
-  res.sendFile(path.join(__dirname, 'public', 'index.html'));
-});
+app.get('/', (req, res) => res.sendFile(path.join(__dirname, 'public', 'index.html')));
 
 // ============================================================
 // 4) OpenClaw WS + existing sync logic
@@ -663,19 +552,13 @@ const { publicKey, privateKey } = crypto.generateKeyPairSync('ed25519');
 const rawPublicKey = publicKey.export({ type: 'spki', format: 'der' }).subarray(12);
 const deviceId = crypto.createHash('sha256').update(rawPublicKey).digest('hex');
 const toB64Url = (buf) =>
-  buf
-    .toString('base64')
-    .replace(/\+/g, '-')
-    .replace(/\//g, '_')
-    .replace(/=+$/, '');
+  buf.toString('base64').replace(/\+/g, '-').replace(/\//g, '_').replace(/=+$/, '');
 
 function cleanupConnection() {
   if (pingInterval) clearInterval(pingInterval);
   if (ws) {
     ws.removeAllListeners();
-    try {
-      ws.terminate();
-    } catch {}
+    try { ws.terminate(); } catch {}
     ws = null;
   }
   isClawReady = false;
@@ -683,6 +566,10 @@ function cleanupConnection() {
 }
 
 function connectOpenClaw(retryCount = 0) {
+  if (!OPENCLAW_WS_URL) {
+    err('OPENCLAW_WS_URL 未配置，无法连接 OpenClaw');
+    return;
+  }
   if (isReconnecting || ws) return;
   isReconnecting = true;
   log(`🔌 连接 OpenClaw (${retryCount + 1})...`);
@@ -694,10 +581,7 @@ function connectOpenClaw(retryCount = 0) {
       log('✅ WS 握手成功');
       isReconnecting = false;
       ws.isAlive = true;
-
-      ws.on('pong', () => {
-        ws.isAlive = true;
-      });
+      ws.on('pong', () => { ws.isAlive = true; });
 
       pingInterval = setInterval(() => {
         if (ws.isAlive === false) {
@@ -731,51 +615,39 @@ function handleDisconnect(retryCount) {
 
 function handleClawMessage(data) {
   let msg;
-  try {
-    msg = JSON.parse(data.toString());
-  } catch {
-    return;
-  }
+  try { msg = JSON.parse(data.toString()); } catch { return; }
 
   if (msg.event === 'connect.challenge') {
     const { nonce } = msg.payload;
     const signedAt = Date.now();
     const payload = [
-      'v2',
-      deviceId,
-      'openclaw-control-ui',
-      'webchat',
-      'operator',
+      'v2', deviceId, 'openclaw-control-ui', 'webchat', 'operator',
       'operator.admin,operator.approvals,operator.pairing',
-      String(signedAt),
-      OPENCLAW_TOKEN || '',
-      nonce
+      String(signedAt), OPENCLAW_TOKEN || '', nonce
     ].join('|');
 
     const signature = crypto.sign(null, Buffer.from(payload), privateKey);
 
-    ws.send(
-      JSON.stringify({
-        type: 'req',
-        id: crypto.randomUUID(),
-        method: 'connect',
-        params: {
-          minProtocol: 3,
-          maxProtocol: 3,
-          client: { id: 'openclaw-control-ui', version: 'dev', platform: 'Win32', mode: 'webchat' },
-          device: {
-            id: deviceId,
-            publicKey: toB64Url(rawPublicKey),
-            signature: toB64Url(signature),
-            signedAt,
-            nonce
-          },
-          auth: { token: OPENCLAW_TOKEN },
-          role: 'operator',
-          scopes: ['operator.admin', 'operator.approvals', 'operator.pairing']
-        }
-      })
-    );
+    ws.send(JSON.stringify({
+      type: 'req',
+      id: crypto.randomUUID(),
+      method: 'connect',
+      params: {
+        minProtocol: 3,
+        maxProtocol: 3,
+        client: { id: 'openclaw-control-ui', version: 'dev', platform: 'Win32', mode: 'webchat' },
+        device: {
+          id: deviceId,
+          publicKey: toB64Url(rawPublicKey),
+          signature: toB64Url(signature),
+          signedAt,
+          nonce
+        },
+        auth: { token: OPENCLAW_TOKEN },
+        role: 'operator',
+        scopes: ['operator.admin', 'operator.approvals', 'operator.pairing']
+      }
+    }));
   }
 
   if (msg.payload?.type === 'hello-ok') {
@@ -787,22 +659,13 @@ function handleClawMessage(data) {
     const req = pendingRequests.get(msg.id);
     pendingRequests.delete(msg.id);
     if (req?.timer) clearTimeout(req.timer);
-    try {
-      req?.resolve?.(msg.payload);
-    } catch {}
+    try { req?.resolve?.(msg.payload); } catch {}
   }
 }
 
-async function fetchClawHistory(cid) {
+async function fetchClawHistory(cid, uid) { // uid 保留兼容旧调用
   try {
-    const payload = await clawRequest(
-      'chat.history',
-      {
-        sessionKey: `agent:main:${cid}`,
-        limit: 5
-      },
-      5000
-    );
+    const payload = await clawRequest('chat.history', { sessionKey: `agent:main:${cid}`, limit: 5 }, 5000);
     return payload?.messages || [];
   } catch {
     return [];
@@ -812,25 +675,22 @@ async function fetchClawHistory(cid) {
 function triggerAgent(cid, uid, name, text, isCommand) {
   if (!isClawReady || !ws || ws.readyState !== WebSocket.OPEN) return;
 
-  const finalMsg = isCommand ? text : `${text}`;
-  ws.send(
-    JSON.stringify({
-      type: 'req',
-      id: crypto.randomUUID(),
-      method: isCommand ? 'chat.send' : 'agent',
-      params: {
-        sessionKey: `agent:main:${cid}`,
-        message: finalMsg,
-        idempotencyKey: crypto.randomUUID(),
-        deliver: isCommand ? false : undefined
-      }
-    })
-  );
-
+  const finalMsg = isCommand ? text : `${name} 说: ${text}`;
+  ws.send(JSON.stringify({
+    type: 'req',
+    id: crypto.randomUUID(),
+    method: isCommand ? 'chat.send' : 'agent',
+    params: {
+      sessionKey: `agent:main:${cid}`,
+      message: finalMsg,
+      idempotencyKey: crypto.randomUUID(),
+      deliver: isCommand ? false : undefined
+    }
+  }));
   log(`🚀 [发送] ${name}: ${text.slice(0, 30)}...`);
 }
 
-// 你原同步逻辑（保留）
+// 你原同步逻辑（保留，未做大改动）
 async function syncChannel(cid) {
   const state = channelRuntime.get(cid);
   if (!state || !state.lastMsgId || !isClawReady) return;
@@ -849,31 +709,28 @@ async function syncChannel(cid) {
     const { data: msgs } = await webuiApi.get(`/api/v1/channels/${cid}/messages?skip=0&limit=10`);
     if (!msgs?.length) throw new Error('No messages');
 
-    const webuiFingerprints = new Set(msgs.map((m) => (m.content || m.data?.content || '').trim()).filter(Boolean));
+    const webuiFingerprints = new Set(msgs.map(m => (m.content || m.data?.content || '').trim()).filter(Boolean));
 
     const activeUsers = new Map();
-    msgs.slice(0, 5).forEach((m) => {
+    msgs.slice(0, 5).forEach(m => {
       if (m.user_id) activeUsers.set(m.user_id, { id: m.user_id, name: m.user?.name || 'User' });
     });
 
     for (const u of activeUsers.values()) {
-      await new Promise((r) => setTimeout(r, 200));
+      await new Promise(r => setTimeout(r, 200));
       const history = await fetchClawHistory(cid, u.id);
-      const replies = history.filter((h) => h.role === 'assistant').slice(-2);
+      const replies = history.filter(h => h.role === 'assistant').slice(-2);
+
       for (const r of replies) {
         const txt =
           typeof r.content === 'string'
             ? r.content.trim()
             : Array.isArray(r.content)
-            ? (r.content[0]?.text || '').trim()
-            : '';
+              ? (r.content[0]?.text || '').trim()
+              : '';
         if (txt && !webuiFingerprints.has(txt)) {
           log(`📥 [回填回复] -> ${u.name}`);
-          await webuiApi.post(`/api/v1/channels/${cid}/messages/post`, {
-            content: txt,
-            data: { files: [] },
-            reply_to_id: null
-          });
+          await webuiApi.post(`/api/v1/channels/${cid}/messages/post`, { content: txt, data: { files: [] }, reply_to_id: null });
           webuiFingerprints.add(txt);
         }
       }
@@ -881,13 +738,11 @@ async function syncChannel(cid) {
 
     const sorted = msgs.reverse();
     let newMsgs = [];
-    const startIdx = sorted.findIndex((m) => m.id === state.lastMsgId);
+    const startIdx = sorted.findIndex(m => m.id === state.lastMsgId);
 
-    if (state.lastMsgId === 'EMPTY_START') {
-      newMsgs = sorted;
-    } else if (startIdx !== -1) {
-      newMsgs = sorted.slice(startIdx + 1);
-    } else {
+    if (state.lastMsgId === 'EMPTY_START') newMsgs = sorted;
+    else if (startIdx !== -1) newMsgs = sorted.slice(startIdx + 1);
+    else {
       if (sorted.length > 0) {
         const newestId = sorted[sorted.length - 1].id;
         log(`⚠️ [${state.name}] 锚点丢失，重置 -> ${newestId}`);
@@ -925,9 +780,7 @@ async function syncChannel(cid) {
         if (rawFiles.length > 0) {
           for (const fItem of rawFiles) {
             try {
-              let buffer;
-              let filename;
-              let mimeType;
+              let buffer, filename, mimeType;
               const f = fItem.file || fItem;
 
               if (fItem.url && fItem.url.startsWith('data:')) {
@@ -959,9 +812,7 @@ async function syncChannel(cid) {
                   const isImage = mimeType?.startsWith('image/');
                   const isAudio = mimeType?.startsWith('audio/');
                   atts.push(
-                    `[${isImage ? '图片' : isAudio ? '语音' : '文件'}: ${filename}](${s3Url}${
-                      isAudio ? '#audio' : ''
-                    }) (必须下载附件，了解内容后才能回复)`
+                    `[${isImage ? '图片' : isAudio ? '语音' : '文件'}: ${filename}](${s3Url}${isAudio ? '#audio' : ''}) (必须下载附件，了解内容后才能回复)`
                   );
                 }
               }
@@ -976,7 +827,7 @@ async function syncChannel(cid) {
         const isCommand = txt.trim().startsWith('/');
         if (txt || atts.length > 0) {
           if (!txt && atts.length > 0) txt = '发送了附件。';
-          await new Promise((r) => setTimeout(r, 500));
+          await new Promise(r => setTimeout(r, 500));
           triggerAgent(cid, m.user_id, sender, txt, isCommand);
         }
       }
@@ -993,7 +844,7 @@ async function loop() {
   if (isClawReady) {
     for (const cid of channelRuntime.keys()) {
       await syncChannel(cid);
-      await new Promise((r) => setTimeout(r, 200));
+      await new Promise(r => setTimeout(r, 200));
     }
   }
   setTimeout(loop, delay);