Fetch all messages (#88)

* add api client with grpc kotlin

* change the message fetching to fetch all messages

* fix up the tests

Author: nplasterer

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

@@ -129,16 +129,14 @@ class LocalInstrumentedTest {
         convo.send(text = "10 seconds ago", sentAt = date)
         Thread.sleep(5000)
         convo.send(text = "now")
-        val messages = convo.messages(limit = 1)
-        assertEquals(1, messages.size)
+        val messages = convo.messages()
+        assertEquals(2, messages.size)
         val nowMessage = messages[0]
         assertEquals("now", nowMessage.body)
-        val messages2 = convo.messages(limit = 1, before = nowMessage.sent)
-        assertEquals(1, messages2.size)
+        val messages2 = convo.messages(before = nowMessage.sent)
         val tenSecondsAgoMessage = messages2[0]
         assertEquals("10 seconds ago", tenSecondsAgoMessage.body)
-        val messages3 = convo.messages(limit = 1, after = tenSecondsAgoMessage.sent)
-        assertEquals(1, messages3.size)
+        val messages3 = convo.messages(after = tenSecondsAgoMessage.sent)
         val nowMessage2 = messages3[0]
         assertEquals("now", nowMessage2.body)
     }
@@ -247,8 +245,8 @@ class LocalInstrumentedTest {
         Thread.sleep(10000)
         convo.send(text = "now")
         val allMessages = convo.messages()
-        val messages = convo.messages(limit = 1)
-        assertEquals(1, messages.size)
+        val messages = convo.messages()
+        assertEquals(2, messages.size)
         val nowMessage = messages[0]
         assertEquals("now", nowMessage.body)
     }

library/src/main/java/org/xmtp/android/library/ConversationV1.kt

@@ -44,10 +44,10 @@ data class ConversationV1(
     ): List<DecodedMessage> {
         val pagination = Pagination(limit = limit, before = before, after = after)
         val result = runBlocking {
-            client.apiClient.queryTopic(topic = topic, pagination = pagination)
+            client.apiClient.envelopes(topic = topic.description, pagination = pagination)
         }
 
-        return result.envelopesList.mapNotNull { envelope ->
+        return result.mapNotNull { envelope ->
             decodeOrNull(envelope = envelope)
         }
     }

library/src/main/java/org/xmtp/android/library/ConversationV2.kt

@@ -65,14 +65,13 @@ data class ConversationV2(
     ): List<DecodedMessage> {
         val pagination = Pagination(limit = limit, before = before, after = after)
         val result = runBlocking {
-            client.apiClient.query(
+            client.apiClient.envelopes(
                 topic = topic,
-                pagination = pagination,
-                cursor = null
+                pagination = pagination
             )
         }
 
-        return result.envelopesList.mapNotNull { envelope ->
+        return result.mapNotNull { envelope ->
             decodeEnvelopeOrNull(envelope)
         }
     }