node-opcua

import { OPCUAServer, OPCUAClient, MessageSecurityMode, SecurityPolicy, DataType, Variant, AttributeIds } from "node-opcua"; import { resolve } from "path"; // --- Server Setup --- async function startServer() { // Ensure a 'certificates' directory exists in your project root // For production, manage certificates securely (e.g., via GDS) // This example uses anonymous authentication for simplicity. const server = new OPCUAServer({ port: 4334, resourcePath: "/UA/MySampleServer", buildInfo: { productName: "MySampleServer", buildNumber: "1234", buildDate: new Date() }, serverInfo: { applicationUri: "urn:MySampleServer", productUri: "urn:MySampleServer", applicationName: { text: "MySampleServer", locale: "en" } }, securityModes: [MessageSecurityMode.None], securityPolicies: [SecurityPolicy.None], allowAnonymous: true, // Certificate files are needed even with securityMode.None in many setups // The toolkit generates default ones in C:\Users\user\AppData\Roaming\node-opcua-default-nodejs // if not provided, but explicitly setting them is good practice for production. // For simplicity in this quickstart, we assume default generation or manual placement. }); await server.start(); console.log(`Server started on port ${server.port}`); console.log(`Server endpointUrl: ${server.endpointUrl}`); server.engine.addressSpace?.getFolder("ObjectsFolder")?.addVariable({ nodeId: "ns=1;s=MyDynamicVariable", browseName: "MyDynamicVariable", dataType: DataType.Int32, value: { get: () => new Variant({ dataType: DataType.Int32, value: Math.floor(Math.random() * 100) }) } }); return server; } // --- Client Setup --- async function startClient(endpointUrl: string) { const client = OPCUAClient.create({ endpointUrl, securityMode: MessageSecurityMode.None, securityPolicy: SecurityPolicy.None, connectionStrategy: { maxRetry: 0, // No retries for quickstart simplicity initialDelay: 100 } }); try { await client.connect(endpointUrl); console.log("Client connected to server."); const session = await client.createSession(); console.log("Client session created."); // Browse the root folder const browseResult = await session.browse("RootFolder"); console.log("RootFolder children:"); for (const reference of browseResult.references || []) { console.log(` - ${reference.browseName.toString()}`); } // Read the value of MyDynamicVariable const readValue = await session.read({ nodeId: "ns=1;s=MyDynamicVariable", attributeId: AttributeIds.Value }); console.log(`Value of MyDynamicVariable: ${readValue.value?.value}`); await session.close(); await client.disconnect(); console.log("Client disconnected."); } catch (err) { console.error("Client error:", err); } } // --- Main Execution --- (async () => { let server: OPCUAServer | null = null; try { server = await startServer(); // Give server a moment to fully initialize await new Promise(resolve => setTimeout(resolve, 1000)); await startClient(server.endpointUrl!); // Use the server's dynamically assigned endpoint } catch (error) { console.error("Error during quickstart execution:", error); } finally { if (server) { console.log("Shutting down server..."); await server.shutdown(); console.log("Server shut down."); } } })();