Expose a new API endpoint to list events for a given task run

Author: myftija

apps/webapp/app/routes/api.v1.runs.$runId.events.ts

@@ -0,0 +1,56 @@
+import { json } from "@remix-run/server-runtime";
+import { z } from "zod";
+import { getTaskEventStoreTableForRun } from "~/v3/taskEventStore.server";
+import { createLoaderApiRoute } from "~/services/routeBuilders/apiBuilder.server";
+import { eventRepository } from "~/v3/eventRepository.server";
+import { ApiRetrieveRunPresenter } from "~/presenters/v3/ApiRetrieveRunPresenter.server";
+
+const ParamsSchema = z.object({
+  runId: z.string(), // This is the run friendly ID
+});
+
+// TODO: paginate the results
+export const loader = createLoaderApiRoute(
+  {
+    params: ParamsSchema,
+    allowJWT: true,
+    corsStrategy: "all",
+    findResource: (params, auth) => {
+      return ApiRetrieveRunPresenter.findRun(params.runId, auth.environment);
+    },
+    shouldRetryNotFound: true,
+    authorization: {
+      action: "read",
+      resource: (run) => ({
+        runs: run.friendlyId,
+        tags: run.runTags,
+        batch: run.batch?.friendlyId,
+        tasks: run.taskIdentifier,
+      }),
+      superScopes: ["read:runs", "read:all", "admin"],
+    },
+  },
+  async ({ resource: run }) => {
+    const runEvents = await eventRepository.getRunEvents(
+      getTaskEventStoreTableForRun(run),
+      run.friendlyId,
+      run.createdAt,
+      run.completedAt ?? undefined
+    );
+
+    // TODO: return only relevant fields, avoid returning the whole events
+    return json(
+      {
+        events: runEvents.map((event) => {
+          return JSON.parse(
+            JSON.stringify(event, (_, value) =>
+              // needed as JSON.stringify doesn't know how to handle BigInt values by default
+              typeof value === "bigint" ? value.toString() : value
+            )
+          );
+        }),
+      },
+      { status: 200 }
+    );
+  }
+);