feat: fix up all the tests to thread

Author: nplasterer

library/src/androidTest/java/org/xmtp/android/library/AttachmentTest.kt

@@ -35,7 +35,7 @@ class AttachmentTest {
                 options = SendOptions(contentType = ContentTypeAttachment),
             )
         }
-        val messages = aliceConversation.messages()
+        val messages = runBlocking { aliceConversation.messages() }
         assertEquals(messages.size, 1)
         if (messages.size == 1) {
             val content: Attachment? = messages[0].content()

library/src/androidTest/java/org/xmtp/android/library/ClientTest.kt

@@ -148,11 +148,12 @@ class ClientTest {
                     appContext = context
                 )
             )
+
         runBlocking {
             client.conversations.newGroup(listOf(client2.address))
             client.conversations.syncGroups()
+            assertEquals(client.conversations.listGroups().size, 1)
         }
-        assertEquals(client.conversations.listGroups().size, 1)
 
         client.deleteLocalDatabase()
 
@@ -166,8 +167,10 @@ class ClientTest {
                 )
             )
 
-        runBlocking { client.conversations.syncGroups() }
-        assertEquals(client.conversations.listGroups().size, 0)
+        runBlocking {
+            client.conversations.syncGroups()
+            assertEquals(client.conversations.listGroups().size, 0)
+        }
     }
 
     @Test
@@ -209,7 +212,7 @@ class ClientTest {
         val notOnNetwork = PrivateKeyBuilder()
         val opts = ClientOptions(ClientOptions.Api(XMTPEnvironment.LOCAL, false))
         val aliceClient = Client().create(aliceWallet, opts)
-        aliceClient.ensureUserContactPublished()
+        runBlocking { aliceClient.ensureUserContactPublished() }
 
         val canMessage = Client.canMessage(aliceWallet.address, opts)
         val cannotMessage = Client.canMessage(notOnNetwork.address, opts)

library/src/androidTest/java/org/xmtp/android/library/CodecTest.kt

@@ -68,7 +68,7 @@ class CodecTest {
                 options = SendOptions(contentType = NumberCodec().contentType),
             )
         }
-        val messages = aliceConversation.messages()
+        val messages = runBlocking { aliceConversation.messages() }
         assertEquals(messages.size, 1)
         if (messages.size == 1) {
             val content: Double? = messages[0].content()
@@ -93,7 +93,7 @@ class CodecTest {
                 options = SendOptions(contentType = CompositeCodec().contentType),
             )
         }
-        val messages = aliceConversation.messages()
+        val messages = runBlocking { aliceConversation.messages() }
         val decoded: DecodedComposite? = messages[0].content()
         assertEquals("hiya", decoded?.content())
     }
@@ -121,7 +121,7 @@ class CodecTest {
                 options = SendOptions(contentType = CompositeCodec().contentType),
             )
         }
-        val messages = aliceConversation.messages()
+        val messages = runBlocking { aliceConversation.messages() }
         val decoded: DecodedComposite? = messages[0].content()
         val part1 = decoded!!.parts[0]
         val part2 = decoded.parts[1].parts[0]
@@ -144,7 +144,7 @@ class CodecTest {
                 options = SendOptions(contentType = codec.contentType),
             )
         }
-        val messages = aliceConversation.messages()
+        val messages = runBlocking { aliceConversation.messages() }
         assert(messages.isNotEmpty())
 
         val message = MessageV2Builder.buildEncode(

library/src/androidTest/java/org/xmtp/android/library/ContactsTest.kt

@@ -1,6 +1,7 @@
 package org.xmtp.android.library
 
 import androidx.test.ext.junit.runners.AndroidJUnit4
+import kotlinx.coroutines.runBlocking
 import org.junit.Assert.assertEquals
 import org.junit.Test
 import org.junit.runner.RunWith
@@ -12,7 +13,7 @@ class ContactsTest {
     @Test
     fun testNormalizesAddresses() {
         val fixtures = fixtures()
-        fixtures.bobClient.ensureUserContactPublished()
+        runBlocking { fixtures.bobClient.ensureUserContactPublished() }
         val bobAddressLowerCased = fixtures.bobClient.address.lowercase()
         val bobContact = fixtures.aliceClient.getUserContact(peerAddress = bobAddressLowerCased)
         assert(bobContact != null)
@@ -21,15 +22,15 @@ class ContactsTest {
     @Test
     fun testCanFindContact() {
         val fixtures = fixtures()
-        fixtures.bobClient.ensureUserContactPublished()
+        runBlocking { fixtures.bobClient.ensureUserContactPublished() }
         val contactBundle = fixtures.aliceClient.contacts.find(fixtures.bob.walletAddress)
         assertEquals(contactBundle?.walletAddress, fixtures.bob.walletAddress)
     }
 
     @Test
     fun testCachesContacts() {
         val fixtures = fixtures()
-        fixtures.bobClient.ensureUserContactPublished()
+        runBlocking { fixtures.bobClient.ensureUserContactPublished() }
         // Look up the first time
         fixtures.aliceClient.contacts.find(fixtures.bob.walletAddress)
         fixtures.fakeApiClient.assertNoQuery {
@@ -48,7 +49,7 @@ class ContactsTest {
 
         assert(!result)
 
-        contacts.allow(listOf(fixtures.alice.walletAddress))
+        runBlocking { contacts.allow(listOf(fixtures.alice.walletAddress)) }
 
         result = contacts.isAllowed(fixtures.alice.walletAddress)
         assert(result)
@@ -63,7 +64,7 @@ class ContactsTest {
 
         assert(!result)
 
-        contacts.deny(listOf(fixtures.alice.walletAddress))
+        runBlocking { contacts.deny(listOf(fixtures.alice.walletAddress)) }
 
         result = contacts.isDenied(fixtures.alice.walletAddress)
         assert(result)