From f7792fb9ae0ef363ce928771c0940366c63fa6bd Mon Sep 17 00:00:00 2001
From: Alexey Zinoviev <alexey.zinoviev@xored.com>
Date: Tue, 11 Feb 2025 18:19:26 +0400
Subject: [PATCH] Qfix doc updates migration (#7984)

Signed-off-by: Alexey Zinoviev <alexey.zinoviev@xored.com>
---
 models/activity/src/migration.ts | 19 ++++++++-----------
 1 file changed, 8 insertions(+), 11 deletions(-)

diff --git a/models/activity/src/migration.ts b/models/activity/src/migration.ts
index 9fecfafe79..85f862e8c0 100644
--- a/models/activity/src/migration.ts
+++ b/models/activity/src/migration.ts
@@ -249,9 +249,9 @@ async function migrateAccountsInDocUpdates (client: MigrationClient): Promise<vo
     au: DocAttributeUpdates,
     update: MigrateUpdate<DocUpdateMessage>['attributeUpdates'],
     field: P
-  ): boolean {
+  ): void {
     const oldValue = au?.[field]
-    if (oldValue == null) return false
+    if (oldValue == null) return
 
     let changed = false
     let newValue: any
@@ -275,8 +275,6 @@ async function migrateAccountsInDocUpdates (client: MigrationClient): Promise<vo
 
       update[field] = newValue
     }
-
-    return changed
   }
 
   const iterator = await client.traverse(DOMAIN_ACTIVITY, {
@@ -301,15 +299,14 @@ async function migrateAccountsInDocUpdates (client: MigrationClient): Promise<vo
       for (const doc of docs) {
         const dum = doc as DocUpdateMessage
         if (dum.attributeUpdates == null) continue
-        let changed = false
         const update: any = { attributeUpdates: { ...dum.attributeUpdates } }
 
-        changed = migrateField(dum.attributeUpdates, update.attributeUpdates, 'added') || changed
-        changed = migrateField(dum.attributeUpdates, update.attributeUpdates, 'prevValue') || changed
-        changed = migrateField(dum.attributeUpdates, update.attributeUpdates, 'removed') || changed
-        changed = migrateField(dum.attributeUpdates, update.attributeUpdates, 'set') || changed
+        migrateField(dum.attributeUpdates, update.attributeUpdates, 'added')
+        migrateField(dum.attributeUpdates, update.attributeUpdates, 'prevValue')
+        migrateField(dum.attributeUpdates, update.attributeUpdates, 'removed')
+        migrateField(dum.attributeUpdates, update.attributeUpdates, 'set')
 
-        if (!changed) continue
+        update.attributeUpdates.attrClass = core.class.TypePersonId
 
         operations.push({
           filter: { _id: dum._id },
@@ -379,7 +376,7 @@ export const activityOperation: MigrateOperation = {
         func: migrateAccountsToSocialIds
       },
       {
-        state: 'accounts-in-doc-updates',
+        state: 'accounts-in-doc-updates-v2',
         func: migrateAccountsInDocUpdates
       }
     ])