{"_id":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","_rev":"4-f61cd0fcc21605d47e8f1f900fb5ad7d","name":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","dist-tags":{"latest":"1.0.3"},"versions":{"1.0.0":{"name":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","version":"1.0.0","keywords":["n8n-community-node-package"],"author":{"name":"Knowyours","email":"agentdatashuttle@knowyours.co"},"license":"MIT","_id":"@agentdatashuttle/n8n-nodes-agent-data-shuttle@1.0.0","maintainers":[{"name":"mritul","email":"mritul2003@gmail.com"},{"name":"sudhay","email":"sudhay2001@gmail.com"}],"homepage":"https://agentdatashuttle.knowyours.co","n8n":{"nodes":["dist/nodes/AdsSubscriber/AdsSubscriber.node.js","dist/nodes/AdsPublisher/AdsPublisher.node.js"],"credentials":["dist/credentials/ADSBridgeClientParamsApi.credentials.js","dist/credentials/ADSRabbitMQClientParamsApi.credentials.js"],"n8nNodesApiVersion":1},"dist":{"shasum":"ac49515e129df29ff7d90004e4dc333b138bb2c8","tarball":"https://registry.npmjs.org/@agentdatashuttle/n8n-nodes-agent-data-shuttle/-/n8n-nodes-agent-data-shuttle-1.0.0.tgz","fileCount":27,"integrity":"sha512-ClLboveS3/4TxPWe4y0Ig4Nl3ydat90Ux4JN9XLSr8zsJt3z2AamTkvAFHX8zrFJRYHzsiTHcZwFK/taVTQB3A==","signatures":[{"sig":"MEUCIFPVUMrl2HYkLtIEfh6mKyWWWfgWMtjF+cnol5fyE17mAiEAgcLtIEwN79gMGMtVO+G3DU89A/Bvpygy75Qvdiz8sNY=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":264802},"main":"index.js","engines":{"node":">=20.15"},"gitHead":"ba99abeb8a3191aba869c5cc09e0520bbf4fe847","scripts":{"dev":"tsc --watch","lint":"eslint nodes credentials package.json","push":"npm publish --access public","build":"npx rimraf dist && tsc && gulp build:icons","format":"prettier nodes credentials --write","lintfix":"eslint nodes credentials package.json --fix","prepublishOnly":"npm run build && npm run lint -c .eslintrc.prepublish.js nodes credentials package.json"},"_npmUser":{"name":"sudhay","email":"sudhay2001@gmail.com"},"_npmVersion":"10.2.4","description":"Custom n8n nodes for Agent Data Shuttle, enabling autonomous event-driven AI workflows via ADS Publisher and Subscriber.","directories":{},"_nodeVersion":"20.11.0","dependencies":{"langchain":"^0.3.27","@agentdatashuttle/adsjs":"^1.0.7"},"_hasShrinkwrap":false,"devDependencies":{"gulp":"^5.0.0","eslint":"^8.57.0","prettier":"^3.5.3","typescript":"^5.8.2","@typescript-eslint/parser":"~8.32.0","eslint-plugin-n8n-nodes-base":"^1.16.3"},"peerDependencies":{"n8n-workflow":"*"},"_npmOperationalInternal":{"tmp":"tmp/n8n-nodes-agent-data-shuttle_1.0.0_1752580726962_0.14191024020620469","host":"s3://npm-registry-packages-npm-production"}},"1.0.1":{"name":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","version":"1.0.1","keywords":["n8n-community-node-package"],"author":{"name":"Knowyours","email":"agentdatashuttle@knowyours.co"},"license":"MIT","_id":"@agentdatashuttle/n8n-nodes-agent-data-shuttle@1.0.1","maintainers":[{"name":"mritul","email":"mritul2003@gmail.com"},{"name":"sudhay","email":"sudhay2001@gmail.com"}],"homepage":"https://agentdatashuttle.knowyours.co","bugs":{"url":"https://github.com/agentdatashuttle/n8n-nodes/issues"},"n8n":{"nodes":["dist/nodes/AdsSubscriber/AdsSubscriber.node.js","dist/nodes/AdsPublisher/AdsPublisher.node.js"],"credentials":["dist/credentials/ADSBridgeClientParamsApi.credentials.js","dist/credentials/ADSRabbitMQClientParamsApi.credentials.js"],"n8nNodesApiVersion":1},"dist":{"shasum":"57e2f51d748cbfbf3e613300cbedaa061806bf8a","tarball":"https://registry.npmjs.org/@agentdatashuttle/n8n-nodes-agent-data-shuttle/-/n8n-nodes-agent-data-shuttle-1.0.1.tgz","fileCount":27,"integrity":"sha512-LvRU6j7/3Z3nlGhk6sJ+Pj9XyLH1ee/7Io6alAk+gpHuzVFA0RcRgOpm0Xfa0PwXtolWLs4oxlUkL4uXSkQ0Zw==","signatures":[{"sig":"MEQCIC2nmmL3yT75t9p+lob+dRLyBn1ZhGyGmeXVwdwxP9aFAiBw8Pl1aHuw9adkp9HDlFonAZUIB17Ojr74GfaVCVJJng==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":264970},"main":"index.js","engines":{"node":">=20.15"},"gitHead":"ba99abeb8a3191aba869c5cc09e0520bbf4fe847","scripts":{"dev":"tsc --watch","lint":"eslint nodes credentials package.json","push":"npm publish --access public","build":"npx rimraf dist && tsc && gulp build:icons","format":"prettier nodes credentials --write","lintfix":"eslint nodes credentials package.json --fix","prepublishOnly":"npm run build && npm run lint -c .eslintrc.prepublish.js nodes credentials package.json"},"_npmUser":{"name":"sudhay","email":"sudhay2001@gmail.com"},"repository":{"url":"git+https://github.com/agentdatashuttle/n8n-nodes.git"},"_npmVersion":"10.2.4","description":"Custom n8n nodes for Agent Data Shuttle, enabling autonomous event-driven AI workflows via ADS Publisher and Subscriber.","directories":{},"_nodeVersion":"20.11.0","dependencies":{"langchain":"^0.3.27","@agentdatashuttle/adsjs":"^1.0.7"},"_hasShrinkwrap":false,"devDependencies":{"gulp":"^5.0.0","eslint":"^8.57.0","prettier":"^3.5.3","typescript":"^5.8.2","@typescript-eslint/parser":"~8.32.0","eslint-plugin-n8n-nodes-base":"^1.16.3"},"peerDependencies":{"n8n-workflow":"*"},"_npmOperationalInternal":{"tmp":"tmp/n8n-nodes-agent-data-shuttle_1.0.1_1752581927907_0.3702442679452471","host":"s3://npm-registry-packages-npm-production"}},"1.0.2":{"name":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","version":"1.0.2","keywords":["n8n-community-node-package"],"author":{"name":"Knowyours","email":"agentdatashuttle@knowyours.co"},"license":"MIT","_id":"@agentdatashuttle/n8n-nodes-agent-data-shuttle@1.0.2","maintainers":[{"name":"mritul","email":"mritul2003@gmail.com"},{"name":"sudhay","email":"sudhay2001@gmail.com"}],"homepage":"https://agentdatashuttle.knowyours.co","bugs":{"url":"https://github.com/agentdatashuttle/n8n-nodes/issues"},"n8n":{"nodes":["dist/nodes/AdsSubscriber/AdsSubscriber.node.js","dist/nodes/AdsPublisher/AdsPublisher.node.js"],"credentials":["dist/credentials/ADSBridgeClientParamsApi.credentials.js","dist/credentials/ADSRabbitMQClientParamsApi.credentials.js"],"n8nNodesApiVersion":1},"dist":{"shasum":"aad47cbe9a667c6978c3e81f90d4ac125a2dd64b","tarball":"https://registry.npmjs.org/@agentdatashuttle/n8n-nodes-agent-data-shuttle/-/n8n-nodes-agent-data-shuttle-1.0.2.tgz","fileCount":27,"integrity":"sha512-u1ukjnZCQQxH7eDprdwNxU1XH+lir8vDaylj5kOrqZ78KXtoNlMCGN/E6A5froTeDCrhITOVGZS7sufp5B36IQ==","signatures":[{"sig":"MEYCIQDbQmpK58n+rs4CxijpXgr/aFZYJjy10TYfeHi4PMKpawIhALlJ1PHdNmkQ4BQBA/dJ181fTHzTKuoeuaCq1IOgpleX","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":273158},"main":"index.js","engines":{"node":">=20.15"},"gitHead":"ba99abeb8a3191aba869c5cc09e0520bbf4fe847","scripts":{"dev":"tsc --watch","lint":"eslint nodes credentials package.json","push":"npm publish --access public","build":"npx rimraf dist && tsc && gulp build:icons","format":"prettier nodes credentials --write","lintfix":"eslint nodes credentials package.json --fix","prepublishOnly":"npm run build && npm run lint -c .eslintrc.prepublish.js nodes credentials package.json"},"_npmUser":{"name":"sudhay","email":"sudhay2001@gmail.com"},"repository":{"url":"git+https://github.com/agentdatashuttle/n8n-nodes.git"},"_npmVersion":"10.2.4","description":"Custom n8n nodes for Agent Data Shuttle, enabling autonomous event-driven AI workflows via ADS Publisher and Subscriber.","directories":{},"_nodeVersion":"20.11.0","dependencies":{"langchain":"^0.3.27","@agentdatashuttle/adsjs":"^1.0.7"},"_hasShrinkwrap":false,"devDependencies":{"gulp":"^5.0.0","eslint":"^8.57.0","prettier":"^3.5.3","typescript":"^5.8.2","@typescript-eslint/parser":"~8.32.0","eslint-plugin-n8n-nodes-base":"^1.16.3"},"peerDependencies":{"n8n-workflow":"*"},"_npmOperationalInternal":{"tmp":"tmp/n8n-nodes-agent-data-shuttle_1.0.2_1752594713538_0.1786445867524611","host":"s3://npm-registry-packages-npm-production"}},"1.0.3":{"name":"@agentdatashuttle/n8n-nodes-agent-data-shuttle","version":"1.0.3","description":"Custom n8n nodes for Agent Data Shuttle, enabling autonomous event-driven AI workflows via ADS Publisher and Subscriber.","keywords":["n8n-community-node-package"],"license":"MIT","homepage":"https://agentdatashuttle.knowyours.co","repository":{"url":"git+https://github.com/agentdatashuttle/n8n-nodes.git"},"author":{"name":"Knowyours","email":"agentdatashuttle@knowyours.co"},"engines":{"node":">=20.15"},"main":"index.js","scripts":{"build":"npx rimraf dist && tsc && gulp build:icons","dev":"tsc --watch","format":"prettier nodes credentials --write","lint":"eslint nodes credentials package.json","lintfix":"eslint nodes credentials package.json --fix","prepublishOnly":"npm run build && npm run lint -c .eslintrc.prepublish.js nodes credentials package.json","push":"npm publish --access public"},"n8n":{"n8nNodesApiVersion":1,"credentials":["dist/credentials/ADSBridgeClientParamsApi.credentials.js","dist/credentials/ADSRabbitMQClientParamsApi.credentials.js"],"nodes":["dist/nodes/AdsSubscriber/AdsSubscriber.node.js","dist/nodes/AdsPublisher/AdsPublisher.node.js"]},"devDependencies":{"@typescript-eslint/parser":"~8.32.0","eslint":"^8.57.0","eslint-plugin-n8n-nodes-base":"^1.16.3","gulp":"^5.0.0","prettier":"^3.5.3","typescript":"^5.8.2"},"peerDependencies":{"n8n-workflow":"*"},"dependencies":{"@agentdatashuttle/adsjs":"^1.0.8","langchain":"^0.3.27"},"_id":"@agentdatashuttle/n8n-nodes-agent-data-shuttle@1.0.3","gitHead":"da945ef2ec3f855336960d7ff79fc663360efce4","bugs":{"url":"https://github.com/agentdatashuttle/n8n-nodes/issues"},"_nodeVersion":"20.11.0","_npmVersion":"10.2.4","dist":{"integrity":"sha512-RhhkfaxdJ1kuQpgVyDROqlUTzdHrkRWkBLgTDBl+Qp2g4O9g7fSezsfH6wpq8xIE6KZ8kZ1gyNhZCMSPcil5LA==","shasum":"56fcebaa044266393a2f86b196a00fc9634c04e9","tarball":"https://registry.npmjs.org/@agentdatashuttle/n8n-nodes-agent-data-shuttle/-/n8n-nodes-agent-data-shuttle-1.0.3.tgz","fileCount":27,"unpackedSize":274321,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEQCIDSQlAPodS8ZXB3smGDJUyaO8lbg2zufSVoRfLCDAxScAiAKgUaxAiX4XJfMavDTMjDuqZANhW4ySELKqtEZ9/5XKQ=="}]},"_npmUser":{"name":"sudhay","email":"sudhay2001@gmail.com"},"directories":{},"maintainers":[{"name":"mritul","email":"mritul2003@gmail.com"},{"name":"sudhay","email":"sudhay2001@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/n8n-nodes-agent-data-shuttle_1.0.3_1753187545242_0.055010569660950415"},"_hasShrinkwrap":false}},"time":{"created":"2025-07-15T11:58:46.865Z","modified":"2025-07-22T12:32:25.686Z","1.0.0":"2025-07-15T11:58:47.159Z","1.0.1":"2025-07-15T12:18:48.682Z","1.0.2":"2025-07-15T15:51:53.702Z","1.0.3":"2025-07-22T12:32:25.462Z"},"bugs":{"url":"https://github.com/agentdatashuttle/n8n-nodes/issues"},"author":{"name":"Knowyours","email":"agentdatashuttle@knowyours.co"},"license":"MIT","homepage":"https://agentdatashuttle.knowyours.co","keywords":["n8n-community-node-package"],"repository":{"url":"git+https://github.com/agentdatashuttle/n8n-nodes.git"},"description":"Custom n8n nodes for Agent Data Shuttle, enabling autonomous event-driven AI workflows via ADS Publisher and Subscriber.","maintainers":[{"name":"mritul","email":"mritul2003@gmail.com"},{"name":"sudhay","email":"sudhay2001@gmail.com"}],"readme":"<!-- TODO -->\n\n# n8n Nodes - Agent Data Shuttle\n\nCustom n8n.io nodes for ADS Publisher and ADS Subscriber — _Design autonomous agentic workflows with real-time event-driven AI._\n\n> **Agent Data Shuttle** provides plug-and-play **n8n nodes** for integrating ADS Publisher and ADS Subscriber into your workflows. These nodes enable seamless event publishing and agentic event subscription, allowing your AI agents to react autonomously to external events via the ADS ecosystem.\n\n---\n\n## Table of Contents\n\n- [Overview](#overview)\n- [Quick Start](#quick-start)\n- [Architecture](#architecture)\n- [Getting Started](#getting-started)\n  - [Prerequisites](#prerequisites)\n  - [Installation](#installation)\n  - [Usage](#usage)\n- [Node Details](#node-details)\n  - [ADS Publisher Node](#ads-publisher-node)\n  - [ADS Subscriber Node](#ads-subscriber-node)\n- [Credentials](#credentials)\n- [Project Structure](#project-structure)\n- [Development](#development)\n- [License](#license)\n- [Contact](#contact)\n\n---\n\n## Overview\n\nThis package contains custom [n8n](https://n8n.io/) nodes for the Agent Data Shuttle (ADS) framework:\n\n- **ADS Publisher Node**: Publishes events to the ADS Bridge via RabbitMQ.\n- **ADS Subscriber Node**: Subscribes to events from ADS Bridge, contextualizes them with an LLM, and triggers agentic workflows.\n\nThese nodes are designed for easy integration into n8n workflows, enabling real-time, autonomous event-driven AI agent orchestration.\n\n---\n\n## Quick Start\n\n### Install via n8n GUI (Recommended)\n\n1. In your n8n instance, go to **Settings > Community Nodes**.\n2. Click **Install** and enter the npm package name:\n   ```\n   @agentdatashuttle/n8n-nodes-agent-data-shuttle\n   ```\n3. Agree to the risks and click **Install**.\n4. Restart n8n if required.\n\n### Add ADS Publisher and Subscriber Nodes\n\n- In your n8n workflow editor, search for **ADS Publisher** and **ADS Subscriber** nodes.\n- Drag them into your workflow and configure credentials as described below.\n\n---\n\n## Architecture\n\n- **ADS Publisher Node**: Publishes events to RabbitMQ, which are then relayed by ADS Bridge.\n- **ADS Subscriber Node**: Connects to ADS Bridge via WebSocket, receives events, and invokes an LLM for contextualization.\n- **Credentials**: Securely manage connection details for RabbitMQ and ADS Bridge.\n- **LLM Integration**: The Subscriber node supports linking to an n8n LLM node for prompt contextualization and autonomous agent invocation.\n\n![Architecture Diagram](https://raw.githubusercontent.com/agentdatashuttle/ads-bridge/main/docs/architecture.png)\n\n---\n\n## Getting Started\n\n### Prerequisites\n\n- [Node.js](https://nodejs.org/) (v20+ recommended)\n- [n8n](https://n8n.io/) (latest version)\n- Access to an ADS Bridge instance for desired ADS Publisher (see [ADS Bridge](https://github.com/agentdatashuttle/ads-bridge))\n- RabbitMQ and Redis (for event delivery and scaling)\n\n### Usage\n\n1. **Configure Credentials**\n\n   - For Publisher: Set RabbitMQ connection parameters.\n   - For Subscriber: Set ADS Bridge connection string and Redis details.\n\n2. **Design Workflows**\n   - Use the **ADS Publisher** node to send events.\n   - Use the **ADS Subscriber** node to receive and process events, further linking for agentic responses.\n\n---\n\n## Node Details\n\n### ADS Publisher Node\n\nPublishes events to ADS Bridge via RabbitMQ.\n\n- **Inputs**: Main input (event payloads)\n- **Outputs**: Main output (publish status and payloads)\n- **Required Credentials**: `adsRabbitMQClientParamsApi`\n  **Properties**:\n  - `ADS Publisher Name`: Identifier for the publisher\n\nSee implementation: `nodes/AdsPublisher/AdsPublisher.node.ts`\n\n### ADS Subscriber Node\n\nSubscribes to events from ADS Bridge and invokes an LLM for contextualization.\n\n- **Inputs**: LLM connection (via `AiLanguageModel`)\n- **Outputs**: Main output (agent invocation prompt and event payload)\n- **Required Credentials**: `adsBridgeClientParamsApi`\n- **Properties**:\n  - `ADS Subscriber Name`: Identifier for the subscriber\n  - `Agent description`: Description of the agent triggered by this subscriber\n\n#### How it works\n\n- On workflow activation, the node connects to ADS Bridge using credentials and subscribes to the configured socket event.\n- When an ADS event is received, it triggers the workflow and passes the event payload.\n- The node expects an LLM input connection (via n8n's AI Language Model node). It sends the event contextualization prompt to the LLM, receives the response, and outputs:\n  - `ads_agent_invocation_prompt`: The final prompt for agent invocation, generated by the LLM.\n  - `ads_event_payload`: The original event payload.\n\nSee implementation: `nodes/AdsSubscriber/AdsSubscriber.node.ts`\n\n---\n\n## Credentials\n\n### ADSRabbitMQClientParamsApi.credentials\n\n**Used by:** ADS Publisher Node\n\n**Credential type name:** `ADSRabbitMQClientParamsApi`\n\n**Purpose:** Stores RabbitMQ connection details for publishing events.\n\n**Required fields:**\n\n- Host\n- Port\n- Username\n- Password\n\n**Setup:**\n\n1. In n8n, go to Credentials and create a new credential of type **ADSRabbitMQClientParamsApi**.\n2. Enter your RabbitMQ server details.\n3. Save and select this credential in the ADS Publisher node.\n\nSee: `credentials/ADSRabbitMQClientParamsApi.credentials.ts`\n\n### ADSBridgeClientParamsApi.credentials\n\n**Used by:** ADS Subscriber Node\n\n**Credential type name:** `ADSBridgeClientParamsApi`\n\n**Purpose:** Stores ADS Bridge and Redis connection details for subscribing to events.\n\n**Required fields:**\n\n- **ADS Bridge connection string**: The full URL or connection string to your ADS Bridge instance (e.g., `http://ads-bridge.example.com:8080`).\n- **Path prefix**: The API path prefix used for routing requests to ADS Bridge (e.g., `/ads`).\n- **Redis host**: Hostname or IP address of your Redis server for event scaling and delivery.\n- **Redis port**: Port number for your Redis server (default is usually `6379`).\n- **Socket event name**: The name of the socket event to subscribe to for receiving ADS events (e.g., `ads_event`).\n- **Pool ID**: Unique identifier for the subscriber pool or group this subscriber belongs to, used for targeted event delivery and agent orchestration.\n\n**Setup:**\n\n1. In n8n, go to Credentials and create a new credential of type **ADSBridgeClientParamsApi**.\n2. Fill in each field:\n   - **ADS Bridge connection string**: Enter the URL to your ADS Bridge instance.\n   - **Path prefix**: Specify the API path prefix (if required by your ADS Bridge setup).\n   - **Redis host**: Enter your Redis server's hostname or IP.\n   - **Redis port**: Enter your Redis server's port number.\n   - **Socket event name**: Enter the event name to listen for (check your ADS Bridge configuration).\n   - **Pool ID**: Enter the pool/group ID for your agent subscriber\n3. Save and select this credential in the ADS Subscriber node.\n\nSee: `credentials/ADSBridgeClientParamsApi.credentials.ts`\n\n---\n\n## Project Structure\n\n```\ncredentials/\n  ADSBridgeClientParamsApi.credentials.ts\n  ADSRabbitMQClientParamsApi.credentials.ts\nnodes/\n  AdsPublisher/\n    AdsPublisher.node.ts\n    AdsPublisher.node.json\n    ads_logo_dark.svg\n    ads_logo_light.svg\n  AdsSubscriber/\n    AdsSubscriber.node.ts\n    AdsSubscriber.node.json\n    ads_logo_dark.svg\n    ads_logo_light.svg\nutils/\n  chat_instance.ts\ngulpfile.js\npackage.json\nREADME.md\n```\n\n- Publisher node: `nodes/AdsPublisher/AdsPublisher.node.ts`\n- Subscriber node: `nodes/AdsSubscriber/AdsSubscriber.node.ts`\n- Credentials: `credentials/ADSRabbitMQClientParamsApi.credentials.ts`, `credentials/ADSBridgeClientParamsApi.credentials.ts`\n- Utility: `utils/chat_instance.ts`\n\n---\n\n## Resources\n\n- [n8n community nodes documentation](https://docs.n8n.io/integrations/#community-nodes)\n- [Agent Data Shuttle documentation](https://agentdatashuttle.knowyours.co)\n- [ADS Bridge GitHub](https://github.com/agentdatashuttle/ads-bridge)\n\n---\n\n## License\n\nThis project is licensed under the **MIT License**\n\n---\n\n## Contact\n\nFor questions or support, please contact  \n[agentdatashuttle@knowyours.co](mailto:agentdatashuttle@knowyours.co) or [sudhay2001@gmail.com](mailto:sudhay2001@gmail.com) or [mritul2003@gmail.com](mailto:mritul2003@gmail.com)\n\nFor more information about Agent Data Shuttle:  \nhttps://agentdatashuttle.knowyours.co\n","readmeFilename":"README.md"}