feat: Add support for reset MLS conversation event [WPB-17706] (#19407)

* feat: Add support for reset MLS conversation event [WPB-17706]

* bump core

Author: thisisamir98

package.json

@@ -16,7 +16,7 @@
     "@wireapp/avs": "10.0.46",
     "@wireapp/avs-debugger": "0.0.7",
     "@wireapp/commons": "5.4.3",
-    "@wireapp/core": "46.33.0",
+    "@wireapp/core": "46.34.0",
     "@wireapp/kalium-backup": "0.0.4",
     "@wireapp/react-ui-kit": "9.63.0",
     "@wireapp/store-engine-dexie": "2.1.15",

src/script/repositories/conversation/ConversationRepository.ts

@@ -46,6 +46,7 @@ import {
   CONVERSATION_EVENT,
   ConversationProtocolUpdateEvent,
   ConversationAddPermissionUpdateEvent,
+  ConversationMLSResetEvent,
 } from '@wireapp/api-client/lib/event';
 import {BackendErrorLabel} from '@wireapp/api-client/lib/http/';
 import type {BackendError} from '@wireapp/api-client/lib/http/';
@@ -1110,9 +1111,15 @@ export class ConversationRepository {
     return this.updateConversations(this.conversationState.archivedConversations());
   }
 
-  private async updateConversationFromBackend(conversationEntity: Conversation) {
+  private async updateConversationFromBackend(conversationEntity: Conversation): Promise<void> {
     const conversationData = await this.conversationService.getConversationById(conversationEntity);
-    const {name, message_timer, type} = conversationData;
+    const {name, message_timer, type, group_id: groupId, epoch} = conversationData;
+
+    if (groupId && typeof epoch === 'number') {
+      ConversationMapper.updateProperties(conversationEntity, {groupId, epoch});
+    }
+
+    ConversationMapper.updateProperties(conversationEntity, {name, type});
     ConversationMapper.updateProperties(conversationEntity, {name, type});
     ConversationMapper.updateSelfStatus(conversationEntity, {message_timer});
   }
@@ -2791,9 +2798,9 @@ export class ConversationRepository {
    * @returns Resolves with updated conversation entity
    */
   private async refreshConversationProtocolProperties(conversation: Conversation) {
-    //refetch the conversation to get all new fields (groupId, ciphersuite, epoch and new protocol)
+    // refetch the conversation to get all new fields (groupId, ciphersuite, epoch and new protocol)
     const remoteConversationData = await this.conversationService.getConversationById(conversation.qualifiedId);
-    //update fields that came after protocol update
+    // update fields that came after protocol update
     const {cipher_suite: cipherSuite, epoch, group_id: newGroupId, protocol: newProtocol} = remoteConversationData;
     const updatedConversation = ConversationMapper.updateProperties(conversation, {
       cipherSuite,
@@ -3192,7 +3199,11 @@ export class ConversationRepository {
 
     const inSelfConversation = this.conversationState.isSelfConversation(conversationId);
     if (inSelfConversation) {
-      const typesInSelfConversation = [CONVERSATION_EVENT.MEMBER_UPDATE, ClientEvent.CONVERSATION.MESSAGE_HIDDEN];
+      const typesInSelfConversation = [
+        CONVERSATION_EVENT.MEMBER_UPDATE,
+        CONVERSATION_EVENT.MLS_RESET,
+        ClientEvent.CONVERSATION.MESSAGE_HIDDEN,
+      ];
 
       const isExpectedType = typesInSelfConversation.includes(type);
       if (!isExpectedType) {
@@ -3406,6 +3417,9 @@ export class ConversationRepository {
       case CONVERSATION_EVENT.MLS_WELCOME_MESSAGE:
         return this.onMLSWelcomeMessage(conversationEntity);
 
+      case CONVERSATION_EVENT.MLS_RESET:
+        return this.onMLSResetMessage(conversationEntity, eventJson);
+
       case ClientEvent.CONVERSATION.ASSET_ADD:
         return this.onAssetAdd(conversationEntity, eventJson);
 
@@ -4101,6 +4115,28 @@ export class ConversationRepository {
     await this.resolve1To1Conversation(otherUserId);
   }
 
+  /**
+   * A user has reset an MLS Conversation.
+   * This means group id and epoch have changed, so we need to
+   * update the conversation to the latest group id and epoch.
+   *
+   * @param conversationEntity Conversation entity user has received a welcome message in
+   * @returns Resolves when the event was handled
+   */
+  private async onMLSResetMessage(conversationEntity: Conversation, eventJson: ConversationMLSResetEvent) {
+    try {
+      if (!isMLSConversation(conversationEntity)) {
+        return;
+      }
+
+      await this.core.service?.conversation.wipeMLSConversation(eventJson.data.group_id);
+
+      await this.refreshConversationProtocolProperties(conversationEntity);
+    } catch (error) {
+      this.logger.error(`Failed to reset MLS conversation ${conversationEntity.id}`, error);
+    }
+  }
+
   /**
    * A user started or stopped typing in a conversation.
    *

yarn.lock

@@ -8094,9 +8094,9 @@ __metadata:
   languageName: node
   linkType: hard
 
-"@wireapp/api-client@npm:^27.74.0":
-  version: 27.74.0
-  resolution: "@wireapp/api-client@npm:27.74.0"
+"@wireapp/api-client@npm:^27.75.0":
+  version: 27.75.0
+  resolution: "@wireapp/api-client@npm:27.75.0"
   dependencies:
     "@aws-sdk/client-s3": "npm:3.864.0"
     "@aws-sdk/lib-storage": "npm:3.864.0"
@@ -8115,7 +8115,7 @@ __metadata:
     uuid: "npm:11.1.0"
     ws: "npm:8.18.1"
     zod: "npm:3.24.2"
-  checksum: 10/e257ac14c6bd575f2cb9699ccdaace2583e4dbb63dd5f2219375d449fe69f69bcc75c38bb76a1e99e488006db452b2b76840b3075402ad9eb3ec2d344b07d23c
+  checksum: 10/d1c44e63897e00318d9cc7c5adef0c1a2c7ccdcc9b158a4cb8b9d99c1d6978ddfcb7226379e9cdb9037d091217edb07770421f791cf442060de98194a45274d3
   languageName: node
   linkType: hard
 
@@ -8192,11 +8192,11 @@ __metadata:
   languageName: node
   linkType: hard
 
-"@wireapp/core@npm:46.33.0":
-  version: 46.33.0
-  resolution: "@wireapp/core@npm:46.33.0"
+"@wireapp/core@npm:46.34.0":
+  version: 46.34.0
+  resolution: "@wireapp/core@npm:46.34.0"
   dependencies:
-    "@wireapp/api-client": "npm:^27.74.0"
+    "@wireapp/api-client": "npm:^27.75.0"
     "@wireapp/commons": "npm:^5.4.4"
     "@wireapp/core-crypto": "npm:7.0.2"
     "@wireapp/cryptobox": "npm:12.8.0"
@@ -8214,7 +8214,7 @@ __metadata:
     long: "npm:^5.2.0"
     uuid: "npm:9.0.1"
     zod: "npm:3.24.2"
-  checksum: 10/ed49aee978368d8981ed623c0ffb92035d5e0eb3fd567fd800976cfab6576980817acd47caefed1b708b5a77935339a4aa104500a9aafac45f9058d6afd16079
+  checksum: 10/4b66657311c6f69f100f9ece61cca9c95be8efeaf6ffa68e17d1221e0904fd1dbd769d218ae7c320f4338a9f2dea98e279fe49e2ee8260e6bbf8c2436f3fd548
   languageName: node
   linkType: hard
 
@@ -9424,12 +9424,12 @@ __metadata:
   linkType: hard
 
 "brace-expansion@npm:^1.1.7":
-  version: 1.1.12
-  resolution: "brace-expansion@npm:1.1.12"
+  version: 1.1.11
+  resolution: "brace-expansion@npm:1.1.11"
   dependencies:
     balanced-match: "npm:^1.0.0"
     concat-map: "npm:0.0.1"
-  checksum: 10/12cb6d6310629e3048cadb003e1aca4d8c9bb5c67c3c321bafdd7e7a50155de081f78ea3e0ed92ecc75a9015e784f301efc8132383132f4f7904ad1ac529c562
+  checksum: 10/faf34a7bb0c3fcf4b59c7808bc5d2a96a40988addf2e7e09dfbb67a2251800e0d14cd2bfc1aa79174f2f5095c54ff27f46fb1289fe2d77dac755b5eb3434cc07
   languageName: node
   linkType: hard
 
@@ -21879,7 +21879,7 @@ __metadata:
     "@wireapp/avs-debugger": "npm:0.0.7"
     "@wireapp/commons": "npm:5.4.3"
     "@wireapp/copy-config": "npm:2.3.1"
-    "@wireapp/core": "npm:46.33.0"
+    "@wireapp/core": "npm:46.34.0"
     "@wireapp/eslint-config": "npm:3.0.7"
     "@wireapp/kalium-backup": "npm:0.0.4"
     "@wireapp/prettier-config": "npm:0.6.4"