fix: adding members to group

wireapp · Mar 12, 2024 · 1ce96eb · 1ce96eb
1 parent ef701f4
commit 1ce96eb
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/...k/src/commonMain/kotlin/com/wire/kalium/network/api/v4/authenticated/ConversationApiV4.kt b/...k/src/commonMain/kotlin/com/wire/kalium/network/api/v4/authenticated/ConversationApiV4.kt
@@ -32,6 +32,7 @@ import com.wire.kalium.network.api.base.model.ConversationId
 import com.wire.kalium.network.api.base.model.GenerateGuestLinkRequest
 import com.wire.kalium.network.api.base.model.JoinConversationRequestV4
 import com.wire.kalium.network.api.v3.authenticated.ConversationApiV3
+import com.wire.kalium.network.exceptions.KaliumException
 import com.wire.kalium.network.utils.NetworkResponse
 import com.wire.kalium.network.utils.handleUnsuccessfulResponse
 import com.wire.kalium.network.utils.mapSuccess
@@ -42,6 +43,7 @@ import io.ktor.client.request.parameter
 import io.ktor.client.request.post
 import io.ktor.client.request.preparePost
 import io.ktor.client.request.setBody
+import io.ktor.utils.io.errors.IOException
 
 internal open class ConversationApiV4 internal constructor(
     authenticatedNetworkClient: AuthenticatedNetworkClient,
@@ -86,16 +88,15 @@ internal open class ConversationApiV4 internal constructor(
     override suspend fun addMember(
         addParticipantRequest: AddConversationMembersRequest,
         conversationId: ConversationId
-    ): NetworkResponse<ConversationMemberAddedResponse> = wrapKaliumResponse(
-        performRequest = {
-            httpClient.post("$PATH_CONVERSATIONS/${conversationId.domain}/${conversationId.value}/$PATH_MEMBERS") {
-                setBody(addParticipantRequest)
-            }
-        },
-        unsuccessfulResponseOverride = {
-            wrapFederationResponse(it) { handleConversationMemberAddedResponse(it) }
+    ): NetworkResponse<ConversationMemberAddedResponse> = try {
+        httpClient.post("$PATH_CONVERSATIONS/${conversationId.domain}/${conversationId.value}/$PATH_MEMBERS") {
+            setBody(addParticipantRequest)
+        }.let { response ->
+            wrapFederationResponse(response) { handleConversationMemberAddedResponse(response) }
         }
-    )
+    } catch (e: IOException) {
+        NetworkResponse.Error(KaliumException.GenericError(e))
+    }
 
     override suspend fun generateGuestRoomLink(
         conversationId: ConversationId,