From d6f3629a3963665fd86a5e60e7f4f8e75c77a393 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Iv=C3=A1n=20Ovejero?= Date: Wed, 2 Oct 2024 09:26:53 +0200 Subject: [PATCH] Fix typecheck --- .../src/scaling/__tests__/subscriber.service.test.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/packages/cli/src/scaling/__tests__/subscriber.service.test.ts b/packages/cli/src/scaling/__tests__/subscriber.service.test.ts index 14e67a8d4dd6c..31e8486b8c97c 100644 --- a/packages/cli/src/scaling/__tests__/subscriber.service.test.ts +++ b/packages/cli/src/scaling/__tests__/subscriber.service.test.ts @@ -17,14 +17,14 @@ describe('Subscriber', () => { describe('constructor', () => { it('should init Redis client in scaling mode', () => { - const subscriber = new Subscriber(mock(), redisClientService); + const subscriber = new Subscriber(mock(), redisClientService, mock()); expect(subscriber.getClient()).toEqual(client); }); it('should not init Redis client in regular mode', () => { config.set('executions.mode', 'regular'); - const subscriber = new Subscriber(mock(), redisClientService); + const subscriber = new Subscriber(mock(), redisClientService, mock()); expect(subscriber.getClient()).toBeUndefined(); }); @@ -32,7 +32,7 @@ describe('Subscriber', () => { describe('shutdown', () => { it('should disconnect Redis client', () => { - const subscriber = new Subscriber(mock(), redisClientService); + const subscriber = new Subscriber(mock(), redisClientService, mock()); subscriber.shutdown(); expect(client.disconnect).toHaveBeenCalled(); }); @@ -40,7 +40,7 @@ describe('Subscriber', () => { describe('subscribe', () => { it('should subscribe to pubsub channel', async () => { - const subscriber = new Subscriber(mock(), redisClientService); + const subscriber = new Subscriber(mock(), redisClientService, mock()); await subscriber.subscribe('n8n.commands'); @@ -50,7 +50,7 @@ describe('Subscriber', () => { describe('setMessageHandler', () => { it('should set message handler function for channel', () => { - const subscriber = new Subscriber(mock(), redisClientService); + const subscriber = new Subscriber(mock(), redisClientService, mock()); const channel = 'n8n.commands'; const handlerFn = jest.fn();