[github-actions]

fxbing/workboard: 0.3.3 → 0.3.4

@fxbing, this update is ready for review. The published version stays unchanged until approval.

Artifact and validation details

Package: paseo-workboard.

{
  "previous": {
    "kind": "npm",
    "package": "paseo-workboard",
    "version": "0.3.3",
    "resolved": "https://registry.npmjs.org/paseo-workboard/-/paseo-workboard-0.3.3.tgz",
    "integrity": "sha512-SUkTIEuxt/GXsnVDtcE6D3x82bwi2udeZYi9sx7VysqZUy/n8Ar5llF6oU5awnnqbSbeChGsTDA7BmIQvsxyPA=="
  },
  "proposed": {
    "kind": "npm",
    "package": "paseo-workboard",
    "version": "0.3.4",
    "resolved": "https://registry.npmjs.org/paseo-workboard/-/paseo-workboard-0.3.4.tgz",
    "integrity": "sha512-shvB6v3+naL/ttjnPKvAPFcArxDY8rMQMjwPnModkO+0EqMwqOuPAUbLjais2KKprbO8Q3MefMLI0MyyBGEWHw=="
  }
}

Inline validation passed: tests and artifact checks. Run node scripts/validate.ts --online --changed on the completed listing before merging. The default GITHUB_TOKEN does not trigger the PR validation workflow.

Artifact diff

diff -ruN a/package/client/strings.ts b/package/client/strings.ts
--- a/package/client/strings.ts	1985-10-26 08:15:00.000000000 +0000
+++ b/package/client/strings.ts	1985-10-26 08:15:00.000000000 +0000
@@ -192,8 +192,7 @@
   archiveCandidateExact: "最后一次已验证对话：{date}",
   archiveCandidateScheduled:
     "记录的活动时间已到复核时间；最后一次对话时间尚未验证。",
-  archiveCandidateUpperBound:
-    "最后对话不晚于：{date}（以已记录活动时间保守计算）",
+  archiveCandidateUpperBound: "最后对话不晚于：{date}（保守上界）",
   enableAutoArchive: "保存自动归档设置",
   enableAutoArchiveConfirm:
     "按新设置有 {count} 个任务已到期（已废弃 {canceled} 个，已完成 {done} 个）。保存后会在安全检查通过时自动归档对应 workspace，可能停止 Agent 和 terminal，并移除托管 worktree。",
@@ -635,7 +634,7 @@
   archiveCandidateScheduled:
     "Recorded activity is due for recheck; the last conversation time has not been verified.",
   archiveCandidateUpperBound:
-    "Last conversation no later than: {date} (conservative recorded-activity bound)",
+    "Last conversation no later than: {date} (conservative upper bound)",
   enableAutoArchive: "Save automatic archive settings",
   enableAutoArchiveConfirm:
     "{count} task(s) are due under the new settings ({canceled} Canceled, {done} Done). Saving will archive their workspaces after safety checks, which may stop agents and terminals and remove managed worktrees.",
diff -ruN a/package/index.server.ts b/package/index.server.ts
--- a/package/index.server.ts	1985-10-26 08:15:00.000000000 +0000
+++ b/package/index.server.ts	1985-10-26 08:15:00.000000000 +0000
@@ -83,11 +83,17 @@
       if (disposed) return;
       const identity = await compat.identity();
       board?.dispose();
