refactor(webapp): reuse logs ClickHouse connection for projection

Author: carderne

.env.example

@@ -25,7 +25,6 @@ RUN_REPLICATION_CLICKHOUSE_URL=http://default:password@localhost:8123
 RUN_REPLICATION_ENABLED=1
 # LOGS_SEARCH_PROJECTOR_ENABLED=1
 # LOGS_SEARCH_PROJECTOR_PREVIEW_ENABLED=1
-# LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL=http://default:password@localhost:8123
 # Store task run spans/traces in ClickHouse so the dashboard trace view is
 # populated in local dev. The local stack is ClickHouse-backed (see above), so
 # leaving this unset falls back to the "postgres" store and dev run traces show

apps/webapp/app/env.server.ts

@@ -2075,11 +2075,10 @@ const EnvironmentSchema = z
     // Keep reads on v1 until the scheduled v2 projector has enough history.
     LOGS_SEARCH_TABLE_VERSION: z.enum(["v1", "v2"]).default("v1"),
 
-    // Scheduled logs-search projection. Disabled by default. The writer URL must reach both the
-    // task_events_v2 source and task_events_search_v2 destination tables.
+    // Scheduled logs-search projection. Disabled by default. LOGS_CLICKHOUSE_URL must reach both
+    // the task_events_v2 source and task_events_search_v2 destination tables.
     LOGS_SEARCH_PROJECTOR_ENABLED: BoolEnv.default(false),
     LOGS_SEARCH_PROJECTOR_PREVIEW_ENABLED: BoolEnv.default(false),
-    LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL: z.string().optional(),
     LOGS_SEARCH_PROJECTOR_MAX_WINDOWS_PER_TICK: z.coerce.number().int().min(1).max(20).default(5),
     LOGS_SEARCH_PROJECTOR_MAX_EXECUTION_TIME_SECONDS: z.coerce
       .number()
@@ -2415,14 +2414,6 @@ const EnvironmentSchema = z
   .and(GithubAppEnvSchema)
   .and(S2EnvSchema)
   .superRefine((env, ctx) => {
-    if (env.LOGS_SEARCH_PROJECTOR_ENABLED && !env.LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL) {
-      ctx.addIssue({
-        code: z.ZodIssueCode.custom,
-        path: ["LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL"],
-        message: "Required when LOGS_SEARCH_PROJECTOR_ENABLED is true",
-      });
-    }
-
     const presets = new Set(env.COMPUTE_TEMPLATE_MACHINE_PRESETS);
     for (const required of env.COMPUTE_TEMPLATE_MACHINE_PRESETS_REQUIRED) {
       if (!presets.has(required)) {

apps/webapp/app/services/clickhouse/clickhouseFactory.server.ts

@@ -38,11 +38,11 @@ const defaultLogsClickhouseClient = singleton(
 );
 
 function initializeLogsSearchProjectorClickhouseClient() {
-  if (!env.LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL) {
-    throw new Error("LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL is not set");
+  if (!env.LOGS_CLICKHOUSE_URL) {
+    throw new Error("LOGS_CLICKHOUSE_URL is not set");
   }
 
-  const url = new URL(env.LOGS_SEARCH_PROJECTOR_CLICKHOUSE_URL);
+  const url = new URL(env.LOGS_CLICKHOUSE_URL);
   url.searchParams.delete("secure");
 
   return new ClickHouse({

apps/webapp/test/logsSearchProjectorStateStore.test.ts

@@ -11,6 +11,7 @@ const at = (value: string) => new Date(value);
 
 postgresTest(
   "persists low-churn control state and append-only finalized checkpoints",
+  { timeout: 20_000 },
   async ({ prisma }) => {
     const store = new PrismaLogsSearchProjectorStateStore(prisma);
     const initial = at("2026-08-14T12:00:00.000Z");