feat: integration builder POC [CM-1372]

backend/src/database/migrations/V1787829533__createSyncUnitsTable.sql

@@ -0,0 +1,25 @@
+CREATE TABLE IF NOT EXISTS integration.sync_units (
+    id                    UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    "integrationId"       UUID NOT NULL REFERENCES public.integrations(id),
+    platform              TEXT NOT NULL,
+    "channelId"           TEXT NOT NULL,
+    "channelName"         TEXT NOT NULL,
+    "syncName"            TEXT NOT NULL,
+    status                TEXT NOT NULL DEFAULT 'active'
+                          CHECK (status IN ('active','paused','dead_letter','decommissioned')),
+    "nextRunAt"           TIMESTAMPTZ NOT NULL DEFAULT now(),
+    "lockedAt"            TIMESTAMPTZ,
+    "lastRunAt"           TIMESTAMPTZ,
+    "lastSuccessAt"       TIMESTAMPTZ,
+    "consecutiveFailures" INT NOT NULL DEFAULT 0,
+    "lastErrorClass"      TEXT,
+    watermark             JSONB,
+    "emittedCount"        INT,
+    "createdAt"           TIMESTAMPTZ NOT NULL DEFAULT now(),
+    "updatedAt"           TIMESTAMPTZ NOT NULL DEFAULT now(),
+    UNIQUE ("integrationId", "channelId", "syncName")
+);
+
+CREATE INDEX IF NOT EXISTS "ix_sync_units_due"
+    ON integration.sync_units ("nextRunAt")
+    WHERE status = 'active';

backend/src/database/migrations/V1788362681__addSyncUnitObservabilityColumns.sql

@@ -0,0 +1,3 @@
+ALTER TABLE integration.sync_units
+  ADD COLUMN "lastErrorMessage" TEXT,
+  ADD COLUMN "lastRunComplete" BOOLEAN;