diff --git a/docs/styles.css b/docs/styles.css
index 06d0c34..7669b91 100644
--- a/docs/styles.css
+++ b/docs/styles.css
@@ -499,3 +499,42 @@ footer a:hover { color: var(--ink); }
.ga-pop { animation: none; opacity: 1; }
.uc-bus::after { animation: none; }
}
+
+/* ---- live board: departures, straight from the bus branch ---- */
+.board {
+ max-width: 760px;
+ margin: 0 auto;
+ background: var(--terminal);
+ border-radius: 14px;
+ padding: 18px 22px 10px;
+ font-family: var(--mono);
+}
+.board-head, .board-row {
+ display: grid;
+ grid-template-columns: 200px 1fr 130px;
+ gap: 14px;
+ padding: 8px 4px;
+ align-items: baseline;
+ min-width: 0;
+}
+.board-head {
+ color: #8494a8;
+ font-size: 0.7rem;
+ letter-spacing: 0.12em;
+ text-transform: uppercase;
+ border-bottom: 1px solid rgba(255, 255, 255, 0.12);
+}
+.board-row { border-bottom: 1px solid rgba(255, 255, 255, 0.06); font-size: 0.82rem; }
+.board-row:last-child { border-bottom: none; }
+.board-name { color: var(--line-git); font-weight: 700; display: flex; gap: 8px; align-items: center; min-width: 0; overflow: hidden; text-overflow: ellipsis; }
+.board-dot { width: 8px; height: 8px; border-radius: 50%; background: #3a4453; flex: none; }
+.board-dot.on { background: var(--terminal-out); box-shadow: 0 0 6px var(--terminal-out); }
+.board-status { color: var(--terminal-text); overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
+.board-status.idle { color: #8494a8; font-style: italic; }
+.board-seen { color: #8494a8; font-size: 0.76rem; text-align: right; }
+.board-foot { color: #8494a8; font-size: 0.78rem; font-family: var(--sans); padding: 12px 4px 8px; margin: 0; }
+.board-foot a { color: var(--line-git); }
+@media (max-width: 720px) {
+ .board-head, .board-row { grid-template-columns: 130px 1fr; }
+ .board-head span:last-child, .board-seen { display: none; }
+}
diff --git a/package.json b/package.json
index 5715342..93394f5 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "agentcomm",
- "version": "0.14.2",
+ "version": "0.14.3",
"description": "A tiny mailbox/message bus for AI agents that shell out to one CLI. Pluggable storage backends behind a single Backend interface.",
"type": "module",
"license": "MIT",
diff --git a/src/daemon.ts b/src/daemon.ts
index 9bcea90..7767a7b 100644
--- a/src/daemon.ts
+++ b/src/daemon.ts
@@ -57,16 +57,10 @@ export async function runDaemon(uri: string): Promise {
async function poll(): Promise {
// Snapshot the outbox BEFORE listing the store: a key is always in at
// least one of the two (spool until delivered, store afterwards) — the
- // other order can miss it mid-flush for a full poll cycle.
- const spooled: string[] = [];
- try {
- for (const f of (await fs.readdir(sockPath + '.spool')).filter((x) => !x.startsWith('.'))) {
- const { key } = JSON.parse(await fs.readFile(path.join(sockPath + '.spool', f), 'utf8')) as {
- key: string;
- };
- spooled.push(key);
- }
- } catch { /* spool not created yet */ }
+ // other order can miss it mid-flush for a full poll cycle. The snapshot
+ // runs under the flush mutex (issue #79): reading a spool file while the
+ // flusher rm's it silently dropped the key for a cycle under load.
+ const spooled: string[] = await snapshotSpool();
const listed = await backend.list('');
const next = new Set([...listed, ...spooled]);
for (const k of listed) {
@@ -82,6 +76,26 @@ export async function runDaemon(uri: string): Promise {
keys = next;
}
+ async function snapshotSpool(): Promise {
+ const take = async (): Promise => {
+ const keys: string[] = [];
+ try {
+ for (const f of (await fs.readdir(sockPath + '.spool')).filter((x) => !x.startsWith('.'))) {
+ try {
+ const { key } = JSON.parse(
+ await fs.readFile(path.join(sockPath + '.spool', f), 'utf8'),
+ ) as { key: string };
+ keys.push(key);
+ } catch { /* entry mid-write */ }
+ }
+ } catch { /* spool not created yet */ }
+ return keys;
+ };
+ // before the socket dir exists (first poll) there is no spool nor mutex state
+ return typeof withSpoolRef === 'function' ? withSpoolRef(take) : take();
+ }
+ let withSpoolRef: ((fn: () => Promise) => Promise) | null = null;
+
await poll();
let lastActivity = Date.now();
@@ -249,6 +263,7 @@ export async function runDaemon(uri: string): Promise {
spoolChain = next.catch(() => {});
return next;
}
+ withSpoolRef = withSpool;
function flush(): Promise {
return withSpool(async () => {
const entries = (await fs.readdir(spoolDir)).filter((f) => !f.startsWith('.')).sort();
diff --git a/vitest.config.ts b/vitest.config.ts
index cf1c338..3600b4e 100644
--- a/vitest.config.ts
+++ b/vitest.config.ts
@@ -7,5 +7,6 @@ export default defineConfig({
// 5s default is margin-less on a loaded runner or laptop; unit tests
// don't care about the extra headroom.
testTimeout: 30000,
+ fileParallelism: false,
},
});