vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-03-15 03:50:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Sessions: discover retired ACP stores under configured roots

Browse Source
This commit is contained in:
Gustavo Madeira Santana
2026-03-12 15:03:30 +00:00
parent 90c674de75
commit f544ffe0ea
1 changed files with 72 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/config/sessions/targets.test.ts
View File

@@ -382,4 +382,76 @@ describe("resolveAllAgentSessionStoreTargetsSync", () => {
});
});
});
it("discovers retired agent stores under a configured custom session root", async () => {
await withTempHome(async (home) => {
const customRoot = path.join(home, "custom-state");
const opsSessionsDir = path.join(customRoot, "agents", "ops", "sessions");
const retiredSessionsDir = path.join(customRoot, "agents", "retired", "sessions");
await fs.mkdir(opsSessionsDir, { recursive: true });
await fs.mkdir(retiredSessionsDir, { recursive: true });
await fs.writeFile(path.join(opsSessionsDir, "sessions.json"), "{}", "utf8");
await fs.writeFile(path.join(retiredSessionsDir, "sessions.json"), "{}", "utf8");
const cfg: OpenClawConfig = {
session: {
store: path.join(customRoot, "agents", "{agentId}", "sessions", "sessions.json"),
},
agents: {
list: [{ id: "ops", default: true }],
},
};
const targets = await resolveAllAgentSessionStoreTargets(cfg, { env: process.env });
expect(targets).toEqual(
expect.arrayContaining([
{
agentId: "ops",
storePath: path.join(opsSessionsDir, "sessions.json"),
},
{
agentId: "retired",
storePath: path.join(retiredSessionsDir, "sessions.json"),
},
]),
);
expect(
targets.filter((target) => target.storePath === path.join(opsSessionsDir, "sessions.json")),
).toHaveLength(1);
});
});
it("respects the caller env when resolving configured and discovered store roots", async () => {
await withTempHome(async (home) => {
const envStateDir = path.join(home, "env-state");
const mainSessionsDir = path.join(envStateDir, "agents", "main", "sessions");
const retiredSessionsDir = path.join(envStateDir, "agents", "retired", "sessions");
await fs.mkdir(mainSessionsDir, { recursive: true });
await fs.mkdir(retiredSessionsDir, { recursive: true });
await fs.writeFile(path.join(mainSessionsDir, "sessions.json"), "{}", "utf8");
await fs.writeFile(path.join(retiredSessionsDir, "sessions.json"), "{}", "utf8");
const env = {
...process.env,
OPENCLAW_STATE_DIR: envStateDir,
};
const cfg: OpenClawConfig = {};
const targets = await resolveAllAgentSessionStoreTargets(cfg, { env });
expect(targets).toEqual(
expect.arrayContaining([
{
agentId: "main",
storePath: path.join(mainSessionsDir, "sessions.json"),
},
{
agentId: "retired",
storePath: path.join(retiredSessionsDir, "sessions.json"),
},
]),
);
});
});
});