feat: add integrations and memberIdentities to Tinybird (#3064)

Author: epipav

backend/src/database/migrations/U1747210214__addMemberIdentitiesAndIntegrationsToTinybird.sql

@@ -0,0 +1,7 @@
+ALTER PUBLICATION sequin_pub ADD TABLE "memberIdentities";
+ALTER PUBLICATION sequin_pub ADD TABLE "integrations";
+ALTER TABLE public."memberIdentities" REPLICA IDENTITY FULL;
+ALTER TABLE public."integrations" REPLICA IDENTITY FULL;
+
+create index "ix_memberIdentities_updatedAt_id" on "memberIdentities" ("updatedAt", id);
+create index "ix_integrations_updatedAt_id" on "integrations" ("updatedAt", id);

backend/src/database/migrations/V1747210214__addMemberIdentitiesAndIntegrationsToTinybird.sql

@@ -0,0 +1,13 @@
+SCHEMA >
+    `id` String `json:$.record.id`,
+    `platform` String `json:$.record.platform` DEFAULT '',
+    `status` String `json:$.record.status` DEFAULT '',
+    `settings` String `json:$.record.settings` DEFAULT '',
+    `integrationIdentifier` String `json:$.record.integrationIdentifier` DEFAULT '',
+    `segmentId` String `json:$.record.segmentId` DEFAULT '',
+    `createdAt` DateTime64(3) `json:$.record.createdAt`,
+    `updatedAt` DateTime64(3) `json:$.record.updatedAt`
+
+ENGINE ReplacingMergeTree
+ENGINE_SORTING_KEY segmentId, id
+ENGINE_VER updatedAt

services/libs/tinybird/datasources/integrations.datasource

@@ -0,0 +1,16 @@
+SCHEMA >
+    `id` String `json:$.record.id`,
+    `memberId` String `json:$.record.id`,
+    `platform` String `json:$.record.platform`,
+    `value` String `json:$.record.value`,
+    `sourceId` String `json:$.record.sourceId` DEFAULT '',
+    `integrationId` String `json:$.record.integrationId` DEFAULT '',
+    `type` String `json:$.record.type`,
+    `verified` UInt8 `json:$.record.verified`,
+    `createdAt` DateTime64(3) `json:$.record.createdAt`,
+    `updatedAt` DateTime64(3) `json:$.record.updatedAt`
+
+ENGINE ReplacingMergeTree
+ENGINE_PARTITION_KEY toYear(createdAt)
+ENGINE_SORTING_KEY integrationId, memberId, id
+ENGINE_VER updatedAt