| Service | Port | Status |
|---|---|---|
| OpenClaw Gateway | ${OPENCLAW_PORT} | ${ocOk?'✅ Running':'❌ Not responding'} |
| CC-Switch-Web | ${CCSWITCH_PORT} | ${csOk?'✅ Running':'❌ Not responding'} |
| Router | ${LISTEN_PORT} | ✅ Running |
${sessionHtml}
${JSON.stringify(status, null, 2)}
${logTail.replace(/
Full log (raw) | Status (JSON) | Config (JSON, passwords hidden) | Sessions on disk | State dir info
`);
return;
}
// === Backup trigger endpoint (手动触发备份) ===
if (req.url.startsWith('/api/backup')) {
const url = new URL(req.url, `http://${req.headers.host}`);
const token = url.searchParams.get('token') || '';
const mode = url.searchParams.get('mode') === 'incremental' ? 'incremental' : 'full';
// 验证 token: 读取 gateway 密码文件
const pwPath = path.join(STATE_DIR, 'logs', 'gateway_password.txt');
let authorized = false;
try {
const expected = fs.readFileSync(pwPath, 'utf-8').trim();
authorized = (token === expected);
} catch {}
if (!authorized) {
res.writeHead(401, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({ error: 'Unauthorized. Use: /api/backup?token=GATEWAY_PASSWORD[&mode=incremental]' }));
return;
}
// 异步执行备份，输出流式返回
res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
res.write(`[Backup] Starting ${mode} backup...\n`);
const { exec } = require('child_process');
const child = exec(`python3 ./backup-manager.py ${mode}`, { timeout: 300000 });
child.stdout.on('data', (data) => res.write(data));
child.stderr.on('data', (data) => res.write(data));
child.on('close', (code) => {
res.write(`[Backup] ${mode} backup exited with code ${code}\n`);
res.end();
});
return;
}
let targetPort, targetPath;
if (req.url.startsWith('/ccswitch')) {
targetPort = CCSWITCH_PORT;
targetPath = req.url.replace(/^\/ccswitch/, '') || '/';
} else if (/^\/api\/(settings|system\/|providers\/|config\/)/.test(req.url)) {
// CCSwitch web API endpoints - route to CC-Switch
targetPort = CCSWITCH_PORT;
targetPath = req.url;
} else {
targetPort = OPENCLAW_PORT;
targetPath = req.url;
}
console.log(`[Router] HTTP ${req.method} ${req.url} -> port ${targetPort}`);
// Collect request body
const chunks = [];
req.on('data', chunk => chunks.push(chunk));
req.on('end', () => {
const body = Buffer.concat(chunks);
// 过滤代理头，避免 OpenClaw 不信任连接
const cleanHeaders = { ...req.headers };
delete cleanHeaders['x-forwarded-for'];
delete cleanHeaders['x-forwarded-proto'];
delete cleanHeaders['x-forwarded-host'];
delete cleanHeaders['x-real-ip'];
delete cleanHeaders['forwarded'];
cleanHeaders.host = `127.0.0.1:${targetPort}`;
const options = {
hostname: '127.0.0.1',
port: targetPort,
path: targetPath,
method: req.method,
headers: cleanHeaders
};
const proxyReq = http.request(options, (proxyRes) => {
res.writeHead(proxyRes.statusCode, proxyRes.headers);
proxyRes.pipe(res);
});
proxyReq.on('error', (err) => {
console.error(`[Router] Error proxying to port ${targetPort}: ${err.message}`);
if (!res.headersSent) {
res.writeHead(502, { 'Content-Type': 'application/json' });
res.end(JSON.stringify({ error: `Service on port ${targetPort} unavailable: ${err.message}` }));
}
});
if (body.length > 0) proxyReq.write(body);
proxyReq.end();
});
});
// 处理 WebSocket 升级
server.on('upgrade', (req, socket, head) => {
let targetPort;
if (req.url.startsWith('/ccswitch')) {
targetPort = CCSWITCH_PORT;
} else {
targetPort = OPENCLAW_PORT;
}
console.log(`[Router] WebSocket upgrade: ${req.url} -> port ${targetPort}`);
console.log(`[Router] WebSocket headers:`, JSON.stringify(req.headers));
// 创建到目标服务器的连接
const proxySocket = new net.Socket();
proxySocket.connect(targetPort, '127.0.0.1', () => {
console.log(`[Router] Connected to port ${targetPort}`);
// 构建升级请求
let upgradeReq = `GET ${req.url} HTTP/1.1\r\n`;
upgradeReq += `Host: 127.0.0.1:${targetPort}\r\n`;
upgradeReq += `Upgrade: ${req.headers.upgrade || 'websocket'}\r\n`;
upgradeReq += `Connection: Upgrade\r\n`;
// 复制其他重要的请求头（排除代理头，避免 OpenClaw 不信任连接）
const skipHeaders = ['host', 'upgrade', 'connection', 'x-forwarded-for', 'x-forwarded-proto', 'x-forwarded-host', 'x-real-ip', 'forwarded'];
for (const [key, value] of Object.entries(req.headers)) {
if (!skipHeaders.includes(key.toLowerCase())) {
upgradeReq += `${key}: ${value}\r\n`;
}
}
upgradeReq += '\r\n';
console.log(`[Router] Sending upgrade request to port ${targetPort}`);
proxySocket.write(upgradeReq);
proxySocket.write(head);
// 双向管道
socket.pipe(proxySocket);
proxySocket.pipe(socket);
console.log(`[Router] WebSocket piped: client <-> port ${targetPort}`);
});
proxySocket.on('error', (err) => {
console.error(`[Router] WebSocket proxy error to port ${targetPort}: ${err.message}`);
socket.end();
});
proxySocket.on('close', () => {
console.log(`[Router] WebSocket connection to port ${targetPort} closed`);
});
socket.on('error', (err) => {
console.error(`[Router] Client socket error: ${err.message}`);
proxySocket.end();
});
socket.on('close', () => {
console.log(`[Router] Client WebSocket connection closed`);
proxySocket.end();
});
});
server.listen(LISTEN_PORT, '0.0.0.0', () => {
console.log(`[Router] Listening on port ${LISTEN_PORT}`);
console.log(`[Router] /ccswitch/* -> port ${CCSWITCH_PORT}`);
console.log(`[Router] /* -> port ${OPENCLAW_PORT}`);
console.log(`[Router] WebSocket support enabled`);
});