{"_id":"@arcanea/agent-bus","name":"@arcanea/agent-bus","dist-tags":{"latest":"0.1.0"},"versions":{"0.1.0":{"name":"@arcanea/agent-bus","version":"0.1.0","description":"Agent-to-agent communication bus with request-response messaging, pub-sub, and delivery guarantees","type":"module","main":"./dist/index.js","types":"./dist/index.d.ts","exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js"},"./types":{"types":"./dist/types.d.ts","import":"./dist/types.js"}},"keywords":["arcanea","agent","bus","messaging","pubsub","communication"],"author":{"name":"FrankX","email":"frank@frankx.ai"},"license":"MIT","publishConfig":{"access":"public"},"repository":{"type":"git","url":"git+https://github.com/frankxai/arcanea.git","directory":"packages/agent-bus"},"devDependencies":{"@types/node":"^25.3.0","typescript":"^5.5.0"},"scripts":{"build":"tsc","dev":"tsc --watch","clean":"rm -rf dist","typecheck":"tsc --noEmit","test":"node --test tests/agent-bus.test.mjs"},"_id":"@arcanea/agent-bus@0.1.0","bugs":{"url":"https://github.com/frankxai/arcanea/issues"},"homepage":"https://github.com/frankxai/arcanea#readme","_integrity":"sha512-SQGymZqQ1WJmiR5KLs/es1Zpj51tLq5KBlVlx+4c1KVQFmTKnH4+aq5SPBjn2PNCPgZDlN3BDepR8dPJn+dCRw==","_resolved":"C:\\Users\\frank\\AppData\\Local\\Temp\\69218def123deac9d77b8a174d088096\\arcanea-agent-bus-0.1.0.tgz","_from":"file:arcanea-agent-bus-0.1.0.tgz","_nodeVersion":"24.8.0","_npmVersion":"11.6.1","dist":{"integrity":"sha512-SQGymZqQ1WJmiR5KLs/es1Zpj51tLq5KBlVlx+4c1KVQFmTKnH4+aq5SPBjn2PNCPgZDlN3BDepR8dPJn+dCRw==","shasum":"59358d13ae6dd76d3ece877719138e4ef3c0bbda","tarball":"https://registry.npmjs.org/@arcanea/agent-bus/-/agent-bus-0.1.0.tgz","fileCount":15,"unpackedSize":40392,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEYCIQC2BqqSAqlrPe0K7tKOoDPZafI/K+JdUVI75cNoSmvpHgIhAIHT1KrxhGw9z7/QsyfIT+ChiV8lBuip9f8+/92ZvoZx"}]},"_npmUser":{"name":"frankxai","email":"friemerx@gmail.com"},"directories":{},"maintainers":[{"name":"frankxai","email":"friemerx@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/agent-bus_0.1.0_1771903035879_0.15007092821620738"},"_hasShrinkwrap":false}},"time":{"created":"2026-02-24T03:17:15.764Z","0.1.0":"2026-02-24T03:17:16.055Z","modified":"2026-02-24T03:17:16.288Z"},"maintainers":[{"name":"frankxai","email":"friemerx@gmail.com"}],"description":"Agent-to-agent communication bus with request-response messaging, pub-sub, and delivery guarantees","homepage":"https://github.com/frankxai/arcanea#readme","keywords":["arcanea","agent","bus","messaging","pubsub","communication"],"repository":{"type":"git","url":"git+https://github.com/frankxai/arcanea.git","directory":"packages/agent-bus"},"author":{"name":"FrankX","email":"frank@frankx.ai"},"bugs":{"url":"https://github.com/frankxai/arcanea/issues"},"license":"MIT","readme":"# @arcanea/agent-bus\r\n\r\nAgent-to-agent communication bus for the Arcanea Intelligence OS — request-response messaging, pub-sub, and delivery guarantees.\r\n\r\n## Install\r\n\r\n```bash\r\nnpm install @arcanea/agent-bus\r\n```\r\n\r\n## Usage\r\n\r\n```js\r\nimport { AgentBus } from '@arcanea/agent-bus';\r\n\r\nconst bus = new AgentBus();\r\n\r\n// Subscribe to a topic\r\nbus.subscribe('task.created', (msg) => {\r\n  console.log(`${msg.from} created task:`, msg.payload);\r\n});\r\n\r\n// Send a direct message\r\nawait bus.send('agent-a', 'agent-b', 'task.created', { task: 'build' });\r\n\r\n// Publish to all subscribers\r\nawait bus.publish('orchestrator', 'guardian.activated', { id: 'shinkami' });\r\n\r\n// Request-response pattern\r\nbus.subscribe('ping', async (msg) => {\r\n  await bus.reply(msg, { pong: true });\r\n});\r\nconst response = await bus.request('client', 'server', 'ping', { data: 1 });\r\n```\r\n\r\n## Features\r\n\r\n- **Direct messaging** — send to specific agents\r\n- **Request-response** — with correlation IDs and timeouts\r\n- **Pub-sub** — topic-based with wildcard matching (`guardian.*`, `task.**`)\r\n- **Middleware pipeline** — intercept, transform, and log messages\r\n- **Dead letter queue** — track failed deliveries\r\n- **Priority levels** — critical, high, normal, low\r\n- **Message TTL** — automatic expiry\r\n- **Statistics** — delivery counts, latency tracking\r\n\r\n## API\r\n\r\n| Export | Description |\r\n|---|---|\r\n| `AgentBus` | Main communication bus class |\r\n\r\n### Topic Matching\r\n\r\n- `guardian.shinkami` — exact match\r\n- `guardian.*` — single-level wildcard\r\n- `task.**` — multi-level wildcard\r\n\r\n## License\r\n\r\nMIT\r\n","readmeFilename":"README.md","_rev":"1-96cd49a143779aa7cc9cfddded60ae13"}