-      const host = new PaseoHost(api, compat, identity, (id) =>
-        board?.changed(id),
+      const host = new PaseoHost(api, compat, identity, (id, agentsChanged) =>
+        agentsChanged ? board?.agentsChanged(id) : board?.changed(id),
       );
       const clock = workboardClock();
-      board = new Workboard(host, store, clock.now, undefined, clock.offsetMs);
+      board = new Workboard(
+        host,
+        store,
+        clock.now,
+        undefined,
+        () => clock.offsetMs,
+      );
       await board.start();
     } catch (failure) {
       const classified = classifyBootFailure(failure);
diff -ruN a/package/package.json b/package/package.json
--- a/package/package.json	1985-10-26 08:15:00.000000000 +0000
+++ b/package/package.json	1985-10-26 08:15:00.000000000 +0000
@@ -1,6 +1,6 @@
 {
   "name": "paseo-workboard",
-  "version": "0.3.3",
+  "version": "0.3.4",
   "description": "Workspace tasks and draft ideas in a label-linked board or list for Paseo",
   "license": "MIT",
   "author": "fxbing",
diff -ruN a/package/server/host.ts b/package/server/host.ts
--- a/package/server/host.ts	1985-10-26 08:15:00.000000000 +0000
+++ b/package/server/host.ts	1985-10-26 08:15:00.000000000 +0000
@@ -65,20 +65,21 @@
   | "updatedAt"
   | "lastUserMessageAt"
   | "archivedAt"
-> & {
-  activity: Card["activity"];
-  parentAgentId?: string;
-  subagentId?: string;
-  /**
-   * Whether this parent's provider children could be listed in this inventory. `skipped`
-   * means the parent is idle and listing was left out on purpose: Paseo loads an agent before
-   * answering a per-agent request, so a refresh must not resume it. Unlike `unavailable`, it
-   * is never retried, and only the archive recheck lists such a parent.
-   */
-  childEnumeration?: "complete" | "refused" | "unavailable" | "skipped";
-  /** A provider child of an idle, unarchived parent; reading it would load that parent. */
-  parentIdle?: boolean;
-};
+> &
+  Partial<Pick<PaseoAgent, "status" | "lastError" | "attentionReason">> & {
+    activity: Card["activity"];
+    parentAgentId?: string;
+    subagentId?: string;
+    /**
+     * Whether this parent's provider children could be listed in this inventory. `skipped`
+     * means the parent is idle and listing was left out on purpose: Paseo loads an agent before
+     * answering a per-agent request, so a refresh must not resume it. Unlike `unavailable`, it
+     * is never retried, and only the archive recheck lists such a parent.
+     */
+    childEnumeration?: "complete" | "refused" | "unavailable" | "skipped";
+    /** A provider child of an idle, unarchived parent; reading it would load that parent. */
+    parentIdle?: boolean;
+  };
 /**
  * One agent's conversation evidence. Display and gate stay separate because Paseo records
  * neither a trustworthy exact time nor a single usable bound for every provider.
@@ -192,7 +193,7 @@
     private api: PaseoApi,
     private compat: PaseoCompat,
     readonly identity: Host["identity"],
-    private changed: (workspaceId?: string) => void,
+    private changed: (workspaceId?: string, agentsChanged?: boolean) => void,
   ) {}
   private own(subscription: Subscription): void {
     let initial = true;
@@ -201,14 +202,14 @@
         if (initial) initial = false;
         else {
           this.invalidateChildren();
-          this.changed();
+          this.changed(undefined, true);
         }
       },
       update: (message) => this.update(message),
       error: () => {
         this.invalidateChildren();
         this.subscriptionsFailed = true;
-        this.changed();
+        this.changed(undefined, true);
       },
     });
     this.subscriptions.push(() => subscription.release());
@@ -234,18 +235,22 @@
     } else if (message.type === "agent_update") {
       const change = message.payload;
       if (change.kind === "upsert") {
+        const previousWorkspace = this.agentWorkspaces.get(change.agent.id);
+        if (previousWorkspace && previousWorkspace !== change.agent.workspaceId)
+          this.changed(previousWorkspace, true);
+        this.agentWorkspaces.set(change.agent.id, change.agent.workspaceId);
         this.agentUpdates.set(change.agent.id, {
           ...change.agent,
           activity: activity(change.agent),
         });
-        this.changed(change.agent.workspaceId);
+        this.changed(change.agent.workspaceId, true);
       } else {
         this.invalidateChildren(change.agentId);
         this.childRecords.delete(change.agentId);
         this.agentUpdates.set(change.agentId, null);
         const workspaceId = this.agentWorkspaces.get(change.agentId);
         this.agentWorkspaces.delete(change.agentId);
-        this.changed(workspaceId);
+        this.changed(workspaceId, true);
       }
     } else if (message.type === "agent.provider_subagents.update") {
       const change = message.payload;
@@ -256,7 +261,7 @@
       // A child change does not have to touch the parent, so the cache cannot wait for
       // the parent's updatedAt to move.
       this.invalidateChildren(parentAgentId);
-      this.changed(this.agentWorkspaces.get(parentAgentId));
+      this.changed(this.agentWorkspaces.get(parentAgentId), true);
     }
   }
   async inventory(): Promise<Inventory> {
diff -ruN a/package/server/test-clock.ts b/package/server/test-clock.ts
--- a/package/server/test-clock.ts	1985-10-26 08:15:00.000000000 +0000
+++ b/package/server/test-clock.ts	1985-10-26 08:15:00.000000000 +0000
@@ -5,6 +5,8 @@
 /** Names the integration marker that `tests/integration/README.md` writes into a temporary home. */
 const MARKER_NAME = ".paseo-workboard-integration";
 const MARKER_VALUE = "paseo-workboard-integration-v1";
+export const CLOCK_FILE_ENV = "WORKBOARD_TEST_CLOCK_FILE";
+export const CLOCK_FILE_NAME = ".workboard-clock-offset-ms";
 export const CLOCK_OFFSET_ENV = "WORKBOARD_TEST_CLOCK_OFFSET_MS";
 
 /** The home must be a disposable one: inside the system temporary directory. */
@@ -53,6 +55,24 @@
   } catch {
     return realClock;
   }
-  const offsetMs = Number(raw);
-  return { now: () => real() + offsetMs, offsetMs };
+  let offsetMs = Number(raw);
+  const offset = () => {
+    if (env[CLOCK_FILE_ENV] === "1") {
+      try {
+        const value = readMarker(paths.join(home, CLOCK_FILE_NAME)).trim();
+        // Retain the last valid offset on partial writes, deletion or backward steps.
+        if (/^\d{1,13}$/.test(value))
+          offsetMs = Math.max(offsetMs, Number(value));
+      } catch {
+        /* An absent file keeps the last valid clock. */
+      }
+    }
+    return offsetMs;
+  };
+  return {
+    now: () => real() + offset(),
+    get offsetMs() {
+      return offset();
+    },
+  };
 }
