fix(webapp): adapt the realtime run-id resolver to paginated listRunIds

listRunIds now returns a keyset page ({ runIds, pagination }); read runIds
from it. The page is already capped to the requested size, so the manual
trim is gone.

Also make the run-change event-bus handler registration return a truthy
value so the singleton() wrapper doesn't re-attach listeners on dev reloads.

Author: ericallam

apps/webapp/app/services/realtime/clickHouseRunListResolver.server.ts

@@ -27,7 +27,7 @@ export class ClickHouseRunListResolver implements RunListResolver {
     const clickhouse = await this.options.getClickhouse(filter.organizationId);
     const repository = new RunsRepository({ clickhouse, prisma: this.options.prisma });
 
-    const ids = await repository.listRunIds({
+    const { runIds } = await repository.listRunIds({
       organizationId: filter.organizationId,
       projectId: filter.projectId,
       environmentId: filter.environmentId,
@@ -37,8 +37,7 @@ export class ClickHouseRunListResolver implements RunListResolver {
       page: { size: filter.limit },
     });
 
-    // listRunIds overfetches by one (size + 1) for has-more detection and doesn't
-    // trim, so enforce the caller's cap here.
-    return ids.slice(0, filter.limit);
+    // listRunIds is keyset-paginated; runIds is already capped to page.size (= limit).
+    return runIds;
   }
 }

apps/webapp/app/services/realtime/runChangeNotifierHandlers.server.ts

@@ -16,8 +16,11 @@ import { publishRunChanged } from "./runChangeNotifierInstance.server";
  * high-value, env-cheap transitions here.
  */
 export function registerRunChangeNotifierHandlers() {
+  // Return a truthy value in every path so the singleton() wrapper (which uses
+  // ??=) caches the result and never re-runs this factory — re-running would
+  // attach duplicate engine-bus listeners on each Remix dev-mode reload.
   if (env.REALTIME_NOTIFIER_ENABLED !== "1") {
-    return;
+    return true;
   }
 
   // Status transitions (checkpoint suspend/resume, pending version, dequeue) —
@@ -70,4 +73,6 @@ export function registerRunChangeNotifierHandlers() {
   });
 
   logger.info("[runChangeNotifier] realtime run-change notifier handlers registered");
+
+  return true;
 }