node-red-contrib-opcua-suite 0.0.1

A modern OPC UA suite for Node-RED with shared connections, batch operations, drag-and-drop certificates, and a clean msg-driven API

npm install node-red-contrib-opcua-suite

node-red-contrib-opcua-suite

A modern, high-performance OPC UA suite for Node-RED — built for real industrial use.

Why This Instead of node-red-contrib-opcua?

Connection Sharing in Detail

With node-red-contrib-opcua, 9 OPC UA nodes = 9 TCP connections to your server. With this suite, 9 nodes referencing the same endpoint = 1 TCP connection, ref-counted. The endpoint config node manages the shared OpcUaClientManager. When the last node closes, the connection is released.

[Client: Read] ──┐
[Client: Write] ──┤
[Client: Sub]   ──┤── Endpoint (1 shared connection) ──► OPC UA Server
[Browser]       ──┤
[Method]        ──┤
[Event]         ──┘

Installation

cd ~/.node-red
npm install node-red-contrib-opcua-suite

Nodes

opcua-endpoint (Config Node)

Shared connection configuration. All client/browser/method/event nodes referencing the same endpoint share ONE TCP connection.

opcua-client (All-in-One)

Single node for all OPC UA operations. Set via msg.operation or default in config.

Read

msg.operation = "read";
msg.nodeId = "ns=2;s=Temperature";  // or msg.topic
// Output: msg.payload = value, msg.statusCode, msg.sourceTimestamp

Read Multiple (Batch)

// Array format
msg.operation = "readmultiple";
msg.items = [
    { nodeId: "ns=2;s=Var1", name: "Temperature" },
    { nodeId: "ns=2;s=Var2", name: "Pressure" }
];

// Object format (friendly names as keys)
msg.operation = "readmultiple";
msg.payload = {
    "Temperature": "ns=1;s=Scalar.Double",
    "Counter": "ns=1;s=Scalar.Int32"
};
// Output: msg.payload = [{nodeId, value, dataType, statusCode, itemName}, ...]

Write

msg.operation = "write";
msg.nodeId = "ns=2;s=Temperature";
msg.payload = 25.5;
msg.datatype = "Double";  // optional: auto-detected from JS type

Write Multiple (Batch)

// Array format
msg.operation = "writemultiple";
msg.items = [
    { nodeId: "ns=2;s=Var1", value: 25.5, datatype: "Double" },
    { nodeId: "ns=2;s=Var2", value: true, datatype: "Boolean" }
];

// Object format (nodeIds as keys)
msg.operation = "writemultiple";
msg.payload = {
    "ns=1;s=Scalar.Double": { value: 42.0, datatype: "Double" },
    "ns=1;s=Scalar.Int32": { value: 100, datatype: "Int32" }
};

Subscribe / Unsubscribe

msg.operation = "subscribe";
msg.nodeId = "ns=2;s=Temperature";
msg.interval = 500;  // sampling interval ms (default: 1000)

msg.operation = "unsubscribe";
msg.nodeId = "ns=2;s=Temperature";

Browse / Method / History / Discovery

msg.operation = "browse";       // Browse address space
msg.operation = "method";       // Call OPC UA method
msg.operation = "history";      // Read historical values
msg.operation = "getendpoints"; // Discover server endpoints
msg.operation = "readattribute";       // Read BrowseName, DisplayName, etc.
msg.operation = "registernodes";       // Register nodes for fast access
msg.operation = "unregisternodes";     // Unregister nodes
msg.operation = "translatebrowsepath"; // Translate browse path to NodeId

opcua-item (Item Collector)

Chain multiple items in series before a client node for visual batch operations.

[Inject] → [Item: Temp] → [Item: Pressure] → [Item: Speed] → [Client (readmultiple)]

Each item adds {nodeId, datatype, itemName} to msg.items. The client reads/writes all items in a single OPC UA service call.

opcua-browser

Dedicated browse node with optional recursive browsing. References an endpoint directly.

opcua-method

Dedicated method call node. Object/Method NodeIds configurable or via msg. References an endpoint directly.

opcua-event

Subscribes to OPC UA events (BaseEventType, AlarmConditionType, etc.). References an endpoint directly.

opcua-server

Embedded OPC UA server. Create address space at runtime via msg.command: addVariable, addFolder, addObject, addMethod, setValue, setWritable, raiseEvent, getServerInfo.

NodeId Formats

DataType Auto-Detection

Explicit override: msg.datatype = "UInt16" or in item config.

Docker

docker compose up -d          # Start Node-RED + OPC UA test server
# Node-RED: http://localhost:1881
# Test server: opc.tcp://localhost:4841

docker compose build --no-cache && docker compose up -d --force-recreate  # Rebuild

Testing

npm test                  # 120 unit tests
node test/live-integration.js  # 36 live integration tests (requires Docker)

License

MIT

Author

blanpa