feat: create group conversation #WPB-18547

* Add Request and Response data classes for creating a Conversation
* Add HTTP requests for claiming key packages, public keys and creating the group conversation
* Add CoreCrypto calls for commiting pending proposals, update keying material and creating a conversation
* Add createGroupConversation method on WireApplicationManager
* Add sample for creating a conversation
* Adjust and add new tests

Author: alexandreferris

lib/src/main/kotlin/com/wire/integrations/jvm/client/BackendClient.kt

@@ -27,9 +27,13 @@ import com.wire.integrations.jvm.model.http.FeaturesResponse
 import com.wire.integrations.jvm.model.http.MlsPublicKeys
 import com.wire.integrations.jvm.model.http.client.RegisterClientRequest
 import com.wire.integrations.jvm.model.http.client.RegisterClientResponse
+import com.wire.integrations.jvm.model.http.conversation.ClaimedKeyPackageList
 import com.wire.integrations.jvm.model.http.conversation.ConversationResponse
+import com.wire.integrations.jvm.model.http.conversation.CreateConversationRequest
+import com.wire.integrations.jvm.model.http.conversation.MlsPublicKeysResponse
 import com.wire.integrations.jvm.model.http.user.UserResponse
 import io.ktor.client.plugins.websocket.DefaultClientWebSocketSession
