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>
discordjs · Oct 27, 2022 · e7cbc1b · e7cbc1b
1 parent 53d8e87
commit e7cbc1b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/packages/brokers/__tests__/index.test.ts b/packages/brokers/__tests__/index.test.ts
@@ -2,6 +2,12 @@ import type Redis from 'ioredis';
 import { test, expect, vi } from 'vitest';
 import { PubSubRedisBroker } from '../src/index.js';
 
+vi.mock('node:fs', () => {
+	return {
+		readFileSync: vi.fn(),
+	};
+});
+
 const mockRedisClient = {
 	defineCommand: vi.fn(),
 	xadd: vi.fn(),

diff --git a/packages/brokers/src/brokers/redis/BaseRedis.ts b/packages/brokers/src/brokers/redis/BaseRedis.ts
@@ -61,7 +61,7 @@ export abstract class BaseRedisBroker<TEvents extends Record<string, any>>
 		this.options = { ...DefaultBrokerOptions, ...options };
 		options.redisClient.defineCommand('xcleangroup', {
 			numberOfKeys: 1,
-			lua: readFileSync(resolve(__dirname, '..', '..', '..', 'scripts', 'xcleangroup.lua'), 'utf8'),
+			lua: readFileSync(resolve(__dirname, '..', 'scripts', 'xcleangroup.lua'), 'utf8'),
 		});
 		this.streamReadClient = options.redisClient.duplicate();
 	}