Speed up build client performance

.changeset/wet-wasps-search.md

@@ -0,0 +1,8 @@
+---
+"@xmtp/react-native-sdk": patch
+---
+
+Speed up build client performance
+Adds ability to filter syncAllConversations by consent state
+Fixes potential forked group issues
+Renames senderAddress to senderInboxId

android/src/main/java/expo/modules/xmtpreactnativesdk/XMTPModule.kt

@@ -59,6 +59,7 @@ import org.xmtp.android.library.messages.PrivateKeyBuilder
 import org.xmtp.android.library.messages.Signature
 import org.xmtp.android.library.push.Service
 import org.xmtp.android.library.push.XMTPPush
+import uniffi.xmtpv3.XmtpApiClient
 import uniffi.xmtpv3.org.xmtp.android.library.libxmtp.GroupPermissionPreconfiguration
 import uniffi.xmtpv3.org.xmtp.android.library.libxmtp.PermissionOption
 import java.io.BufferedReader
@@ -191,6 +192,7 @@ class XMTPModule : Module() {
     }
 
     private var clients: MutableMap<String, Client> = mutableMapOf()
+    private var apiClient: XmtpApiClient? = null
     private var xmtpPush: XMTPPush? = null
     private var signer: ReactNativeSigner? = null
     private val isDebugEnabled = BuildConfig.DEBUG // TODO: consider making this configurable
@@ -290,6 +292,15 @@ class XMTPModule : Module() {
             signer?.handleSCW(id = requestID, signature = signature)
         }
 
+        AsyncFunction("connectToApiBackend") Coroutine { environment: String ->
+            withContext(Dispatchers.IO) {
+                logV("connectToApiBackend")
+                val api = apiEnvironments(environment, null)
+                val xmtpApiClient = Client.connectToApiBackend(api)
+                apiClient = xmtpApiClient
+            }
+        }
+
         AsyncFunction("createRandom") Coroutine { hasPreAuthenticateToInboxCallback: Boolean?, dbEncryptionKey: List<Int>, authParams: String ->
             withContext(Dispatchers.IO) {
                 logV("createRandom")
@@ -299,10 +310,12 @@ class XMTPModule : Module() {
                     authParams,
                     hasPreAuthenticateToInboxCallback,
                 )
-                val randomClient = Client().create(account = privateKey, options = options)
+                val randomClient =
+                    Client().create(account = privateKey, options = options, apiClient = apiClient)
 
                 ContentJson.Companion
                 clients[randomClient.installationId] = randomClient
+                apiClient = randomClient.apiClient
                 ClientWrapper.encodeToObj(randomClient)
             }
         }
@@ -324,8 +337,10 @@ class XMTPModule : Module() {
                     authParams,
                     hasAuthInboxCallback,
                 )
-                val client = Client().create(account = reactSigner, options = options)
+                val client =
+                    Client().create(account = reactSigner, options = options, apiClient = apiClient)
                 clients[client.installationId] = client
+                apiClient = client.apiClient
                 ContentJson.Companion
                 signer = null
                 sendEvent("authed", ClientWrapper.encodeToObj(client))
@@ -339,9 +354,15 @@ class XMTPModule : Module() {
                     dbEncryptionKey,
                     authParams,
                 )
-                val client = Client().build(address = address, options = options, inboxId = inboxId)
+                val client = Client().build(
+                    address = address,
+                    options = options,
+                    inboxId = inboxId,
+                    apiClient = apiClient
+                )
                 ContentJson.Companion
                 clients[client.installationId] = client
+                apiClient = client.apiClient
                 ClientWrapper.encodeToObj(client)
             }
         }
@@ -450,7 +471,8 @@ class XMTPModule : Module() {
                 Client.canMessage(
                     peerAddresses,
                     context,
-                    apiEnvironments(environment, null)
+                    apiEnvironments(environment, null),
+                    apiClient = apiClient
                 )
             }
         }

example/src/tests/groupPerformanceTests.ts

