Files
openclaw/src/shared/store-writer-queue.test.ts
Peter Steinberger 6df0fb818d feat: add session thread management (#98510)
* feat: add session thread management

Squash of codex/thread-management (025aefc3ad1) onto origin/main:
pin/archive/rename sessions via sessions.patch, archived-aware
sessions.list, lifecycle fencing, read-only archived chat, SDK +
Swift protocol support, Control UI session management.

* refactor(ui): minimal session rows with hover-revealed management

Chat picker and sidebar recents share session-row primitives: single-line
rows, relative timestamps, rename/archive/pin revealed on hover or focus,
accent pin badge for pinned rows, and an active-run spinner in the trail
slot. Sidebar floats pinned sessions above recency via the shared
comparator and gains archive/pin actions through the unified sessions-view
patch fallback. Archive eligibility is one shared policy
(canArchiveSessionRow); the sidebar/picker active-run tooltip now uses the
real sessionsView.activeRun locale key.

* fix: align session admission with mailbox-era main

Integration fixes after rebasing onto current main: sessions_list mailbox
test expectations learn the archived/pinned row fields and archived:false
list param; gateway agent admission treats a session as deleted only when
both the requested and canonical alias sets miss it (legacy bare-main
stores and exec-approval followups read under different spellings); cron
persist tests keep a consistent store across claim-guarded persist calls;
the ACP abort hook test asserts abort propagation instead of signal
identity; drop dead lifecycle writes flagged by no-useless-assignment and
fix the promise-executor return in the codex compact test.

* fix(qa): align UI e2e and shard fixtures with redesigned session rows

Sidebar session rows are wrapper divs with an inner link now: update the
navigation browser tests and chat-flow Playwright selectors. Seed a real
per-test session store for the auto-fallback admission guard instead of
depending on leftover host files at /tmp/sessions.json. Teach the
test-projects routing fixture about the suites that newly import the
shared temp-dir helper. Document the Codex thread-format contract for
archivedAt/pinnedAt (flag derived from server-stamped timestamp, epoch ms
here vs Codex epoch seconds) at the type and in the session docs.

* test: route auto-fallback suite through temp-dir helper plans

The auto-fallback suite now imports the shared temp-dir helper for its
seeded session store, so the top-level helper routing fixture must list
it in the auto-reply plan.
2026-07-04 14:30:47 -04:00

43 lines
1.4 KiB
TypeScript

// Verifies queue ownership and reentrancy across separately loaded runtime chunks.
import { importFreshModule } from "openclaw/plugin-sdk/test-fixtures";
import { expect, it } from "vitest";
import type { StoreWriterQueue } from "./store-writer-queue.js";
it("shares reentrant writer context across duplicate module instances", async () => {
const first = await importFreshModule<typeof import("./store-writer-queue.js")>(
import.meta.url,
"./store-writer-queue.js?scope=store-writer-a",
);
const second = await importFreshModule<typeof import("./store-writer-queue.js")>(
import.meta.url,
"./store-writer-queue.js?scope=store-writer-b",
);
const queues = new Map<string, StoreWriterQueue>();
const order: string[] = [];
const result = await first.runQueuedStoreWrite({
queues,
storePath: "shared-store",
label: "outer",
fn: async () => {
order.push("outer:start");
const nested = await second.runQueuedStoreWrite({
queues,
storePath: "shared-store",
label: "inner",
reentrant: true,
fn: async () => {
order.push("inner");
return "nested-result";
},
});
order.push("outer:end");
return nested;
},
});
expect(result).toBe("nested-result");
expect(order).toEqual(["outer:start", "inner", "outer:end"]);
expect(queues.size).toBe(0);
});