feat: activate Evolution Lab scheduled discovery

Author: binzi1989

CHANGELOG.md

@@ -2,6 +2,15 @@
 
 本项目遵循“先记录真实能力，再发布版本”的原则。未完成签名、公证和真实端到端基准的构建均标记为 Preview。
 
+## 1.0.2
+
+### Fixed
+
+- Evolution Lab 的“定时提出候选”不再只是保存开关；AgentOS 现会在应用空闲 10 分钟后执行首次本地扫描，之后每 6 小时最多扫描一次；
+- 自动发现从近 30 天任务快照中识别失败恢复或重复工作流信号，并对同一批信号去重；
+- 候选生成不调用模型、不预留 Token、不创建插件沙箱，也不会自动安装；准备、模型运行、验证和采纳仍需用户明确操作；
+- Evolution Lab 会显示最近扫描、下一次扫描窗口与本轮状态，并在后台发现候选时实时刷新。
+
 ## 0.9.0-preview.29
 
 ### Added

Nova.AgentOS.Bridge/Program.cs

@@ -114,6 +114,10 @@ internal sealed class AgentOsBridgeHost : IDisposable
     private readonly ConcurrentDictionary<string, byte> _agentRuns =
         new(StringComparer.OrdinalIgnoreCase);
     private readonly SemaphoreSlim _bootGate = new(1, 1);
+    private readonly CancellationTokenSource _lifetime = new();
+    private Task? _evolutionDiscoveryLoop;
+    private long _lastForegroundActivityUnixMs =
+        DateTimeOffset.Now.ToUnixTimeMilliseconds();
     private bool _booted;
 
     public AgentOsBridgeHost(Func<string, object, Task> publish)
@@ -125,7 +129,15 @@ public AgentOsBridgeHost(Func<string, object, Task> publish)
     }
 
     public async Task<object?> ExecuteAsync(string method, JsonObject parameters)
-        => method switch
+    {
+        if (IsForegroundActivity(method))
+        {
+            Interlocked.Exchange(
+                ref _lastForegroundActivityUnixMs,
+                DateTimeOffset.Now.ToUnixTimeMilliseconds());
+        }
+
+        return method switch
         {
             "boot" => await BootAsync(),
             "health" => await HealthAsync(),
@@ -165,6 +177,7 @@ public AgentOsBridgeHost(Func<string, object, Task> publish)
                 RequiredString(parameters, "id")),
             _ => throw new InvalidOperationException($"Unknown bridge method: {method}")
         };
+    }
 
     private async Task<object> BootAsync()
     {
@@ -187,6 +200,8 @@ await _kernel.ReportServiceAsync(
                     "Electron bridge lease layer active",
                     boot.BootId);
                 _booted = true;
+                _evolutionDiscoveryLoop = RunEvolutionDiscoveryLoopAsync(
+                    _lifetime.Token);
             }
         }
         finally
@@ -197,6 +212,68 @@ await _kernel.ReportServiceAsync(
         return ProjectKernel();
     }
 
