feat(webapp): give the realtime runs feed its own pub/sub Redis

Run the realtime runs feed's run-changed pub/sub on a dedicated
REALTIME_RUNS_PUBSUB_REDIS_* connection set (falling back to
PUBSUB_REDIS_* / REDIS_*), so its publish/subscribe traffic can be
isolated from the shared pub/sub Redis.

Author: ericallam

apps/webapp/app/env.server.ts

@@ -357,6 +357,37 @@ const EnvironmentSchema = z
     PUBSUB_REDIS_TLS_DISABLED: z.string().default(process.env.REDIS_TLS_DISABLED ?? "false"),
     PUBSUB_REDIS_CLUSTER_MODE_ENABLED: z.string().default("0"),
 
+    // Dedicated pub/sub Redis for the realtime runs feed's run-changed notifier, so
+    // its publish/subscribe traffic can run on its own instance. Each value falls
+    // back to the shared PUBSUB_REDIS_* (then REDIS_*) when unset, so the default is
+    // unchanged until explicitly pointed at a dedicated instance.
+    REALTIME_RUNS_PUBSUB_REDIS_HOST: z
+      .string()
+      .optional()
+      .transform((v) => v ?? process.env.PUBSUB_REDIS_HOST ?? process.env.REDIS_HOST),
+    REALTIME_RUNS_PUBSUB_REDIS_PORT: z.coerce
+      .number()
+      .optional()
+      .transform((v) => {
+        if (v !== undefined) return v;
+        const raw = process.env.PUBSUB_REDIS_PORT ?? process.env.REDIS_PORT;
+        return raw ? parseInt(raw) : undefined;
+      }),
+    REALTIME_RUNS_PUBSUB_REDIS_USERNAME: z
+      .string()
+      .optional()
+      .transform((v) => v ?? process.env.PUBSUB_REDIS_USERNAME ?? process.env.REDIS_USERNAME),
+    REALTIME_RUNS_PUBSUB_REDIS_PASSWORD: z
+      .string()
+      .optional()
+      .transform((v) => v ?? process.env.PUBSUB_REDIS_PASSWORD ?? process.env.REDIS_PASSWORD),
+    REALTIME_RUNS_PUBSUB_REDIS_TLS_DISABLED: z
+      .string()
+      .default(process.env.PUBSUB_REDIS_TLS_DISABLED ?? process.env.REDIS_TLS_DISABLED ?? "false"),
+    REALTIME_RUNS_PUBSUB_REDIS_CLUSTER_MODE_ENABLED: z
+      .string()
+      .default(process.env.PUBSUB_REDIS_CLUSTER_MODE_ENABLED ?? "0"),
+
     DEFAULT_ENV_EXECUTION_CONCURRENCY_LIMIT: z.coerce.number().int().default(100),
     DEFAULT_ENV_EXECUTION_CONCURRENCY_BURST_FACTOR: z.coerce.number().default(1.0),
     DEFAULT_ORG_EXECUTION_CONCURRENCY_LIMIT: z.coerce.number().int().default(300),

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

@@ -21,12 +21,12 @@ const notifierEnabled = env.REALTIME_NOTIFIER_ENABLED === "1";
 function initializeRunChangeNotifier(): RunChangeNotifier {
   const notifier = new RunChangeNotifier({
     redis: {
-      host: env.PUBSUB_REDIS_HOST,
-      port: env.PUBSUB_REDIS_PORT,
-      username: env.PUBSUB_REDIS_USERNAME,
-      password: env.PUBSUB_REDIS_PASSWORD,
-      tlsDisabled: env.PUBSUB_REDIS_TLS_DISABLED === "true",
-      clusterMode: env.PUBSUB_REDIS_CLUSTER_MODE_ENABLED === "1",
+      host: env.REALTIME_RUNS_PUBSUB_REDIS_HOST,
+      port: env.REALTIME_RUNS_PUBSUB_REDIS_PORT,
+      username: env.REALTIME_RUNS_PUBSUB_REDIS_USERNAME,
+      password: env.REALTIME_RUNS_PUBSUB_REDIS_PASSWORD,
+      tlsDisabled: env.REALTIME_RUNS_PUBSUB_REDIS_TLS_DISABLED === "true",
+      clusterMode: env.REALTIME_RUNS_PUBSUB_REDIS_CLUSTER_MODE_ENABLED === "1",
     },
   });