Extract config API routes

docs/engineering-refactor-roadmap.md

@@ -22,6 +22,7 @@ Config Mate 后续会持续承担现场安装包配置、服务编排、日志
 - `src/server/services/runtime.js` 统一处理服务状态查询和启动/停止/重启动作。
 - `src/server/routes/system.js` 统一处理健康检查、登录状态、登录/退出、版本、部署信息等系统路由。
 - `src/server/routes/services.js` 统一处理服务列表、服务配置、启停重启、清理计划和清理执行等服务路由。
+- `src/server/routes/config.js` 统一处理配置读取保存、历史版本、源码模式和运行时差异检查等配置路由。
 - `test/app-context.test.js` 覆盖现场目录识别规则。
 - `test/service-registry.test.js` 覆盖服务注册表 Cloud/Edge 过滤和路径解析。
 - `test/docker-compose.test.js` 覆盖 Docker Compose 探测和 fallback。
@@ -67,7 +68,8 @@ Config Mate 后续会持续承担现场安装包配置、服务编排、日志
 
 - 已完成系统路由拆分：健康检查、登录状态、登录/退出、版本、部署信息。
 - 已完成服务路由拆分：服务列表、服务配置、启动/停止/重启、清理计划和清理执行。
-- 下一步拆分配置路由：配置读取保存、历史版本、源码模式、运行时差异检查。
+- 已完成配置路由拆分：配置读取保存、历史版本、源码模式、运行时差异检查。
+- 下一步拆分安装路由：安装检查、compose 校验、初始化安装日志流。
 
 ### 第三阶段：配置读写层拆分
 

src/server/routes/config.js

