Add Waitpoint resolver

Author: matt-aitken

internal-packages/database/prisma/migrations/20250502154714_waitpoint_added_resolvers/migration.sql

@@ -0,0 +1,6 @@
+-- CreateEnum
+CREATE TYPE "WaitpointResolver" AS ENUM ('ENGINE', 'TOKEN', 'HTTP_CALLBACK');
+
+-- AlterTable
+ALTER TABLE "Waitpoint"
+ADD COLUMN "resolver" "WaitpointResolver" NOT NULL DEFAULT 'ENGINE';

internal-packages/database/prisma/migrations/20250502155009_waitpoint_resolve_index_for_dashboard/migration.sql

@@ -0,0 +1,2 @@
+-- CreateIndex
+CREATE INDEX CONCURRENTLY IF NOT EXISTS "Waitpoint_environmentId_resolver_createdAt_idx" ON "Waitpoint" ("environmentId", "resolver", "createdAt" DESC);

internal-packages/database/prisma/schema.prisma

@@ -2100,6 +2100,9 @@ model Waitpoint {
   type   WaitpointType
   status WaitpointStatus @default(PENDING)
 
+  /// This is what will resolve the waitpoint, used to filter waitpoints in the dashboard
+  resolver WaitpointResolver @default(ENGINE)
+
   completedAt DateTime?
 
   /// If it's an Event type waitpoint, this is the event. It can also be provided for the DATETIME type
@@ -2150,7 +2153,7 @@ model Waitpoint {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  /// Denormized column that holds the raw tags
+  /// Denormalized column that holds the raw tags
   tags String[]
 
   /// Quickly find an idempotent waitpoint
@@ -2162,6 +2165,8 @@ model Waitpoint {
   @@index([environmentId, type, createdAt(sort: Desc)])
   /// Status filtering
   @@index([environmentId, type, status])
+  /// Dashboard filtering
+  @@index([environmentId, resolver, createdAt(sort: Desc)])
 }
 
 enum WaitpointType {
@@ -2176,6 +2181,15 @@ enum WaitpointStatus {
   COMPLETED
 }
 
+enum WaitpointResolver {
+  /// The engine itself will resolve the waitpoint
+  ENGINE
+  /// A token will resolve the waitpoint, i.e. the user completes a token
+  TOKEN
+  /// A HTTP callback will resolve the waitpoint, i.e. the user uses our waitForHttpCallback function
+  HTTP_CALLBACK
+}
+
 model TaskRunWaitpoint {
   id String @id @default(cuid())