Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #499 from xmtp/np/v3-only-client
Create a pure v3 client
- Loading branch information
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,135 @@ | ||
| /* eslint-disable @typescript-eslint/no-extra-non-null-assertion */ | ||
| import { Client } from 'xmtp-react-native-sdk' | ||
|
|
||
| import { | ||
| Test, | ||
| assert, | ||
| createV3TestingClients, | ||
| delayToPropogate, | ||
| } from './test-utils' | ||
|
|
||
| export const v3OnlyTests: Test[] = [] | ||
| let counter = 1 | ||
| function test(name: string, perform: () => Promise<boolean>) { | ||
| v3OnlyTests.push({ | ||
| name: String(counter++) + '. ' + name, | ||
| run: perform, | ||
| }) | ||
| } | ||
|
|
||
| test('can make a V3 only client', async () => { | ||
| // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
| const keyBytes = new Uint8Array([ | ||
| 233, 120, 198, 96, 154, 65, 132, 17, 132, 96, 250, 40, 103, 35, 125, 64, | ||
| 166, 83, 208, 224, 254, 44, 205, 227, 175, 49, 234, 129, 74, 252, 135, 145, | ||
| ]) | ||
| const client = await Client.createRandomV3({ | ||
| env: 'local', | ||
| appVersion: 'Testing/0.0.0', | ||
| enableV3: true, | ||
| dbEncryptionKey: keyBytes, | ||
| }) | ||
|
|
||
| const inboxId = await Client.getOrCreateInboxId(client.address, { | ||
| env: 'local', | ||
| }) | ||
|
|
||
| assert( | ||
| client.inboxId === inboxId, | ||
| `inboxIds should match but were ${client.inboxId} and ${inboxId}` | ||
| ) | ||
| const canMessageV3 = await client.canGroupMessage([client.address]) | ||
|
|
||
| assert( | ||
| canMessageV3[client.address.toLowerCase()] === true, | ||
| `canMessageV3 should be true` | ||
| ) | ||
| try { | ||
| await client.canMessage(client.address) | ||
| // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
| } catch (error) { | ||
| return true | ||
| } | ||
|
|
||
| throw new Error('should throw error when hitting V2 api') | ||
| }) | ||
|
|
||
| test('can create group', async () => { | ||
| const [alixV2, boV3, caroV2V3] = await createV3TestingClients() | ||
| const group = await boV3.conversations.newGroup([caroV2V3.address]) | ||
| assert(group?.members?.length === 2, `group should have 2 members`) | ||
|
|
||
| try { | ||
| await boV3.conversations.newGroup([alixV2.address]) | ||
| // eslint-disable-next-line @typescript-eslint/no-unused-vars | ||
| } catch (error) { | ||
| return true | ||
| } | ||
| throw new Error( | ||
| 'should throw error when trying to add a V2 only client to a group' | ||
| ) | ||
| }) | ||
|
|
||
| test('can send message', async () => { | ||
| const [alixV2, boV3, caroV2V3] = await createV3TestingClients() | ||
| const group = await boV3.conversations.newGroup([caroV2V3.address]) | ||
| await group.send('gm') | ||
| await group.sync() | ||
| const groupMessages = await group.messages() | ||
| assert( | ||
| groupMessages[0].content() === 'gm', | ||
| `first should be gm but was ${groupMessages[0].content()}` | ||
| ) | ||
|
|
||
| await caroV2V3.conversations.syncGroups() | ||
| const sameGroups = await caroV2V3.conversations.listGroups() | ||
| await sameGroups[0].sync() | ||
|
|
||
| const sameGroupMessages = await sameGroups[0].messages() | ||
| assert( | ||
| sameGroupMessages[0].content() === 'gm', | ||
| `second should be gm but was ${sameGroupMessages[0].content()}` | ||
| ) | ||
| return true | ||
| }) | ||
|
|
||
| test('can stream all messages', async () => { | ||
| const [alixV2, boV3, caroV2V3] = await createV3TestingClients() | ||
| const conversation = await alixV2.conversations.newConversation( | ||
| caroV2V3.address | ||
| ) | ||
| const group = await boV3.conversations.newGroup([caroV2V3.address]) | ||
| await caroV2V3.conversations.syncGroups() | ||
|
|
||
| const allMessages: any[] = [] | ||
|
|
||
| await caroV2V3.conversations.streamAllMessages(async (conversation) => { | ||
| allMessages.push(conversation) | ||
| }, true) | ||
|
|
||
| await conversation.send('hi') | ||
| await group.send('hi') | ||
|
|
||
| assert(allMessages.length === 2, '2 messages should have been streamed') | ||
|
|
||
| return true | ||
| }) | ||
|
|
||
| test('can stream groups and conversations', async () => { | ||
| const [alixV2, boV3, caroV2V3] = await createV3TestingClients() | ||
|
|
||
| const allConvos: any[] = [] | ||
|
|
||
| await caroV2V3.conversations.streamAll(async (conversation) => { | ||
| allConvos.push(conversation) | ||
| }) | ||
|
|
||
| await alixV2.conversations.newConversation(caroV2V3.address) | ||
| await boV3.conversations.newGroup([caroV2V3.address]) | ||
|
|
||
| await delayToPropogate() | ||
|
|
||
| assert(allConvos.length === 2, '2 convos should have been streamed') | ||
|
|
||
| return true | ||
| }) | ||
Oops, something went wrong.