update

asyncua_server.py

@@ -68,16 +68,51 @@ class asyncua_server():
             await self.server.stop()
 
 asr = asyncua_server()
-
-def analyse_hierarchy(hierarchy):
+identifier_array_received=[]
+def get_received_hierarchy_array(hierarchy):
     for key in hierarchy:
         if(key!="hash"):
             if(isinstance(hierarchy[key],dict)):
-                print(hierarchy[key])
-                analyse_hierarchy(hierarchy[key])
+                identifier_array_received.append(key)
+                get_received_hierarchy_array(hierarchy[key])
+    return identifier_array_received
+
+async def get_existing_hierarchy_array(client,node_objects):
+    node_hierarchy = {}
+    for sub_obj in node_objects:
+        if ("ns=3;" in str(sub_obj)):
+            node = client.get_node(sub_obj)
+            children_nodes = await node.get_children()
+            identifier = str(children_nodes[0].nodeid.Identifier) if children_nodes else ""
+            node_class = await sub_obj.read_node_class()
+            if (identifier not in str(sub_obj)):
+                child_disp_name = await sub_obj.read_display_name()
+                identifier_name = sub_obj.nodeid.Identifier
+                node_hierarchy[identifier_name] = await get_existing_hierarchy_array(client, children_nodes)
+                node_hierarchy[identifier_name]["name"] = child_disp_name.Text
+                if (node_class._name_ == "Variable"):
+                    datatype = await sub_obj.read_data_type_as_variant_type()
+                    node_hierarchy[identifier_name]["datatype"] = datatype._value_
             else:
-                if(key=="datatype"):
-                    print()
+                disp_name = await sub_obj.read_display_name()
+                identifier_name = sub_obj.nodeid.Identifier
+                node_hierarchy[identifier_name] = {}
+                node_hierarchy[identifier_name]["name"] = disp_name.Text
+                if (node_class._name_ == "Variable"):
+                    datatype = await sub_obj.read_data_type_as_variant_type()
+                    node_hierarchy[identifier_name]["datatype"] = datatype._value_
+    return node_hierarchy
+
+def analyse_hierarchy(hierarchy):
+    array1=get_received_hierarchy_array(hierarchy)
+    print(array1)
+    root_node=asr.server.get_root_node()
+    object_root_node=asyncio.run(root_node.get_children())
+    node_objects= asyncio.run(object_root_node[0].get_children())
+    print(node_objects)
+    existing_h=asyncio.run(get_existing_hierarchy_array(asr.server,node_objects))
+    print(existing_h)
+    identifier_array_received.clear()
 
 def hash_receive():
     prev_hash = 0
@@ -89,18 +124,15 @@ def hash_receive():
         hierarchy=json.loads(hierarchy)
         if(prev_hash!=hierarchy["hash"] and asr.idx):
             print("changed")
-            print(hierarchy)
             analyse_hierarchy(hierarchy)
-        #     asyncio.run(asr.delete_all_objects())
-        #     for object in hierarchy:
-        #         if(object!="hash"):
-        #             display_name=object
-        #             asyncio.run(asr.add_object(object,hierarchy))
+            asyncio.run(asr.delete_all_objects())
+            for object in hierarchy:
+                if(object!="hash"):
+                    display_name=object
+                    asyncio.run(asr.add_object(object,hierarchy))
             prev_hash=hierarchy["hash"]
 
 def st():
     t1=threading.Thread(target=hash_receive)
     t1.start()
-    asyncio.run(asr.start_server("opc.tcp://2.2.2.5:53531/myopc/free","http://klopc.com"))
-
+    asyncio.run(asr.start_server("opc.tcp://2.2.2.5:53531/myopc/free","http://klopc.com"))
\ No newline at end of file
-st()
\ No newline at end of file