mongodb

Author: muniter

debug-mongo.js

@@ -0,0 +1,34 @@
+import { MongoClient } from 'mongodb';
+import { createMongoQueue } from './dist/adapters/mongodb.js';
+
+// Simple debug script to test MongoDB adapter
+async function debugMongo() {
+  const client = new MongoClient('mongodb://localhost:27017');
+  await client.connect();
+  
+  const queue = createMongoQueue(client, 'debug_test', 'jobs');
+  
+  console.log('1. Adding a job...');
+  const jobId = await queue.addJob('test-job', { payload: { data: 'debug test' } });
+  console.log('Job added with ID:', jobId);
+  
+  console.log('2. Checking job status...');
+  const status = await queue.status(jobId);
+  console.log('Job status:', status);
+  
+  console.log('3. Checking database directly...');
+  const db = client.db('debug_test');
+  const collection = db.collection('jobs');
+  const jobs = await collection.find({}).toArray();
+  console.log('Jobs in database:', jobs.length);
+  console.log('First job:', JSON.stringify(jobs[0], null, 2));
+  
+  console.log('4. Trying to reserve a job...');
+  const adapter = queue.db;
+  const reserved = await adapter.reserveJob(5);
+  console.log('Reserved job:', reserved);
+  
+  await client.close();
+}
+
+debugMongo().catch(console.error);

package.json

@@ -38,8 +38,10 @@
   "devDependencies": {
     "@aws-sdk/client-sqs": "^3.831.0",
     "@types/better-sqlite3": "7.6.13",
+    "@types/mongodb": "^4.0.7",
     "@types/node": "^20.0.0",
     "better-sqlite3": "^12.0.0",
+    "mongodb": "^6.17.0",
     "redis": "^5.5.6",
     "testcontainers": "^11.0.3",
     "typescript": "^5.0.0",
@@ -61,11 +63,16 @@
     "./sqs": {
       "import": "./dist/adapters/sqs.js",
       "types": "./dist/adapters/sqs.d.ts"
+    },
+    "./mongodb": {
+      "import": "./dist/adapters/mongodb.js",
+      "types": "./dist/adapters/mongodb.d.ts"
     }
   },
   "peerDependencies": {
     "@aws-sdk/client-sqs": "^3.0.0",
     "better-sqlite3": "^9.0.0",
+    "mongodb": "^6.0.0",
     "redis": "^4.0.0"
   },
   "peerDependenciesMeta": {
@@ -75,6 +82,9 @@
     "better-sqlite3": {
       "optional": true
     },
+    "mongodb": {
+      "optional": true
+    },
     "redis": {
       "optional": true
     }