Your lightweight queue system is set up and ready to use!

A complete SQLite-based queue system with:

• ✅ Database schema initialized
• ✅ Priority-based task processing
• ✅ Delayed/scheduled execution
• ✅ Automatic retries with dead letter queue
• ✅ Worker running every minute
• ✅ Built-in monitoring

Visit: https://www.val.town/x/nbbaier/lightweightQueue

curl -X POST https://nbbaier--c5bd3e20c8cc11f0a88c42dde27851f2.web.val.run \
  -H "Content-Type: application/json" \
  -d '{
    "task_type": "log_message",
    "payload": {
      "message": "Hello from my queue!",
      "level": "info"
    }
  }'

Visit: https://lightweightqueue-monitor.val.run/

1. log_message - Log a message
2. send_email - Send an email via Val Town
3. webhook - Call an external webhook
4. http_request - Make HTTP requests

{
  "task_type": "log_message",
  "payload": { "message": "Important task!" },
  "priority": 10
}

{
  "task_type": "log_message",
  "payload": { "message": "Future task!" },
  "scheduled_for": 1732406400
}

{
  "task_type": "send_email",
  "payload": {
    "to": "user@example.com",
    "subject": "Test",
    "text": "Hello from the queue!"
  }
}

Edit processors.ts and add a new processor:

case "my_custom_task":
  await processMyCustomTask(payload);
  break;

• schema.ts - Database initialization
• enqueue.ts - API to add tasks
• worker.ts - Processes tasks every minute
• processors.ts - Task processing logic
• monitor.ts - Queue statistics API
• test.ts - Example test cases
• README.md - Full documentation

1. Run the test file to see it in action
2. Check the monitor endpoint to see queue stats
3. Add your own custom task processors
4. Adjust worker interval if needed (currently 1 minute)

See README.md for complete documentation including:

• All task type examples
• API reference
• Architecture details
• Error handling
• Best practices

Note: The worker processes up to 10 tasks per minute. Failed tasks are automatically retried up to 3 times before moving to the dead letter queue.