Android App Version (#73)

* add api client with grpc kotlin

* add app version to the android app

* a few more small tweaks

* Empty-Commit to trigger build

Author: nplasterer

example/src/main/java/org/xmtp/android/example/ClientManager.kt

@@ -13,7 +13,7 @@ import org.xmtp.android.library.messages.PrivateKeyBundleV1Builder
 
 object ClientManager {
 
-    val CLIENT_OPTIONS = ClientOptions(api = ClientOptions.Api(XMTPEnvironment.DEV))
+    val CLIENT_OPTIONS = ClientOptions(api = ClientOptions.Api(XMTPEnvironment.DEV, appVersion = "XMTPAndroidExample/v1.0.0"))
 
     private val _clientState = MutableStateFlow<ClientState>(ClientState.Unknown)
     val clientState: StateFlow<ClientState> = _clientState

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

@@ -31,7 +31,7 @@ class InstrumentedTest {
         val aliceWallet = PrivateKeyBuilder()
         val alicePrivateKey = aliceWallet.getPrivateKey()
         val clientOptions =
-            ClientOptions(api = ClientOptions.Api(env = XMTPEnvironment.LOCAL, isSecure = false))
+            ClientOptions(api = ClientOptions.Api(env = XMTPEnvironment.LOCAL, isSecure = false, appVersion = "XMTPTest/v1.0.0"))
         val client = Client().create(aliceWallet, clientOptions)
         assertEquals(XMTPEnvironment.LOCAL, client.apiClient.environment)
         runBlocking {

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

@@ -34,7 +34,7 @@ interface ApiClient {
     suspend fun subscribe(topics: List<String>): Flow<Envelope>
 }
 
-data class GRPCApiClient(override val environment: XMTPEnvironment, val secure: Boolean = true) :
+data class GRPCApiClient(override val environment: XMTPEnvironment, val secure: Boolean = true, val appVersion: String? = null) :
     ApiClient, Closeable {
     companion object {
         val AUTHORIZATION_HEADER_KEY: Metadata.Key<String> =
@@ -102,6 +102,10 @@ data class GRPCApiClient(override val environment: XMTPEnvironment, val secure:
         authToken?.let { token ->
             headers.put(AUTHORIZATION_HEADER_KEY, "Bearer $token")
         }
+        headers.put(CLIENT_VERSION_HEADER_KEY, Constants.VERSION)
+        if (appVersion != null) {
+            headers.put(APP_VERSION_HEADER_KEY, appVersion)
+        }
         return client.query(request, headers = headers)
     }
 
@@ -131,15 +135,24 @@ data class GRPCApiClient(override val environment: XMTPEnvironment, val secure:
         }
 
         headers.put(CLIENT_VERSION_HEADER_KEY, Constants.VERSION)
-        headers.put(APP_VERSION_HEADER_KEY, Constants.VERSION)
+        if (appVersion != null) {
+            headers.put(APP_VERSION_HEADER_KEY, appVersion)
+        }
 
         return client.publish(request, headers)
     }
 
     override suspend fun subscribe(topics: List<String>): Flow<Envelope> {
         val request =
             MessageApiOuterClass.SubscribeRequest.newBuilder().addAllContentTopics(topics).build()
-        return client.subscribe(request)
+        val headers = Metadata()
+
+        headers.put(CLIENT_VERSION_HEADER_KEY, Constants.VERSION)
+        if (appVersion != null) {
+            headers.put(APP_VERSION_HEADER_KEY, appVersion)
+        }
+
+        return client.subscribe(request, headers)
     }
 
     override fun close() {

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

@@ -43,7 +43,7 @@ typealias PublishResponse = org.xmtp.proto.message.api.v1.MessageApiOuterClass.P
 typealias QueryResponse = org.xmtp.proto.message.api.v1.MessageApiOuterClass.QueryResponse
 
 data class ClientOptions(val api: Api = Api()) {
-    data class Api(val env: XMTPEnvironment = XMTPEnvironment.DEV, val isSecure: Boolean = true)
+    data class Api(val env: XMTPEnvironment = XMTPEnvironment.DEV, val isSecure: Boolean = true, val appVersion: String? = null)
 }
 
 class Client() {

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

@@ -1,5 +1,5 @@
 package org.xmtp.android.library
 
 object Constants {
-    const val VERSION = "0.0.0-development"
+    const val VERSION = "0.1.3-development"
 }