update

.idea/misc.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9" project-jdk-type="Python SDK" />
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.9 (pythonProject)" project-jdk-type="Python SDK" />
 </project>
\ No newline at end of file

.idea/opcua-cloning.iml

@@ -2,7 +2,7 @@
 <module type="PYTHON_MODULE" version="4">
   <component name="NewModuleRootManager">
     <content url="file://$MODULE_DIR$" />
-    <orderEntry type="jdk" jdkName="Python 3.9" jdkType="Python SDK" />
+    <orderEntry type="jdk" jdkName="Python 3.9 (pythonProject)" jdkType="Python SDK" />
     <orderEntry type="sourceFolder" forTests="false" />
   </component>
 </module>
\ No newline at end of file

.idea/workspace.xml

@@ -49,7 +49,7 @@
       <recent name="D:\opcua-cloning" />
     </key>
   </component>
-  <component name="RunManager" selected="Python.opcua-transmitter (1)">
+  <component name="RunManager" selected="Python.opcua_receiver">
     <configuration name="asyncua_server (1)" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
       <module name="opcua-cloning" />
       <option name="INTERPRETER_OPTIONS" value="" />
@@ -178,9 +178,9 @@
     </configuration>
     <recent_temporary>
       <list>
+        <item itemvalue="Python.opcua_receiver" />
         <item itemvalue="Python.opcua-transmitter (1)" />
         <item itemvalue="Python.hash_sender" />
-        <item itemvalue="Python.opcua_receiver" />
         <item itemvalue="Python.asyncua_server (1)" />
         <item itemvalue="Python.asyncua_server" />
       </list>

asyncua_server.py

 import asyncio
+import pickle
 from asyncua import ua, Server
 import socket
 import threading
@@ -48,10 +49,15 @@ class asyncua_server():
 asr = asyncua_server()
 
 def hash_receive():
+    prev_hash = 0
     while (True):
         bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
         message = bytesAddressPair[0]
-        print(message)
+        hierarchy=pickle.loads(message)
+        print(hierarchy["hash"])
+        if(prev_hash!=hierarchy["hash"]):
+            print("changed")
+            prev_hash=hierarchy["hash"]
 
 def st():
     t1=threading.Thread(target=hash_receive)

opcua_receiver.py

@@ -34,5 +34,4 @@ while (True):
     bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
     message = bytesAddressPair[0]
     datatype,value,ns,nodeid = message.decode().split("&")
-    print(nodeid)
     opua.write_opcua_value(sock,ns,nodeid, value,datatype)

opcua_subscriber/opcua_subscribe.py

@@ -459,4 +459,3 @@ class opcua_pack():
         else:
             sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.cs, int(ns),int(nodeid),float(val), datatype))
             self.cs=self.cs+1
-        print(sock.recv(1024))