From 4ccaaa68c0514135c125507225724a69c9ff24d7 Mon Sep 17 00:00:00 2001 From: Rogger Valverde Date: Sun, 3 Mar 2024 14:19:56 -0600 Subject: [PATCH] refactor: replace lodash invert method (#2459) --- src/classes/job.ts | 4 ++-- src/utils.ts | 26 ++++++++++++++++++-------- 2 files changed, 20 insertions(+), 10 deletions(-) diff --git a/src/classes/job.ts b/src/classes/job.ts index 532f03c038..2b2ee0c12f 100644 --- a/src/classes/job.ts +++ b/src/classes/job.ts @@ -1,5 +1,4 @@ import { ChainableCommander } from 'ioredis'; -import { invert } from 'lodash'; import { debuglog } from 'util'; import { BackoffOptions, @@ -24,6 +23,7 @@ import { } from '../types'; import { errorObject, + invertObject, isEmpty, getParentKey, lengthInUtf8Bytes, @@ -44,7 +44,7 @@ const optsDecodeMap = { rdof: 'removeDependencyOnFailure', }; -const optsEncodeMap = invert(optsDecodeMap); +const optsEncodeMap = invertObject(optsDecodeMap); export const PRIORITY_LIMIT = 2 ** 21; diff --git a/src/utils.ts b/src/utils.ts index ed19d84621..eebbd6bdc2 100644 --- a/src/utils.ts +++ b/src/utils.ts @@ -67,6 +67,24 @@ export function delay( }); } +export function increaseMaxListeners( + emitter: EventEmitter, + count: number, +): void { + const maxListeners = emitter.getMaxListeners(); + emitter.setMaxListeners(maxListeners + count); +} + +export const invertObject = (obj: Record) => { + return Object.entries(obj).reduce>( + (encodeMap, [key, value]) => { + encodeMap[value] = key; + return encodeMap; + }, + {}, + ); +}; + export function isRedisInstance(obj: any): obj is Redis | Cluster { if (!obj) { return false; @@ -79,14 +97,6 @@ export function isRedisCluster(obj: unknown): obj is Cluster { return isRedisInstance(obj) && (obj).isCluster; } -export function increaseMaxListeners( - emitter: EventEmitter, - count: number, -): void { - const maxListeners = emitter.getMaxListeners(); - emitter.setMaxListeners(maxListeners + count); -} - export function decreaseMaxListeners( emitter: EventEmitter, count: number,