boltx-nats

n8n community node — NATS publish + trigger. Khớp type với goworker custom executor.

Package Information

Released: 1 mo ago
Downloads: 1 weekly / 38 monthly
Latest Version: 0.2.0
Author: BoltX

Available Nodes

Documentation generating…

NATS (BoltX) icon
NATS (BoltX)
Publish message tới NATS subject. Khớp type với goworker.
NATS Trigger (BoltX) icon
NATS Trigger (BoltX)
Subscribe NATS subject, emit message. Khớp type với goworker (worker handle subscribe production runtime).
NATS JetStream (BoltX) icon
NATS JetStream (BoltX)
Publish vào stream JetStream và chờ ack. Khác node NATS thường: có xác nhận đã ghi, khử trùng theo Message ID, subject không thuộc stream thì báo lỗi. Khớp type với goworker.
NATS JetStream Trigger (BoltX) icon
NATS JetStream Trigger (BoltX)
Consumer durable đọc từ stream JetStream. Message chỉ mất khi flow chạy xong (có ack), khác NATS thường là bắn rồi quên. Runtime thật do goworker chạy.

Documentation

n8n-nodes-boltx-nats

Community node n8n cho NATS publish + trigger. Type khớp 1-1 với executor native bên goworker:

  • n8n-nodes-boltx-nats.nats → publish 1 message (worker: node_nats.go)
  • n8n-nodes-boltx-nats.natsTrigger → subscribe subject (worker: node_nats_trigger.go)

Workflow viết 1 lần chạy đúng trên cả 2 runtime:

  • n8n native (UI test / dev) → execute bằng nats.js (npm nats v2).
  • goworker production → execute bằng github.com/nats-io/nats.go Go native, kết nối pooled qua nats_ops.go.

Cài lên n8n self-host

Option A — Community Nodes UI (npm)

  1. cd worker/node-raw/n8n-nodes-boltx-nats && npm install --ignore-scripts && npm run build && npm publish --access public.
  2. Trên n8n UI → Settings → Community Nodes → Install → paste n8n-nodes-boltx-nats → Install.
  3. Restart n8n nếu cần. Node palette hiện:
    • "NATS (BoltX)" (publish, category Communication)
    • "NATS Trigger (BoltX)" (subscribe trigger)

Option B — Mount thủ công

npm install --prefix ~/.n8n/nodes n8n-nodes-boltx-nats

Restart n8n.

Credential natsApi

Compat với Synadia (url) + LuxChanLu (servers) — worker đọc cả 2 field:

Field Mục đích
url NATS server URL (nats://user:pass@host:4222). Ưu tiên hơn servers.
username / user Auth user (worker đọc cả 2).
password / pass Auth pass.
token NATS auth token. Ưu tiên hơn user/pass khi cả 2 cùng có.

⚠️ goworker env override: nếu GO_NATS env set trên worker, worker bỏ qua credential trên node → dùng URL của env. n8n native vẫn dùng credential bình thường.

Param khớp worker

Publish nats (Nats.node.ts)

Param n8n Field worker
subject subject (bắt buộc)
data data (default ={{ $json }} → worker fast-path bypass expression eval)

Output: pass-through input items (worker behaviour).

Trigger natsTrigger (NatsTrigger.node.ts)

Param n8n Mục đích
subject Subject subscribe (hỗ trợ wildcard * và >)
queueGroup Optional, queue group cho load-balance
parseJson Bật → JSON.parse payload, lỗi → giữ raw string

Emit shape: { subject, reply, sid, data }.

⚠️ Trên goworker, NatsTriggerNode.Execute chỉ passthrough — logic subscribe thực hiện ngoài (internal/transport/...) đọc descriptor để subscribe đúng subject/queue.

Async publish flag

Khi worker chạy với GO_NATS_ASYNC=1, publish thành fire-and-forget (không chờ ACK). Param descriptor n8n không expose flag này — chỉnh ở env worker production.

Build local

npm install --ignore-scripts    # bỏ qua native compile của transitive deps
npm run build                   # tsc + gulp copy icons → dist/
npm run dev                     # tsc --watch

Discussion