@@ -116,17 +116,23 @@ describe("sweepCronRunSessions", () => {
|
116 | 116 | expect(result.pruned).toBe(2); |
117 | 117 | |
118 | 118 | const updated = JSON.parse(fs.readFileSync(storePath, "utf-8")); |
119 | | -expect(updated["agent:main:cron:job1"]).toMatchObject({ sessionId: "base-session" }); |
120 | | -expect(updated["agent:main:cron:job1:run:old-run"]).toBeUndefined(); |
121 | | -expect(updated["agent:main:cron:job1:run:old-run:subagent:worker"]).toBeUndefined(); |
122 | | -expect(updated["agent:main:cron:job1:run:recent-run"]).toMatchObject({ |
123 | | -sessionId: "recent-run", |
124 | | -}); |
125 | | -expect(updated["agent:main:cron:job1:run:recent-run:thread:reply"]).toMatchObject({ |
126 | | -sessionId: "recent-run-thread", |
127 | | -}); |
128 | | -expect(updated["agent:main:telegram:dm:123"]).toMatchObject({ |
129 | | -sessionId: "regular-session", |
| 119 | +expect(updated).toEqual({ |
| 120 | +"agent:main:cron:job1": { |
| 121 | +sessionId: "base-session", |
| 122 | +updatedAt: now, |
| 123 | +}, |
| 124 | +"agent:main:cron:job1:run:recent-run": { |
| 125 | +sessionId: "recent-run", |
| 126 | +updatedAt: now - 1 * 3_600_000, |
| 127 | +}, |
| 128 | +"agent:main:cron:job1:run:recent-run:thread:reply": { |
| 129 | +sessionId: "recent-run-thread", |
| 130 | +updatedAt: now - 1 * 3_600_000, |
| 131 | +}, |
| 132 | +"agent:main:telegram:dm:123": { |
| 133 | +sessionId: "regular-session", |
| 134 | +updatedAt: now - 100 * 3_600_000, |
| 135 | +}, |
130 | 136 | }); |
131 | 137 | }); |
132 | 138 | |
|
