completely removed the need for lodash

package.json

@@ -39,7 +39,6 @@
     "dayjs": "1.11.5",
     "debug": "4.3.4",
     "ioredis": "4.28.5",
-    "lodash": "4.17.21",
     "p-queue": "6.6.2",
     "p-timeout": "4.1.0",
     "rate-limiter-flexible": "2.3.8",
@@ -50,9 +49,7 @@
     "@types/debug": "4.1.7",
     "@types/ioredis": "4.28.10",
     "@types/jest": "29.0.0",
-    "@types/lodash": "4.14.184",
     "@types/node": "18.7.15",
-    "@types/set-interval-async": "^1.0.0",
     "@types/uuid": "8.3.4",
     "@typescript-eslint/eslint-plugin": "5.36.2",
     "@typescript-eslint/parser": "5.36.2",

src/actions/are-tasks-stalled.ts

@@ -1,5 +1,5 @@
 import { Redis } from 'ioredis';
-import { zipWith } from 'lodash';
+import { zipWith } from '../utils/general';
 import { getTaskAcknowledgedKey } from '../utils/keys';
 import { exec } from '../utils/redis';
 import { getStallingTaskIds } from './get-stalling-task-ids';

src/actions/create-manager.ts

@@ -1,13 +1,13 @@
 /* eslint-disable @typescript-eslint/no-non-null-assertion */
 import debugF from 'debug';
 import { Redis } from 'ioredis';
-import { set } from 'lodash';
 import { Event } from '../domain/events/event';
 import { EventType } from '../domain/events/event-type';
 import { Manager } from '../domain/manager/manager';
 import { TaskResponse } from '../domain/manager/task-response';
 import { Task } from '../domain/tasks/task';
 import { TaskStatus } from '../domain/tasks/task-status';
+import { set } from '../utils/general';
 import {
   createClientAndLoadLuaScripts,
   ensureDisconnected,

src/actions/create-worker.ts

@@ -1,6 +1,5 @@
 import debugF from 'debug';
 import { Redis } from 'ioredis';
-import { debounce } from 'lodash';
 import PQueue from 'p-queue';
 import { RateLimiterRedis } from 'rate-limiter-flexible';
 import {
@@ -14,7 +13,7 @@ import { Task } from '../domain/tasks/task';
 import { serializeWorker } from '../domain/worker/serialize-worker';
 import { Worker } from '../domain/worker/worker';
 import { WorkerInstance } from '../domain/worker/worker-instance';
-import { createWorkerId, sleep } from '../utils/general';
+import { createWorkerId, debounce, sleep } from '../utils/general';
 import {
   getWorkerKey,
   getWorkerPausedChannel,

src/utils/general.ts

@@ -30,3 +30,29 @@ export const pickBy = (
   }
   return obj;
 };
+
+export const zipWith = (
+  arr1: Array<any>,
+  arr2: Array<any>,
+  fn: (value: any, value2: any) => any,
+) => arr1.map((value, index) => fn(value, arr2[index]));
+
+export const set = (object: Record<string, any>, path: string, value: any) => {
+  /* eslint-disable no-param-reassign */
+  const [current, ...rest] = path.split('.');
+  if (rest.length >= 1) {
+    object[current] = object[current] || {};
+    set(object[current], rest.join('.'), value);
+  } else {
+    object[current] = value;
+  }
+  return object;
+};
+
+export const debounce = (fn: (args: []) => any, timeout: number) => {
+  let timer: NodeJS.Timeout;
+  return (...args: any) => {
+    clearTimeout(timer);
+    timer = setTimeout(() => fn(args), timeout);
+  };
+};