feat: device import from integrations

apps/api/src/integration-platform/controllers/dynamic-integrations.controller.ts

@@ -65,6 +65,11 @@ export class DynamicIntegrationsController {
       ? SyncDefinitionSchema.parse(rawSyncDef)
       : undefined;
 
+    const rawDeviceSyncDef = body.deviceSyncDefinition;
+    const validatedDeviceSyncDef = rawDeviceSyncDef
+      ? SyncDefinitionSchema.parse(rawDeviceSyncDef)
+      : undefined;
+
     // Upsert the integration
     const integration = await this.dynamicIntegrationRepo.upsertBySlug({
       slug: def.slug,
@@ -83,6 +88,11 @@ export class DynamicIntegrationsController {
             JSON.stringify(validatedSyncDef),
           ) as Prisma.InputJsonValue)
         : null,
+      deviceSyncDefinition: validatedDeviceSyncDef
+        ? (JSON.parse(
+            JSON.stringify(validatedDeviceSyncDef),
+          ) as Prisma.InputJsonValue)
+        : null,
       services: (def.services as unknown as Prisma.InputJsonValue) ?? undefined,
     });
 
@@ -167,6 +177,12 @@ export class DynamicIntegrationsController {
     const validatedSyncDefCreate = rawSyncDefCreate
       ? SyncDefinitionSchema.parse(rawSyncDefCreate)
       : undefined;
+
+    const rawDeviceSyncDefCreate = body.deviceSyncDefinition;
+    const validatedDeviceSyncDefCreate = rawDeviceSyncDefCreate
+      ? SyncDefinitionSchema.parse(rawDeviceSyncDefCreate)
+      : undefined;
+
     const integration = await this.dynamicIntegrationRepo.create({
       slug: def.slug,
       name: def.name,
@@ -184,6 +200,11 @@ export class DynamicIntegrationsController {
             JSON.stringify(validatedSyncDefCreate),
           ) as Prisma.InputJsonValue)
         : undefined,
+      deviceSyncDefinition: validatedDeviceSyncDefCreate
+        ? (JSON.parse(
+            JSON.stringify(validatedDeviceSyncDefCreate),
+          ) as Prisma.InputJsonValue)
+        : undefined,
     });
 
     for (const [index, check] of def.checks.entries()) {