Reuse MessageSigner instance in test to avoid worker startup overhead

Author: mondoreale

packages/sdk/test/unit/waitForAssignmentsToPropagate.test.ts

@@ -1,4 +1,4 @@
-import { StreamID, toStreamID, toStreamPartID, utf8ToBinary, wait } from '@streamr/utils'
+import { StreamID, toStreamID, toStreamPartID, UserID, utf8ToBinary, wait } from '@streamr/utils'
 import range from 'lodash/range'
 import shuffle from 'lodash/shuffle'
 import { MessageSigner } from '../../src/signature/MessageSigner'
@@ -7,7 +7,6 @@ import { waitForAssignmentsToPropagate } from '../../src/utils/waitForAssignment
 import { createRandomIdentity, mockLoggerFactory } from '../test-utils/utils'
 import { MessageID } from './../../src/protocol/MessageID'
 import { StreamMessage, StreamMessageType } from './../../src/protocol/StreamMessage'
-import { Identity } from '../../src/identity/Identity'
 import { ContentType, EncryptionType, SignatureType } from '@streamr/trackerless-network'
 
 const RACE_TIMEOUT_IN_MS = 20
@@ -22,11 +21,12 @@ describe(waitForAssignmentsToPropagate, () => {
     let messageStream: MessageStream
     let propagatePromiseState: 'rejected' | 'resolved' | 'pending'
     let propagatePromise: Promise<any>
-    let identity: Identity
+    let messageSigner: MessageSigner
+    let publisherId: UserID
 
     async function makeMsg(ts: number, content: unknown): Promise<StreamMessage> {
-        return new MessageSigner(identity).createSignedMessage({
-            messageId: new MessageID(toStreamID('assignmentStreamId'), 0, ts, 0, await identity.getUserId(), 'msgChain'),
+        return messageSigner.createSignedMessage({
+            messageId: new MessageID(toStreamID('assignmentStreamId'), 0, ts, 0, publisherId, 'msgChain'),
             messageType: StreamMessageType.MESSAGE,
             content: utf8ToBinary(JSON.stringify(content)),
             contentType: ContentType.JSON,
@@ -46,7 +46,13 @@ describe(waitForAssignmentsToPropagate, () => {
     }
 
     beforeAll(async () => {
-        identity = await createRandomIdentity()
+        const identity = await createRandomIdentity()
+        messageSigner = new MessageSigner(identity)
+        publisherId = await identity.getUserId()
+    })
+
+    afterAll(() => {
+        messageSigner.destroy()
     })
 
     beforeEach(() => {