fix(gastown): address review comments — reset poll_null_count on all non-null polls, abort orphaned session on startup abort, guard agents.delete with identity check

Author: jrf0110

cloudflare-gastown/container/src/process-manager.ts

@@ -686,14 +686,27 @@ export async function startAgent(
       if (sessionCounted) {
         const instance = sdkInstances.get(workdir);
         if (instance) {
+          // Abort the orphaned session if one was created before the abort
+          if (agent.sessionId) {
+            try {
+              await instance.client.session.abort({ path: { id: agent.sessionId } });
+            } catch (abortErr) {
+              console.error(
+                `${MANAGER_LOG} startAgent: failed to abort orphaned session ${agent.sessionId}:`,
+                abortErr
+              );
+            }
+          }
           instance.sessionCount--;
           if (instance.sessionCount <= 0) {
             instance.server.close();
             sdkInstances.delete(workdir);
           }
         }
       }
-      agents.delete(request.agentId);
+      if (agents.get(request.agentId) === agent) {
+        agents.delete(request.agentId);
+      }
       throw err;
     }
 

cloudflare-gastown/src/dos/town/actions.ts

@@ -574,8 +574,8 @@ export function applyAction(ctx: ApplyActionContext, action: Action): (() => Pro
       return async () => {
         try {
           const status = await ctx.checkPRStatus(action.pr_url);
-          if (status && status !== 'open') {
-            // Successful non-open status — reset null counter and emit event
+          if (status !== null) {
+            // Any non-null result resets the consecutive null counter
             query(
               sql,
               /* sql */ `
@@ -588,11 +588,13 @@ export function applyAction(ctx: ApplyActionContext, action: Action): (() => Pro
               `,
               [action.bead_id]
             );
-            ctx.insertEvent('pr_status_changed', {
-              bead_id: action.bead_id,
-              payload: { pr_url: action.pr_url, pr_state: status },
-            });
-          } else if (status === null) {
+            if (status !== 'open') {
+              ctx.insertEvent('pr_status_changed', {
+                bead_id: action.bead_id,
+                payload: { pr_url: action.pr_url, pr_state: status },
+              });
+            }
+          } else {
             // Null result — increment consecutive null counter
             query(
               sql,