improvements

Author: muniter

DESIGN.md

@@ -2,6 +2,8 @@
 
 The Mongoose adapter allows you to use Mongoose models with the adapter-queue system, providing seamless integration with your existing Mongoose-based application. It implements the `DatabaseAdapter` interface directly, offering a native Mongoose experience.
 
+**Key Feature**: No separate worker processes needed - each queue processes its own jobs through the `run()` method.
+
 ## Installation
 
 First, ensure you have both `adapter-queue` and `mongoose` installed:
@@ -32,8 +34,11 @@ queue.setHandlers({
 // Push a job
 await queue.push('send-email', { to: 'user@example.com' });
 
-// Start the worker
+// Process all jobs once
 await queue.run();
+
+// Or run continuously (polling every 5 seconds)
+await queue.run(true, 5);
 ```
 
 ## Using Custom Models

docs/mongoose-adapter.md

@@ -64,9 +64,10 @@ async function main() {
   });
   console.log(`Image job created with ID: ${imageJobId}`);
 
-  // Run the queue worker
-  console.log('\nStarting queue worker...');
+  // Process all jobs once
+  console.log('\nProcessing jobs...');
   await queue.run();
+  console.log('All jobs processed!');
 }
 
 // Alternative: Using a custom model
@@ -95,8 +96,37 @@ async function customModelExample(): Promise<void> {
   });
 }
 
-// Run the example
+// Continuous processing example
+async function continuousProcessingExample(): Promise<void> {
+  await mongoose.connect('mongodb://localhost:27017/queue-example');
+  
+  const queue = createMongooseQueue<MyJobs>('continuous-queue');
+  
+  queue.setHandlers({
+    'send-email': async (job) => {
+      console.log(`[${new Date().toISOString()}] Processing email job: ${job.id}`);
+      await new Promise(resolve => setTimeout(resolve, 1000));
+      console.log(`Email sent to ${job.payload.to}`);
+    },
+    'process-image': async (job) => {
+      console.log(`[${new Date().toISOString()}] Processing image job: ${job.id}`);
+      await new Promise(resolve => setTimeout(resolve, 2000));
+      console.log(`Image processed: ${job.payload.url}`);
+    }
+  });
+
+  console.log('Starting continuous job processing (polling every 3 seconds)...');
+  console.log('Add jobs from another process and watch them get processed!');
+  
+  // This will run forever, polling every 3 seconds
+  await queue.run(true, 3);
+}
+
+// Run the example (uncomment the one you want to test)
 main().catch(console.error);
 
+// For continuous processing, run this instead:
+// continuousProcessingExample().catch(console.error);
+
 // Export for testing
-export { main, customModelExample };
+export { main, customModelExample, continuousProcessingExample };

example-queue-project/mongoose-example.ts

@@ -81,10 +81,6 @@
     "./mongoose": {
       "import": "./dist/src/adapters/mongoose.js",
       "types": "./dist/src/adapters/mongoose.d.ts"
-    },
-    "./worker": {
-      "import": "./dist/src/worker/worker.js",
-      "types": "./dist/src/worker/worker.d.ts"
     }
   },
   "peerDependencies": {

package.json

@@ -25,4 +25,17 @@ export type {
 } from './interfaces/database.ts';
 
 
-export type { WorkerOptions } from './worker/worker.ts';
+export { DbQueue } from './drivers/db.ts';
+export { FileQueue } from './drivers/file.ts';
+export { InMemoryQueue } from './drivers/memory.ts';
+
+// Mongoose adapter exports
+export { 
+  MongooseQueue,
+  createMongooseQueue,
+  createQueueModel,
+  QueueJob,
+  MongooseDatabaseAdapter,
+  QueueJobSchema
+} from './adapters/mongoose.ts';
+export type { IQueueJob } from './adapters/mongoose.ts';