feat: streamAll method and ConversationContainer interface

example/src/tests.ts

@@ -2,6 +2,7 @@ import { content } from '@xmtp/proto'
 import ReactNativeBlobUtil from 'react-native-blob-util'
 import { TextEncoder, TextDecoder } from 'text-encoding'
 import { DecodedMessage } from 'xmtp-react-native-sdk/lib/DecodedMessage'
+import { DefaultContentTypes } from 'xmtp-react-native-sdk/lib/types/DefaultContentType'
 
 import {
   Query,
@@ -15,7 +16,6 @@ import {
   ConversationContainer,
   ConversationVersion,
 } from '../../src/index'
-import { DefaultContentTypes } from 'xmtp-react-native-sdk/lib/types/DefaultContentType'
 
 type EncodedContent = content.EncodedContent
 type ContentTypeId = content.ContentTypeId
@@ -612,7 +612,7 @@ test('can stream all groups and conversations', async () => {
     throw Error('Unexpected num groups (should be 1): ' + containers.length)
   }
   if (containers[0].version === ConversationVersion.GROUP) {
-    (containers[0] as Group).sync()
+    ;(containers[0] as Group).sync()
   } else {
     console.log(JSON.stringify(containers[0] as Group))
     throw Error('Unexpected first ConversationContainer should be a group')
@@ -628,8 +628,14 @@ test('can stream all groups and conversations', async () => {
     throw Error('Unexpected num groups (should be 2): ' + containers.length)
   }
 
-  if(containers[1].version === ConversationVersion.DIRECT && bobConversation.conversationID != (containers[1] as Conversation<any>).conversationID) {
-    throw Error('Conversation from streamed all should match conversationID with created conversation')
+  if (
+    containers[1].version === ConversationVersion.DIRECT &&
+    bobConversation.conversationID !=
+      (containers[1] as Conversation<any>).conversationID
+  ) {
+    throw Error(
+      'Conversation from streamed all should match conversationID with created conversation'
+    )
   }
 
   // * Note Alice creating a v2 Conversation does trigger alice conversations

src/index.ts

@@ -560,7 +560,10 @@ export * from './XMTP.types'
 export { Client } from './lib/Client'
 export * from './lib/ContentCodec'
 export { Conversation } from './lib/Conversation'
-export { ConversationContainer, ConversationVersion } from './lib/ConversationContainer'
+export {
+  ConversationContainer,
+  ConversationVersion,
+} from './lib/ConversationContainer'
 export { Query } from './lib/Query'
 export { XMTPPush } from './lib/XMTPPush'
 export { ConsentListEntry, DecodedMessage }

src/lib/Conversation.ts

@@ -4,13 +4,13 @@ import {
 } from './ConversationContainer'
 import { ConversationSendPayload } from './types/ConversationCodecs'
 import { DefaultContentTypes } from './types/DefaultContentType'
+import { SendOptions } from './types/SendOptions'
 import * as XMTP from '../index'
 import {
   ConversationContext,
   DecodedMessage,
   PreparedLocalMessage,
 } from '../index'
-import { SendOptions } from './types/SendOptions'
 
 export class Conversation<ContentTypes extends DefaultContentTypes>
   implements ConversationContainer<ContentTypes>

src/lib/ConversationContainer.ts

@@ -2,8 +2,8 @@ import { DefaultContentTypes } from './types/DefaultContentType'
 import * as XMTP from '../index'
 
 export enum ConversationVersion {
-  DIRECT = "DIRECT",
-  GROUP = "GROUP"
+  DIRECT = 'DIRECT',
+  GROUP = 'GROUP',
 }
 
 export interface ConversationContainer<

src/lib/Group.ts

@@ -5,8 +5,8 @@ import {
 import { DecodedMessage } from './DecodedMessage'
 import { ConversationSendPayload } from './types/ConversationCodecs'
 import { DefaultContentTypes } from './types/DefaultContentType'
-import * as XMTP from '../index'
 import { SendOptions } from './types/SendOptions'
+import * as XMTP from '../index'
 
 export class Group<
   ContentTypes extends DefaultContentTypes = DefaultContentTypes,
@@ -134,7 +134,7 @@ export class Group<
   async removeMembers(addresses: string[]): Promise<void> {
     return XMTP.removeGroupMembers(this.client.address, this.id, addresses)
   }
-  
+
   isActive(): boolean {
     return XMTP.isGroupActive(this.client.address, this.id)
   }