various new clickhouse syncs

apps/backend/prisma/migrations/20260316000000_add_team_team_member_sequence_columns/migration.sql

@@ -0,0 +1,25 @@
+-- AlterTable
+ALTER TABLE "Team" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Team_sequenceId_key" ON "Team"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "Team_tenancyId_sequenceId_idx" ON "Team"("tenancyId", "sequenceId");
+
+-- CreateIndex
+CREATE INDEX "Team_shouldUpdateSequenceId_idx" ON "Team"("shouldUpdateSequenceId", "tenancyId");
+
+-- AlterTable
+ALTER TABLE "TeamMember" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "TeamMember_sequenceId_key" ON "TeamMember"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "TeamMember_tenancyId_sequenceId_idx" ON "TeamMember"("tenancyId", "sequenceId");
+
+-- CreateIndex
+CREATE INDEX "TeamMember_shouldUpdateSequenceId_idx" ON "TeamMember"("shouldUpdateSequenceId", "tenancyId");

apps/backend/prisma/migrations/20260316000001_add_email_outbox_sequence_columns/migration.sql

@@ -0,0 +1,12 @@
+-- AlterTable
+ALTER TABLE "EmailOutbox" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "EmailOutbox_sequenceId_key" ON "EmailOutbox"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "EmailOutbox_tenancyId_sequenceId_idx" ON "EmailOutbox"("tenancyId", "sequenceId");
+
+-- CreateIndex
+CREATE INDEX "EmailOutbox_shouldUpdateSequenceId_idx" ON "EmailOutbox"("shouldUpdateSequenceId", "tenancyId");

apps/backend/prisma/migrations/20260316000002_add_session_replay_sequence_columns/migration.sql

@@ -0,0 +1,12 @@
+-- AlterTable
+ALTER TABLE "SessionReplay" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "SessionReplay_sequenceId_key" ON "SessionReplay"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "SessionReplay_tenancyId_sequenceId_idx" ON "SessionReplay"("tenancyId", "sequenceId");
+
+-- CreateIndex
+CREATE INDEX "SessionReplay_shouldUpdateSequenceId_idx" ON "SessionReplay"("shouldUpdateSequenceId", "tenancyId");

apps/backend/prisma/migrations/20260317000000_add_team_permission_invitation_sequence_columns/migration.sql

@@ -0,0 +1,22 @@
+-- AlterTable
+ALTER TABLE "TeamMemberDirectPermission" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "TeamMemberDirectPermission_sequenceId_key" ON "TeamMemberDirectPermission"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "TeamMemberDirectPermission_shouldUpdateSequenceId_idx" ON "TeamMemberDirectPermission"("shouldUpdateSequenceId", "tenancyId");
+
+-- CreateIndex
+CREATE INDEX "TeamMemberDirectPermission_tenancyId_sequenceId_idx" ON "TeamMemberDirectPermission"("tenancyId", "sequenceId");
+
+-- AlterTable
+ALTER TABLE "VerificationCode" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "VerificationCode_sequenceId_key" ON "VerificationCode"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "VerificationCode_shouldUpdateSequenceId_type_idx" ON "VerificationCode"("shouldUpdateSequenceId", "type");

apps/backend/prisma/migrations/20260317000001_add_project_permission_notification_preference_sequence_columns/migration.sql

@@ -0,0 +1,25 @@
+-- AlterTable
+ALTER TABLE "ProjectUserDirectPermission" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "ProjectUserDirectPermission_sequenceId_key" ON "ProjectUserDirectPermission"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserDirectPermission_shouldUpdateSequenceId_idx" ON "ProjectUserDirectPermission"("shouldUpdateSequenceId", "tenancyId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserDirectPermission_tenancyId_sequenceId_idx" ON "ProjectUserDirectPermission"("tenancyId", "sequenceId");
+
+-- AlterTable
+ALTER TABLE "UserNotificationPreference" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "UserNotificationPreference_sequenceId_key" ON "UserNotificationPreference"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "UserNotificationPreference_shouldUpdateSequenceId_idx" ON "UserNotificationPreference"("shouldUpdateSequenceId", "tenancyId");
+
+-- CreateIndex
+CREATE INDEX "UserNotificationPreference_tenancyId_sequenceId_idx" ON "UserNotificationPreference"("tenancyId", "sequenceId");

