High-performance job queue for Bun and AI agents. Memory or one-file SQLite, optional PostgreSQL 15–18 multi-broker persistence, cron, retries, DLQ, and MCP.
Drift inferred · capture-to-capture
No drift recorded — single capability capture; advisories appear once its surface changes.
transport stdio counts 73 tools · 0 res
· 0 prompts
permission surface via code analysis
tools
-
bunqueue_ack_job
-
bunqueue_ack_job_batch
-
bunqueue_add_cron
-
bunqueue_add_flow
-
bunqueue_add_flow_bulk_then
-
bunqueue_add_flow_chain
-
bunqueue_add_job
-
bunqueue_add_job_log
-
bunqueue_add_jobs_bulk
-
bunqueue_add_webhook
-
bunqueue_cancel_job
-
bunqueue_change_delay
-
bunqueue_change_job_priority
-
bunqueue_clean_queue
-
bunqueue_clear_concurrency
-
bunqueue_clear_job_logs
-
bunqueue_clear_rate_limit
-
bunqueue_compact_memory
-
bunqueue_count_jobs
-
bunqueue_delete_cron
-
bunqueue_discard_job
-
bunqueue_drain_queue
-
bunqueue_extend_lock
-
bunqueue_fail_job
-
bunqueue_get_children_values
-
bunqueue_get_counts_per_priority
-
bunqueue_get_cron
-
bunqueue_get_dlq
-
bunqueue_get_flow
-
bunqueue_get_job
-
bunqueue_get_job_by_custom_id
-
bunqueue_get_job_counts
-
bunqueue_get_job_logs
-
bunqueue_get_job_result
-
bunqueue_get_job_state
-
bunqueue_get_jobs
-
bunqueue_get_memory_stats
-
bunqueue_get_per_queue_stats
-
bunqueue_get_progress
-
bunqueue_get_prometheus_metrics
-
bunqueue_get_queue_stats
-
bunqueue_get_stats
-
bunqueue_get_storage_status
-
bunqueue_is_paused
-
bunqueue_job_heartbeat
-
bunqueue_job_heartbeat_batch
-
bunqueue_list_crons
-
bunqueue_list_handlers
-
bunqueue_list_queues
-
bunqueue_list_webhooks
-
bunqueue_list_workers
-
bunqueue_move_to_delayed
-
bunqueue_obliterate_queue
-
bunqueue_pause_queue
-
bunqueue_promote_job
-
bunqueue_pull_job
-
bunqueue_pull_job_batch
-
bunqueue_purge_dlq
-
bunqueue_register_handler
-
bunqueue_register_worker
-
bunqueue_remove_webhook
-
bunqueue_resume_queue
-
bunqueue_retry_completed
-
bunqueue_retry_dlq
-
bunqueue_set_concurrency
-
bunqueue_set_rate_limit
-
bunqueue_set_webhook_enabled
-
bunqueue_unregister_handler
-
bunqueue_unregister_worker
-
bunqueue_update_job_data
-
bunqueue_update_progress
-
bunqueue_wait_for_job
-
bunqueue_worker_heartbeat
evidence-backed
findings quoted directly from the published source artifact — not inferred
code files: 1428
filesystem 6
- fs package/dist/client/manager.js :4
import { realpathSync } from 'node:fs'; - fs package/dist/client/sandboxed/wrapper.js :5
import { mkdir, unlink, realpath } from 'node:fs/promises'; - fs package/dist/client/tcp/transport.js :1
import { readFileSync } from 'node:fs'; - fs package/dist/config/loader.js :5
import { existsSync } from 'node:fs'; - fs package/dist/infrastructure/backup/sqliteBackupFiles.js :5
import { rename, rm } from 'node:fs/promises'; - fs package/dist/infrastructure/server/tls.js :5
import { existsSync } from 'node:fs';
network 5
- net package/dist/application/webhookManager.js :111
const response = await fetch(webhook.url, { - net package/dist/cli/commands/doctor.js :13
const response = await fetch(`http://${endpoint}/health`, { - net package/dist/cli/localOutput.js :14
const response = await fetch(`http://${server.endpoint}/health`, { - net package/dist/infrastructure/cloud/httpSender.js :95
const res = await fetch(url, { - net package/dist/mcp/httpHandler.js :32
const res = await fetch(handler.url, init);
secrets 1
- secrets package/dist/mcp/adapter.js :11
token: process.env.BUNQUEUE_TOKEN,
tool registrations 73
- bunqueue_pull_job package/dist/mcp/tools/consumptionTools.js :9
- bunqueue_pull_job_batch package/dist/mcp/tools/consumptionTools.js :25
- bunqueue_ack_job package/dist/mcp/tools/consumptionTools.js :42
- bunqueue_ack_job_batch package/dist/mcp/tools/consumptionTools.js :51
- bunqueue_fail_job package/dist/mcp/tools/consumptionTools.js :61
- bunqueue_job_heartbeat package/dist/mcp/tools/consumptionTools.js :70
- bunqueue_job_heartbeat_batch package/dist/mcp/tools/consumptionTools.js :76
- bunqueue_extend_lock package/dist/mcp/tools/consumptionTools.js :86
- bunqueue_add_cron package/dist/mcp/tools/cronTools.js :8
- bunqueue_list_crons package/dist/mcp/tools/cronTools.js :23
- bunqueue_get_cron package/dist/mcp/tools/cronTools.js :31
- bunqueue_delete_cron package/dist/mcp/tools/cronTools.js :45
- bunqueue_get_dlq package/dist/mcp/tools/dlqTools.js :8
- bunqueue_retry_dlq package/dist/mcp/tools/dlqTools.js :22
- bunqueue_purge_dlq package/dist/mcp/tools/dlqTools.js :33
- bunqueue_retry_completed package/dist/mcp/tools/dlqTools.js :43
- bunqueue_add_flow package/dist/mcp/tools/flowTools.js :36
- bunqueue_add_flow_chain package/dist/mcp/tools/flowTools.js :55
- bunqueue_add_flow_bulk_then package/dist/mcp/tools/flowTools.js :64
- bunqueue_get_flow package/dist/mcp/tools/flowTools.js :71
- bunqueue_register_handler package/dist/mcp/tools/handlerTools.js :9
- bunqueue_unregister_handler package/dist/mcp/tools/handlerTools.js :42
- bunqueue_list_handlers package/dist/mcp/tools/handlerTools.js :55
- bunqueue_update_job_data package/dist/mcp/tools/jobMgmtTools.js :9
- bunqueue_change_job_priority package/dist/mcp/tools/jobMgmtTools.js :16
- bunqueue_move_to_delayed package/dist/mcp/tools/jobMgmtTools.js :25
- bunqueue_discard_job package/dist/mcp/tools/jobMgmtTools.js :34
- bunqueue_get_progress package/dist/mcp/tools/jobMgmtTools.js :40
- bunqueue_change_delay package/dist/mcp/tools/jobMgmtTools.js :52
- bunqueue_add_job package/dist/mcp/tools/jobTools.js :9
- bunqueue_add_jobs_bulk package/dist/mcp/tools/jobTools.js :20
- bunqueue_get_job package/dist/mcp/tools/jobTools.js :34
- bunqueue_get_job_state package/dist/mcp/tools/jobTools.js :46
- bunqueue_get_job_result package/dist/mcp/tools/jobTools.js :52
- bunqueue_cancel_job package/dist/mcp/tools/jobTools.js :60
- bunqueue_promote_job package/dist/mcp/tools/jobTools.js :66
- bunqueue_update_progress package/dist/mcp/tools/jobTools.js :72
- bunqueue_get_children_values package/dist/mcp/tools/jobTools.js :82
- bunqueue_get_job_by_custom_id package/dist/mcp/tools/jobTools.js :95
- bunqueue_wait_for_job package/dist/mcp/tools/jobTools.js :107
- bunqueue_get_stats package/dist/mcp/tools/monitoringTools.js :8
- bunqueue_get_queue_stats package/dist/mcp/tools/monitoringTools.js :12
- bunqueue_list_workers package/dist/mcp/tools/monitoringTools.js :20
- bunqueue_get_job_logs package/dist/mcp/tools/monitoringTools.js :31
- bunqueue_add_job_log package/dist/mcp/tools/monitoringTools.js :44
- bunqueue_get_storage_status package/dist/mcp/tools/monitoringTools.js :52
- bunqueue_get_per_queue_stats package/dist/mcp/tools/monitoringTools.js :56
- bunqueue_get_memory_stats package/dist/mcp/tools/monitoringTools.js :60
- bunqueue_get_prometheus_metrics package/dist/mcp/tools/monitoringTools.js :64
- bunqueue_clear_job_logs package/dist/mcp/tools/monitoringTools.js :68
- bunqueue_compact_memory package/dist/mcp/tools/monitoringTools.js :81
- bunqueue_list_queues package/dist/mcp/tools/queueTools.js :9
- bunqueue_count_jobs package/dist/mcp/tools/queueTools.js :13
- bunqueue_get_jobs package/dist/mcp/tools/queueTools.js :19
- bunqueue_get_job_counts package/dist/mcp/tools/queueTools.js :38
- bunqueue_pause_queue package/dist/mcp/tools/queueTools.js :44
- bunqueue_resume_queue package/dist/mcp/tools/queueTools.js :57
- bunqueue_drain_queue package/dist/mcp/tools/queueTools.js :70
- bunqueue_obliterate_queue package/dist/mcp/tools/queueTools.js :80
- bunqueue_clean_queue package/dist/mcp/tools/queueTools.js :93
- bunqueue_is_paused package/dist/mcp/tools/queueTools.js :112
- bunqueue_get_counts_per_priority package/dist/mcp/tools/queueTools.js :118
- bunqueue_set_rate_limit package/dist/mcp/tools/rateLimitTools.js :8
- bunqueue_clear_rate_limit package/dist/mcp/tools/rateLimitTools.js :22
- bunqueue_set_concurrency package/dist/mcp/tools/rateLimitTools.js :35
- bunqueue_clear_concurrency package/dist/mcp/tools/rateLimitTools.js :49
- bunqueue_add_webhook package/dist/mcp/tools/webhookTools.js :9
- bunqueue_remove_webhook package/dist/mcp/tools/webhookTools.js :21
- bunqueue_list_webhooks package/dist/mcp/tools/webhookTools.js :27
- bunqueue_set_webhook_enabled package/dist/mcp/tools/webhookTools.js :38
- bunqueue_register_worker package/dist/mcp/tools/workerMgmtTools.js :9
- bunqueue_unregister_worker package/dist/mcp/tools/workerMgmtTools.js :20
- bunqueue_worker_heartbeat package/dist/mcp/tools/workerMgmtTools.js :26
install hooks 2
- prepare package/package.json :106
git config core.hooksPath .husky - prepublishOnly package/package.json :142
bun run build:lib
declared dependencies 20
- @modelcontextprotocol/sdk@^1.26.0
- msgpackr@^1.11.8
- @ai-sdk/anthropic@^4.0.22
- @anthropic-ai/claude-agent-sdk@^0.3.220
- @langchain/core@^1.2.3
- @langchain/langgraph@^1.4.8
- @mastra/core@^1.53.0
- @openai/agents@^0.13.5
- @types/bun@^1.4.0
- ai@^7.0.38
- bullmq@^5.79.3
- elysia@^1.4.25
- fast-check@^4.9.0
- ioredis@^5.11.1
- oxfmt@0.64.0
- oxlint@1.79.0
- oxlint-tsgolint@7.0.2001
- typedoc@^0.28.20
- typescript@^5.9.3
- zod@^4.3.6
obfuscation 1
- dynamic require()/import() package/dist/client/sandboxed/wrapper.js :55
const processor = (await import('${escapedPath}')).default;