add "add references" in client and server network interface

Author: oroulet

opcua/server/uaprocessor.py

@@ -290,6 +290,18 @@ def _process_message(self, typeid, requesthdr, algohdr, seqhdr, body):
             self.logger.info("sending delete node response")
             self.send_response(requesthdr.RequestHandle, algohdr, seqhdr, response)
 
+        elif typeid == ua.NodeId(ua.ObjectIds.AddReferencesRequest_Encoding_DefaultBinary):
+            self.logger.info("add references request")
+            params = ua.AddReferencesParameters.from_binary(body)
+
+            results = self.session.add_references(params.ReferencesToAdd)
+
+            response = ua.AddReferencesResponse()
+            response.Results = results
+
+            self.logger.info("sending add references response")
+            self.send_response(requesthdr.RequestHandle, algohdr, seqhdr, response)
+
         elif typeid == ua.NodeId(ua.ObjectIds.CreateSubscriptionRequest_Encoding_DefaultBinary):
             self.logger.info("create subscription request")
             params = ua.CreateSubscriptionParameters.from_binary(body)

opcua/ua/uaprotocol_auto.py

@@ -5293,6 +5293,49 @@ def __str__(self):
     __repr__ = __str__
 
 
+class AddReferencesParameters(FrozenClass):
+    '''
+    :ivar ReferencesToAdd:
+    :vartype ReferencesToAdd: AddReferencesItem
+    '''
+
+    ua_types = {
+        'ReferencesToAdd': 'AddReferencesItem',
+               }
+
+    def __init__(self, binary=None):
+        if binary is not None:
+            self._binary_init(binary)
+            self._freeze = True
+            return
+        self.ReferencesToAdd = []
+        self._freeze = True
+
+    def to_binary(self):
+        packet = []
+        packet.append(uabin.Primitives.Int32.pack(len(self.ReferencesToAdd)))
+        for fieldname in self.ReferencesToAdd:
+            packet.append(fieldname.to_binary())
+        return b''.join(packet)
+
+    @staticmethod
+    def from_binary(data):
+        return AddReferencesParameters(data)
+
+    def _binary_init(self, data):
+        length = uabin.Primitives.Int32.unpack(data)
+        array = []
+        if length != -1:
+            for _ in range(0, length):
+                array.append(AddReferencesItem.from_binary(data))
+        self.ReferencesToAdd = array
+
+    def __str__(self):
+        return 'AddReferencesParameters(' + 'ReferencesToAdd:' + str(self.ReferencesToAdd) + ')'
+
+    __repr__ = __str__
+
+
 class AddReferencesRequest(FrozenClass):
     '''
     Adds one or more references to the server address space.
@@ -5301,14 +5344,14 @@ class AddReferencesRequest(FrozenClass):
     :vartype TypeId: NodeId
     :ivar RequestHeader:
     :vartype RequestHeader: RequestHeader
-    :ivar ReferencesToAdd:
-    :vartype ReferencesToAdd: AddReferencesItem
+    :ivar Parameters:
+    :vartype Parameters: AddReferencesParameters
     '''
 
     ua_types = {
         'TypeId': 'NodeId',
         'RequestHeader': 'RequestHeader',
-        'ReferencesToAdd': 'AddReferencesItem',
+        'Parameters': 'AddReferencesParameters',
                }
 
     def __init__(self, binary=None):
@@ -5318,16 +5361,14 @@ def __init__(self, binary=None):
             return
         self.TypeId = FourByteNodeId(ObjectIds.AddReferencesRequest_Encoding_DefaultBinary)
         self.RequestHeader = RequestHeader()
-        self.ReferencesToAdd = []
+        self.Parameters = AddReferencesParameters()
         self._freeze = True
 
     def to_binary(self):
         packet = []
         packet.append(self.TypeId.to_binary())
         packet.append(self.RequestHeader.to_binary())
