write react native side

xmtp · Jun 24, 2024 · f3f0b5a · f3f0b5a
1 parent 82fa1a2
commit f3f0b5a
Show file tree

Hide file tree

Showing 2 changed files with 51 additions and 8 deletions.
diff --git a/android/src/main/java/expo/modules/xmtpreactnativesdk/XMTPModule.kt b/android/src/main/java/expo/modules/xmtpreactnativesdk/XMTPModule.kt
@@ -597,15 +597,21 @@ class XMTPModule : Module() {
             withContext(Dispatchers.IO) {
                 logV("findV3Message")
                 val client = clients[inboxId] ?: throw XMTPException("No client")
-                client.findMessage(Hex.hexStringToByteArray(messageId))
+                val message = client.findMessage(Hex.hexStringToByteArray(messageId))
+                message?.let {
+                    DecodedMessageWrapper.encode(it.decrypt())
+                }
             }
         }
 
         AsyncFunction("findGroup") Coroutine { inboxId: String, groupId: String ->
             withContext(Dispatchers.IO) {
                 logV("findGroup")
                 val client = clients[inboxId] ?: throw XMTPException("No client")
-                client.findGroup(Hex.hexStringToByteArray(groupId))
+                val group = client.findGroup(Hex.hexStringToByteArray(groupId))
+                group?.let {
+                    GroupWrapper.encode(client, it)
+                }
             }
         }
 

diff --git a/src/index.ts b/src/index.ts
@@ -46,6 +46,13 @@ export function inboxId(): string {
   return XMTPModule.inboxId()
 }
 
+export async function findInboxIdFromAddress(
+  inboxId: string,
+  address: string
+): Promise<string> {
+  return XMTPModule.findInboxIdFromAddress(inboxId, address)
+}
+
 export async function deleteLocalDatabase(inboxId: string) {
   return XMTPModule.deleteLocalDatabase(inboxId)
 }
@@ -58,6 +65,10 @@ export async function reconnectLocalDatabase(inboxId: string) {
   return XMTPModule.reconnectLocalDatabase(inboxId)
 }
 
+export async function requestMessageHistorySync(inboxId: string) {
+  return XMTPModule.requestMessageHistorySync(inboxId)
+}
+
 export async function auth(
   inboxId: string,
   environment: 'local' | 'dev' | 'production',
@@ -66,7 +77,8 @@ export async function auth(
   hasEnableIdentityCallback?: boolean | undefined,
   enableV3?: boolean | undefined,
   dbEncryptionKey?: Uint8Array | undefined,
-  dbDirectory?: string | undefined
+  dbDirectory?: string | undefined,
+  historySyncUrl?: string | undefined
 ) {
   return await XMTPModule.auth(
     inboxId,
@@ -76,7 +88,8 @@ export async function auth(
     hasEnableIdentityCallback,
     enableV3,
     dbEncryptionKey ? Array.from(dbEncryptionKey) : undefined,
-    dbDirectory
+    dbDirectory,
+    historySyncUrl
   )
 }
 
@@ -91,7 +104,8 @@ export async function createRandom(
   hasEnableIdentityCallback?: boolean | undefined,
   enableV3?: boolean | undefined,
   dbEncryptionKey?: Uint8Array | undefined,
-  dbDirectory?: string | undefined
+  dbDirectory?: string | undefined,
+  historySyncUrl?: string | undefined
 ): Promise<string> {
   return await XMTPModule.createRandom(
     environment,
@@ -100,7 +114,8 @@ export async function createRandom(
     hasEnableIdentityCallback,
     enableV3,
     dbEncryptionKey ? Array.from(dbEncryptionKey) : undefined,
-    dbDirectory
+    dbDirectory,
+    historySyncUrl
   )
 }
 
@@ -110,15 +125,17 @@ export async function createFromKeyBundle(
   appVersion?: string | undefined,
   enableV3?: boolean | undefined,
   dbEncryptionKey?: Uint8Array | undefined,
-  dbDirectory?: string | undefined
+  dbDirectory?: string | undefined,
+  historySyncUrl?: string | undefined
 ): Promise<string> {
   return await XMTPModule.createFromKeyBundle(
     keyBundle,
     environment,
     appVersion,
     enableV3,
     dbEncryptionKey ? Array.from(dbEncryptionKey) : undefined,
-    dbDirectory
+    dbDirectory,
+    historySyncUrl
   )
 }
 
@@ -207,6 +224,26 @@ export async function groupMessages<
   })
 }
 
+export async function findGroup<
+  ContentTypes extends DefaultContentTypes = DefaultContentTypes,
+>(
+  client: Client<ContentTypes>,
+  groupId: string
+): Promise<Group<ContentTypes> | undefined> {
+  const group = await XMTPModule.findGroup(client.inboxId, groupId)
+  return new Group(client, JSON.parse(group))
+}
+
+export async function findV3Message<
+  ContentTypes extends DefaultContentTypes = DefaultContentTypes,
+>(
+  client: Client<ContentTypes>,
+  messageId: string
+): Promise<DecodedMessage<ContentTypes> | undefined> {
+  const message = await XMTPModule.findV3Message(client.inboxId, messageId)
+  return DecodedMessage.from(message, client)
+}
+
 export async function syncGroups(inboxId: string) {
   await XMTPModule.syncGroups(inboxId)
 }