+import java.util.UUID
 
 interface BackendClient {
     suspend fun connectWebSocket(handleFrames: suspend (DefaultClientWebSocketSession) -> Unit)
@@ -54,6 +58,14 @@ interface BackendClient {
         mlsKeyPackages: List<ByteArray>
     )
 
+    suspend fun claimKeyPackages(
+        userDomain: String,
+        userId: UUID,
+        cipherSuite: String
+    ): ClaimedKeyPackageList
+
+    suspend fun getPublicKeys(): MlsPublicKeysResponse
+
     suspend fun uploadCommitBundle(commitBundle: ByteArray)
 
     suspend fun sendMessage(mlsMessage: ByteArray)
@@ -76,6 +88,10 @@ interface BackendClient {
         assetUploadData: AssetUploadData
     ): AssetUploadResponse
 
+    suspend fun createGroupConversation(
+        createConversationRequest: CreateConversationRequest
+    ): ConversationResponse
+
     companion object {
         const val API_VERSION = "v9"
     }

lib/src/main/kotlin/com/wire/integrations/jvm/client/BackendClientDemo.kt

@@ -32,7 +32,10 @@ import com.wire.integrations.jvm.model.http.MlsKeyPackageRequest
 import com.wire.integrations.jvm.model.http.MlsPublicKeys
 import com.wire.integrations.jvm.model.http.client.RegisterClientRequest
 import com.wire.integrations.jvm.model.http.client.RegisterClientResponse
+import com.wire.integrations.jvm.model.http.conversation.ClaimedKeyPackageList
 import com.wire.integrations.jvm.model.http.conversation.ConversationResponse
+import com.wire.integrations.jvm.model.http.conversation.CreateConversationRequest
+import com.wire.integrations.jvm.model.http.conversation.MlsPublicKeysResponse
 import com.wire.integrations.jvm.model.http.user.UserResponse
 import com.wire.integrations.jvm.persistence.AppStorage
 import com.wire.integrations.jvm.utils.Mls
@@ -45,6 +48,7 @@ import io.ktor.client.plugins.websocket.wss
 import io.ktor.client.request.accept
 import io.ktor.client.request.get
 import io.ktor.client.request.headers
+import io.ktor.client.request.parameter
 import io.ktor.client.request.post
 import io.ktor.client.request.prepareGet
 import io.ktor.client.request.put
@@ -228,6 +232,33 @@ internal class BackendClientDemo(
         logger.info("Updated client with mls key packages for client: $appClientId")
     }
 
+    override suspend fun claimKeyPackages(
+        userDomain: String,
+        userId: UUID,
+        cipherSuite: String
+    ): ClaimedKeyPackageList {
+        val token = loginUser()
+        return httpClient.post("$API_VERSION/mls/key-packages/claim/$userDomain/$userId") {
+            headers {
+                append(HttpHeaders.Authorization, "Bearer $token")
+            }
+            parameter("ciphersuite", cipherSuite)
+            contentType(ContentType.Application.Json)
+            accept(ContentType.Application.Json)
+        }.body<ClaimedKeyPackageList>()
+    }
+
+    override suspend fun getPublicKeys(): MlsPublicKeysResponse {
+        val token = loginUser()
+        return httpClient.get("$API_VERSION/mls/public-keys") {
+            headers {
+                append(HttpHeaders.Authorization, "Bearer $token")
+            }
+            contentType(ContentType.Application.Json)
+            accept(ContentType.Application.Json)
+        }.body<MlsPublicKeysResponse>()
+    }
+
     override suspend fun uploadCommitBundle(commitBundle: ByteArray) {
         val token = loginUser()
         httpClient.post("/$API_VERSION/mls/commit-bundles") {
@@ -331,6 +362,20 @@ internal class BackendClientDemo(
         }.body<AssetUploadResponse>()
     }
 
+    override suspend fun createGroupConversation(
+        createConversationRequest: CreateConversationRequest
+    ): ConversationResponse {
+        val token = loginUser()
+        return httpClient.post("/$API_VERSION/conversations") {
+            headers {
+                append(HttpHeaders.Authorization, "Bearer $token")
+            }
+            setBody(createConversationRequest)
+            contentType(ContentType.Application.Json)
+            accept(ContentType.Application.Json)
+        }.body<ConversationResponse>()
+    }
+
     internal class AssetBody internal constructor(
         private val assetContent: ByteArray,
         assetSize: Long,

lib/src/main/kotlin/com/wire/integrations/jvm/client/BackendClientImpl.kt

@@ -29,7 +29,10 @@ import com.wire.integrations.jvm.model.http.FeaturesResponse
 import com.wire.integrations.jvm.model.http.MlsPublicKeys
 import com.wire.integrations.jvm.model.http.client.RegisterClientRequest
 import com.wire.integrations.jvm.model.http.client.RegisterClientResponse
+import com.wire.integrations.jvm.model.http.conversation.ClaimedKeyPackageList
 import com.wire.integrations.jvm.model.http.conversation.ConversationResponse
+import com.wire.integrations.jvm.model.http.conversation.CreateConversationRequest
+import com.wire.integrations.jvm.model.http.conversation.MlsPublicKeysResponse
 import com.wire.integrations.jvm.model.http.user.UserResponse
 import io.ktor.client.HttpClient
 import io.ktor.client.call.body
@@ -39,6 +42,7 @@ import io.ktor.client.request.get
 import io.ktor.client.request.header
 import io.ktor.client.request.post
 import io.ktor.http.HttpHeaders
+import java.util.UUID
 import org.slf4j.LoggerFactory
 
 /**
@@ -102,6 +106,18 @@ internal class BackendClientImpl(private val httpClient: HttpClient) : BackendCl
         TODO("Not yet implemented")
     }
 
+    override suspend fun claimKeyPackages(
+        userDomain: String,
+        userId: UUID,
+        cipherSuite: String
+    ): ClaimedKeyPackageList {
+        TODO("Not yet implemented")
+    }
+
+    override suspend fun getPublicKeys(): MlsPublicKeysResponse {
+        TODO("Not yet implemented")
+    }
+
     override suspend fun uploadCommitBundle(commitBundle: ByteArray) {
         TODO("Not yet implemented")
     }
@@ -137,4 +153,10 @@ internal class BackendClientImpl(private val httpClient: HttpClient) : BackendCl
     ): AssetUploadResponse {
         TODO("Not yet implemented")
     }
+
+    override suspend fun createGroupConversation(
+        createConversationRequest: CreateConversationRequest
+    ): ConversationResponse {
+        TODO("Not yet implemented")
+    }
 }

lib/src/main/kotlin/com/wire/integrations/jvm/crypto/CoreCryptoClient.kt

@@ -4,6 +4,7 @@ import com.wire.crypto.Ciphersuite
 import com.wire.crypto.Ciphersuites
 import com.wire.crypto.CoreCrypto
 import com.wire.crypto.DatabaseKey
+import com.wire.crypto.ExternalSenderKey
 import com.wire.crypto.GroupInfo
 import com.wire.crypto.MLSGroupId
 import com.wire.crypto.MLSKeyPackage
@@ -146,15 +147,37 @@ internal class CoreCryptoClient private constructor(
         return coreCrypto.transaction { it.joinByExternalCommit(groupInfo).id }
     }
 
-    override suspend fun createConversation(groupId: MLSGroupId) {
+    override suspend fun createConversation(
+        groupId: MLSGroupId,
+        externalSenders: ByteArray
+    ) {
         return coreCrypto.transaction {
             it.createConversation(
                 id = groupId,
-                ciphersuite = ciphersuite
+                ciphersuite = ciphersuite,
+                externalSenders = listOf(
+                    ExternalSenderKey(
+                        value = com.wire.crypto.uniffi.ExternalSenderKey(
+                            bytes = externalSenders
+                        )
+                    )
+                )
             )
         }
     }
 
+    override suspend fun commitPendingProposals(mlsGroupId: MLSGroupId) {
+        coreCrypto.transaction {
+            it.commitPendingProposals(mlsGroupId)
+        }
+    }
+
+    override suspend fun updateKeyingMaterial(mlsGroupId: MLSGroupId) {
+        coreCrypto.transaction {
+            it.updateKeyingMaterial(mlsGroupId)
+        }
+    }
+
     override suspend fun addMemberToMlsConversation(
         mlsGroupId: MLSGroupId,
         keyPackages: List<MLSKeyPackage>
@@ -215,7 +238,7 @@ internal class CoreCryptoClient private constructor(
             )
         }
 
-        private fun getMlsCipherSuiteName(code: Int): Ciphersuite =
+        fun getMlsCipherSuiteName(code: Int): Ciphersuite =
             when (code) {
                 DEFAULT_CIPHERSUITE_IDENTIFIER -> Ciphersuite.DEFAULT
                 2 -> Ciphersuite.MLS_128_DHKEMP256_AES128GCM_SHA256_P256

lib/src/main/kotlin/com/wire/integrations/jvm/crypto/CryptoClient.kt

@@ -72,7 +72,14 @@ internal interface CryptoClient : AutoCloseable {
     /**
      * Create an MLS conversation, adding the client as the first member.
      */
-    suspend fun createConversation(groupId: MLSGroupId)
+    suspend fun createConversation(
+        groupId: MLSGroupId,
+        externalSenders: ByteArray
+    )
+
+    suspend fun commitPendingProposals(mlsGroupId: MLSGroupId)
+
+    suspend fun updateKeyingMaterial(mlsGroupId: MLSGroupId)
 
     /**
      * Alternative way to add a member to an MLS conversation.

lib/src/main/kotlin/com/wire/integrations/jvm/model/http/conversation/ConversationAccess.kt

@@ -0,0 +1,42 @@
+/*
+ * Wire
+ * Copyright (C) 2025 Wire Swiss GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see http://www.gnu.org/licenses/.
+ */
+
+package com.wire.integrations.jvm.model.http.conversation
+
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+
+@Serializable
+enum class ConversationAccess {
+    @SerialName("private")
+    PRIVATE,
+
+    @SerialName("code")
+    CODE,
+
+    @SerialName("invite")
+    INVITE,
+
+    @SerialName("self_invite")
+    SELF_INVITE,
+
+    @SerialName("link")
+    LINK;
+
+    override fun toString(): String {
+        return this.name.lowercase()
+    }
+}

lib/src/main/kotlin/com/wire/integrations/jvm/model/http/conversation/ConversationAccessRole.kt

@@ -0,0 +1,42 @@
+/*
+ * Wire
+ * Copyright (C) 2025 Wire Swiss GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see http://www.gnu.org/licenses/.
+ */
+
+package com.wire.integrations.jvm.model.http.conversation
+
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+
+@Serializable
+enum class ConversationAccessRole {
+    @SerialName("team_member")
+    TEAM_MEMBER,
+
+    @SerialName("non_team_member")
+    NON_TEAM_MEMBER,
+
+    @SerialName("guest")
+    GUEST,
+
+    @SerialName("service")
+    SERVICE,
+
+    @SerialName("partner")
+    EXTERNAL;
+
+    override fun toString(): String {
+        return this.name.lowercase()
+    }
+}

lib/src/main/kotlin/com/wire/integrations/jvm/model/http/conversation/ConversationProtocol.kt

@@ -0,0 +1,36 @@
+/*
+ * Wire
+ * Copyright (C) 2025 Wire Swiss GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see http://www.gnu.org/licenses/.
+ */
+
+package com.wire.integrations.jvm.model.http.conversation
+
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+
+@Serializable
+enum class ConversationProtocol {
+    @SerialName("proteus")
+    PROTEUS,
+
+    @SerialName("mls")
+    MLS,
+
+    @SerialName("mixed")
+    MIXED;
+
+    override fun toString(): String {
+        return this.name.lowercase()
+    }
+}

lib/src/main/kotlin/com/wire/integrations/jvm/model/http/conversation/ConversationResponse.kt

@@ -38,7 +38,9 @@ data class ConversationResponse(
     @SerialName("members")
     val members: ConversationMembers,
     @SerialName("type")
-    val type: Type
+    val type: Type,
+    @SerialName("public_keys")
+    val publicKeys: MlsPublicKeysResponse? = null
 ) {
     @Serializable
     enum class Type {

lib/src/main/kotlin/com/wire/integrations/jvm/model/http/conversation/ConversationTeamInfo.kt

@@ -0,0 +1,27 @@
+/*
+ * Wire
+ * Copyright (C) 2025 Wire Swiss GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see http://www.gnu.org/licenses/.
+ */
+
+package com.wire.integrations.jvm.model.http.conversation
+
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class ConversationTeamInfo(
+    @Deprecated("Not parsed any more")
+    @SerialName("managed") val managed: Boolean,
+    @SerialName("teamid") val teamId: String
+)