chore: upgrade dependencies (#35)

Author: manast

agents.md

@@ -20,7 +20,7 @@
   },
   "dependencies": {
     "@sinclair/typebox": "^0.31.28",
-    "bullmq": "5.41.0",
+    "bullmq": "^5.65.1",
     "chalk": "^5.4.1",
     "ioredis": "^5.5.0",
     "semver": "^7.7.1"
@@ -29,19 +29,19 @@
     "@taskforcesh/message-broker"
   ],
   "devDependencies": {
-    "@commitlint/cli": "^19.7.1",
-    "@commitlint/config-conventional": "^19.7.1",
+    "@commitlint/cli": "^20.1.0",
+    "@commitlint/config-conventional": "^20.0.0",
     "@semantic-release/changelog": "^6.0.3",
-    "@semantic-release/commit-analyzer": "^9.0.2",
+    "@semantic-release/commit-analyzer": "^13.0.1",
     "@semantic-release/git": "^10.0.1",
-    "@semantic-release/github": "^8.1.0",
-    "@semantic-release/npm": "^9.0.2",
+    "@semantic-release/github": "^12.0.2",
+    "@semantic-release/npm": "^13.1.2",
     "@tsconfig/node-lts": "^18.12.5",
-    "@types/bun": "1.2.2",
-    "@types/node": "^12.20.55",
+    "@types/bun": "^1.3.3",
+    "@types/node": "^24.10.1",
     "husky": "^9.1.7",
     "prettier": "^3.5.1",
-    "semantic-release": "^19.0.5",
+    "semantic-release": "^25.0.2",
     "typescript": "^5.7.3"
   },
   "release": {

bun.lockb

@@ -1,5 +1,4 @@
 import { afterAll, afterEach, beforeAll, beforeEach, describe, expect, it, jest, mock } from "bun:test";
-import { Server } from "bun";
 import { cleanProxy, startProxy } from "./proxy";
 import { Redis } from "ioredis";
 import { config } from "./config";
@@ -51,7 +50,7 @@ describe("e2e", () => {
     const proxy = await startProxy(0, redisClient, redisClient.duplicate());
     const proxyPort = proxy.port;
 
-    let server: Server;
+    let server: any;
     const processingJob = new Promise<void>((resolve, reject) => {
       server = Bun.serve({
         // Typescript requires this dummy websocket

package-lock.json

@@ -1,13 +1,14 @@
 import { Redis, Cluster } from "ioredis";
+import { Server } from "bun";
 
 import {
   QueueController,
   WorkerController,
   QueueEventsController,
 } from "./controllers";
+import { WebSocketData } from "./interfaces";
 import { RouteMatcher } from "./utils/router-matcher";
 import { warn } from "./utils/log";
-import { Server } from "bun";
 import queuesRoutes from "./routes/queues-routes";
 import asciiArt from "./ascii-art";
 import workersRoutes from "./routes/workers-routes";
@@ -35,7 +36,7 @@ routeMatcher.addWebSocketRoute<{ queueName: string }>(
 
 export const fetchHandler = (
   connection: Redis | Cluster,
-  workersConnection: Redis | Cluster) => async (req: Request, server: Server) => {
+  workersConnection: Redis | Cluster) => async (req: Request, server: Server<WebSocketData>) => {
     const url = new URL(req.url);
     const { searchParams } = url;
     const { method } = req;

package.json

@@ -1,4 +1,3 @@
-import { Server } from "bun";
 import IORedis, { Cluster, Redis } from "ioredis";
 
 import { startProxy } from "./proxy";
@@ -54,7 +53,7 @@ workersConnection.on("error", (err) => {
   }
 })
 
-startProxy(config.port, connection, workersConnection).then((server: Server) => {
+startProxy(config.port, connection, workersConnection).then((server) => {
   info(`Running BullMQ Proxy on port ${server.port} (c) ${new Date().getFullYear()} Taskforce.sh Inc. v${pkg.version}`);
 }).catch((err) => {
   error(`Error starting server ${(<Error>err).message}`);

src/e2e-test.ts

@@ -1,5 +1,6 @@
 export * from './http-handler-opts';
 export * from './websocket-behaviour';
+export * from './websocket-data';
 export * from './worker-endpoint';
 export * from './worker-metadata';
 export * from './buffer-source';

src/fetch-handler.ts

@@ -0,0 +1,15 @@
+import { WebSocketHandler } from "bun";
+import { ConnectionOptions } from "bullmq";
+
+/**
+ * Data associated with each WebSocket connection in the proxy.
+ */
+export type WebSocketData = {
+  route: any;
+  controller: WebSocketHandler<any>;
+  queueName: string;
+  concurrency: number;
+  connection: ConnectionOptions;
+  events: any;
+  searchParams: URLSearchParams;
+};

src/index.ts

@@ -1,18 +1,12 @@
 import { Cluster, Redis } from "ioredis";
 import chalk from "chalk";
 
-import { WebSocketBehaviour } from "./interfaces/websocket-behaviour";
+import { WebSocketData } from "./interfaces";
 import { warn } from "./utils/log";
 import { fetchHandler } from "./fetch-handler";
 import asciiArt from "./ascii-art";
 import { WorkerHttpController } from "./controllers/http/worker-http-controller";
 
-type WebSocketData = {
-  createdAt: number;
-  params: any;
-  controller: WebSocketBehaviour;
-};
-
 const websocket = {
   message(ws: any, message: any) {
     const { controller } = ws.data;