Update server.js

server.js

@@ -30,6 +30,7 @@ const {
   CONNECT_PASSWORD = '',
   FRONT_STREAM_INTERVAL = '1500',
   MAX_UPLOAD_MB = '30',
+  DEFAULT_MESSAGE_LIMIT = '120',
 
   STORAGE_EXTERNAL_ENDPOINT,
   STORAGE_PUBLIC_BUCKET,
@@ -39,10 +40,17 @@ const {
   STORAGE_S3_FORCE_PATH_STYLE
 } = process.env;
 
-const IS_DEBUG = String(DEBUG_LOGS).toLowerCase() !== 'false';
-const STREAM_INTERVAL = Math.max(parseInt(FRONT_STREAM_INTERVAL, 10) || 1500, 800);
-const UPLOAD_MAX_BYTES = (parseInt(MAX_UPLOAD_MB, 10) || 30) * 1024 * 1024;
+const runtimeConfig = {
+  botUsername: BOT_USERNAME,
+  debugLogs: String(DEBUG_LOGS).toLowerCase() !== 'false',
+  streamInterval: Math.max(parseInt(FRONT_STREAM_INTERVAL, 10) || 1500, 800),
+  defaultMessageLimit: Math.max(parseInt(DEFAULT_MESSAGE_LIMIT, 10) || 120, 20)
+};
 
+const uploadMaxMB = Math.max(parseInt(MAX_UPLOAD_MB, 10) || 30, 5);
+const uploadMaxBytes = uploadMaxMB * 1024 * 1024;
+
+// S3
 const s3 = new S3Client({
   region: STORAGE_REGION || 'us-east-1',
   endpoint: STORAGE_EXTERNAL_ENDPOINT,
@@ -56,9 +64,10 @@ const s3 = new S3Client({
 const S3_PREFIX_CONFIG = 'openclaw/channels.json';
 const S3_PREFIX_UPLOADS = 'openclaw/uploads/';
 
+// logs
 const logBuffer = [];
 function addLog(type, msg) {
-  if (type === 'info' && !IS_DEBUG) return;
+  if (type === 'info' && !runtimeConfig.debugLogs) return;
   const time = new Date().toLocaleTimeString('zh-CN', { hour12: false });
   const line = `[${time}] ${type === 'err' ? '❌ ' : ''}${msg}`;
   console[type === 'err' ? 'error' : 'log'](line);
@@ -185,11 +194,11 @@ async function cleanOldS3Files() {
 }
 
 // ============================================================
-// 2) HTTP API
+// 2) API
 // ============================================================
 
 const app = express();
-app.use(express.json({ limit: `${Math.max(parseInt(MAX_UPLOAD_MB, 10) || 30, 10)}mb` }));
+app.use(express.json({ limit: `${uploadMaxMB}mb` }));
 app.use(express.static(path.join(__dirname, 'public')));
 
 function passOK(req) {
@@ -204,16 +213,37 @@ function apiGuard(req, res, next) {
 }
 app.use('/api', apiGuard);
 
+// 给前端默认配置
 app.get('/api/config', (req, res) => {
   res.json({
-    botUsername: BOT_USERNAME,
-    debug: IS_DEBUG,
     needPassword: !!CONNECT_PASSWORD,
-    streamInterval: STREAM_INTERVAL,
-    maxUploadMB: parseInt(MAX_UPLOAD_MB, 10) || 30
+    maxUploadMB: uploadMaxMB,
+    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));
+  }
+  log(`⚙️ 运行设置更新: ${JSON.stringify(runtimeConfig)}`);
+  res.json({ success: true, runtimeConfig });
+});
+
 app.get('/api/channels', (req, res) => {
   res.json(Array.from(channelRuntime.values()).map(({ id, name }) => ({ id, name })));
 });
@@ -231,7 +261,7 @@ app.get('/api/logs', (req, res) => res.json(logBuffer));
 app.get('/api/messages/:cid', async (req, res) => {
   const cid = req.params.cid;
   try {
-    const limit = parseInt(req.query.limit, 10) || 120;
+    const limit = Math.max(parseInt(req.query.limit, 10) || runtimeConfig.defaultMessageLimit, 20);
     const { data } = await webuiApi.get(`/api/v1/channels/${cid}/messages?limit=${limit}`);
     res.json(Array.isArray(data) ? data : []);
   } catch (e) {
@@ -240,11 +270,11 @@ app.get('/api/messages/:cid', async (req, res) => {
   }
 });
 
-// SSE 增量消息
+// SSE
 app.get('/api/messages/:cid/stream', async (req, res) => {
   const cid = req.params.cid;
-  const limit = parseInt(req.query.limit, 10) || 120;
-  const interval = Math.max(parseInt(req.query.interval, 10) || STREAM_INTERVAL, 800);
+  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');
 
@@ -271,7 +301,7 @@ app.get('/api/messages/:cid/stream', async (req, res) => {
     try {
       const { data } = await webuiApi.get(`/api/v1/channels/${cid}/messages?limit=${limit}`);
       const list = Array.isArray(data) ? data : [];
-      const sorted = [...list].reverse(); // old -> new
+      const sorted = [...list].reverse();
 
       if (!lastSeen) {
         if (sorted.length > 0) lastSeen = sorted[sorted.length - 1].id;
@@ -308,8 +338,8 @@ app.post('/api/upload', async (req, res) => {
 
   try {
     const buffer = Buffer.from(base64, 'base64');
-    if (buffer.length > UPLOAD_MAX_BYTES) {
-      return res.status(413).json({ error: `文件过大，超过 ${MAX_UPLOAD_MB}MB` });
+    if (buffer.length > uploadMaxBytes) {
+      return res.status(413).json({ error: `文件过大，超过 ${uploadMaxMB}MB` });
     }
 
     const url = await uploadToS3(filename, buffer, mimeType);
@@ -349,7 +379,7 @@ app.get('/', (req, res) => {
 });
 
 // ============================================================
-// 3) OpenClaw bridge logic (保留你的稳定逻辑)
+// 3) OpenClaw logic (你的逻辑保留)
 // ============================================================
 
 app.listen(PORT, async () => {
@@ -385,7 +415,6 @@ async function initChannelBaseline(id) {
   }
 }
 
-// WS connect
 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');
@@ -454,15 +483,9 @@ function handleClawMessage(data) {
     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);
@@ -474,19 +497,8 @@ function handleClawMessage(data) {
       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
-        },
+        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']
@@ -539,7 +551,6 @@ function fetchClawHistory(cid, uid) {
 function triggerAgent(cid, uid, name, text, isCommand) {
   if (!isClawReady) return;
   const finalMsg = isCommand ? text : `${name} 说: ${text}`;
-
   ws.send(JSON.stringify({
     type: 'req',
     id: crypto.randomUUID(),
@@ -551,13 +562,9 @@ function triggerAgent(cid, uid, name, text, isCommand) {
       deliver: isCommand ? false : undefined
     }
   }));
-  log(`🚀 [发送] ${name}: ${text.slice(0, 28)}...`);
+  log(`🚀 [发送] ${name}: ${text.slice(0, 30)}...`);
 }
 
-// ============================================================
-// 4) Sync loop (保留你的保护策略)
-// ============================================================
-
 async function syncChannel(cid) {
   const state = channelRuntime.get(cid);
   if (!state || !state.lastMsgId || !isClawReady) return;
@@ -576,7 +583,6 @@ 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)
     );
@@ -595,16 +601,13 @@ async function syncChannel(cid) {
         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
+            content: txt, data: { files: [] }, reply_to_id: null
           });
           webuiFingerprints.add(txt);
         }
       }
     }
 
-    // 新消息处理
     const sorted = msgs.reverse();
     let newMsgs = [];
     const startIdx = sorted.findIndex(m => m.id === state.lastMsgId);
@@ -616,7 +619,7 @@ async function syncChannel(cid) {
     } else {
       if (sorted.length > 0) {
         const newestId = sorted[sorted.length - 1].id;
-        log(`⚠️ [${state.name}] 锚点丢失，重置 -> ${newestId}（跳过历史）`);
+        log(`⚠️ [${state.name}] 锚点丢失，重置 -> ${newestId}`);
         state.lastMsgId = newestId;
       }
       newMsgs = [];