remove fusebox sync engine col

Author: BilalG1

apps/backend/prisma/migrations/20260204014127_external_db_metadata/migration.sql

@@ -13,7 +13,6 @@ CREATE TABLE "ExternalDbSyncMetadata" (
     "singleton" "BooleanTrue" NOT NULL DEFAULT 'TRUE',
     "sequencerEnabled" BOOLEAN NOT NULL DEFAULT true,
     "pollerEnabled" BOOLEAN NOT NULL DEFAULT true,
-    "syncEngineEnabled" BOOLEAN NOT NULL DEFAULT true,
     "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "updatedAt" TIMESTAMP(3) NOT NULL,
 

apps/backend/prisma/schema.prisma

@@ -101,7 +101,6 @@ model ExternalDbSyncMetadata {
 
   sequencerEnabled  Boolean @default(true)
   pollerEnabled     Boolean @default(true)
-  syncEngineEnabled Boolean @default(true)
 
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt

apps/backend/src/app/api/latest/internal/external-db-sync/fusebox/route.ts

@@ -17,7 +17,6 @@ const fuseboxResponseSchema = yupObject({
     ok: yupBoolean().defined(),
     sequencer_enabled: yupBoolean().defined(),
     poller_enabled: yupBoolean().defined(),
-    sync_engine_enabled: yupBoolean().defined(),
   }).defined(),
 });
 
@@ -29,7 +28,6 @@ const fuseboxRequestSchema = yupObject({
   body: yupObject({
     sequencer_enabled: yupBoolean().defined(),
     poller_enabled: yupBoolean().defined(),
-    sync_engine_enabled: yupBoolean().defined(),
   }).defined(),
   method: yupString().oneOf(["POST"]).defined(),
 });
@@ -67,7 +65,6 @@ export const GET = createSmartRouteHandler({
         ok: true,
         sequencer_enabled: fusebox.sequencerEnabled,
         poller_enabled: fusebox.pollerEnabled,
-        sync_engine_enabled: fusebox.syncEngineEnabled,
       },
     };
   },
