From e7cbc1bf111b09b64accfd95e82ad9f3a408fc4c Mon Sep 17 00:00:00 2001 From: DD Date: Thu, 27 Oct 2022 22:47:00 +0300 Subject: [PATCH] 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> --- packages/brokers/__tests__/index.test.ts | 6 ++++++ packages/brokers/src/brokers/redis/BaseRedis.ts | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/packages/brokers/__tests__/index.test.ts b/packages/brokers/__tests__/index.test.ts index e133c58d9487..898be4e7b61f 100644 --- 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 index a075c0a47e68..1e95913b4c05 100644 --- a/packages/brokers/src/brokers/redis/BaseRedis.ts +++ b/packages/brokers/src/brokers/redis/BaseRedis.ts @@ -61,7 +61,7 @@ export abstract class BaseRedisBroker> 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(); }