235 lines
8.0 KiB
JavaScript
235 lines
8.0 KiB
JavaScript
/**
|
||
* ═══════════════════════════════════════════════════════════
|
||
* 🔌 Channel Switcher · 母编号 × 子编号 切换器 (Phase 1 最小版本)
|
||
* ═══════════════════════════════════════════════════════════
|
||
*
|
||
* 角色:
|
||
* 一台服务器 (母编号 ZY-SVR-XXX) 上常驻的唯一切换 Agent.
|
||
* Phase 1 仅支持只读: list / current. 不实施真实切换 (避免误动生产).
|
||
* Phase 2 增加 activate (移软链 + reload PM2 + reload Nginx).
|
||
*
|
||
* 守护: 铸渊 · ICE-GL-ZY001
|
||
* 主权: TCS-0002∞ | SYS-GLW-0001
|
||
* 版权: 国作登字-2026-A-00037559
|
||
*
|
||
* 监听:
|
||
* 仅 127.0.0.1:39000 (CHANNEL_SWITCHER_BIND / CHANNEL_SWITCHER_PORT 可覆盖)
|
||
* 由 Nginx 反向代理到 /__switch (各域名共享同一切换器)
|
||
*
|
||
* 数据源:
|
||
* FUNCTION_MANIFEST_PATH (默认 /opt/guanghu/_manifest/function-manifest.json)
|
||
* 该文件由部署 workflow 从仓库 .github/brain/architecture/ 同步而来,
|
||
* 不直接读仓库 — 服务器零 git 依赖.
|
||
*
|
||
* 路由:
|
||
* GET /__switch/health 健康
|
||
* GET /__switch/current 当前服务器激活的 ZY-FN 列表
|
||
* GET /__switch/list 本服务器上所有已登记的 ZY-FN
|
||
* GET /__switch/manifest 返回精简后的 manifest (供前端徽章)
|
||
* POST /__switch/activate Phase 2 实现, 当前返回 501
|
||
*
|
||
* SYSLOG 回执: 每次有意义的查询写一行到 stdout, 由 PM2 收集后由
|
||
* .github/workflows/bridge-syslog-to-notion.yml 汇聚到 AG-ZY-README,
|
||
* 天眼涌现层自然感知.
|
||
*/
|
||
|
||
'use strict';
|
||
|
||
const http = require('http');
|
||
const fs = require('fs');
|
||
const url = require('url');
|
||
const os = require('os');
|
||
|
||
const PORT = parseInt(process.env.CHANNEL_SWITCHER_PORT || '39000', 10);
|
||
const BIND = process.env.CHANNEL_SWITCHER_BIND || '127.0.0.1';
|
||
const SERVER_ID = process.env.CHANNEL_SWITCHER_SERVER_ID || 'ZY-SVR-UNKNOWN';
|
||
const MANIFEST_PATH =
|
||
process.env.FUNCTION_MANIFEST_PATH ||
|
||
'/opt/guanghu/_manifest/function-manifest.json';
|
||
|
||
let manifestCache = null;
|
||
let manifestMtime = 0;
|
||
|
||
function loadManifest() {
|
||
try {
|
||
const stat = fs.statSync(MANIFEST_PATH);
|
||
if (manifestCache && stat.mtimeMs === manifestMtime) {
|
||
return manifestCache;
|
||
}
|
||
const raw = fs.readFileSync(MANIFEST_PATH, 'utf8');
|
||
const parsed = JSON.parse(raw);
|
||
manifestCache = parsed;
|
||
manifestMtime = stat.mtimeMs;
|
||
return parsed;
|
||
} catch (err) {
|
||
return { _error: err.message };
|
||
}
|
||
}
|
||
|
||
function jsonResponse(res, status, body) {
|
||
res.writeHead(status, {
|
||
'Content-Type': 'application/json; charset=utf-8',
|
||
'Cache-Control': 'no-store'
|
||
});
|
||
res.end(JSON.stringify(body, null, 2));
|
||
}
|
||
|
||
function logSyslog(event, payload) {
|
||
const line = JSON.stringify({
|
||
ts: new Date().toISOString(),
|
||
source: 'channel-switcher',
|
||
server_id: SERVER_ID,
|
||
host: os.hostname(),
|
||
event,
|
||
payload: payload || {}
|
||
});
|
||
process.stdout.write(line + '\n');
|
||
}
|
||
|
||
function serverFunctionsFromManifest(manifest) {
|
||
if (!manifest || !Array.isArray(manifest.functions)) return [];
|
||
return manifest.functions.filter((fn) => fn.host_server === SERVER_ID);
|
||
}
|
||
|
||
function activeRoutesForServer(manifest) {
|
||
if (!manifest || !manifest.active_routes) return {};
|
||
const out = {};
|
||
for (const [domain, route] of Object.entries(manifest.active_routes)) {
|
||
if (!route || typeof route !== 'object') continue;
|
||
if (route.host_server === SERVER_ID) out[domain] = route;
|
||
}
|
||
return out;
|
||
}
|
||
|
||
function handleHealth(_req, res) {
|
||
jsonResponse(res, 200, {
|
||
ok: true,
|
||
service: 'channel-switcher',
|
||
server_id: SERVER_ID,
|
||
bind: BIND,
|
||
port: PORT,
|
||
manifest_path: MANIFEST_PATH,
|
||
manifest_loaded: !!manifestCache,
|
||
phase: 1,
|
||
capabilities: ['list', 'current', 'manifest'],
|
||
activate_supported: false
|
||
});
|
||
}
|
||
|
||
function handleList(_req, res) {
|
||
const manifest = loadManifest();
|
||
if (manifest._error) return jsonResponse(res, 500, { error: true, message: manifest._error });
|
||
const fns = serverFunctionsFromManifest(manifest).map((fn) => ({
|
||
id: fn.id,
|
||
display_name_zh: fn.display_name_zh,
|
||
aliases: fn.aliases || [],
|
||
domain: fn.domain,
|
||
description: fn.description,
|
||
status: fn.status,
|
||
keep_decision: fn.keep_decision || 'evaluate'
|
||
}));
|
||
logSyslog('list', { count: fns.length });
|
||
jsonResponse(res, 200, { server_id: SERVER_ID, count: fns.length, functions: fns });
|
||
}
|
||
|
||
function handleCurrent(_req, res) {
|
||
const manifest = loadManifest();
|
||
if (manifest._error) return jsonResponse(res, 500, { error: true, message: manifest._error });
|
||
const routes = activeRoutesForServer(manifest);
|
||
const fns = serverFunctionsFromManifest(manifest);
|
||
const fnById = Object.fromEntries(fns.map((f) => [f.id, f]));
|
||
const enriched = {};
|
||
for (const [domain, route] of Object.entries(routes)) {
|
||
const fn = fnById[route.active_fn];
|
||
enriched[domain] = {
|
||
active_fn: route.active_fn,
|
||
display_name_zh: fn ? fn.display_name_zh : null,
|
||
since: route.since || null,
|
||
status: fn ? fn.status : 'unknown'
|
||
};
|
||
}
|
||
logSyslog('current', { domains: Object.keys(enriched) });
|
||
jsonResponse(res, 200, { server_id: SERVER_ID, active_routes: enriched });
|
||
}
|
||
|
||
function handleManifest(_req, res) {
|
||
const manifest = loadManifest();
|
||
if (manifest._error) return jsonResponse(res, 500, { error: true, message: manifest._error });
|
||
// 精简版: 仅本服务器 + 必要字段, 不暴露 secrets 别名映射的全貌
|
||
const fns = serverFunctionsFromManifest(manifest).map((fn) => ({
|
||
id: fn.id,
|
||
display_name_zh: fn.display_name_zh,
|
||
aliases: fn.aliases || [],
|
||
domain: fn.domain,
|
||
description: fn.description,
|
||
created_for: fn.created_for,
|
||
status: fn.status,
|
||
keep_decision: fn.keep_decision || 'evaluate'
|
||
}));
|
||
jsonResponse(res, 200, {
|
||
server_id: SERVER_ID,
|
||
version: manifest.version,
|
||
updated_at: manifest.updated_at,
|
||
functions: fns,
|
||
active_routes: activeRoutesForServer(manifest)
|
||
});
|
||
}
|
||
|
||
function handleActivate(_req, res) {
|
||
// Phase 1 不支持真实切换. 返回 501 但带上未来形状, 让前端可以提前对接.
|
||
logSyslog('activate.rejected', { reason: 'phase-1-readonly' });
|
||
jsonResponse(res, 501, {
|
||
error: true,
|
||
code: 'not_implemented_phase_1',
|
||
message: '切换器当前为只读模式 (Phase 1). Phase 2 将启用 activate.',
|
||
future_shape: {
|
||
method: 'POST',
|
||
path: '/__switch/activate',
|
||
body: { fn_id: 'ZY-FN-XXXX', token: '<语言层令牌>' }
|
||
}
|
||
});
|
||
}
|
||
|
||
const ROUTES = {
|
||
'/__switch/health': handleHealth,
|
||
'/__switch/list': handleList,
|
||
'/__switch/current': handleCurrent,
|
||
'/__switch/manifest': handleManifest,
|
||
'/__switch/activate': handleActivate
|
||
};
|
||
|
||
const server = http.createServer((req, res) => {
|
||
const parsed = url.parse(req.url || '/', true);
|
||
const pathname = (parsed.pathname || '/').replace(/\/+$/, '') || '/';
|
||
const handler = ROUTES[pathname];
|
||
if (!handler) {
|
||
return jsonResponse(res, 404, {
|
||
error: true,
|
||
code: 'not_found',
|
||
message: `未知路径 ${pathname}`,
|
||
available: Object.keys(ROUTES)
|
||
});
|
||
}
|
||
if (pathname === '/__switch/activate' && req.method !== 'POST') {
|
||
return jsonResponse(res, 405, { error: true, code: 'method_not_allowed' });
|
||
}
|
||
if (pathname !== '/__switch/activate' && req.method !== 'GET') {
|
||
return jsonResponse(res, 405, { error: true, code: 'method_not_allowed' });
|
||
}
|
||
try {
|
||
handler(req, res);
|
||
} catch (err) {
|
||
jsonResponse(res, 500, { error: true, message: err.message });
|
||
}
|
||
});
|
||
|
||
if (require.main === module) {
|
||
server.listen(PORT, BIND, () => {
|
||
logSyslog('bootstrap', { bind: BIND, port: PORT, server_id: SERVER_ID, manifest: MANIFEST_PATH });
|
||
// eslint-disable-next-line no-console
|
||
console.log(`[channel-switcher] ${SERVER_ID} listening on ${BIND}:${PORT} · manifest: ${MANIFEST_PATH}`);
|
||
});
|
||
}
|
||
|
||
module.exports = { server, loadManifest, serverFunctionsFromManifest, activeRoutesForServer };
|