test: Split async tasks across multiple before hooks in resend tests.

Author: timoxley

test/integration/Resends.test.ts

@@ -78,10 +78,12 @@ describe('StreamrClient resends', () => {
 
                 await stream.addToStorageNode(config.clientOptions.storageNode.address)
 
+            })
+
+            beforeEach(async () => {
                 publishTestMessages = getPublishTestMessages(client, {
                     stream
                 })
-
                 published = await publishTestMessages(MAX_MESSAGES, {
                     waitForLast: true,
                     waitForLastTimeout: WAIT_FOR_STORAGE_TIMEOUT,
@@ -341,7 +343,9 @@ describe('StreamrClient resends', () => {
                 publishTestMessages = getPublishTestMessages(client, {
                     stream
                 })
+            })
 
+            beforeEach(async () => {
                 client.debug(`Publishing ${LONG_RESEND} messages...`)
                 published = await publishTestMessages(LONG_RESEND, {
                     waitForLast: true,

test/integration/SubscriberResends.test.ts

@@ -63,16 +63,25 @@ describeRepeats('resends', () => {
         subscriber = client.subscriber
 
         // eslint-disable-next-line require-atomic-updates
-        client.debug('connecting before test >>')
+        client.debug('connecting before all tests >>')
         await Promise.all([
             client.connect(),
             client.session.getSessionToken(),
         ])
+        client.debug('connecting before all tests <<')
+        client.debug('createStream >>')
         stream = await client.createStream({
             name: uid('stream')
         })
-        await stream.addToStorageNode(config.clientOptions.storageNode.address)
-        client.debug('connecting before test <<')
+        client.debug('createStream <<')
+    })
+
+    beforeAll(async () => {
+        client.debug('addToStorageNode >>')
+        await stream.addToStorageNode(config.clientOptions.storageNode.address, {
+            timeout: WAIT_FOR_STORAGE_TIMEOUT * 2,
+        })
+        client.debug('addToStorageNode <<')
 
         publishTestMessages = getPublishTestMessages(client, {
             stream,