refactor(webapp): replace runsRepositoryFactory with direct RunsRepository instantiation

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 { createRunsRepository } from "~/services/runsRepositoryFactory.server";
+import { RunsRepository } from "~/services/runsRepository/runsRepository.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 = createRunsRepository({
+    const runsRepository = new RunsRepository({
       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 { createRunsRepository } from "~/services/runsRepositoryFactory.server";
+import { RunsRepository } from "~/services/runsRepository/runsRepository.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 = createRunsRepository({
+    const runsRepository = new RunsRepository({
       clickhouse: this.clickhouse,
       prisma: this.replica as PrismaClient,
     });

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

@@ -13,6 +13,7 @@ import { startActiveSpan } from "~/v3/tracer.server";
 import { logger } from "../logger.server";
 import { ClickHouseRunsRepository } from "./clickhouseRunsRepository.server";
 import { PostgresRunsRepository } from "./postgresRunsRepository.server";
+import { env } from "~/env.server";
 
 export type RunsRepositoryOptions = {
   clickhouse: ClickHouse;
@@ -130,7 +131,11 @@ export class RunsRepository implements IRunsRepository {
   ) {
     this.clickHouseRunsRepository = new ClickHouseRunsRepository(options);
     this.postgresRunsRepository = new PostgresRunsRepository(options);
-    this.defaultRepository = options.defaultRepository ?? "clickhouse";
+    this.defaultRepository =
+      options.defaultRepository ??
+      ((env.RUN_REPLICATION_ENABLED === "1" && env.RUN_REPLICATION_CLICKHOUSE_URL)
+        ? "clickhouse"
+        : "postgres");
     this.logger = options.logger ?? logger;
   }
 

apps/webapp/app/services/runsRepositoryFactory.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 = createRunsRepository({
+    const runsRepository = new RunsRepository({
       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 = createRunsRepository({
+    const runsRepository = new RunsRepository({
       clickhouse: clickhouseClient,
       prisma: this._replica as PrismaClient,
     });