DestroySignal to tests

Author: juslesan

packages/sdk/test/unit/MessageFactory.test.ts

@@ -16,6 +16,7 @@ import { StreamMessage, StreamMessageType } from './../../src/protocol/StreamMes
 import { EthereumKeyPairIdentity } from '../../src/identity/EthereumKeyPairIdentity'
 import { EncryptionType, SignatureType, ContentType } from '@streamr/trackerless-network'
 import { StrictStreamrClientConfig } from '../../src/Config'
+import { DestroySignal } from '../../src/DestroySignal'
 
 const CONTENT = { foo: 'bar' }
 const TIMESTAMP = Date.parse('2001-02-03T04:05:06Z')
@@ -58,7 +59,7 @@ describe('MessageFactory', () => {
                         isStreamPublisher: true
                     }),
                     groupKeyQueue: await createGroupKeyQueue(identity, GROUP_KEY),
-                    signatureValidator: new SignatureValidator(opts?.erc1271ContractFacade ?? mock<ERC1271ContractFacade>()),
+                    signatureValidator: new SignatureValidator(opts?.erc1271ContractFacade ?? mock<ERC1271ContractFacade>(), new DestroySignal()),
                     messageSigner: new MessageSigner(identity),
                     config: {
                         validation: {

packages/sdk/test/unit/SignatureValidator.test.ts

@@ -11,14 +11,15 @@ import { StreamrClientError } from './../../src/StreamrClientError'
 import { MessageID } from './../../src/protocol/MessageID'
 import { StreamMessage, StreamMessageType } from './../../src/protocol/StreamMessage'
 import { ContentType, EncryptionType, SignatureType } from '@streamr/trackerless-network'
+import { DestroySignal } from '../../src/DestroySignal'
 
 describe('SignatureValidator', () => {
     let erc1271ContractFacade: MockProxy<ERC1271ContractFacade>
     let signatureValidator: SignatureValidator
 
     beforeEach(() => {
         erc1271ContractFacade = mock<ERC1271ContractFacade>()
-        signatureValidator = new SignatureValidator(erc1271ContractFacade)
+        signatureValidator = new SignatureValidator(erc1271ContractFacade, new DestroySignal())
     })
 
     describe('SECP256K1', () => {

packages/sdk/test/unit/messagePipeline.test.ts

@@ -88,7 +88,7 @@ describe('messagePipeline', () => {
             getStorageNodes: undefined as any,
             resends: undefined as any,
             streamRegistry: streamRegistry as any,
-            signatureValidator: new SignatureValidator(mock<ERC1271ContractFacade>()),
+            signatureValidator: new SignatureValidator(mock<ERC1271ContractFacade>(), destroySignal),
             groupKeyManager: new GroupKeyManager(
                 mock<SubscriberKeyExchange>(),
                 groupKeyStore,

packages/sdk/test/unit/validateStreamMessage.test.ts

@@ -12,6 +12,7 @@ import { validateStreamMessage } from '../../src/utils/validateStreamMessage'
 import { createMockMessage } from '../test-utils/utils'
 import { StreamMessage } from './../../src/protocol/StreamMessage'
 import { StrictStreamrClientConfig } from '../../src/Config'
+import { DestroySignal } from '../../src/DestroySignal'
 
 const PARTITION_COUNT = 3
 
@@ -47,7 +48,7 @@ describe('Validator', () => {
         await validateStreamMessage(
             msg,
             streamRegistry as any,
-            new SignatureValidator(mock<ERC1271ContractFacade>()),
+            new SignatureValidator(mock<ERC1271ContractFacade>(), new DestroySignal()),
             {
                 validation: {
                     permissions: true,

packages/sdk/test/unit/validateStreamMessage2.test.ts

@@ -14,6 +14,7 @@ import { MessageID } from './../../src/protocol/MessageID'
 import { MessageRef } from './../../src/protocol/MessageRef'
 import { StreamMessage, StreamMessageType } from './../../src/protocol/StreamMessage'
 import { StrictStreamrClientConfig } from '../../src/Config'
+import { DestroySignal } from '../../src/DestroySignal'
 
 const groupKeyRequestToStreamMessage = async (
     groupKeyRequest: GroupKeyRequest,
@@ -71,7 +72,7 @@ describe('Validator2', () => {
                     isStreamPublisher: (streamId: string, userId: UserID) => isPublisher(userId, streamId),
                     isStreamSubscriber: (streamId: string, userId: UserID) => isSubscriber(userId, streamId)
                 } as any,
-                new SignatureValidator(mock<ERC1271ContractFacade>()),
+                new SignatureValidator(mock<ERC1271ContractFacade>(), new DestroySignal()),
                 {
                     validation: {
                         permissions: true,