Generated with Hive: Add performance trace models, ingest endpoint, signature and sketch utils, and seed data

prisma/migrations/20260702145209_add_performance_trace_models/migration.sql

@@ -0,0 +1,75 @@
+-- CreateTable
+CREATE TABLE "performance_trace_groups" (
+    "id" TEXT NOT NULL,
+    "workspace_id" TEXT NOT NULL,
+    "repository_id" TEXT,
+    "repo_key" TEXT NOT NULL,
+    "transaction_name" TEXT NOT NULL,
+    "signature" TEXT NOT NULL,
+    "sample_count" INTEGER NOT NULL DEFAULT 1,
+    "p50_ms" DOUBLE PRECISION NOT NULL,
+    "p95_ms" DOUBLE PRECISION NOT NULL,
+    "p99_ms" DOUBLE PRECISION NOT NULL,
+    "throughput" DOUBLE PRECISION NOT NULL,
+    "db_time_ms" DOUBLE PRECISION NOT NULL,
+    "sketch_state" JSONB NOT NULL,
+    "first_seen_at" TIMESTAMP(3) NOT NULL,
+    "last_seen_at" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "performance_trace_groups_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateTable
+CREATE TABLE "performance_trace_events" (
+    "id" TEXT NOT NULL,
+    "group_id" TEXT NOT NULL,
+    "workspace_id" TEXT NOT NULL,
+    "repository_id" TEXT,
+    "repo_key" TEXT NOT NULL,
+    "blob_url" TEXT NOT NULL,
+    "transaction_name" TEXT NOT NULL,
+    "total_duration_ms" DOUBLE PRECISION NOT NULL,
+    "spans" JSONB NOT NULL,
+    "created_at" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+
+    CONSTRAINT "performance_trace_events_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE INDEX "performance_trace_groups_workspace_id_idx" ON "performance_trace_groups"("workspace_id");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_groups_repository_id_idx" ON "performance_trace_groups"("repository_id");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_groups_last_seen_at_idx" ON "performance_trace_groups"("last_seen_at");
+
+-- CreateIndex
+CREATE UNIQUE INDEX "performance_trace_groups_workspace_id_repo_key_signature_key" ON "performance_trace_groups"("workspace_id", "repo_key", "signature");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_events_group_id_idx" ON "performance_trace_events"("group_id");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_events_workspace_id_idx" ON "performance_trace_events"("workspace_id");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_events_repository_id_idx" ON "performance_trace_events"("repository_id");
+
+-- CreateIndex
+CREATE INDEX "performance_trace_events_created_at_idx" ON "performance_trace_events"("created_at");
+
+-- AddForeignKey
+ALTER TABLE "performance_trace_groups" ADD CONSTRAINT "performance_trace_groups_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "performance_trace_groups" ADD CONSTRAINT "performance_trace_groups_repository_id_fkey" FOREIGN KEY ("repository_id") REFERENCES "repositories"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "performance_trace_events" ADD CONSTRAINT "performance_trace_events_group_id_fkey" FOREIGN KEY ("group_id") REFERENCES "performance_trace_groups"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "performance_trace_events" ADD CONSTRAINT "performance_trace_events_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces"("id") ON DELETE CASCADE ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "performance_trace_events" ADD CONSTRAINT "performance_trace_events_repository_id_fkey" FOREIGN KEY ("repository_id") REFERENCES "repositories"("id") ON DELETE SET NULL ON UPDATE CASCADE;

prisma/schema.prisma

@@ -286,6 +286,8 @@ model Workspace {
   agentLogs               AgentLog[]
   errorIssues             ErrorIssue[]
   errorEvents             ErrorEvent[]
+  performanceTraceGroups  PerformanceTraceGroup[]
+  performanceTraceEvents  PerformanceTraceEvent[]
   diagrams                DiagramWorkspace[]
   discordChannels         DiscordChannel[]
   features                Feature[]
@@ -515,9 +517,11 @@ model Repository {
   deployments           Deployment[]
   recommendations       JanitorRecommendation[]
   janitorRuns           JanitorRun[]
-  errorIssues           ErrorIssue[]
-  errorEvents           ErrorEvent[]
-  workspace             Workspace               @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
+  errorIssues              ErrorIssue[]
+  errorEvents              ErrorEvent[]
+  performanceTraceGroups   PerformanceTraceGroup[]
+  performanceTraceEvents   PerformanceTraceEvent[]
+  workspace                Workspace               @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
   tasks                 Task[]
 
   @@unique([repositoryUrl, workspaceId], name: "repositoryUrl_workspaceId")
@@ -2198,6 +2202,59 @@ model ErrorEvent {
   @@map("error_events")
 }
 
+/// Deduplicated performance trace group — one row per unique (workspace, repoKey, signature).
+/// repoKey is non-null: resolved repositoryId when matched, normalised raw identifier, or "unknown".
+/// sketchState stores the serialized latency sketch for streaming p50/p95/p99 updates.
+model PerformanceTraceGroup {
+  id              String                  @id @default(cuid())
+  workspaceId     String                  @map("workspace_id")
+  repositoryId    String?                 @map("repository_id")
+  repoKey         String                  @map("repo_key")
+  transactionName String                  @map("transaction_name")
+  signature       String
+  sampleCount     Int                     @default(1) @map("sample_count")
+  p50Ms           Float                   @map("p50_ms")
+  p95Ms           Float                   @map("p95_ms")
+  p99Ms           Float                   @map("p99_ms")
+  throughput      Float
+  dbTimeMs        Float                   @map("db_time_ms")
+  sketchState     Json                    @map("sketch_state")
+  firstSeenAt     DateTime                @map("first_seen_at")
+  lastSeenAt      DateTime                @map("last_seen_at")
+  workspace       Workspace               @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
+  repository      Repository?             @relation(fields: [repositoryId], references: [id], onDelete: SetNull)
+  events          PerformanceTraceEvent[]
+
+  @@unique([workspaceId, repoKey, signature])
+  @@index([workspaceId])
+  @@index([repositoryId])
+  @@index([lastSeenAt])
+  @@map("performance_trace_groups")
+}
+
+/// Individual performance trace sample linked to its deduplicated group.
+model PerformanceTraceEvent {
+  id              String                 @id @default(cuid())
+  groupId         String                 @map("group_id")
+  workspaceId     String                 @map("workspace_id")
+  repositoryId    String?                @map("repository_id")
+  repoKey         String                 @map("repo_key")
+  blobUrl         String                 @map("blob_url")
+  transactionName String                 @map("transaction_name")
+  totalDurationMs Float                  @map("total_duration_ms")
+  spans           Json
+  createdAt       DateTime               @default(now()) @map("created_at")
+  group           PerformanceTraceGroup  @relation(fields: [groupId], references: [id], onDelete: Cascade)
+  workspace       Workspace              @relation(fields: [workspaceId], references: [id], onDelete: Cascade)
+  repository      Repository?            @relation(fields: [repositoryId], references: [id], onDelete: SetNull)
+
+  @@index([groupId])
+  @@index([workspaceId])
+  @@index([repositoryId])
+  @@index([createdAt])
+  @@map("performance_trace_events")
+}
+
 /// Cross-realm typed edge between two URN-addressed nodes.
 /// Persists relationships between Postgres entities, Canvas authored nodes,
 /// and KG concepts that cannot be expressed via FK columns alone.

scripts/helpers/seed-database.ts

@@ -17,6 +17,7 @@ import { config as dotenvConfig } from "dotenv";
 import { seedDeploymentTracking } from "./seed-deployment-tracking";
 import { seedAgentLogs } from "./seed-agent-logs";
 import { seedErrorEvents } from "./seed-error-events";
+import { seedPerformanceTraces } from "./seed-performance-traces";
 
 dotenvConfig({ path: ".env.local" });
 
@@ -1903,6 +1904,7 @@ async function main() {
   await seedDeploymentTracking();
   await seedAgentLogs();
   await seedErrorEvents();
+  await seedPerformanceTraces();
   await seedDashboardConversations(users);
   await seedPlatformConfig();
   await seedInitiativesAndMilestones(users);