Skip to content

Commit e7cbc1b

Browse files
fix(BaseRedisBroker): proper import path to lua script (#8776)
* fix(BaseRedisBroker): proper import path to lua script * chore: fix tests Co-authored-by: kodiakhq[bot] <49736102+kodiakhq[bot]@users.noreply.github.com>
1 parent 53d8e87 commit e7cbc1b

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

packages/brokers/__tests__/index.test.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,12 @@ import type Redis from 'ioredis';
22
import { test, expect, vi } from 'vitest';
33
import { PubSubRedisBroker } from '../src/index.js';
44

5+
vi.mock('node:fs', () => {
6+
return {
7+
readFileSync: vi.fn(),
8+
};
9+
});
10+
511
const mockRedisClient = {
612
defineCommand: vi.fn(),
713
xadd: vi.fn(),

packages/brokers/src/brokers/redis/BaseRedis.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ export abstract class BaseRedisBroker<TEvents extends Record<string, any>>
6161
this.options = { ...DefaultBrokerOptions, ...options };
6262
options.redisClient.defineCommand('xcleangroup', {
6363
numberOfKeys: 1,
64-
lua: readFileSync(resolve(__dirname, '..', '..', '..', 'scripts', 'xcleangroup.lua'), 'utf8'),
64+
lua: readFileSync(resolve(__dirname, '..', 'scripts', 'xcleangroup.lua'), 'utf8'),
6565
});
6666
this.streamReadClient = options.redisClient.duplicate();
6767
}

0 commit comments

Comments
 (0)