diff --git a/src/cache/adapters/workeradapter.ts b/src/cache/adapters/workeradapter.ts index 5ba42b2..9eb0d27 100644 --- a/src/cache/adapters/workeradapter.ts +++ b/src/cache/adapters/workeradapter.ts @@ -1,5 +1,5 @@ import { randomUUID } from 'node:crypto'; -import { parentPort, type MessagePort } from 'node:worker_threads'; +import { parentPort } from 'node:worker_threads'; import type { WorkerData } from '../../websocket'; import type { WorkerSendCacheRequest } from '../../websocket/discord/worker'; import type { Adapter } from './types'; @@ -8,10 +8,7 @@ export class WorkerAdapter implements Adapter { isAsync = true; promises = new Map void; timeout: NodeJS.Timeout }>(); - constructor( - readonly parent: MessagePort | NodeJS.Process, - public workerData: WorkerData, - ) {} + constructor(public workerData: WorkerData) {} postMessage(body: any) { if (parentPort) return parentPort.postMessage(body); diff --git a/src/client/workerclient.ts b/src/client/workerclient.ts index d6242f8..828f7d0 100644 --- a/src/client/workerclient.ts +++ b/src/client/workerclient.ts @@ -65,7 +65,7 @@ export class WorkerClient extends BaseClient { (manager ?? process).on('message', (data: ManagerMessages) => this.handleManagerMessages(data)); this.setServices({ cache: { - adapter: new WorkerAdapter(manager ?? process, workerData), + adapter: new WorkerAdapter(workerData), disabledCache: options?.disabledCache, }, });