From 8a1c4883a35803e68a4407212eb66636c44d292d Mon Sep 17 00:00:00 2001 From: cameronvoell Date: Mon, 18 Nov 2024 09:41:55 -0800 Subject: [PATCH] remove extra comments --- example/src/tests/groupTests.ts | 76 ++++++++++++++++----------------- 1 file changed, 38 insertions(+), 38 deletions(-) diff --git a/example/src/tests/groupTests.ts b/example/src/tests/groupTests.ts index 089c5aea..10abd1fc 100644 --- a/example/src/tests/groupTests.ts +++ b/example/src/tests/groupTests.ts @@ -1598,44 +1598,44 @@ test('can create new installation without breaking group', async () => { return true }) -// // Commenting this out so it doesn't block people, but nice to have? -// // test('can stream messages for a long time', async () => { -// // const bo = await Client.createRandom({ env: 'local', enableV3: true }) -// // await delayToPropogate() -// // const alix = await Client.createRandom({ env: 'local', enableV3: true }) -// // await delayToPropogate() -// // const caro = await Client.createRandom({ env: 'local', enableV3: true }) -// // await delayToPropogate() - -// // // Setup stream alls -// // const allBoMessages: any[] = [] -// // const allAliMessages: any[] = [] - -// // const group = await caro.conversations.newGroup([alix.address]) -// // await bo.conversations.streamAllMessages(async (conversation) => { -// // allBoMessages.push(conversation) -// // }, true) -// // await alix.conversations.streamAllMessages(async (conversation) => { -// // allAliMessages.push(conversation) -// // }, true) - -// // // Wait for 15 minutes -// // await delayToPropogate(15 * 1000 * 60) - -// // // Start Caro starts a new conversation. -// // const convo = await caro.conversations.newConversation(alix.address) -// // await group.send({ text: 'hello' }) -// // await convo.send({ text: 'hello' }) -// // await delayToPropogate() -// // if (allBoMessages.length !== 0) { -// // throw Error('Unexpected all conversations count ' + allBoMessages.length) -// // } -// // if (allAliMessages.length !== 2) { -// // throw Error('Unexpected all conversations count ' + allAliMessages.length) -// // } - -// // return true -// // }) +// Commenting this out so it doesn't block people, but nice to have? +// test('can stream messages for a long time', async () => { +// const bo = await Client.createRandom({ env: 'local', enableV3: true }) +// await delayToPropogate() +// const alix = await Client.createRandom({ env: 'local', enableV3: true }) +// await delayToPropogate() +// const caro = await Client.createRandom({ env: 'local', enableV3: true }) +// await delayToPropogate() + +// // Setup stream alls +// const allBoMessages: any[] = [] +// const allAliMessages: any[] = [] + +// const group = await caro.conversations.newGroup([alix.address]) +// await bo.conversations.streamAllMessages(async (conversation) => { +// allBoMessages.push(conversation) +// }, true) +// await alix.conversations.streamAllMessages(async (conversation) => { +// allAliMessages.push(conversation) +// }, true) + +// // Wait for 15 minutes +// await delayToPropogate(15 * 1000 * 60) + +// // Start Caro starts a new conversation. +// const convo = await caro.conversations.newConversation(alix.address) +// await group.send({ text: 'hello' }) +// await convo.send({ text: 'hello' }) +// await delayToPropogate() +// if (allBoMessages.length !== 0) { +// throw Error('Unexpected all conversations count ' + allBoMessages.length) +// } +// if (allAliMessages.length !== 2) { +// throw Error('Unexpected all conversations count ' + allAliMessages.length) +// } + +// return true +// }) test('groups cannot fork', async () => { const [alix, bo, new_one, new_two] = await createClients(4)