@@ -87,7 +84,6 @@ export const POST = createSmartRouteHandler({
     const fusebox = await updateExternalDbSyncFusebox({
       sequencerEnabled: body.sequencer_enabled,
       pollerEnabled: body.poller_enabled,
-      syncEngineEnabled: body.sync_engine_enabled,
     });
     return {
       statusCode: 200,
@@ -96,7 +92,6 @@ export const POST = createSmartRouteHandler({
         ok: true,
         sequencer_enabled: fusebox.sequencerEnabled,
         poller_enabled: fusebox.pollerEnabled,
-        sync_engine_enabled: fusebox.syncEngineEnabled,
       },
     };
   },

apps/backend/src/app/api/latest/internal/external-db-sync/sync-engine/route.tsx

@@ -36,16 +36,6 @@ export const POST = createSmartRouteHandler({
       },
     }, async (span) => {
       await ensureUpstashSignature(fullReq);
-
-      const fusebox = await getExternalDbSyncFusebox();
-      span.setAttribute("stack.external-db-sync.sync-engine-enabled", fusebox.syncEngineEnabled);
-      if (!fusebox.syncEngineEnabled) {
-        return {
-          statusCode: 200,
-          bodyType: "success",
-        };
-      }
-
       const { tenancyId } = body;
 
       const tenancy = await traceSpan("external-db-sync.sync-engine.loadTenancy", async (tenancySpan) => {

apps/backend/src/lib/external-db-sync-metadata.ts

@@ -4,13 +4,11 @@ import { globalPrismaClient } from "@/prisma-client";
 export type ExternalDbSyncFusebox = {
   sequencerEnabled: boolean,
   pollerEnabled: boolean,
-  syncEngineEnabled: boolean,
 };
 
 const fuseboxSelect = {
   sequencerEnabled: true,
   pollerEnabled: true,
-  syncEngineEnabled: true,
 };
 
 export async function getExternalDbSyncFusebox(): Promise<ExternalDbSyncFusebox> {

apps/dashboard/src/app/(main)/(protected)/projects/[projectId]/external-db-sync/page-client.tsx

@@ -127,14 +127,12 @@ type ExternalDbSyncStatus = {
 type ExternalDbSyncFusebox = {
   sequencerEnabled: boolean,
   pollerEnabled: boolean,
-  syncEngineEnabled: boolean,
 };
 
 type ExternalDbSyncFuseboxResponse = {
   ok: true,
   sequencer_enabled: boolean,
   poller_enabled: boolean,
-  sync_engine_enabled: boolean,
 };
 
 type AdminAppInternals = {
@@ -293,7 +291,6 @@ export default function PageClient() {
     const nextFusebox = {
       sequencerEnabled: result.data.sequencer_enabled,
       pollerEnabled: result.data.poller_enabled,
-      syncEngineEnabled: result.data.sync_engine_enabled,
     };
     setFusebox(nextFusebox);
     setSavedFusebox(nextFusebox);
@@ -311,7 +308,6 @@ export default function PageClient() {
           body: JSON.stringify({
             sequencer_enabled: fusebox.sequencerEnabled,
             poller_enabled: fusebox.pollerEnabled,
-            sync_engine_enabled: fusebox.syncEngineEnabled,
           }),
           headers: { "content-type": "application/json" },
         },
@@ -335,7 +331,6 @@ export default function PageClient() {
     const nextFusebox = {
       sequencerEnabled: result.data.sequencer_enabled,
       pollerEnabled: result.data.poller_enabled,
-      syncEngineEnabled: result.data.sync_engine_enabled,
     };
     setFusebox(nextFusebox);
     setSavedFusebox(nextFusebox);
@@ -439,8 +434,7 @@ export default function PageClient() {
   const fuseboxDirty = useMemo(() => {
     if (!fusebox || !savedFusebox) return false;
     return fusebox.sequencerEnabled !== savedFusebox.sequencerEnabled
-      || fusebox.pollerEnabled !== savedFusebox.pollerEnabled
-      || fusebox.syncEngineEnabled !== savedFusebox.syncEngineEnabled;
+      || fusebox.pollerEnabled !== savedFusebox.pollerEnabled;
   }, [fusebox, savedFusebox]);
 
   if (adminApp.projectId !== "internal") {
@@ -722,16 +716,7 @@ export default function PageClient() {
                   onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, pollerEnabled: checked } : current)}
                 />
               </div>
-              <div className="flex items-center justify-between gap-6">
-                <div>
-                  <Typography type="p" className="text-sm font-medium">Sync engine</Typography>
-                  <Typography type="p" className="text-xs text-muted-foreground">Processes mapping batches for tenants.</Typography>
-                </div>
-                <Switch
-                  checked={fusebox.syncEngineEnabled}
-                  onCheckedChange={(checked) => setFusebox((current) => current ? { ...current, syncEngineEnabled: checked } : current)}
-                />
-              </div>
+
               <div className="flex justify-end">
                 <Button onClick={saveFusebox} disabled={!fuseboxDirty || savingFusebox} loading={savingFusebox}>
                   Save

apps/e2e/tests/backend/endpoints/api/v1/external-db-sync-basics.test.ts

@@ -468,7 +468,6 @@ describe.sequential('External DB Sync - Basic Tests', () => {
       ok: true,
       sequencer_enabled: expect.any(Boolean),
       poller_enabled: expect.any(Boolean),
-      sync_engine_enabled: expect.any(Boolean),
     });
 
     const postResponse = await niceBackendFetch('/api/latest/internal/external-db-sync/fusebox', {
@@ -477,7 +476,6 @@ describe.sequential('External DB Sync - Basic Tests', () => {
       body: {
         sequencer_enabled: getResponse.body.sequencer_enabled,
         poller_enabled: getResponse.body.poller_enabled,
-        sync_engine_enabled: getResponse.body.sync_engine_enabled,
       },
     });
 
@@ -486,7 +484,6 @@ describe.sequential('External DB Sync - Basic Tests', () => {
       ok: true,
       sequencer_enabled: getResponse.body.sequencer_enabled,
       poller_enabled: getResponse.body.poller_enabled,
-      sync_engine_enabled: getResponse.body.sync_engine_enabled,
     });
   }, TEST_TIMEOUT);
 });

apps/e2e/tests/backend/endpoints/api/v1/users.test.ts

@@ -9,7 +9,7 @@ describe("without project access", () => {
     projectKeys: "no-project",
   });
 
-  it("should not be able to read own user", async ({ expect }) => {
+  it.only("should not be able to read own user", async ({ expect }) => {
     await backendContext.with({
       projectKeys: InternalProjectKeys,
     }, async () => {