(iotdb) branch new_opc_server updated: part

[justinchen]

This is an automated email from the ASF dual-hosted git repository.

justinchen pushed a commit to branch new_opc_server
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/new_opc_server by this push:
     new 24a6fe3c3e4 part
24a6fe3c3e4 is described below

commit 24a6fe3c3e4f5097856eb6dccc09d89ebaf35059
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Dec 4 14:16:05 2025 +0800

    part
---
 .../iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
index 8303b59122c..69b9c52c261 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaNameSpace.java
@@ -52,6 +52,7 @@ import org.eclipse.milo.opcua.stack.core.StatusCodes;
 import org.eclipse.milo.opcua.stack.core.UaException;
 import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
 import org.eclipse.milo.opcua.stack.core.types.builtin.DateTime;
+import org.eclipse.milo.opcua.stack.core.types.builtin.ExtensionObject;
 import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText;
 import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
 import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode;
@@ -475,22 +476,26 @@ public class OpcUaNameSpace extends 
ManagedNamespaceWithLifecycle {
     UaVariableNode measurementNode;
     final List<AddNodesResult> results = new ArrayList<>(nodesToAdd.size());
     for (final AddNodesItem item : nodesToAdd) {
+      final ExtensionObject attributes = item.getNodeAttributes();
+      if 
(attributes.getBodyType().equals(ExtensionObject.BodyType.ByteString)) {
+
+      }
       if (item.getNodeClass().equals(NodeClass.Variable)) {
         final Optional<NodeId> nodeId =
             
item.getRequestedNewNodeId().toNodeId(getServer().getNamespaceTable());
         if (!nodeId.isPresent()) {
           results.add(
-              new AddNodesResult(new 
StatusCode(StatusCodes.Bad_InvalidArgument), NodeId.NULL_VALUE));
+              new AddNodesResult(new 
StatusCode(StatusCodes.Bad_NodeIdRejected), NodeId.NULL_VALUE));
           continue;
         }
         if (!getNodeManager()
             .containsNode(nodeId.get())) {
           measurementNode =
               new UaVariableNode.UaVariableNodeBuilder(getNodeContext())
-                  .setNodeId(newNodeId(currentFolder + name))
+                  .setNodeId(nodeId.get())
                   .setAccessLevel(AccessLevel.READ_WRITE)
                   .setUserAccessLevel(AccessLevel.READ_WRITE)
-                  .setBrowseName(newQualifiedName(name))
+                  .setBrowseName(item.getBrowseName())
                   .setDisplayName(LocalizedText.english(name))
                   .setDataType(convertToOpcDataType(type))
                   .setTypeDefinition(Identifiers.BaseDataVariableType)
@@ -502,6 +507,10 @@ public class OpcUaNameSpace extends 
ManagedNamespaceWithLifecycle {
                   Identifiers.Organizes,
                   measurementNode.getNodeId().expanded(),
                   true));
+        } else {
+          results.add(
+                  new AddNodesResult(new 
StatusCode(StatusCodes.Bad_NodeIdExists), NodeId.NULL_VALUE));
+          continue;
         }
       }
     }