style(run-ops): apply oxfmt

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: d-cs

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

@@ -197,43 +197,38 @@ export class BatchListPresenter extends BasePresenter {
     }
     const createdAtLte: Date | undefined = time.to;
 
-    const batches = await this.#scanBatchTaskRun(
-      pageSize,
-      direction,
-      (client) =>
-        client.batchTaskRun.findMany({
-          where: {
-            runtimeEnvironmentId: environmentId,
-            ...(cursor
-              ? { id: direction === "forward" ? { lt: cursor } : { gt: cursor } }
-              : {}),
-            ...(friendlyId ? { friendlyId } : {}),
-            ...(statuses && statuses.length > 0
-              ? { status: { in: statuses }, batchVersion: { not: "v1" } }
-              : {}),
-            ...(createdAtGte !== undefined || createdAtLte !== undefined
-              ? {
-                  createdAt: {
-                    ...(createdAtGte !== undefined ? { gte: createdAtGte } : {}),
-                    ...(createdAtLte !== undefined ? { lte: createdAtLte } : {}),
-                  },
-                }
-              : {}),
-          },
-          orderBy: { id: direction === "forward" ? "desc" : "asc" },
-          take: pageSize + 1,
-          select: {
-            id: true,
-            friendlyId: true,
-            runtimeEnvironmentId: true,
-            status: true,
-            createdAt: true,
-            updatedAt: true,
-            completedAt: true,
-            runCount: true,
-            batchVersion: true,
-          },
-        })
+    const batches = await this.#scanBatchTaskRun(pageSize, direction, (client) =>
+      client.batchTaskRun.findMany({
+        where: {
+          runtimeEnvironmentId: environmentId,
+          ...(cursor ? { id: direction === "forward" ? { lt: cursor } : { gt: cursor } } : {}),
+          ...(friendlyId ? { friendlyId } : {}),
+          ...(statuses && statuses.length > 0
+            ? { status: { in: statuses }, batchVersion: { not: "v1" } }
+            : {}),
+          ...(createdAtGte !== undefined || createdAtLte !== undefined
+            ? {
+                createdAt: {
+                  ...(createdAtGte !== undefined ? { gte: createdAtGte } : {}),
+                  ...(createdAtLte !== undefined ? { lte: createdAtLte } : {}),
+                },
+              }
+            : {}),
+        },
+        orderBy: { id: direction === "forward" ? "desc" : "asc" },
+        take: pageSize + 1,
+        select: {
+          id: true,
+          friendlyId: true,
+          runtimeEnvironmentId: true,
+          status: true,
+          createdAt: true,
+          updatedAt: true,
+          completedAt: true,
+          runCount: true,
+          batchVersion: true,
+        },
+      })
     );
 
     const hasMore = batches.length > pageSize;

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

@@ -170,7 +170,8 @@ export class WaitpointListPresenter extends BasePresenter {
     }
     if (from !== undefined) {
       const fromDate = new Date(from);
-      createdAtGte = createdAtGte === undefined ? fromDate : fromDate > createdAtGte ? fromDate : createdAtGte;
+      createdAtGte =
+        createdAtGte === undefined ? fromDate : fromDate > createdAtGte ? fromDate : createdAtGte;
     }
     const createdAtLte: Date | undefined = to !== undefined ? new Date(to) : undefined;
 