@@ -0,0 +1,200 @@
+const { readRequestBody, writeJson } = require('../http');
+
+const DEFAULT_IGNORED_RUNTIME_PREFIXES = [
+    'PATH',
+    'JAVA_',
+    'LANG',
+    'LC_',
+    'HOME',
+    'LOG_DIR',
+    'LIB_DIR',
+    'CONFIG_PATH',
+    'APP_NAME',
+    'CONFIG_NAME',
+    'LOGGING_CONFIG',
+    'HOSTNAME',
+    'PWD',
+    'GPG_KEY'
+];
+
+function buildRuntimeEnvDiff(localEnvMap, runtimeEnvMap, ignoredPrefixes = DEFAULT_IGNORED_RUNTIME_PREFIXES) {
+    const diffs = [];
+    Object.keys(localEnvMap || {}).forEach(key => {
+        if (ignoredPrefixes.some(prefix => key.startsWith(prefix))) return;
+
+        const runtimeVal = runtimeEnvMap ? runtimeEnvMap[key] : undefined;
+        const localVal = localEnvMap[key];
+        if (runtimeVal !== localVal) {
+            diffs.push({
+                key,
+                runtimeVal: runtimeVal === undefined ? '(missing)' : runtimeVal,
+                localVal: localVal === undefined ? '(missing)' : localVal,
+                state: runtimeVal === undefined ? 'DELETED' : 'MODIFIED'
+            });
+        }
+    });
+
+    diffs.sort((a, b) => {
+        const score = state => state === 'MODIFIED' ? 0 : (state === 'NEW' ? 1 : 2);
+        return score(a.state) - score(b.state);
+    });
+    return diffs;
+}
+
+function parseRuntimeEnvFromInspect(stdout, logger = console) {
+    try {
+        const inspectData = JSON.parse(stdout || '[]');
+        const envList = inspectData?.[0]?.Config?.Env || [];
+        return envList.reduce((acc, envStr) => {
+            const parts = String(envStr).split('=');
+            const key = parts[0];
+            const val = parts.slice(1).join('=');
+            if (key) acc[key] = val;
+            return acc;
+        }, {});
+    } catch (e) {
+        logger.error?.('[Error] Failed to parse inspect output:', e);
+        return {};
+    }
+}
+
+function createConfigRoutes({
+    configMeta,
+    envStore,
+    parseEnvFile,
+    saveEnvFile,
+    dockerRuntime,
+    getServiceDefinition,
+    getPackageServiceId,
+    logger = console
+}) {
+    function handle(req, res, { method, pathname, headers }) {
+        if (pathname === '/api/config' && method === 'GET') {
+            writeJson(res, 200, {
+                meta: configMeta,
+                values: parseEnvFile()
+            }, headers);
+            return true;
+        }
+
+        if (pathname === '/api/save' && method === 'POST') {
+            readRequestBody(req).then(body => {
+                const newConfig = JSON.parse(body || '{}');
+                saveEnvFile(newConfig);
+                writeJson(res, 200, { status: 'ok' }, headers);
+            }).catch(e => writeJson(res, 500, { status: 'error', message: e.message }, headers));
+            return true;
+        }
+
+        if (pathname === '/api/history' && method === 'GET') {
+            writeJson(res, 200, { status: 'success', data: envStore.listHistory() }, headers);
+            return true;
+        }
+
+        if (pathname === '/api/history/restore' && method === 'POST') {
+            readRequestBody(req).then(body => {
+                const { filename } = JSON.parse(body || '{}');
+                const result = envStore.restoreHistory(filename);
+                if (!result.ok) {
+                    writeJson(res, result.statusCode || 500, { status: 'error', message: result.message }, headers);
+                    return;
+                }
+                writeJson(res, 200, { status: 'success', message: result.message }, headers);
+            }).catch(e => writeJson(res, 500, { status: 'error', message: e.message }, headers));
+            return true;
+        }
+
+        if (pathname === '/api/history/content' && method === 'POST') {
+            readRequestBody(req).then(body => {
+                const { filename } = JSON.parse(body || '{}');
+                const result = envStore.readHistoryContent(filename);
+                if (!result.ok) {
+                    writeJson(res, result.statusCode || 500, { status: 'error', message: result.message }, headers);
+                    return;
+                }
+                writeJson(res, 200, { status: 'success', content: result.content }, headers);
+            }).catch(e => writeJson(res, 500, { status: 'error', message: e.message }, headers));
+            return true;
+        }
+
+        if (pathname === '/api/env-raw' && method === 'GET') {
+            try {
+                res.writeHead(200, { ...headers, 'Content-Type': 'text/plain; charset=utf-8' });
+                res.end(envStore.readRaw());
+            } catch (e) {
+                writeJson(res, 500, { status: 'error', message: e.message }, headers);
+            }
+            return true;
+        }
+
+        if (pathname === '/api/save-raw' && method === 'POST') {
+            readRequestBody(req).then(body => {
+                envStore.saveRaw(body);
+                writeJson(res, 200, { status: 'ok' }, headers);
+            }).catch(e => writeJson(res, 500, { status: 'error', message: e.message }, headers));
+            return true;
+        }
+
+        if (pathname === '/api/diff-runtime' && method === 'GET') {
+            handleDiffRuntime(res, headers).catch(e => {
+                writeJson(res, 500, { status: 'error', message: 'Internal Server Error', details: e.message }, headers);
+            });
+            return true;
+        }
+
+        return false;
+    }
+
+    async function handleDiffRuntime(res, headers) {
+        if (!dockerRuntime.dockerComposeCmd) {
+            writeJson(res, 500, { status: 'error', message: 'Docker not available' }, headers);
+            return;
+        }
+
+        const def = getServiceDefinition(getPackageServiceId());
+        if (!def || !def.exists) {
+            writeJson(res, 200, { status: 'not_running', service: getPackageServiceId() }, headers);
+            return;
+        }
+
+        const ps = await dockerRuntime.exec(
+            dockerRuntime.dockerComposeCmd,
+            dockerRuntime.composeArgsFor(def, ['ps', '-q', def.composeService])
+        );
+        if (ps.error) {
+            writeJson(res, 500, { status: 'error', message: 'Failed to resolve container ID', details: ps.error.message }, headers);
+            return;
+        }
+
+        const containerId = ps.stdout.trim();
+        if (!containerId) {
+            writeJson(res, 200, { status: 'not_running', service: def.id }, headers);
+            return;
+        }
+
+        const inspect = await dockerRuntime.exec(dockerRuntime.dockerPath, ['inspect', containerId]);
+        if (inspect.error) {
+            writeJson(res, 500, { status: 'error', message: 'Failed to inspect container', details: inspect.error.message }, headers);
+            return;
+        }
+
+        const runtimeEnvMap = parseRuntimeEnvFromInspect(inspect.stdout, logger);
+        const localEnvMap = parseEnvFile();
+        writeJson(res, 200, {
+            status: 'success',
+            service: def.id,
+            containerId,
+            diffs: buildRuntimeEnvDiff(localEnvMap, runtimeEnvMap)
+        }, headers);
+    }
+
+    return {
+        handle
+    };
+}
+
+module.exports = {
+    buildRuntimeEnvDiff,
+    createConfigRoutes,
+    parseRuntimeEnvFromInspect
+};