-        packet.append(uabin.Primitives.Int32.pack(len(self.ReferencesToAdd)))
-        for fieldname in self.ReferencesToAdd:
-            packet.append(fieldname.to_binary())
+        packet.append(self.Parameters.to_binary())
         return b''.join(packet)
 
     @staticmethod
@@ -5337,17 +5378,12 @@ def from_binary(data):
     def _binary_init(self, data):
         self.TypeId = NodeId.from_binary(data)
         self.RequestHeader = RequestHeader.from_binary(data)
-        length = uabin.Primitives.Int32.unpack(data)
-        array = []
-        if length != -1:
-            for _ in range(0, length):
-                array.append(AddReferencesItem.from_binary(data))
-        self.ReferencesToAdd = array
+        self.Parameters = AddReferencesParameters.from_binary(data)
 
     def __str__(self):
         return 'AddReferencesRequest(' + 'TypeId:' + str(self.TypeId) + ', ' + \
                'RequestHeader:' + str(self.RequestHeader) + ', ' + \
-               'ReferencesToAdd:' + str(self.ReferencesToAdd) + ')'
+               'Parameters:' + str(self.Parameters) + ')'
 
     __repr__ = __str__
 

schemas/generate_model.py

@@ -14,7 +14,7 @@
 #we want to implement som struct by hand, to make better interface or simply because they are too complicated
 IgnoredStructs = []#["NodeId", "ExpandedNodeId", "Variant", "QualifiedName", "DataValue", "LocalizedText"]#, "ExtensionObject"]
 #by default we split requests and respons in header and parameters, but some are so simple we do not split them
-NoSplitStruct = ["GetEndpointsResponse", "CloseSessionRequest", "AddNodesResponse", "DeleteNodesResponse", "BrowseResponse", "HistoryReadResponse", "HistoryUpdateResponse", "RegisterServerResponse", "CloseSecureChannelRequest", "CloseSecureChannelResponse", "CloseSessionRequest", "CloseSessionResponse", "UnregisterNodesResponse", "MonitoredItemModifyRequest", "MonitoredItemsCreateRequest", "ReadResponse", "WriteResponse", "TranslateBrowsePathsToNodeIdsResponse", "DeleteSubscriptionsResponse", "DeleteMonitoredItemsResponse", "CreateMonitoredItemsResponse", "ServiceFault", "AddReferencesRequest", "AddReferencesResponse", "ModifyMonitoredItemsResponse", "RepublishResponse", "CallResponse", "FindServersResponse", "RegisterServerRequest", "RegisterServer2Response"]
+NoSplitStruct = ["GetEndpointsResponse", "CloseSessionRequest", "AddNodesResponse", "DeleteNodesResponse", "BrowseResponse", "HistoryReadResponse", "HistoryUpdateResponse", "RegisterServerResponse", "CloseSecureChannelRequest", "CloseSecureChannelResponse", "CloseSessionRequest", "CloseSessionResponse", "UnregisterNodesResponse", "MonitoredItemModifyRequest", "MonitoredItemsCreateRequest", "ReadResponse", "WriteResponse", "TranslateBrowsePathsToNodeIdsResponse", "DeleteSubscriptionsResponse", "DeleteMonitoredItemsResponse", "CreateMonitoredItemsResponse", "ServiceFault", "AddReferencesResponse", "ModifyMonitoredItemsResponse", "RepublishResponse", "CallResponse", "FindServersResponse", "RegisterServerRequest", "RegisterServer2Response"]
 #structs that end with Request or Response but are not
 NotRequest = ["MonitoredItemCreateRequest", "MonitoredItemModifyRequest", "CallMethodRequest"]
 OverrideTypes = {}#AttributeId": "AttributeID",  "ResultMask": "BrowseResultMask", "NodeClassMask": "NodeClass", "AccessLevel": "VariableAccessLevel", "UserAccessLevel": "VariableAccessLevel", "NotificationData": "NotificationData"}