add more awaits

xmtp · Sep 26, 2024 · b64e6e8 · b64e6e8
1 parent 2e28e90
commit b64e6e8
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/ios/Wrappers/ConversationContainerWrapper.swift b/ios/Wrappers/ConversationContainerWrapper.swift
@@ -10,17 +10,17 @@ import XMTP
 
 // Wrapper around XMTP.ConversationContainer to allow passing these objects back into react native.
 struct ConversationContainerWrapper {
-	static func encodeToObj(_ conversation: XMTP.Conversation, client: XMTP.Client) throws -> [String: Any] {
+	static func encodeToObj(_ conversation: XMTP.Conversation, client: XMTP.Client) async throws -> [String: Any] {
 		switch conversation {
 		case .group(let group):
-			return try GroupWrapper.encodeToObj(group, client: client)
+			return try await GroupWrapper.encodeToObj(group, client: client)
 		default:
 			return try ConversationWrapper.encodeToObj(conversation, client: client)
 		}
 	}
 
-	static func encode(_ conversation: XMTP.Conversation, client: XMTP.Client) throws -> String {
-		let obj = try encodeToObj(conversation, client: client)
+	static func encode(_ conversation: XMTP.Conversation, client: XMTP.Client) async throws -> String {
+		let obj = try await encodeToObj(conversation, client: client)
 		let data = try JSONSerialization.data(withJSONObject: obj)
 		guard let result = String(data: data, encoding: .utf8) else {
 			throw WrapperError.encodeError("could not encode conversation")

diff --git a/ios/XMTPModule.swift b/ios/XMTPModule.swift
@@ -557,7 +557,7 @@ public class XMTPModule: Module {
 			var results: [String] = []
 			for conversation in conversationContainerList {
 				await self.conversationsManager.set(conversation.cacheKey(inboxId), conversation)
-				let encodedConversationContainer = try ConversationContainerWrapper.encode(conversation, client: client)
+				let encodedConversationContainer = try await ConversationContainerWrapper.encode(conversation, client: client)
 				results.append(encodedConversationContainer)
 			}
 
@@ -1832,7 +1832,7 @@ public class XMTPModule: Module {
 		await subscriptionsManager.set(getConversationsKey(inboxId: inboxId), Task {
 			do {
 				for try await conversation in await client.conversations.streamAll() {
-					try sendEvent("conversationContainer", [
+					try await sendEvent("conversationContainer", [
 						"inboxId": inboxId,
 						"conversationContainer": ConversationContainerWrapper.encodeToObj(conversation, client: client),
 					])