Prune stale sessions more aggressively

sarahsturgeon · sarahsturgeon · commit 9d422b07ba41 · 2026-04-14T17:08:01.000-07:00
diff --git a/web/src/queue/manager.ts b/web/src/queue/manager.ts
@@ -49,6 +49,7 @@ export class SessionManager extends DurableObject<Env> {
           createdAt: value.createdAt ?? 0,
         });
       }
+      this.pruneStaleSessions();
 
       const now = Date.now();
       const expiredKeys: string[] = [];
@@ -165,6 +166,8 @@ export class SessionManager extends DurableObject<Env> {
       return new Response("Method not allowed", { status: 405 });
     }
 
+    this.pruneStaleSessions();
+
     const sessionType = (url.searchParams.get("type") || "public") as SessionType;
     if (!VALID_SESSION_TYPES.includes(sessionType)) {
       return Response.json({ error: "Invalid session type" }, { status: 400 });

Original file line number	Diff line number	Diff line change
`@@ -49,6 +49,7 @@ export class SessionManager extends DurableObject<Env> {`
`49`	`49`	`createdAt: value.createdAt ?? 0,`
`50`	`50`	`});`
`51`	`51`	`}`
	`52`	`+ this.pruneStaleSessions();`
`52`	`53`
`53`	`54`	`const now = Date.now();`
`54`	`55`	`const expiredKeys: string[] = [];`
`@@ -165,6 +166,8 @@ export class SessionManager extends DurableObject<Env> {`
`165`	`166`	`return new Response("Method not allowed", { status: 405 });`
`166`	`167`	`}`
`167`	`168`
	`169`	`+ this.pruneStaleSessions();`
	`170`	`+`
`168`	`171`	`const sessionType = (url.searchParams.get("type") \|\| "public") as SessionType;`
`169`	`172`	`if (!VALID_SESSION_TYPES.includes(sessionType)) {`
`170`	`173`	`return Response.json({ error: "Invalid session type" }, { status: 400 });`