WIP importing otlp traces and logs into TaskEvent table

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "packages/otlp-importer/protos"]
+	path = packages/otlp-importer/protos
+	url = https://github.com/open-telemetry/opentelemetry-proto.git

apps/webapp/app/routes/otel.v1.logs.ts

@@ -1,5 +1,13 @@
 import { ActionFunctionArgs } from "@remix-run/server-runtime";
+import { ExportLogsServiceRequest, ExportLogsServiceResponse } from "@trigger.dev/otlp-importer";
+import { otlpExporter } from "~/v3/otlpExporter.server";
 
-export function action({ request }: ActionFunctionArgs) {
-  return new Response(null, { status: 200 });
+export async function action({ request }: ActionFunctionArgs) {
+  const buffer = await request.arrayBuffer();
+
+  const exportRequest = ExportLogsServiceRequest.decode(new Uint8Array(buffer));
+
+  const exportResponse = await otlpExporter.exportLogs(exportRequest);
+
+  return new Response(ExportLogsServiceResponse.encode(exportResponse).finish(), { status: 200 });
 }

apps/webapp/app/routes/otel.v1.traces.ts

@@ -1,5 +1,13 @@
 import { ActionFunctionArgs } from "@remix-run/server-runtime";
+import { ExportTraceServiceRequest, ExportTraceServiceResponse } from "@trigger.dev/otlp-importer";
+import { otlpExporter } from "~/v3/otlpExporter.server";
 
-export function action({ request }: ActionFunctionArgs) {
-  return new Response(null, { status: 200 });
+export async function action({ request }: ActionFunctionArgs) {
+  const buffer = await request.arrayBuffer();
+
+  const exportRequest = ExportTraceServiceRequest.decode(new Uint8Array(buffer));
+
+  const exportResponse = await otlpExporter.exportTraces(exportRequest);
+
+  return new Response(ExportTraceServiceResponse.encode(exportResponse).finish(), { status: 200 });
 }

apps/webapp/app/v3/eventRepository.server.ts

@@ -0,0 +1,18 @@
+import { Prisma, TaskEventStatus, type TaskEventKind } from "@trigger.dev/database";
+import { PrismaClient, prisma } from "~/db.server";
+
+export type CreatableEvent = Omit<Prisma.TaskEventCreateInput, "id" | "createdAt">;
+export type CreatableEventKind = TaskEventKind;
+export type CreatableEventStatus = TaskEventStatus;
+
+export class EventRepository {
+  constructor(private db: PrismaClient = prisma) {}
+
+  async insert(event: CreatableEvent) {
+    return this.db.taskEvent.create({ data: event });
+  }
+
+  async insertMany(events: CreatableEvent[]) {
+    return this.db.taskEvent.createMany({ data: events });
+  }
+}