feat: 完善 FSC Gateway Daemon，添加 CLI 接口（submit/query/status）和任务存储

Author: 2233admin

fsc/fsc-gateway-daemon.ts

@@ -7,17 +7,21 @@
  * - 分发任务到 Redis 队列
  * - 收集结果
  * - Session 管理
+ * - CLI 接口：submit/query/status
  */
 
 import { createClient } from 'redis';
 import winston from 'winston';
+import { randomUUID } from 'crypto';
 
 // ============ 配置 ============
 const REDIS_HOST = process.env.REDIS_HOST || '127.0.0.1';
 const REDIS_PORT = parseInt(process.env.REDIS_PORT || '6379');
 const TASK_QUEUE = 'fsc:task_queue';
 const RESULT_QUEUE = 'fsc:result_queue';
 const FAILED_QUEUE = 'fsc:failed_tasks';
+const TASK_STORE_PREFIX = 'fsc:task:';
+const RESULT_STORE_PREFIX = 'fsc:result:';
 
 // ============ Logger ============
 const logger = winston.createLogger({
@@ -72,9 +76,42 @@ interface TaskResult {
   timestamp: number;
 }
 
+// ============ 存储任务和结果 ============
+async function storeTask(task: Task) {
+  await redis.set(`${TASK_STORE_PREFIX}${task.id}`, JSON.stringify({
+    ...task,
+    createdAt: Date.now(),
+    status: 'queued'
+  }));
+}
+
+async function getTask(taskId: string): Promise<Task & { createdAt: number; status: string } | null> {
+  const data = await redis.get(`${TASK_STORE_PREFIX}${taskId}`);
+  return data ? JSON.parse(data) : null;
+}
+
+async function storeResult(result: TaskResult) {
+  await redis.set(`${RESULT_STORE_PREFIX}${result.taskId}`, JSON.stringify(result));
+  // 更新任务状态
+  const task = await getTask(result.taskId);
+  if (task) {
+    await redis.set(`${TASK_STORE_PREFIX}${result.taskId}`, JSON.stringify({
+      ...task,
+      status: result.status,
+      completedAt: result.timestamp
+    }));
+  }
+}
+
+async function getResult(taskId: string): Promise<TaskResult | null> {
+  const data = await redis.get(`${RESULT_STORE_PREFIX}${taskId}`);
+  return data ? JSON.parse(data) : null;
+}
+
 // ============ 提交任务 ============
 async function submitTask(task: Task): Promise<string> {
   logger.info(`[Gateway] Submitting task ${task.id}`);
+  await storeTask(task);
   await redis.rPush(TASK_QUEUE, JSON.stringify(task));
   return task.id;
 }
@@ -96,8 +133,8 @@ async function resultCollectorLoop() {
       const taskResult = JSON.parse(result.element) as TaskResult;
       logger.info(`[Gateway] Received result for task ${taskResult.taskId}: ${taskResult.status}`);
 
-      // TODO: 持久化结果、通知订阅者、更新 Session
-      // 暂时先打日志
+      // 存储结果
+      await storeResult(taskResult);
     } catch (error) {
       logger.error('Result collector error:', error);
       await new Promise(resolve => setTimeout(resolve, 1000));
@@ -107,6 +144,70 @@ async function resultCollectorLoop() {
   logger.info('Result collector exited');
 }
 
+// ============ CLI 接口 ============
+async function handleCli() {
+  const args = process.argv.slice(2);
+  
+  if (args.length === 0) {
+    // 启动 daemon 模式
+    await main();
+    return;
+  }
+
+  // CLI 命令模式
+  await redis.connect();
+
+  try {
+    if (args[0] === 'submit') {
+      // 提交任务：submit <image> <command...>
+      const image = args[1];
+      const commands = args.slice(2);
+      
+      if (!image || commands.length === 0) {
+        console.error('Usage: submit <image> <command...>');
+        process.exit(1);
+      }
+
+      const taskId = randomUUID();
+      const task: Task = { id: taskId, image, commands, timeoutSeconds: 300 };
+      await submitTask(task);
+      console.log(`Task submitted: ${taskId}`);
+      process.exit(0);
+
+    } else if (args[0] === 'query') {
+      // 查询任务：query <taskId>
+      const taskId = args[1];
+      if (!taskId) {
+        console.error('Usage: query <taskId>');
+        process.exit(1);
+      }
+
+      const task = await getTask(taskId);
+      const result = await getResult(taskId);
+      
+      console.log('Task:', task);
+      console.log('Result:', result);
+      process.exit(0);
+
+    } else if (args[0] === 'status') {
+      // 查看状态：status
+      const queueLen = await redis.lLen(TASK_QUEUE);
+      const resultLen = await redis.lLen(RESULT_QUEUE);
+      const failedLen = await redis.lLen(FAILED_QUEUE);
+
+      console.log(`Queue: ${queueLen} pending, ${resultLen} results, ${failedLen} failed`);
+      process.exit(0);
+
+    } else {
+      console.error('Unknown command:', args[0]);
+      console.error('Commands: submit | query | status');
+      process.exit(1);
+    }
+  } finally {
+    await redis.quit();
+  }
+}
+
 // ============ 健康检查 ============
 setInterval(async () => {
   try {
@@ -149,7 +250,5 @@ async function main() {
   });
 }
 
-main().catch((error) => {
-  logger.error('Fatal error:', error);
-  process.exit(1);
-});
+// ============ 入口 ============
+handleCli();