fix(webapp): runs not appearing in local development

Author: LeoKaynan

apps/webapp/app/presenters/v3/CreateBulkActionPresenter.server.ts

@@ -1,7 +1,7 @@
 import { type PrismaClient } from "@trigger.dev/database";
 import { CreateBulkActionSearchParams } from "~/routes/resources.orgs.$organizationSlug.projects.$projectParam.env.$envParam.runs.bulkaction";
 import { clickhouseClient } from "~/services/clickhouseInstance.server";
-import { RunsRepository } from "~/services/runsRepository/runsRepository.server";
+import { createRunsRepository } from "~/services/runsRepositoryFactory.server";
 import { getRunFiltersFromRequest } from "../RunFilters.server";
 import { BasePresenter } from "./basePresenter.server";
 
@@ -24,7 +24,7 @@ export class CreateBulkActionPresenter extends BasePresenter {
       Object.fromEntries(new URL(request.url).searchParams)
     );
 
-    const runsRepository = new RunsRepository({
+    const runsRepository = createRunsRepository({
       clickhouse: clickhouseClient,
       prisma: this._replica as PrismaClient,
     });

apps/webapp/app/presenters/v3/NextRunListPresenter.server.ts

@@ -9,7 +9,7 @@ import { type Direction } from "~/components/ListPagination";
 import { timeFilters } from "~/components/runs/v3/SharedFilters";
 import { findDisplayableEnvironment } from "~/models/runtimeEnvironment.server";
 import { getAllTaskIdentifiers } from "~/models/task.server";
-import { RunsRepository } from "~/services/runsRepository/runsRepository.server";
+import { createRunsRepository } from "~/services/runsRepositoryFactory.server";
 import { machinePresetFromRun } from "~/v3/machinePresets.server";
 import { ServiceValidationError } from "~/v3/services/baseService.server";
 import { isCancellableRunStatus, isFinalRunStatus, isPendingRunStatus } from "~/v3/taskStatus";
@@ -153,7 +153,7 @@ export class NextRunListPresenter {
       throw new ServiceValidationError("No environment found");
     }
 
-    const runsRepository = new RunsRepository({
+    const runsRepository = createRunsRepository({
       clickhouse: this.clickhouse,
       prisma: this.replica as PrismaClient,
     });

apps/webapp/app/services/runsRepositoryFactory.server.ts

@@ -0,0 +1,22 @@
+import type { ClickHouse } from "@internal/clickhouse";
+import type { PrismaClient } from "@trigger.dev/database";
+import { env } from "~/env.server";
+import { RunsRepository } from "./runsRepository/runsRepository.server";
+
+export function createRunsRepository(options: {
+  clickhouse: ClickHouse;
+  prisma: PrismaClient;
+}): RunsRepository {
+  const isReplicationEnabled = env.RUN_REPLICATION_ENABLED === "1";
+  const isClickHouseConfigured = !!env.RUN_REPLICATION_CLICKHOUSE_URL;
+  
+  const defaultRepository = isReplicationEnabled && isClickHouseConfigured 
+    ? "clickhouse" 
+    : "postgres";
+
+  return new RunsRepository({
+    ...options,
+    defaultRepository,
+  });
+}
+

apps/webapp/app/v3/services/bulk/BulkActionV2.server.ts

@@ -8,10 +8,10 @@ import {
 import { getRunFiltersFromRequest } from "~/presenters/RunFilters.server";
 import { type CreateBulkActionPayload } from "~/routes/resources.orgs.$organizationSlug.projects.$projectParam.env.$envParam.runs.bulkaction";
 import { clickhouseClient } from "~/services/clickhouseInstance.server";
+import { createRunsRepository } from "~/services/runsRepositoryFactory.server";
 import {
   parseRunListInputOptions,
   type RunListInputFilters,
-  RunsRepository,
 } from "~/services/runsRepository/runsRepository.server";
 import { BaseService } from "../baseService.server";
 import { commonWorker } from "~/v3/commonWorker.server";
@@ -38,7 +38,7 @@ export class BulkActionService extends BaseService {
     const filters = await getFilters(payload, request);
 
     // Count the runs that will be affected by the bulk action
-    const runsRepository = new RunsRepository({
+    const runsRepository = createRunsRepository({
       clickhouse: clickhouseClient,
       prisma: this._replica as PrismaClient,
     });
@@ -145,7 +145,7 @@ export class BulkActionService extends BaseService {
       ...(group.params && typeof group.params === "object" ? group.params : {}),
     });
 
-    const runsRepository = new RunsRepository({
+    const runsRepository = createRunsRepository({
       clickhouse: clickhouseClient,
       prisma: this._replica as PrismaClient,
     });