+    private async Task RunEvolutionDiscoveryLoopAsync(
+        CancellationToken cancellationToken)
+    {
+        using var timer = new PeriodicTimer(TimeSpan.FromMinutes(1));
+        try
+        {
+            while (await timer.WaitForNextTickAsync(cancellationToken))
+            {
+                try
+                {
+                    if (_active.Count > 0 || _agentRuns.Count > 0)
+                    {
+                        continue;
+                    }
+
+                    var lastActivity = DateTimeOffset.FromUnixTimeMilliseconds(
+                        Interlocked.Read(ref _lastForegroundActivityUnixMs));
+                    if (DateTimeOffset.Now - lastActivity < TimeSpan.FromMinutes(10))
+                    {
+                        continue;
+                    }
+
+                    var discovery = await _evolutionLab.TryDiscoverCandidateAsync(
+                        _snapshots.LoadAll(),
+                        cancellationToken: cancellationToken);
+                    if (!discovery.Scanned)
+                    {
+                        continue;
+                    }
+
+                    await _publish("evolution_event", new
+                    {
+                        kind = discovery.Candidate is null ? "scan" : "candidate",
+                        candidateId = discovery.Candidate?.Id,
+                        objective = discovery.Candidate?.Objective,
+                        discovery.Snapshot.DiscoveryStatus,
+                        discovery.Snapshot.LastDiscoveryAt,
+                        discovery.Snapshot.NextDiscoveryAt
+                    });
+                }
+                catch (OperationCanceledException) when (
+                    cancellationToken.IsCancellationRequested)
+                {
+                    throw;
+                }
+                catch (Exception exception)
+                {
+                    await _publish("evolution_event", new
+                    {
+                        kind = "error",
+                        discoveryStatus = $"自动发现本轮失败，将在下个检查周期重试：{exception.Message}",
+                        lastDiscoveryAt = DateTimeOffset.Now
+                    });
+                }
+            }
+        }
+        catch (OperationCanceledException) when (cancellationToken.IsCancellationRequested)
+        {
+            // Normal bridge shutdown.
+        }
+    }
+
     private async Task<object> HealthAsync()
     {
         await BootAsync();
@@ -1198,11 +1275,29 @@ private static TaskState NormalizeRecoveredState(TaskState state)
             ? TaskState.Paused
             : state;
 
+    private static bool IsForegroundActivity(string method)
+        => method is
+            "start_task"
+            or "run_agent"
+            or "verify_result"
+            or "task_event"
+            or "complete_task"
+            or "propose_evolution"
+            or "prepare_evolution"
+            or "evaluate_evolution"
+            or "adopt_evolution"
+            or "reject_evolution"
+            or "configure_evolution_lab";
+
     private static string NormalizeRecoveredStage(TaskState state, string stage)
         => state is TaskState.Running or TaskState.Waiting or TaskState.BudgetExhausted
             ? "Previous host stopped; task is safely paused"
             : stage;
 
     public void Dispose()
-        => _supervisor.Dispose();
+    {
+        _lifetime.Cancel();
+        _supervisor.Dispose();
+        _lifetime.Dispose();
+    }
 }

NovaDesktop.Electron/electron/main.cjs

@@ -1109,6 +1109,9 @@ function createBridgeClient() {
     if (eventName === "agent_event" && mainWindow && !mainWindow.isDestroyed()) {
       mainWindow.webContents.send("nova:agent-event", payload);
     }
+    if (eventName === "evolution_event" && mainWindow && !mainWindow.isDestroyed()) {
+      mainWindow.webContents.send("nova:evolution-event", payload);
+    }
   };
   return client;
 }

NovaDesktop.Electron/electron/preload.cjs

@@ -50,7 +50,12 @@ contextBridge.exposeInMainWorld("nova", {
     prepareEvolution: (request) => invoke("nova:prepare-evolution", request),
     evaluateEvolution: (request) => invoke("nova:evaluate-evolution", request),
     adoptEvolution: (request) => invoke("nova:adopt-evolution", request),
-    rejectEvolution: (request) => invoke("nova:reject-evolution", request)
+    rejectEvolution: (request) => invoke("nova:reject-evolution", request),
+    onEvolutionEvent: (listener) => {
+      const handler = (_event, payload) => listener(payload);
+      ipcRenderer.on("nova:evolution-event", handler);
+      return () => ipcRenderer.removeListener("nova:evolution-event", handler);
+    }
   },
   window: {
     minimize: () => invoke("nova:window-minimize"),

NovaDesktop.Electron/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "nova-agentos-electron",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "private": true,
   "author": "NOVA AgentOS Project",
   "description": "NOVA AgentOS next-generation desktop shell",

NovaDesktop.Electron/package.json

@@ -40,6 +40,7 @@ import type {
   BootInfo,
   CapabilityState,
   DesktopSnapshot,
+  EvolutionDiscoveryEvent,
   EvolutionLabState,
   LivingMemoryState,
   ExecutionMode,
@@ -100,6 +101,23 @@ function now() {
   });
 }
 
+function formatLocalDateTime(value?: string | null) {
+  if (!value) return "尚未安排";
+  return new Date(value).toLocaleString("zh-CN", {
+    month: "2-digit",
+    day: "2-digit",
+    hour: "2-digit",
+    minute: "2-digit"
+  });
+}
+
+function formatDiscoveryWindow(value?: string | null) {
+  if (!value) return "等待首次扫描";
+  return new Date(value).getTime() <= Date.now()
+    ? "已到扫描窗口，等待应用空闲"
+    : `下次窗口 ${formatLocalDateTime(value)}`;
+}
+
 function readableRunError(error: unknown) {
   const raw = error instanceof Error ? error.message : "任务执行失败";
   return raw
@@ -610,6 +628,24 @@ function App() {
     };
   }, []);
 
