Skip to content

O
opcua-cloning
Commit 7510c15e authored by yogesh.m's avatar yogesh.m
Browse files
Options

update

parent 1c9ee7b2
Hide whitespace changes
Inline Side-by-side
Showing with 178 additions and 14 deletions
.idea/workspace.xml
View file @ 7510c15e
...@@ -6,17 +6,7 @@ ...@@ -6,17 +6,7 @@
<component name="ChangeListManager"> <component name="ChangeListManager">
<list default="true" id="e733891a-c063-4f94-92d6-4559e921107b" name="Default Changelist" comment=""> <list default="true" id="e733891a-c063-4f94-92d6-4559e921107b" name="Default Changelist" comment="">
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" /> <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/Analysis-00.toc" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/Analysis-00.toc" afterDir="false" /> <change beforePath="$PROJECT_DIR$/asyncua_server.py" beforeDir="false" afterPath="$PROJECT_DIR$/asyncua_server.py" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/EXE-00.toc" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/EXE-00.toc" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/PKG-00.toc" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/PKG-00.toc" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/PYZ-00.pyz" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/PYZ-00.pyz" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/base_library.zip" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/base_library.zip" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/main.pkg" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/main.pkg" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/warn-main.txt" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/warn-main.txt" afterDir="false" />
<change beforePath="$PROJECT_DIR$/build/main/xref-main.html" beforeDir="false" afterPath="$PROJECT_DIR$/build/main/xref-main.html" afterDir="false" />
<change beforePath="$PROJECT_DIR$/dist/opcua_cloner.exe" beforeDir="false" />
<change beforePath="$PROJECT_DIR$/hash_sender.py" beforeDir="false" afterPath="$PROJECT_DIR$/hash_sender.py" afterDir="false" />
<change beforePath="$PROJECT_DIR$/opcua_transmitter.py" beforeDir="false" afterPath="$PROJECT_DIR$/opcua_transmitter.py" afterDir="false" />
</list> </list>
<option name="SHOW_DIALOG" value="false" /> <option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" /> <option name="HIGHLIGHT_CONFLICTS" value="true" />
...@@ -62,7 +52,7 @@ ...@@ -62,7 +52,7 @@
<recent name="D:\opcua-cloning" /> <recent name="D:\opcua-cloning" />
</key> </key>
</component> </component>
<component name="RunManager" selected="Python.opcua_transmitter"> <component name="RunManager" selected="Python.opcua_receiver">
<configuration name="asyncua_server (1)" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true"> <configuration name="asyncua_server (1)" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
<module name="opcua-cloning" /> <module name="opcua-cloning" />
<option name="INTERPRETER_OPTIONS" value="" /> <option name="INTERPRETER_OPTIONS" value="" />
...@@ -191,10 +181,10 @@ ...@@ -191,10 +181,10 @@
</configuration> </configuration>
<recent_temporary> <recent_temporary>
<list> <list>
<item itemvalue="Python.opcua_receiver" />
<item itemvalue="Python.opcua_transmitter" /> <item itemvalue="Python.opcua_transmitter" />
<item itemvalue="Python.hash_sender" /> <item itemvalue="Python.hash_sender" />
<item itemvalue="Python.opcua-transmitter (1)" /> <item itemvalue="Python.opcua-transmitter (1)" />
<item itemvalue="Python.opcua_receiver" />
<item itemvalue="Python.asyncua_server (1)" /> <item itemvalue="Python.asyncua_server (1)" />
</list> </list>
</recent_temporary> </recent_temporary>
......
asyncua_server.py
View file @ 7510c15e
...@@ -57,11 +57,98 @@ class asyncua_server(): ...@@ -57,11 +57,98 @@ class asyncua_server():
await self.variables[node]["node"].delete() await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Int32) self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Int32)
await self.variables[node]["node"].set_writable() await self.variables[node]["node"].set_writable()
elif (datatype == 1):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Boolean)
await self.variables[node]["node"].set_writable()
elif (datatype == 2):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.SByte)
await self.variables[node]["node"].set_writable()
elif (datatype == 3):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Byte)
await self.variables[node]["node"].set_writable()
elif (datatype == 4):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Int16)
await self.variables[node]["node"].set_writable()
elif (datatype == 5):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.UInt16)
await self.variables[node]["node"].set_writable()
elif (datatype == 7):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.UInt32)
await self.variables[node]["node"].set_writable()
elif (datatype == 8):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Int64)
await self.variables[node]["node"].set_writable()
elif (datatype == 9):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.UInt64)
await self.variables[node]["node"].set_writable()
elif (datatype == 10):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Float)
await self.variables[node]["node"].set_writable()
elif (datatype == 12):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.String)
await self.variables[node]["node"].set_writable()
elif (datatype == 13):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.DateTime)
await self.variables[node]["node"].set_writable()
elif (datatype == 14):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.Guid)
await self.variables[node]["node"].set_writable()
elif (datatype == 15):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.ByteString)
await self.variables[node]["node"].set_writable()
elif (datatype == 16):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.XmlElement)
await self.variables[node]["node"].set_writable()
elif (datatype == 17):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.NodeId)
await self.variables[node]["node"].set_writable()
elif (datatype == 18):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.ExpandedNodeId)
await self.variables[node]["node"].set_writable()
elif (datatype == 19):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.StatusCode)
await self.variables[node]["node"].set_writable()
elif (datatype == 20):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.QualifiedName)
await self.variables[node]["node"].set_writable()
elif (datatype == 21):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.LocalizedText)
await self.variables[node]["node"].set_writable()
elif (datatype == 22):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.ExtensionObject)
await self.variables[node]["node"].set_writable()
elif (datatype == 23):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.DataValue)
await self.variables[node]["node"].set_writable()
elif (datatype == 24): elif (datatype == 24):
print(node_index, parent_node, self.variables[node]["name"],datatype)
await self.variables[node]["node"].delete() await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0,ua.VariantType.Null) self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0,ua.VariantType.Null)
await self.variables[node]["node"].set_writable() await self.variables[node]["node"].set_writable()
elif (datatype == 25):
await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], 0, ua.VariantType.DiagnosticInfo)
await self.variables[node]["node"].set_writable()
else: else:
await self.variables[node]["node"].delete() await self.variables[node]["node"].delete()
self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], None) self.variables[node]["node"] = await parent_node.add_variable(node_index, self.variables[node]["name"], None)
...@@ -95,9 +182,96 @@ class asyncua_server(): ...@@ -95,9 +182,96 @@ class asyncua_server():
elif(hierarchy["datatype"]==6): elif(hierarchy["datatype"]==6):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,ua.VariantType.Int32) self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,ua.VariantType.Int32)
await self.variables[node]["node"].set_writable() await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 1):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"],True,
ua.VariantType.Boolean)
await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 2):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.SByte)
await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 3):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.Byte)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 4):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.Int16)
await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 5):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.UInt16)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 7):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.UInt32)
await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 8):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.Int64)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 9):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.UInt64)
await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 10):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], float(0),
ua.VariantType.Float)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 12):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "",
ua.VariantType.String)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 13):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "March 17, 2023 12:34:56 PM",
ua.VariantType.DateTime)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 14):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "8d2b1fc4-af4f-4a21-a4d0-4ad51d76c0b7",
ua.VariantType.Guid)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 15):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], b"",
ua.VariantType.ByteString)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 16):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "<root><node>value</node></root>",
ua.VariantType.XmlElement)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 17):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "ns=1;i=1001",
ua.VariantType.NodeId)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 18):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "ns=1;i=1001",
ua.VariantType.ExpandedNodeId)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 19):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.StatusCode)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 20):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "Myvar",
ua.VariantType.QualifiedName)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 21):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], "Localized text in English",
ua.VariantType.LocalizedText)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 22):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], {},
ua.VariantType.ExtensionObject)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 23):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0,
ua.VariantType.DataValue)
await self.variables[node]["node"].set_writable
elif (hierarchy["datatype"] == 24): elif (hierarchy["datatype"] == 24):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0, ua.VariantType.Null) self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0, ua.VariantType.Null)
await self.variables[node]["node"].set_writable() await self.variables[node]["node"].set_writable()
elif (hierarchy["datatype"] == 25):
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], 0, ua.VariantType.DiagnosticInfo)
await self.variables[node]["node"].set_writable()
else: else:
self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], None) self.variables[node]["node"] = await node_space.add_variable(node_id, hierarchy["name"], None)
await self.variables[node]["node"].set_writable() await self.variables[node]["node"].set_writable()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment