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);