diff -ruN a/package/server/workboard.ts b/package/server/workboard.ts
--- a/package/server/workboard.ts	1985-10-26 08:15:00.000000000 +0000
+++ b/package/server/workboard.ts	1985-10-26 08:15:00.000000000 +0000
@@ -107,6 +107,34 @@
   left.every((value, index) => value === right[index]);
 const hidden = (task: Task) =>
   task.archived?.status === "archived" || task.archived?.status === "external";
+/** Only a lastError-only idle Agent can be superseded by a newer user message. */
+function workspaceActivity(agents: readonly Agent[]): Card["activity"] {
+  const live = agents.filter((agent) => !agent.archivedAt);
+  const healthyTimes = live
+    .filter((agent) => agent.activity !== "error")
+    .map((agent) => Date.parse(agent.lastUserMessageAt ?? ""))
+    .filter(Number.isFinite);
+  const newestHealthy = healthyTimes.length ? Math.max(...healthyTimes) : null;
+  const activities = live
+    .filter((agent) => {
+      if (
+        agent.activity !== "error" ||
+        agent.status !== "idle" ||
+        !agent.lastError ||
+        agent.attentionReason === "error" ||
+        newestHealthy === null
+      )
+        return true;
+      const updated = Date.parse(agent.updatedAt);
+      return !Number.isFinite(updated) || updated >= newestHealthy;
+    })
+    .map((agent) => agent.activity);
+  return (
+    (["waiting", "error", "attention", "running"] as const).find((activity) =>
+      activities.includes(activity),
+    ) ?? "idle"
+  );
+}
 
 function projectChangeRequest(workspace?: Workspace): Card["changeRequest"] {
   const runtime = workspace?.githubRuntime;
@@ -156,6 +184,9 @@
    * nothing; it only schedules a recheck and never authorizes an archive.
    */
   private recheckHints = new Map<string, string>();
+  /** First trustworthy empty inventory in this process, never a task edit timestamp. */
+  private emptySince = new Map<string, string>();
+  private emptyRevision = 0;
   private archiveDeferrals = new Map<
     string,
     {
@@ -174,7 +205,7 @@
     private now: () => number = Date.now,
     private interval = 60000,
     /** Reported to clients so their due-date arithmetic uses this clock; 0 outside tests. */
-    private clockOffsetMs = 0,
+    private clockOffsetMs: number | (() => number) = 0,
   ) {}
   private serial<T>(run: () => Promise<T>): Promise<T> {
     const work = this.queue.then(() => {
@@ -264,7 +295,42 @@
     return `${this.epoch}:${this.workspaceEpochs.get(id) ?? 0}`;
   }
   agentChanged(id: string): void {
-    this.changed(this.inventory.agents.find((a) => a.id === id)?.workspaceId);
+    this.agentsChanged(
+      this.inventory.agents.find((a) => a.id === id)?.workspaceId,
+    );
+  }
+  agentsChanged(workspaceId?: string): void {
+    this.emptyRevision++;
+    if (workspaceId) this.emptySince.delete(workspaceId);
+    else this.emptySince.clear();
+    this.changed(workspaceId);
+  }
+  private async readInventory(): Promise<Inventory> {
+    const revision = this.emptyRevision;
+    try {
+      const inventory = await this.host.inventory();
+      const occupied = new Set(
+        inventory.agents.map((agent) => agent.workspaceId),
+      );
+      const active = new Set(
+        inventory.workspaces.map((workspace) => workspace.id),
+      );
+      for (const id of this.emptySince.keys())
+        if (occupied.has(id) || !active.has(id)) this.emptySince.delete(id);
+      // Events during the read can describe Agents absent from its final rows.
+      if (revision === this.emptyRevision)
+        for (const workspace of inventory.workspaces)
+          if (!occupied.has(workspace.id) && !this.emptySince.has(workspace.id))
+            this.emptySince.set(
+              workspace.id,
+              new Date(this.now()).toISOString(),
+            );
+      return inventory;
+    } catch (error) {
+      this.emptyRevision++;
+      this.emptySince.clear();
+      throw error;
+    }
   }
   changed(workspaceId?: string): void {
     if (workspaceId)
@@ -291,6 +357,8 @@
   disconnected(reason = "Paseo disconnected"): void {
     this.epoch++;
     this.connectionGeneration++;
+    this.emptyRevision++;
+    this.emptySince.clear();
     this.connected = false;
     this.error = reason;
   }
@@ -301,7 +369,10 @@
       connected: this.connected,
       error: this.error,
       refreshedAt: this.refreshedAt,
-      clockOffsetMs: this.clockOffsetMs,
+      clockOffsetMs:
+        typeof this.clockOffsetMs === "function"
+          ? this.clockOffsetMs()
+          : this.clockOffsetMs,
       settings: data.settings,
       cardOrderByStage: data.cardOrderByStage,
       projects: this.inventory.projects,
@@ -312,13 +383,7 @@
         const agents = this.inventory.agents.filter(
           (a) => a.workspaceId === task.workspaceId,
         );
-        const activities = agents
-          .filter((a) => !a.archivedAt)
-          .map((a) => a.activity);
-        const activity: Card["activity"] =
-          (["waiting", "error", "attention", "running"] as const).find((a) =>
-            activities.includes(a),
-          ) ?? "idle";
+        const activity = workspaceActivity(agents);
         const stage = task.workspaceId
           ? workspace
             ? resolveStage(
@@ -369,7 +434,7 @@
   }
   private async reconcile(scope?: ReadonlySet<string>): Promise<void> {
     const connection = this.connectionGeneration;
-    const inventory = await this.host.inventory();
+    const inventory = await this.readInventory();
     await this.syncPins(inventory, connection);
     if (this.archiveDeferrals.size) {
       let cleared: string[] = [];
@@ -388,9 +453,21 @@
         (task) => task.workspaceId === workspace.id,
       );
       if (scope && !scope.has(workspace.id) && previous) continue;
-      if (previous && this.archiveDeferred(previous, workspace, agents))
+      if (
+        previous &&
+        this.archiveDeferred(previous, workspace, agents) &&
+        !(
+          agents.length === 0 &&
+          this.emptySince.get(workspace.id) !== previous.conversationGateAt
+        )
+      )
         continue;
-      const evidence = await this.observe(agents, previous, this.now());
+      const evidence = await this.observe(
+        agents,
+        previous,
+        this.now(),
+        workspace.id,
+      );
       if (evidence.recheckAt)
         this.recheckHints.set(workspace.id, evidence.recheckAt);
       else this.recheckHints.delete(workspace.id);
@@ -505,7 +582,21 @@
               labels: statusLabels(workspace.labels, data.settings.groups),
             });
         }
-        const observation = observations.get(workspace.id);
+        let observation = observations.get(workspace.id);
+        if (
+          observation?.gate === "upper-bound" &&
+          !inventory.agents.some(
+            (agent) => agent.workspaceId === workspace.id,
+          ) &&
+          this.emptySince.get(workspace.id) !== observation.gateAt
+        )
+          observation = {
+            ...observation,
+            displayAt: null,
+            display: "unknown",
+            gateAt: null,
+            gate: "unknown",
+          };
         if (observation) {
           task.lastConversationAt = observation.displayAt;
           task.conversationDisplayEvidence = observation.display;
@@ -600,8 +691,34 @@
     agents: readonly Agent[],
     previous: Task | undefined,
     now: number,
+    workspaceId: string,
     options: { recheck?: boolean } = {},
   ): Promise<WorkspaceConversation> {
+    // A single displayed reason can hide another failure, including child enumeration.
+    const unresolvedReason =
+      agents.length === 0 &&
+      previous?.conversationReason &&
+      (previous.conversationGateEvidence === "unknown" ||
+        previous.conversationReason === "child-enumeration-unavailable")
+        ? previous.conversationReason
+        : null;
+    if (
+      agents.length === 0 &&
+      !previous?.conversationAgents.length &&
+      !unresolvedReason
+    ) {
+      const bound = this.emptySince.get(workspaceId);
+      if (bound)
+        return {
+          displayAt: bound,
+          display: "upper-bound",
+          gateAt: bound,
+          gate: "upper-bound",
+          reason: null,
+          agents: [],
+          recheckAt: null,
+        };
+    }
     const readings: Array<{
       agent: Agent;
       conversation: ConversationEvidence;
@@ -630,6 +747,10 @@
     let blocked = false;
     // Whether anything besides a deliberately skipped idle parent keeps the gate unknown.
     let hardBlocked = false;
+    if (unresolvedReason) {
+      blocked = true;
+      reasons.add(unresolvedReason);
+    }
     let skipped = false;
     const recordedById = new Map(
       (previous?.conversationAgents ?? []).map((entry) => [entry.id, entry]),
@@ -790,9 +911,15 @@
       // The recheck is the one place that loads an idle agent: it lists every idle parent's
       // children and reads the idle histories, and a failed or overtaken listing rejects.
       checked = await this.host.recheckAgents(agents);
-      const evidence = await this.observe(checked, candidate, this.now(), {
-        recheck: true,
-      });
+      const evidence = await this.observe(
+        checked,
+        candidate,
+        this.now(),
+        candidate.workspaceId!,
+        {
+          recheck: true,
+        },
+      );
       // Keep what was learned as display evidence, so a refresh does not make the same
       // candidate read the same history again. It never moves backwards and never gates.
       await this.store.update((data) => {
@@ -973,7 +1100,7 @@
     }
     if (removed.length) {
       const epoch = this.epoch;
-      const inventory = await this.host.inventory();
+      const inventory = await this.readInventory();
       if (epoch !== this.epoch || !this.connected)
         throw new Error("Workspaces changed; refresh before deleting a group");
       for (const group of removed) {
@@ -1725,7 +1852,7 @@
     const epochs = new Map(
       candidates.map((task) => [task.id, this.observation(task.workspaceId!)]),
     );
-    const inventory = await this.host.inventory();
+    const inventory = await this.readInventory();
     for (const candidate of candidates) {
       if (this.stopped || this.pendingMutations > 0) return;
       const id = candidate.workspaceId!;
@@ -1825,7 +1952,7 @@
       // Storage and safety checks can take time. Re-read membership, labels and Agent state before sending.
       let finalIssue: string | null = null;
       try {
-        const fresh = await this.host.inventory();
+        const fresh = await this.readInventory();
         const current = fresh.workspaces.find((w) => w.id === id);
         const currentAgents = fresh.agents.filter((a) => a.workspaceId === id);
         const fingerprint = (items: readonly Agent[]) => agentRows(items);
@@ -1865,7 +1992,7 @@
           throw new Error(
             result.error ?? "Native archive returned no timestamp",
           );
-        const active = await this.host.inventory();
+        const active = await this.readInventory();
         this.inventory = active;
         if (active.workspaces.some((w) => w.id === id))
           throw new Error(

[paseo-bot]

Workboard 0.3.4 is approved for publication, @fxbing. I refreshed the review timestamp and retained your English and Chinese pages and existing media. Nothing further is needed from you.

For the next release, explain the empty-workspace archive countdown in the overview: it starts from a complete empty inventory and resets after disconnection or an Agent change. This helps users understand postponed archive dates.

Review data

• Reviewed registry head: 0d9d93c3a45bc3d65d5aa165601769352e0b29db. Main REVIEW.md blob: 8da1286fd8870c87ff53767e8644858627b7371f.
• Independently downloaded and compared npm paseo-workboard 0.3.3 and 0.3.4, matched both records and npm version/tarball/SHA-512 metadata, and checked archive paths/types before extraction. Each contains 51 files. New artifact: https://registry.npmjs.org/paseo-workboard/-/paseo-workboard-0.3.4.tgz, integrity sha512-shvB6v3+naL/ttjnPKvAPFcArxDY8rMQMjwPnModkO+0EqMwqOuPAUbLjais2KKprbO8Q3MefMLI0MyyBGEWHw==. Existing submittedBy, package author and repository attribution agree. No npm provenance reported or source-match gate imposed. No linked registry submission issue found in this bump or its history.
• Inspected the full independent delta in client strings, index.server.ts, server/host.ts, server/test-clock.ts and server/workboard.ts, package/manifest metadata, both overviews and translation metadata, runtime imports, and the affected inventory, conversation verification and archive paths. No runtime dependencies or preparation commands; imports use host libraries and local files. Package scripts are author development/publication checks, with no installation lifecycle hooks; none were run.
• server/workboard.ts:308-333,700-724 records an in-process conservative bound only after successful complete inventory with no agents, no remembered children and no unresolved conversation reason. Agent events and disconnects clear that bound; inventory failures clear it, and events during an inventory prevent admitting a new bound. Persisted observations are rejected when the admitted empty bound changes. Unresolved child history/enumeration still keeps the archive gate unknown. The activity display ignores an idle lastError-only agent only when a healthy agent has a newer user message; explicit error attention is retained. Archive safety continues to inspect actual agents rather than that display summary.
• Automatic archive remains off by default, separately enabled for Done/Canceled, and limited to configured delays. server/workboard.ts:1814-2033 rechecks conversation/children and current inventory, rejects active agents/workspaces, checks terminals/scripts and Git safety, persists intent, then rechecks membership/labels/agent fingerprints/change epoch and safety before calling native archive. Native archive can remove managed worktrees, as both overviews disclose. No direct filesystem deletion is added.
• server/test-clock.ts:37-78 reads the optional offset file only after an explicit test offset, an absolute Paseo home physically under a temporary directory, and the exact integration marker; ordinary hosts retain the real clock. No new runtime download or external data destination. Existing host IPC uses the authenticated Paseo session; existing Git safety uses execFile argument arrays and checks the configured remote with ls-remote.
• The supplied English/Chinese pages and descriptions remain accurate; packaged visual media is unchanged and the board screenshot was visually inspected. Only registry edit is reviewedAt. Trusted current-main online validation passes for one changed artifact; the same unchanged registry scripts passed all 172 tests during this execution. Exact-head GitHub validation passes.
• Static artifact inspection only: no plugin or dependency installed, built, imported or executed, and no live archive/provider/UI test. Timing races and compatibility with every supported host were not exercised. The overview suggestion is optional next-release advice.