Organizations keeping existing website on integration updates (#1760)

Author: epipav

services/apps/data_sink_worker/src/service/organization.service.ts

@@ -188,7 +188,13 @@ export class OrganizationService extends LoggerBase {
             'weakIdentities',
           ]
           fields.forEach((field) => {
-            if (cached[field] && !isEqual(cached[field], existing[field])) {
+            if (field === 'website' && !existing.website) {
+              updateData[field] = cached[field]
+            } else if (
+              field !== 'website' &&
+              cached[field] &&
+              !isEqual(cached[field], existing[field])
+            ) {
               updateData[field] = cached[field]
             }
           })
@@ -235,6 +241,15 @@ export class OrganizationService extends LoggerBase {
 
         const identities = await txRepo.getIdentities(id, tenantId)
 
+        // create identities with incoming website
+        if (data.website) {
+          data.identities.push({
+            name: websiteNormalizer(data.website),
+            platform: 'email',
+            integrationId,
+          })
+        }
+
         for (const identity of data.identities) {
           const identityExists = identities.find(
             (i) => i.name === identity.name && i.platform === identity.platform,