feat(worker): 实现基于进程的 Worker 调度与管理

[ckeyer]

• 新增 WorkerScheduler 接口替代原 WorkerRuntime
• 新增 WorkerEnvType 类型定义 (process/docker/kubevirt)
• 实现 ProcessScheduler 支持 Worker 进程启动/停止/健康检查
• Worker 启动时通过 WebSocket 从 Server 获取 DigitalAssistant 配置
• Server 新增 getConfig 消息处理，从数据库查询配置返回给 Worker
• DigitalAssistant Service 创建时自动启动对应的 Worker 进程
• 支持 --assistant-code 参数指定数字员工标识

架构流程:
用户创建 DigitalAssistant → 保存数据库 → 启动 Worker 进程 →
Worker 连接 Server 获取配置 → 初始化 Agent Runtime → 就绪

[ckeyer]

/oc

[ckeyer]

/oc

[opencode-agent]

This PR implements a process-based Worker scheduling and management system for SingerOS.

Key changes:

• Replaces WorkerRuntime with a new WorkerScheduler interface
• Adds WorkerEnvType enum supporting process/docker/kubevirt environments
• New ProcessScheduler handles worker process lifecycle (start/stop/health checks)
• Workers fetch DigitalAssistant config via WebSocket on startup
• Server adds getConfig message handler to query and return config from DB
• Creating a DigitalAssistant automatically triggers its Worker process
• Supports --assistant-code CLI parameter

Architecture flow: User creates DigitalAssistant → Saved to DB → Worker process started → Worker connects via WebSocket for config → Agent Runtime initialized → Ready

Scope: 9 files changed, +659/-289 lines. Two new files (scheduler.go, process_scheduler.go) and significant modifications to worker client, server, and digital assistant service.

One review from author (/oc command trigger).

opencode session  |  github run

[ckeyer]

/oc 检查一下变更是否有什么问题

[opencode-agent]

检查发现以下主要问题：

严重问题：

1. process_scheduler.go:214 - healthCheck 使用 os.Interrupt 信号检测进程存活是错误的，应改为：

   if err := process.Signal(syscall.Signal(0)); err != nil {
       return fmt.Errorf("process is not responding: %w", err)
   }

2. server.go:70-91 - handleWorkerWebSocket 可能永久阻塞等待 worker_register 消息，应添加超时或上下文取消检查

3. server.go:494 - createWorker 强制覆盖 spec.EnvType = worker.WorkerEnvProcess，会忽略客户端指定的环境类型

中等问题：

4. router.go:66 - ServerAddr 硬编码为 ":8080"，应从配置读取

5. server.go:271 - handleGetConfig 使用 context.Background() 而非请求上下文，应传递上下文

6. 竞态条件 - monitorProcess 和 Stop 都可能调用 removeInstance，存在重复删除风险

逻辑问题：

7. digital_assistant_service.go:77 - 只有状态为 Active 时才启动 Worker，但 CreateDigitalAssistant 默认状态为 Draft，新创建的 assistant 不会自动启动 Worker（PR 描述中的"自动启动"可能不准确）

opencode session  |  github run