Removed old Postgres RunListPresenter

Author: matt-aitken

apps/webapp/app/components/runs/v3/TaskRunsTable.tsx

@@ -18,15 +18,16 @@ import { Header3 } from "~/components/primitives/Headers";
 import { PopoverMenuItem } from "~/components/primitives/Popover";
 import { useSelectedItems } from "~/components/primitives/SelectedItemsProvider";
 import { SimpleTooltip } from "~/components/primitives/Tooltip";
+import { TruncatedCopyableValue } from "~/components/primitives/TruncatedCopyableValue";
+import { useEnvironment } from "~/hooks/useEnvironment";
 import { useFeatures } from "~/hooks/useFeatures";
 import { useOrganization } from "~/hooks/useOrganizations";
 import { useProject } from "~/hooks/useProject";
-import { useUser } from "~/hooks/useUser";
 import {
-  type RunListAppliedFilters,
-  type RunListItem,
-} from "~/presenters/v3/RunListPresenter.server";
-import { formatCurrencyAccurate, formatNumber } from "~/utils/numberFormatter";
+  type NextRunListAppliedFilters,
+  type NextRunListItem,
+} from "~/presenters/v3/NextRunListPresenter.server";
+import { formatCurrencyAccurate } from "~/utils/numberFormatter";
 import { docsPath, v3RunSpanPath, v3TestPath } from "~/utils/pathBuilder";
 import { DateTime } from "../../primitives/DateTime";
 import { Paragraph } from "../../primitives/Paragraph";
@@ -51,17 +52,13 @@ import {
   filterableTaskRunStatuses,
   TaskRunStatusCombo,
 } from "./TaskRunStatus";
-import { useEnvironment } from "~/hooks/useEnvironment";
-import { CopyableText } from "~/components/primitives/CopyableText";
-import { ClipboardField } from "~/components/primitives/ClipboardField";
-import { TruncatedCopyableValue } from "~/components/primitives/TruncatedCopyableValue";
 
 type RunsTableProps = {
   total: number;
   hasFilters: boolean;
-  filters: RunListAppliedFilters;
+  filters: NextRunListAppliedFilters;
   showJob?: boolean;
-  runs: RunListItem[];
+  runs: NextRunListItem[];
   isLoading?: boolean;
   allowSelection?: boolean;
   variant?: TableVariant;
@@ -411,7 +408,7 @@ export function TaskRunsTable({
   );
 }
 
-function RunActionsCell({ run, path }: { run: RunListItem; path: string }) {
+function RunActionsCell({ run, path }: { run: NextRunListItem; path: string }) {
   const location = useLocation();
 
   if (!run.isCancellable && !run.isReplayable) return <TableCell to={path}>{""}</TableCell>;

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

@@ -7,12 +7,13 @@ import {
 import { type Project, type RuntimeEnvironment, type TaskRunStatus } from "@trigger.dev/database";
 import assertNever from "assert-never";
 import { z } from "zod";
+import { clickhouseClient } from "~/services/clickhouseInstance.server";
 import { logger } from "~/services/logger.server";
 import { CoercedDate } from "~/utils/zod";
+import { ServiceValidationError } from "~/v3/services/baseService.server";
 import { ApiRetrieveRunPresenter } from "./ApiRetrieveRunPresenter.server";
-import { type RunListOptions, RunListPresenter } from "./RunListPresenter.server";
+import { NextRunListPresenter, type RunListOptions } from "./NextRunListPresenter.server";
 import { BasePresenter } from "./basePresenter.server";
-import { ServiceValidationError } from "~/v3/services/baseService.server";
 
 export const ApiRunListSearchParams = z.object({
   "page[size]": z.coerce.number().int().positive().min(1).max(100).optional(),
@@ -136,10 +137,12 @@ export class ApiRunListPresenter extends BasePresenter {
       }
 
       let environmentId: string | undefined;
+      let organizationId: string | undefined;
 
       // filters
       if (environment) {
         environmentId = environment.id;
+        organizationId = environment.organizationId;
       } else {
         if (searchParams["filter[env]"]) {
           const environments = await this._prisma.runtimeEnvironment.findMany({
@@ -152,13 +155,18 @@ export class ApiRunListPresenter extends BasePresenter {
           });
 
           environmentId = environments.at(0)?.id;
+          organizationId = environments.at(0)?.organizationId;
         }
       }
 
       if (!environmentId) {
         throw new ServiceValidationError("No environment found");
       }
 
+      if (!organizationId) {
+        throw new ServiceValidationError("No organization found");
+      }
+
       if (searchParams["filter[status]"]) {
         options.statuses = searchParams["filter[status]"].flatMap((status) =>
           ApiRunListPresenter.apiStatusToRunStatuses(status)
@@ -205,11 +213,15 @@ export class ApiRunListPresenter extends BasePresenter {
         options.batchId = searchParams["filter[batch]"];
       }
 
-      const presenter = new RunListPresenter();
+      if (!clickhouseClient) {
+        throw new Error("Clickhouse is not supported yet");
+      }
+
+      const presenter = new NextRunListPresenter(this._prisma, clickhouseClient);
 
       logger.debug("Calling RunListPresenter", { options });
 
-      const results = await presenter.call(environmentId, options);
+      const results = await presenter.call(organizationId, environmentId, options);
 
       logger.debug("RunListPresenter results", { runs: results.runs.length });