node-opcua-service-register-node

import { OPCUAServer, OPCUAClient, MessageSecurityMode, SecurityPolicy, UserTokenType, NodeId, resolveNodeId } from 'node-opcua'; import { RegisterNodesRequest, RegisterNodesResponse } from 'node-opcua-service-register-node'; async function startOpcUaExample() { // 1. Setup a simple OPC UA Server const server = new OPCUAServer({ port: 4334, resourcePath: '/UA/MyServer', buildInfo: { productName: 'MySampleServer', buildNumber: '1234', buildDate: new Date() } }); await server.initialize(); const addressSpace = server.engine.addressSpace; if (!addressSpace) { throw new Error('AddressSpace not initialized'); } const device = addressSpace.getFolder('ObjectsFolder')?.addFolder({ browseName: 'MyDevice' }); if (device) { device.addVariable({ browseName: 'Temperature', nodeId: 's=TemperatureSensor1', dataType: 'Double', value: { get: () => new Variant({ dataType: DataType.Double, value: 25.5 }) } }); console.log('Server initialized with a Temperature variable.'); } await server.start(); console.log(`Server is running at ${server.endpoints[0]?.endpointDescriptions()[0]?.endpointUrl}`); // 2. Setup a simple OPC UA Client and demonstrate RegisterNodesRequest structure const client = OPCUAClient.create({ endpointUrl: server.endpoints[0]?.endpointDescriptions()[0]?.endpointUrl, securityMode: MessageSecurityMode.None, securityPolicy: SecurityPolicy.None, connectionStrategy: { maxRetry: 0 } }); try { await client.connect(server.endpoints[0]?.endpointDescriptions()[0]?.endpointUrl ?? ''); console.log('Client connected to server.'); const session = await client.createSession({ userIdentity: { type: UserTokenType.Anonymous } }); console.log('Client session created.'); // Create a RegisterNodesRequest (this package provides the type definition) const nodesToRegister = [ resolveNodeId('s=TemperatureSensor1'), new NodeId('ns=1;s=AnotherNode') // Example of another node ]; const registerRequest = new RegisterNodesRequest({ nodesToRegister: nodesToRegister }); console.log('Constructed RegisterNodesRequest:', JSON.stringify(registerRequest.toJSON(), null, 2)); // In a real client, you would send this request via session.performMessage or similar: // const response: RegisterNodesResponse = await session.registerNodes(registerRequest.nodesToRegister); // console.log('RegisterNodes response:', response); await session.close(); await client.disconnect(); console.log('Client disconnected.'); } catch (err) { console.error('Client error:', err); } finally { await server.shutdown(); console.log('Server shut down.'); } } startOpcUaExample().catch(console.error);