@@ -180,9 +181,7 @@ export class WaitpointListPresenter extends BasePresenter {
           where: {
             environmentId: environment.id,
             type: "MANUAL",
-            ...(cursor
-              ? { id: direction === "forward" ? { lt: cursor } : { gt: cursor } }
-              : {}),
+            ...(cursor ? { id: direction === "forward" ? { lt: cursor } : { gt: cursor } } : {}),
             ...(id ? { friendlyId: id } : {}),
             ...(statusesToFilter.length ? { status: { in: statusesToFilter } } : {}),
             ...(filterOutputIsError !== undefined ? { outputIsError: filterOutputIsError } : {}),

apps/webapp/test/apiRunResultPresenter.readthrough.test.ts

@@ -82,10 +82,7 @@ async function seedEnv(prisma: PrismaClient, slug: string) {
   return { organization, project, environment };
 }
 
-async function seedWorker(
-  prisma: PrismaClient,
-  ctx: { environmentId: string; projectId: string }
-) {
+async function seedWorker(prisma: PrismaClient, ctx: { environmentId: string; projectId: string }) {
   const queue = await prisma.taskQueue.create({
     data: {
       friendlyId: `queue_${idGenerator()}`,

apps/webapp/test/apiWaitpointPresenter.readthrough.test.ts

@@ -225,7 +225,10 @@ describe("ApiWaitpointPresenter read-through (heterogeneous legacy + new Postgre
         newClient: recording(prisma17).handle,
         legacyReplica: newLegacy.handle,
       });
-      const migratedResult = await migratedPresenter.call(environmentArg(newEnv.environment), newId);
+      const migratedResult = await migratedPresenter.call(
+        environmentArg(newEnv.environment),
+        newId
+      );
       expect(migratedResult.id).toBe(`waitpoint_${newId}`);
       expect(newLegacy.calls.length).toBe(0);
 
@@ -241,7 +244,10 @@ describe("ApiWaitpointPresenter read-through (heterogeneous legacy + new Postgre
         newClient: recording(prisma17).handle,
         legacyReplica: recording(prisma14).handle,
       });
-      const retentionResult = await retentionPresenter.call(environmentArg(oldEnv.environment), oldId);
+      const retentionResult = await retentionPresenter.call(
+        environmentArg(oldEnv.environment),
+        oldId
+      );
       expect(retentionResult.id).toBe(`waitpoint_${oldId}`);
     }
   );

apps/webapp/test/batchListPresenter.readroute.test.ts

@@ -13,7 +13,11 @@ vi.mock("~/db.server", () => ({
   sqlDatabaseSchema: Prisma.sql(["public"]),
 }));
 
-import { heteroPostgresTest, heteroRunOpsPostgresTest, postgresTest } from "@internal/testcontainers";
+import {
+  heteroPostgresTest,
+  heteroRunOpsPostgresTest,
+  postgresTest,
+} from "@internal/testcontainers";
 import { PrismaClient } from "@trigger.dev/database";
 import { RunOpsPrismaClient } from "@internal/run-ops-database";
 import {
@@ -34,7 +38,12 @@ type SeedContext = {
 // against a direct $queryRaw of the identical SQL on each DB version.
 function rawScan(
   prisma: PrismaClient,
-  opts: { environmentId: string; pageSize: number; direction: "forward" | "backward"; cursor?: string }
+  opts: {
+    environmentId: string;
+    pageSize: number;
+    direction: "forward" | "backward";
+    cursor?: string;
+  }
 ) {
   const { environmentId, pageSize, direction, cursor } = opts;
   const sqlDatabaseSchema = Prisma.sql(["public"]);
@@ -178,7 +187,10 @@ async function createBatch(
   });
 }
 
-const baseCall = (ctx: SeedContext, overrides: Partial<BatchListOptions> = {}): BatchListOptions => ({
+const baseCall = (
+  ctx: SeedContext,
+  overrides: Partial<BatchListOptions> = {}
+): BatchListOptions => ({
   projectId: ctx.projectId,
   environmentId: ctx.environmentId,
   userId: ctx.userId,
@@ -201,7 +213,8 @@ function spyClient(
             if (trProp === "findMany") {
               return (...args: any[]) => {
                 counts.findMany++;
-                if (opts.throwOnQueryRaw) throw new Error("batchTaskRun.findMany must not be invoked on this handle");
+                if (opts.throwOnQueryRaw)
+                  throw new Error("batchTaskRun.findMany must not be invoked on this handle");
                 return (trTarget as any).findMany(...args);
               };
             }
@@ -286,7 +299,11 @@ describe("BatchListPresenter run-ops read routing (PG14 control-plane/legacy + P
       // The TS codepoint comparator reproduces the DB ORDER BY over the seeded id set.
       const allIds = ids.map((i) => `batch_${i}`);
       const dbForward = (
-        await rawScan(prisma17, { environmentId: ctx17.environmentId, pageSize: 50, direction: "forward" })
+        await rawScan(prisma17, {
+          environmentId: ctx17.environmentId,
+          pageSize: 50,
+          direction: "forward",
+        })
       ).map((r) => r.id);
       expect(dbForward).toEqual([...allIds].sort(desc));
     }
@@ -389,7 +406,9 @@ describe("BatchListPresenter run-ops read routing (PG14 control-plane/legacy + P
       expect(page.hasAnyBatches).toBe(true);
 
       // Now wipe legacy too => both empty => hasAnyBatches false.
-      await prisma14.batchTaskRun.deleteMany({ where: { runtimeEnvironmentId: ctx.environmentId } });
+      await prisma14.batchTaskRun.deleteMany({
+        where: { runtimeEnvironmentId: ctx.environmentId },
+      });
       const page2 = await presenter.call(baseCall(ctx, { friendlyId: "fr_does_not_exist" }));
       expect(page2.batches).toHaveLength(0);
       expect(page2.hasAnyBatches).toBe(false);

apps/webapp/test/batchPresenter.test.ts

@@ -333,27 +333,28 @@ describe("BatchPresenter single-DB passthrough", () => {
   // TaskRuns — the dangling-reference gate over members is owned by the migration / dangling-gate
   // units, not this presenter. This unit's contribution is "batch detail loads regardless of
   // which run-ops store holds the batch row."
-  containerTest("e2e #3 proxy: a batch spanning migrated + abandoned runs still resolves", async ({
-    prisma,
-  }) => {
-    const ctx = await seedEnvironment(prisma, "e2e3");
-    await seedBatch(prisma, ctx.environmentId, {
-      friendlyId: "batch_e2e3",
-      runCount: 10, // implies members spanning migrated + abandoned runs
-    });
+  containerTest(
+    "e2e #3 proxy: a batch spanning migrated + abandoned runs still resolves",
+    async ({ prisma }) => {
+      const ctx = await seedEnvironment(prisma, "e2e3");
+      await seedBatch(prisma, ctx.environmentId, {
+        friendlyId: "batch_e2e3",
+        runCount: 10, // implies members spanning migrated + abandoned runs
+      });
 
-    const presenter = new BatchPresenter(prisma, prisma, {
-      splitEnabled: false,
-      newClient: prisma,
-      resolveDisplayableEnvironment: makeEnvResolver(prisma),
-    });
+      const presenter = new BatchPresenter(prisma, prisma, {
+        splitEnabled: false,
+        newClient: prisma,
+        resolveDisplayableEnvironment: makeEnvResolver(prisma),
+      });
 
-    const result = await presenter.call({
-      environmentId: ctx.environmentId,
-      batchId: "batch_e2e3",
-    });
+      const result = await presenter.call({
+        environmentId: ctx.environmentId,
+        batchId: "batch_e2e3",
+      });
 
-    expect(result.friendlyId).toBe("batch_e2e3");
-    expect(result.runCount).toBe(10);
-  });
+      expect(result.friendlyId).toBe("batch_e2e3");
+      expect(result.runCount).toBe(10);
+    }
+  );
 });

apps/webapp/test/nextRunListPresenter.readthrough.test.ts

@@ -206,7 +206,11 @@ describe("NextRunListPresenter dual-DB empty-state probe + routed hydrate (legac
           splitEnabled: true,
         });
 
-        const result = await presenter.call(ctx.organizationId, ctx.environmentId, callOptions(ctx));
+        const result = await presenter.call(
+          ctx.organizationId,
+          ctx.environmentId,
+          callOptions(ctx)
+        );
 
         // CH id-set is empty within the page window, but the legacy probe finds the row.
         expect(result.runs).toHaveLength(0);
@@ -253,7 +257,11 @@ describe("NextRunListPresenter dual-DB empty-state probe + routed hydrate (legac
         });
 
         // If the legacy spy were invoked, this would throw — the test passing IS the proof.
-        const result = await presenter.call(ctx.organizationId, ctx.environmentId, callOptions(ctx));
+        const result = await presenter.call(
+          ctx.organizationId,
+          ctx.environmentId,
+          callOptions(ctx)
+        );
 
         expect(result.runs).toHaveLength(0);
         expect(result.hasAnyRuns).toBe(true);
@@ -291,7 +299,11 @@ describe("NextRunListPresenter dual-DB empty-state probe + routed hydrate (legac
           splitEnabled: true,
         });
 
-        const result = await presenter.call(ctx.organizationId, ctx.environmentId, callOptions(ctx));
+        const result = await presenter.call(
+          ctx.organizationId,
+          ctx.environmentId,
+          callOptions(ctx)
+        );
 
         expect(result.runs).toHaveLength(0);
         expect(result.hasAnyRuns).toBe(false);
@@ -392,7 +404,11 @@ describe("NextRunListPresenter dual-DB empty-state probe + routed hydrate (legac
           splitEnabled: true,
         });
 
-        const result = await presenter.call(ctx.organizationId, ctx.environmentId, callOptions(ctx));
+        const result = await presenter.call(
+          ctx.organizationId,
+          ctx.environmentId,
+          callOptions(ctx)
+        );
 
         const expectedIds = [migratedA.id, migratedB.id, legacyOnlyA.id, legacyOnlyB.id].sort(
           (a, b) => (a < b ? 1 : a > b ? -1 : 0)

apps/webapp/test/presenters/TestTaskPresenter.readthrough.test.ts

@@ -511,5 +511,4 @@ describe("TestTaskPresenter recent-payloads read-through (PG14 legacy + PG17 new
       }
     }
   );
-
 });

apps/webapp/test/realtime/clickHouseRunListResolver.test.ts

@@ -362,7 +362,11 @@ describe("ClickHouseRunListResolver (realtime run-list id-set, split-neutral)",
       const otherEnvId = await seedSecondEnvironment(prisma, ctx, "envscope");
 
       const inEnv = await createRun(prisma, ctx, { friendlyId: "run_inEnv" });
-      await createRun(prisma, { ...ctx, environmentId: otherEnvId }, { friendlyId: "run_otherEnv" });
+      await createRun(
+        prisma,
+        { ...ctx, environmentId: otherEnvId },
+        { friendlyId: "run_otherEnv" }
+      );
 
       await setTimeout(1500);