@@ -88,6 +88,26 @@ test('building and creating', async () => {
   const end3 = performance.now()
   console.log(`Built a client with inboxId in ${end3 - start3}ms`)
 
+  await Client.connectToApiBackend('dev')
+  const start4 = performance.now()
+  await Client.createRandom({
+    env: 'dev',
+    appVersion: 'Testing/0.0.0',
+    dbEncryptionKey: keyBytes,
+    dbDirectory: dbDirPath,
+    codecs: [
+      new ReactionCodec(),
+      new ReplyCodec(),
+      new GroupUpdatedCodec(),
+      new StaticAttachmentCodec(),
+      new RemoteAttachmentCodec(),
+    ],
+  })
+  const end4 = performance.now()
+  console.log(
+    `Created a client after connecting to backend in ${end4 - start4}ms`
+  )
+
   assert(
     end2 - start2 < end1 - start1,
     'building a client should be faster than creating one'
@@ -100,6 +120,10 @@ test('building and creating', async () => {
     end3 - start3 < end2 - start2,
     'building a client with an inboxId should be faster than building without'
   )
+  assert(
+    end4 - start4 < end1 - start1,
+    'creating a client with an apiClient cached should be faster than creating one without'
+  )
 
   return true
 })

ios/XMTPModule.swift

@@ -31,6 +31,7 @@ actor IsolatedManager<T> {
 public class XMTPModule: Module {
 	var signer: ReactNativeSigner?
 	let clientsManager = ClientsManager()
+	var apiClient: XmtpApiClient?
 	let subscriptionsManager = IsolatedManager<Task<Void, Never>>()
 	private var preAuthenticateToInboxCallbackDeferred: DispatchSemaphore?
 
@@ -219,6 +220,14 @@ public class XMTPModule: Module {
 			try signer?.handleSCW(id: requestID, signature: signature)
 		}
 
+		AsyncFunction("connectToApiBackend") {
+			(environment: String) in
+			let xmtpApiClient = try await XMTP.Client.connectToApiBackend(
+				api: createApiClient(env: environment)
+			)
+			apiClient = xmtpApiClient
+		}
+
 		AsyncFunction("createRandom") {
 			(
 				hasAuthenticateToInboxCallback: Bool?, dbEncryptionKey: [UInt8],
@@ -241,8 +250,8 @@ public class XMTPModule: Module {
 				preAuthenticateToInboxCallback: preAuthenticateToInboxCallback
 			)
 			let client = try await Client.create(
-				account: privateKey, options: options)
-
+				account: privateKey, options: options, apiClient: apiClient)
+			apiClient = client.apiClient
 			await clientsManager.updateClient(
 				key: client.installationID, client: client)
 			return try ClientWrapper.encodeToObj(client)
@@ -277,9 +286,10 @@ public class XMTPModule: Module {
 				preAuthenticateToInboxCallback: preAuthenticateToInboxCallback
 			)
 			let client = try await XMTP.Client.create(
-				account: signer, options: options)
+				account: signer, options: options, apiClient: apiClient)
 			await self.clientsManager.updateClient(
 				key: client.installationID, client: client)
+			apiClient = client.apiClient
 			self.signer = nil
 			self.sendEvent("authed", try ClientWrapper.encodeToObj(client))
 		}
@@ -299,9 +309,11 @@ public class XMTPModule: Module {
 				preAuthenticateToInboxCallback: preAuthenticateToInboxCallback
 			)
 			let client = try await XMTP.Client.build(
-				address: address, options: options, inboxId: inboxId)
+				address: address, options: options, inboxId: inboxId,
+				apiClient: apiClient)
 			await clientsManager.updateClient(
 				key: client.installationID, client: client)
+			apiClient = client.apiClient
 			return try ClientWrapper.encodeToObj(client)
 		}
 

src/index.ts

@@ -119,6 +119,12 @@ export async function receiveSCWSignature(
   return await XMTPModule.receiveSCWSignature(requestID, signature)
 }
 
+export async function connectToApiBackend(
+  environment: XMTPEnvironment
+): Promise<void> {
+  return await XMTPModule.connectToApiBackend(environment)
+}
+
 export async function createRandom(
   environment: 'local' | 'dev' | 'production',
   dbEncryptionKey: Uint8Array,

src/lib/Client.ts

@@ -79,6 +79,16 @@ export class Client<
     }
   }
 
+  /**
+   * Connects to the XMTP api backend to speed up creating and building future clients.
+   *
+   * @param {XMTPEnvironment} env - Environment to connect to
+   * @returns {Promise<void>} A Promise to let you know the api has been connected
+   */
+  static async connectToApiBackend(env: XMTPEnvironment): Promise<void> {
+    return await XMTPModule.connectToApiBackend(env)
+  }
+
   /**
    * Creates a new instance of the XMTP Client with a randomly generated address.
    *