fix: OTLP nanosecond timestamp overflow in webapp event repository

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

@@ -25,7 +25,7 @@ export function extractContextFromCarrier(carrier: Record<string, unknown>) {
 }
 
 export function getNowInNanoseconds(): bigint {
-  return BigInt(new Date().getTime() * 1_000_000);
+  return convertDateToNanoseconds(new Date());
 }
 
 export function getDateFromNanoseconds(nanoseconds: bigint): Date {
@@ -39,7 +39,7 @@ export function calculateDurationFromStart(
 ) {
   const $endtime = typeof endTime === "string" ? new Date(endTime) : endTime;
 
-  const duration = Number(BigInt($endtime.getTime() * 1_000_000) - startTime);
+  const duration = Number(convertDateToNanoseconds($endtime) - startTime);
 
   if (minimumDuration && duration < minimumDuration) {
     return minimumDuration;

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

@@ -9,10 +9,10 @@ import { FEATURE_FLAG } from "../featureFlags";
 import { flag } from "../featureFlags.server";
 import { getTaskEventStore } from "../taskEventStore.server";
 import { clickhouseFactory } from "~/services/clickhouse/clickhouseFactoryInstance.server";
+import { convertDateToNanoseconds } from "./common.server";
 
 export const EVENT_STORE_TYPES = {
-  POSTGRES: "postgres",
-  CLICKHOUSE: "clickhouse",
+  POSTGRES: "postgres",  CLICKHOUSE: "clickhouse",
   CLICKHOUSE_V2: "clickhouse_v2",
 } as const;
 
@@ -208,10 +208,9 @@ async function recordRunEvent(
         runId: foundRun.friendlyId,
         ...attributes,
       },
-      startTime: BigInt((startTime?.getTime() ?? Date.now()) * 1_000_000),
+      startTime: convertDateToNanoseconds(startTime ?? new Date()),
       ...optionsRest,
     });
-
     return {
       success: true,
     };

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

@@ -24,7 +24,10 @@ import { MetadataTooLargeError } from "~/utils/packets";
 import { QueueSizeLimitExceededError } from "~/v3/services/common.server";
 import { TriggerTaskService } from "~/v3/services/triggerTask.server";
 import { tracer } from "~/v3/tracer.server";
-import { createExceptionPropertiesFromError } from "./eventRepository/common.server";
+import {
+  convertDateToNanoseconds,
+  createExceptionPropertiesFromError,
+} from "./eventRepository/common.server";
 import { getEventRepositoryForStore, recordRunDebugLog } from "./eventRepository/index.server";
 import { roomFromFriendlyRunId, socketIo } from "./handleSocketIo.server";
 import { engine } from "./runEngine.server";
@@ -555,7 +558,7 @@ export function registerRunEngineEventBusHandlers() {
         );
 
         await eventRepository.recordEvent(retryMessage, {
-          startTime: BigInt(time.getTime() * 1000000),
+          startTime: convertDateToNanoseconds(time),
           taskSlug: run.taskIdentifier,
           environment,
           attributes: {

apps/webapp/test/eventRepositoryNanoseconds.test.ts

@@ -0,0 +1,31 @@
+import { afterEach, describe, expect, it, vi } from "vitest";
+import {
+  calculateDurationFromStart,
+  convertDateToNanoseconds,
+  getNowInNanoseconds,
+} from "~/v3/eventRepository/common.server";
+
+const EPOCH_MS = 1_782_994_600_413;
+
+describe("event repository nanosecond conversion", () => {
+  afterEach(() => {
+    vi.useRealTimers();
+  });
+
+  it("converts a date to nanoseconds without losing precision", () => {
+    expect(convertDateToNanoseconds(new Date(EPOCH_MS))).toBe(1_782_994_600_413_000_000n);
+  });
+
+  it("returns the current time in exact nanoseconds", () => {
+    vi.useFakeTimers();
+    vi.setSystemTime(new Date(EPOCH_MS));
+
+    expect(getNowInNanoseconds()).toBe(1_782_994_600_413_000_000n);
+  });
+
+  it("calculates an exact duration from a nanosecond start time", () => {
+    const startTime = convertDateToNanoseconds(new Date(EPOCH_MS));
+
+    expect(calculateDurationFromStart(startTime, new Date(EPOCH_MS + 2))).toBe(2_000_000);
+  });
+});