dont return self for peers and add erroring to new group creation

xmtp · Jan 30, 2024 · eae74a3 · eae74a3
1 parent 655ad0d
commit eae74a3
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 2 deletions.
diff --git a/library/src/main/java/org/xmtp/android/library/Conversation.kt b/library/src/main/java/org/xmtp/android/library/Conversation.kt
@@ -55,7 +55,11 @@ sealed class Conversation {
             return when (this) {
                 is V1 -> conversationV1.peerAddress
                 is V2 -> conversationV2.peerAddress
-                is Group -> group.memberAddresses().joinToString(",")
+                is Group -> {
+                    val addresses = group.memberAddresses().toMutableList()
+                    addresses.remove(clientAddress)
+                    addresses.joinToString(",")
+                }
             }
         }
 
@@ -64,7 +68,11 @@ sealed class Conversation {
             return when (this) {
                 is V1 -> listOf(conversationV1.peerAddress)
                 is V2 -> listOf(conversationV2.peerAddress)
-                is Group -> group.memberAddresses()
+                is Group -> {
+                    val addresses = group.memberAddresses().toMutableList()
+                    addresses.remove(clientAddress)
+                    addresses
+                }
             }
         }
 

diff --git a/library/src/main/java/org/xmtp/android/library/Conversations.kt b/library/src/main/java/org/xmtp/android/library/Conversations.kt
@@ -90,6 +90,19 @@ data class Conversations(
     }
 
     fun newGroup(accountAddresses: List<String>): Group {
+        if (accountAddresses.isEmpty()) {
+            throw XMTPException("Cannot start an empty group chat.")
+        }
+        if (accountAddresses.size == 1 && accountAddresses.first()
+                .lowercase() == client.address.lowercase()
+        ) {
+            throw XMTPException("Recipient is sender")
+        }
+        val contacts = accountAddresses.map { client.contacts.find(it) }
+        if (contacts.size != accountAddresses.size) {
+            throw XMTPException("Recipient not on network")
+        }
+
         val group = runBlocking {
             libXMTPConversations?.createGroup(accountAddresses)
                 ?: throw XMTPException("Client does not support Groups")