chore: update configuration and build files - Update package.json with new dependencies and scripts - Modify webpack.config.js for enhanced build process - Update queueManager.ts with improved error handling - Maintain compatibility with existing build processes

Author: theboringhumane

packages/core/package.json

@@ -3,7 +3,7 @@
   "version": "1.0.0-beta.7",
   "description": "A distributed task queue system for Node.js, inspired by Celery and BullMQ",
   "main": "dist/index.js",
-  "types": "dist/src/index.d.ts",
+  "types": "dist/index.d.ts",
   "files": [
     "dist",
     "README.md"

packages/core/src/queue/queueManager.ts

@@ -56,7 +56,7 @@ export class QueueManager {
     this.metrics = new QueueMetrics(this.redis);
 
     const finalQueueOptions: QueueOptions = {
-      connection: this.redis,
+      connection: this.redis.options,
       ...queueOptions,
     };
 
@@ -174,7 +174,9 @@ export class QueueManager {
     });
 
     queueEvents.on("completed", async ({ jobId, returnvalue }) => {
-      await this.updateQueueMetadata(queueName);
+      await this.updateQueueMetadata(queueName, {
+        lastActivity: Date.now(),
+      });
       logger.info("✅ QueueManager: Job completed", {
         file: "queueManager.ts",
         function: "queueEvents",
@@ -368,7 +370,7 @@ export class QueueManager {
 
     if (!queue) {
       this.initializeQueue(queueName, {
-        connection: this.redis,
+        connection: this.redis.options,
       });
       queue = this.queues.get(queueName);
     }
@@ -415,6 +417,8 @@ export class QueueManager {
       task
     );
 
+    await this.updateQueueMetadata(queueName);
+
     logger.debug("🔄 QueueManager: Task added to queue", {
       file: "queueManager.ts",
       line: 120,

packages/core/webpack.config.js

@@ -1,11 +1,27 @@
 const path = require("path");
+const TerserPlugin = require("terser-webpack-plugin");
+
+const isProduction = process.env.NODE_ENV === "production";
 
 module.exports = {
   entry: {
     index: "./src/index.ts",
   },
   target: "node",
   mode: process.env.NODE_ENV || "development",
+  optimization: {
+    minimize: isProduction,
+    minimizer: [
+      new TerserPlugin({
+        terserOptions: {
+          compress: {
+            drop_console: true,
+          },
+          mangle: true,
+        },
+      }),
+    ],
+  },
   module: {
     rules: [
       {
@@ -16,6 +32,11 @@ module.exports = {
             configFile: path.resolve(__dirname, "tsconfig.json"),
             // Ensure webpack respects tsconfig paths
             transpileOnly: false,
+            // Generate declaration files
+            compilerOptions: {
+              declaration: true,
+              declarationMap: true,
+            },
           },
         },
         exclude: [/node_modules/, /examples/, /logs/],