update

hash_sender.py

@@ -2,6 +2,7 @@ from asyncua import Client
 import asyncio
 import socket
 from time import sleep
+import pickle
 ENDPOINT = 'opc.tcp://2.2.2.7:53530/OPCUA/SimulationServer'
 NAMESPACE = 'http://www.prosysopc.com/OPCUA/SimulationServer/'
 
@@ -18,20 +19,27 @@ async def get_send_hash():
         nm_no = await client.get_namespace_index("http://www.prosysopc.com/OPCUA/SimulationNodes/")
         while True:
             sleep(1)
-            main_obj = []
+            main_obj = {}
             hierarchy = {}
             Objects = await root_objects[0].get_children()
             for sub_obj in Objects:
                 if (sub_obj.nodeid.NamespaceIndex == nm_no):
                     display_name=await sub_obj.read_display_name()
                     identifier_type = sub_obj.nodeid.NodeIdType._name_
-                    ch = await sub_obj.get_children()
-                    main_obj = main_obj + ch
+                    children = await sub_obj.get_children()
+                    for ch in children:
+                        main_obj["identifier"]=ch.nodeid.Identifier
+                        node_name=await ch.read_display_name()
+                        main_obj["node_name"]=node_name.Text
+                        datatype=await ch.read_data_type_as_variant_type()
+                        main_obj["datatype"] = datatype._value_
                     hierarchy[display_name.Text] = {}
                     hierarchy[display_name.Text]["name"]=identifier_type
-                    hierarchy[display_name.Text]["obj"]=main_obj
-            UDPClientSocket.sendto(str.encode(str(hash(str(main_obj)))+"&"+str(hierarchy)), serverAddressPort)
-            print(str(hash(str(main_obj)))+"&"+str(hierarchy))
+                    hierarchy[display_name.Text]["obj"]=pickle.dumps(main_obj)
+            hierarchy["hash"]=hash(str(main_obj))
+            hierarchy=pickle.dumps(hierarchy)
+            UDPClientSocket.sendto(hierarchy, serverAddressPort)
+            print(hierarchy)
 
 if __name__ == '__main__':
     asyncio.run(get_send_hash())
\ No newline at end of file