refactor: replace lodash invert method (#2459)

Author: roggervalf

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;
 

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<string, string>) => {
+  return Object.entries(obj).reduce<Record<string, string>>(
+    (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) && (<Cluster>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,