+  useEffect(() => {
+    const unsubscribe = window.nova.growth.onEvolutionEvent(
+      async (event: EvolutionDiscoveryEvent) => {
+        try {
+          setEvolutionLab(await window.nova.growth.getEvolutionLab());
+        } catch {
+          // The persisted state will be loaded the next time the growth hub opens.
+        }
+        if (event.kind === "candidate") {
+          setNotice("Evolution Lab 已生成一个本地改进候选，等待你的审阅");
+        } else if (event.kind === "error") {
+          setNotice(event.discoveryStatus);
+        }
+      }
+    );
+    return unsubscribe;
+  }, []);
+
   useEffect(() => {
     if (!running) {
       setRuntimePulse("等待下一项任务");
@@ -1823,6 +1859,22 @@ function App() {
                       </form>
                     )}
 
+                    {evolutionLab && (
+                      <div className="evolution-discovery-status">
+                        <div>
+                          <strong>{evolutionLab.discoveryStatus}</strong>
+                          <small>
+                            最近扫描 {formatLocalDateTime(evolutionLab.lastDiscoveryAt)}
+                          </small>
+                        </div>
+                        <span>
+                          {evolutionLab.policy.scheduledDiscoveryEnabled
+                            ? formatDiscoveryWindow(evolutionLab.nextDiscoveryAt)
+                            : "自动发现未启用"}
+                        </span>
+                      </div>
+                    )}
+
                     <form
                       className="evolution-proposal"
                       onSubmit={async (event) => {

NovaDesktop.Electron/src/App.tsx

@@ -2222,6 +2222,41 @@ select:focus-visible {
   cursor: pointer;
 }
 
+.evolution-discovery-status {
+  display: flex;
+  align-items: center;
+  justify-content: space-between;
+  gap: 12px;
+  margin: -2px 0 12px;
+  padding: 9px 11px;
+  border-left: 2px solid #7f9270;
+  background: #171a15;
+}
+
+.evolution-discovery-status > div {
+  display: grid;
+  gap: 3px;
+  min-width: 0;
+}
+
+.evolution-discovery-status strong {
+  overflow: hidden;
+  color: #cbd3c2;
+  font-size: 9px;
+  text-overflow: ellipsis;
+  white-space: nowrap;
+}
+
+.evolution-discovery-status small,
+.evolution-discovery-status > span {
+  color: #7e8876;
+  font-size: 8px;
+}
+
+.evolution-discovery-status > span {
+  flex: 0 0 auto;
+}
+
 .evolution-proposal {
   display: grid;
   grid-template-columns: minmax(0, 1fr) auto;

NovaDesktop.Electron/src/styles.css

@@ -204,6 +204,19 @@ export interface EvolutionLabState {
   usedTokensThisMonth: number;
   remainingTokensThisMonth: number;
   usageMonth: string;
+  lastDiscoveryAt?: string | null;
+  nextDiscoveryAt?: string | null;
+  discoveryStatus: string;
+  lastDiscoveryCandidateId?: string | null;
+}
+
+export interface EvolutionDiscoveryEvent {
+  kind: "scan" | "candidate" | "error";
+  candidateId?: string | null;
+  objective?: string | null;
+  discoveryStatus: string;
+  lastDiscoveryAt?: string | null;
+  nextDiscoveryAt?: string | null;
 }
 
 export interface DesktopSnapshot {
@@ -324,6 +337,7 @@ export interface NovaApi {
     evaluateEvolution(request: { id: string }): Promise<EvolutionLabState>;
     adoptEvolution(request: { id: string }): Promise<EvolutionLabState>;
     rejectEvolution(request: { id: string }): Promise<EvolutionLabState>;
+    onEvolutionEvent(listener: (event: EvolutionDiscoveryEvent) => void): () => void;
   };
   window: {
     minimize(): Promise<void>;