Skip to content

Commit

Permalink
Fix typecheck
Browse files Browse the repository at this point in the history
  • Loading branch information
ivov committed Oct 2, 2024
1 parent eaef187 commit d6f3629
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions packages/cli/src/scaling/__tests__/subscriber.service.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -17,30 +17,30 @@ 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();
});
});

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();
});
});

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');

Expand All @@ -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();

Expand Down

0 comments on commit d6f3629

Please sign in to comment.