apps/backend/prisma/migrations/20260318000000_add_sequence_id_to_refresh_tokens_and_oauth_accounts/migration.sql

@@ -0,0 +1,25 @@
+-- AlterTable
+ALTER TABLE "ProjectUserRefreshToken" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "ProjectUserRefreshToken_sequenceId_key" ON "ProjectUserRefreshToken"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserRefreshToken_shouldUpdateSequenceId_idx" ON "ProjectUserRefreshToken"("shouldUpdateSequenceId", "tenancyId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserRefreshToken_tenancyId_sequenceId_idx" ON "ProjectUserRefreshToken"("tenancyId", "sequenceId");
+
+-- AlterTable
+ALTER TABLE "ProjectUserOAuthAccount" ADD COLUMN "sequenceId" BIGINT,
+ADD COLUMN "shouldUpdateSequenceId" BOOLEAN NOT NULL DEFAULT true;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "ProjectUserOAuthAccount_sequenceId_key" ON "ProjectUserOAuthAccount"("sequenceId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserOAuthAccount_shouldUpdateSequenceId_idx" ON "ProjectUserOAuthAccount"("shouldUpdateSequenceId", "tenancyId");
+
+-- CreateIndex
+CREATE INDEX "ProjectUserOAuthAccount_tenancyId_sequenceId_idx" ON "ProjectUserOAuthAccount"("tenancyId", "sequenceId");

apps/backend/prisma/schema.prisma

@@ -179,11 +179,16 @@ model Team {
   serverMetadata         Json?
   profileImageUrl        String?
 
+  sequenceId             BigInt? @unique
+  shouldUpdateSequenceId Boolean @default(true)
+
   teamMembers   TeamMember[]
   projectApiKey ProjectApiKey[]
 
   @@id([tenancyId, teamId])
   @@unique([mirroredProjectId, mirroredBranchId, teamId])
+  @@index([tenancyId, sequenceId], name: "Team_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "Team_shouldUpdateSequenceId_idx")
 }
 
 // This is used for fields that are boolean but only the true value is part of a unique constraint.
@@ -205,6 +210,9 @@ model TeamMember {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
+  sequenceId             BigInt? @unique
+  shouldUpdateSequenceId Boolean @default(true)
+
   projectUser                 ProjectUser                  @relation(fields: [tenancyId, projectUserId], references: [tenancyId, projectUserId], onDelete: Cascade)
   team                        Team                         @relation(fields: [tenancyId, teamId], references: [tenancyId, teamId], onDelete: Cascade)
   isSelected                  BooleanTrue?
@@ -213,6 +221,8 @@ model TeamMember {
   @@id([tenancyId, projectUserId, teamId])
   @@unique([tenancyId, projectUserId, isSelected])
   @@index([tenancyId, projectUserId, isSelected], map: "TeamMember_projectUserId_isSelected_idx")
+  @@index([tenancyId, sequenceId], name: "TeamMember_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "TeamMember_shouldUpdateSequenceId_idx")
 }
 
 model ProjectUserDirectPermission {
@@ -226,7 +236,12 @@ model ProjectUserDirectPermission {
 
   projectUser ProjectUser @relation(fields: [tenancyId, projectUserId], references: [tenancyId, projectUserId], onDelete: Cascade)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@unique([tenancyId, projectUserId, permissionId])
+  @@index([shouldUpdateSequenceId, tenancyId], name: "ProjectUserDirectPermission_shouldUpdateSequenceId_idx")
+  @@index([tenancyId, sequenceId], name: "ProjectUserDirectPermission_tenancyId_sequenceId_idx")
 }
 
 model TeamMemberDirectPermission {
@@ -241,7 +256,12 @@ model TeamMemberDirectPermission {
 
   teamMember TeamMember @relation(fields: [tenancyId, projectUserId, teamId], references: [tenancyId, projectUserId, teamId], onDelete: Cascade)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@unique([tenancyId, projectUserId, teamId, permissionId])
+  @@index([shouldUpdateSequenceId, tenancyId], name: "TeamMemberDirectPermission_shouldUpdateSequenceId_idx")
+  @@index([tenancyId, sequenceId], name: "TeamMemberDirectPermission_tenancyId_sequenceId_idx")
 }
 
 model ProjectUser {
@@ -328,9 +348,14 @@ model ProjectUserOAuthAccount {
   allowConnectedAccounts Boolean          @default(true)
   allowSignIn            Boolean          @default(true)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@id([tenancyId, id])
   @@unique([tenancyId, configOAuthProviderId, projectUserId, providerAccountId])
   @@index([tenancyId, projectUserId])
+  @@index([tenancyId, sequenceId], name: "ProjectUserOAuthAccount_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "ProjectUserOAuthAccount_shouldUpdateSequenceId_idx")
 }
 
 model SessionReplay {
@@ -346,6 +371,9 @@ model SessionReplay {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
+  sequenceId             BigInt? @unique
+  shouldUpdateSequenceId Boolean @default(true)
+
   projectUser ProjectUser @relation(fields: [tenancyId, projectUserId], references: [tenancyId, projectUserId], onDelete: Cascade)
   tenancy     Tenancy     @relation(fields: [tenancyId], references: [id], onDelete: Cascade)
 
@@ -357,6 +385,8 @@ model SessionReplay {
   @@index([tenancyId, lastEventAt])
   // index by updatedAt instead of lastEventAt because event timing can be spoofed
   @@index([tenancyId, refreshTokenId, updatedAt])
+  @@index([tenancyId, sequenceId], name: "SessionReplay_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "SessionReplay_shouldUpdateSequenceId_idx")
 }
 
 model SessionReplayChunk {
@@ -597,7 +627,12 @@ model ProjectUserRefreshToken {
   expiresAt       DateTime?
   isImpersonation Boolean   @default(false)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@id([tenancyId, id])
+  @@index([tenancyId, sequenceId], name: "ProjectUserRefreshToken_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "ProjectUserRefreshToken_shouldUpdateSequenceId_idx")
 }
 
 model ProjectUserAuthorizationCode {
@@ -637,9 +672,13 @@ model VerificationCode {
   data         Json
   attemptCount Int                  @default(0)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@id([projectId, branchId, id])
   @@unique([projectId, branchId, code])
   @@index([data(ops: JsonbPathOps)], type: Gin)
+  @@index([shouldUpdateSequenceId, type], name: "VerificationCode_shouldUpdateSequenceId_type_idx")
 }
 
 enum VerificationCodeType {
@@ -994,13 +1033,18 @@ model EmailOutbox {
   unsubscribedAt DateTime?
   markedAsSpamAt DateTime?
 
+  sequenceId             BigInt? @unique
+  shouldUpdateSequenceId Boolean @default(true)
+
   tenancy Tenancy @relation(fields: [tenancyId], references: [id], onDelete: Cascade)
 
   @@id([tenancyId, id])
   @@index([tenancyId, finishedSendingAt(sort: Desc), scheduledAtIfNotYetQueued(sort: Desc), priority, id], map: "EmailOutbox_ordering_idx")
   @@index([tenancyId, simpleStatus], map: "EmailOutbox_simple_status_tenancy_idx")
   @@index([tenancyId, status], map: "EmailOutbox_status_tenancy_idx")
   @@index([isQueued], map: "EmailOutbox_isQueued_idx")
+  @@index([tenancyId, sequenceId], name: "EmailOutbox_tenancyId_sequenceId_idx")
+  @@index([shouldUpdateSequenceId, tenancyId], name: "EmailOutbox_shouldUpdateSequenceId_idx")
 }
 
 model EmailOutboxProcessingMetadata {
@@ -1060,8 +1104,13 @@ model UserNotificationPreference {
   enabled     Boolean
   projectUser ProjectUser @relation(fields: [tenancyId, projectUserId], references: [tenancyId, projectUserId], onDelete: Cascade)
 
+  sequenceId             BigInt?  @unique
+  shouldUpdateSequenceId Boolean  @default(true)
+
   @@id([tenancyId, id])
   @@unique([tenancyId, projectUserId, notificationCategoryId])
+  @@index([shouldUpdateSequenceId, tenancyId], name: "UserNotificationPreference_shouldUpdateSequenceId_idx")
+  @@index([tenancyId, sequenceId], name: "UserNotificationPreference_tenancyId_sequenceId_idx")
 }
 
 model ThreadMessage {