feat(run-store): wire RunStore into run-engine SystemResources and webapp BaseService

Add RunStore field to SystemResources, instantiate PostgresRunStore in
RunEngine constructor (after prisma/readOnlyPrisma are set), and expose
it on the resources object passed to all systems. Create a webapp
singleton (runStore.server.ts) and thread it as a default parameter
into BaseService so subclasses can access it without changes.

Author: d-cs

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

@@ -0,0 +1,8 @@
+import { PostgresRunStore } from "@internal/run-store";
+import { $replica, prisma } from "~/db.server";
+import { singleton } from "~/utils/singleton";
+
+export const runStore = singleton(
+  "PostgresRunStore",
+  () => new PostgresRunStore({ prisma, readOnlyPrisma: $replica })
+);

apps/webapp/app/v3/services/baseService.server.ts

@@ -1,16 +1,19 @@
 import { Span, SpanKind } from "@opentelemetry/api";
+import type { RunStore } from "@internal/run-store";
 import { $replica, PrismaClientOrTransaction, prisma } from "~/db.server";
 import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
 import { attributesFromAuthenticatedEnv, tracer } from "../tracer.server";
 import { engine, RunEngine } from "../runEngine.server";
+import { runStore as defaultRunStore } from "../runStore.server";
 import { ServiceValidationError } from "./common.server";
 
 export { ServiceValidationError };
 
 export abstract class BaseService {
   constructor(
     protected readonly _prisma: PrismaClientOrTransaction = prisma,
-    protected readonly _replica: PrismaClientOrTransaction = $replica
+    protected readonly _replica: PrismaClientOrTransaction = $replica,
+    protected readonly runStore: RunStore = defaultRunStore
   ) {}
 
   protected async traceWithEnv<T>(

internal-packages/run-engine/src/engine/index.ts

@@ -73,6 +73,7 @@ import { RaceSimulationSystem } from "./systems/raceSimulationSystem.js";
 import { RunAttemptSystem } from "./systems/runAttemptSystem.js";
 import { NoopPendingVersionRunIdLookup } from "./services/pendingVersionLookup.js";
 import { SystemResources } from "./systems/systems.js";
+import { PostgresRunStore, RunStore } from "@internal/run-store";
 import { TtlSystem } from "./systems/ttlSystem.js";
 import { WaitpointSystem } from "./systems/waitpointSystem.js";
 import {
@@ -102,6 +103,7 @@ export class RunEngine {
 
   prisma: PrismaClient;
   readOnlyPrisma: PrismaReplicaClient;
+  runStore: RunStore;
   runQueue: RunQueue;
   eventBus: EventBus = new EventEmitter<EventBusEvents>();
   executionSnapshotSystem: ExecutionSnapshotSystem;
@@ -123,6 +125,7 @@ export class RunEngine {
     this.logger = options.logger ?? new Logger("RunEngine", this.options.logLevel ?? "info");
     this.prisma = options.prisma;
     this.readOnlyPrisma = options.readOnlyPrisma ?? this.prisma;
+    this.runStore = new PostgresRunStore({ prisma: this.prisma, readOnlyPrisma: this.readOnlyPrisma });
     this.runLockRedis = createRedisClient(
       {
         ...options.runLock.redis,
@@ -313,6 +316,7 @@ export class RunEngine {
     const resources: SystemResources = {
       prisma: this.prisma,
       readOnlyPrisma: this.readOnlyPrisma,
+      runStore: this.runStore,
       worker: this.worker,
       eventBus: this.eventBus,
       logger: this.logger,

internal-packages/run-engine/src/engine/systems/systems.ts

@@ -1,4 +1,5 @@
 import { Meter, Tracer } from "@internal/tracing";
+import { RunStore } from "@internal/run-store";
 import { Logger } from "@trigger.dev/core/logger";
 import { PrismaClient, PrismaReplicaClient } from "@trigger.dev/database";
 import { RunQueue } from "../../run-queue/index.js";
@@ -11,6 +12,7 @@ import { RaceSimulationSystem } from "./raceSimulationSystem.js";
 export type SystemResources = {
   prisma: PrismaClient;
   readOnlyPrisma: PrismaReplicaClient;
+  runStore: RunStore;
   worker: EngineWorker;
   eventBus: EventBus;
   logger: Logger;