Skip to content

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

update

parent cbbc7301
Show whitespace changes
Inline Side-by-side
Showing with 538 additions and 10 deletions
.idea/workspace.xml
View file @ df6a7ede
...@@ -7,6 +7,13 @@ ...@@ -7,6 +7,13 @@
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" /> <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" /> <option name="LAST_RESOLUTION" value="IGNORE" />
</component> </component>
<component name="FileTemplateManagerImpl">
<option name="RECENT_TEMPLATES">
<list>
<option value="Python Script" />
</list>
</option>
</component>
<component name="Git.Settings"> <component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" /> <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
</component> </component>
...@@ -25,7 +32,7 @@ ...@@ -25,7 +32,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="main" type="PythonConfigurationType" factoryName="Python" nameIsGenerated="true"> <configuration name="main" type="PythonConfigurationType" factoryName="Python" nameIsGenerated="true">
<module name="opcua-cloning" /> <module name="opcua-cloning" />
<option name="INTERPRETER_OPTIONS" value="" /> <option name="INTERPRETER_OPTIONS" value="" />
...@@ -47,6 +54,27 @@ ...@@ -47,6 +54,27 @@
<option name="INPUT_FILE" value="" /> <option name="INPUT_FILE" value="" />
<method v="2" /> <method v="2" />
</configuration> </configuration>
<configuration name="opcua-transmitter (1)" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
<module name="opcua-cloning" />
<option name="INTERPRETER_OPTIONS" value="" />
<option name="PARENT_ENVS" value="true" />
<envs>
<env name="PYTHONUNBUFFERED" value="1" />
</envs>
<option name="SDK_HOME" value="" />
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
<option name="IS_MODULE_SDK" value="true" />
<option name="ADD_CONTENT_ROOTS" value="true" />
<option name="ADD_SOURCE_ROOTS" value="true" />
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/opcua-transmitter.py" />
<option name="PARAMETERS" value="" />
<option name="SHOW_COMMAND_LINE" value="false" />
<option name="EMULATE_TERMINAL" value="false" />
<option name="MODULE_MODE" value="false" />
<option name="REDIRECT_INPUT" value="false" />
<option name="INPUT_FILE" value="" />
<method v="2" />
</configuration>
<configuration name="opcua-transmitter" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true"> <configuration name="opcua-transmitter" 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="" />
...@@ -68,8 +96,53 @@ ...@@ -68,8 +96,53 @@
<option name="INPUT_FILE" value="" /> <option name="INPUT_FILE" value="" />
<method v="2" /> <method v="2" />
</configuration> </configuration>
<configuration name="opcua_receiver" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
<module name="opcua-cloning" />
<option name="INTERPRETER_OPTIONS" value="" />
<option name="PARENT_ENVS" value="true" />
<envs>
<env name="PYTHONUNBUFFERED" value="1" />
</envs>
<option name="SDK_HOME" value="" />
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
<option name="IS_MODULE_SDK" value="true" />
<option name="ADD_CONTENT_ROOTS" value="true" />
<option name="ADD_SOURCE_ROOTS" value="true" />
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/opcua_receiver.py" />
<option name="PARAMETERS" value="" />
<option name="SHOW_COMMAND_LINE" value="false" />
<option name="EMULATE_TERMINAL" value="false" />
<option name="MODULE_MODE" value="false" />
<option name="REDIRECT_INPUT" value="false" />
<option name="INPUT_FILE" value="" />
<method v="2" />
</configuration>
<configuration name="test" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
<module name="opcua-cloning" />
<option name="INTERPRETER_OPTIONS" value="" />
<option name="PARENT_ENVS" value="true" />
<envs>
<env name="PYTHONUNBUFFERED" value="1" />
</envs>
<option name="SDK_HOME" value="" />
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
<option name="IS_MODULE_SDK" value="true" />
<option name="ADD_CONTENT_ROOTS" value="true" />
<option name="ADD_SOURCE_ROOTS" value="true" />
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/test.py" />
<option name="PARAMETERS" value="" />
<option name="SHOW_COMMAND_LINE" value="false" />
<option name="EMULATE_TERMINAL" value="false" />
<option name="MODULE_MODE" value="false" />
<option name="REDIRECT_INPUT" value="false" />
<option name="INPUT_FILE" value="" />
<method v="2" />
</configuration>
<recent_temporary> <recent_temporary>
<list> <list>
<item itemvalue="Python.opcua_receiver" />
<item itemvalue="Python.opcua-transmitter (1)" />
<item itemvalue="Python.test" />
<item itemvalue="Python.opcua-transmitter" /> <item itemvalue="Python.opcua-transmitter" />
</list> </list>
</recent_temporary> </recent_temporary>
......
opcua-transmitter.py
View file @ df6a7ede
...@@ -24,11 +24,8 @@ class MyHandler(SubHandler): ...@@ -24,11 +24,8 @@ class MyHandler(SubHandler):
async def process(self) -> None: async def process(self) -> None:
try: try:
while True: while True:
# Get data in a queue.
[node, value, data] = self._queue.get_nowait() [node, value, data] = self._queue.get_nowait()
path = await node.get_path(as_string=True)
datatype = type(value) datatype = type(value)
packet = str(datatype) + "&" + str(value) + "&" + 'ns=' + str(node.nodeid.NamespaceIndex) + ";i=" + str(node.nodeid.Identifier) packet = str(datatype) + "&" + str(value) + "&" + 'ns=' + str(node.nodeid.NamespaceIndex) + ";i=" + str(node.nodeid.Identifier)
UDPClientSocket.sendto(str.encode(packet), serverAddressPort) UDPClientSocket.sendto(str.encode(packet), serverAddressPort)
......
opcua_receiver.py
View file @ df6a7ede
import socket import socket
from opcua import Client,ua from opcua import Client,ua
from opcua_subscriber.opcua_subscribe import *
client = Client("opc.tcp://DESKTOP-KMDNN6H:53530/OPCUA/SimulationServer") # client = Client("opc.tcp:2.2.2.7:53530/OPCUA/SimulationServer")
client.connect() # client.connect()
localIP = "2.2.2.5" localIP = "2.2.2.5"
...@@ -20,16 +21,18 @@ UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM) ...@@ -20,16 +21,18 @@ UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
# Bind to address and ip # Bind to address and ip
UDPServerSocket.bind((localIP, localPort)) #UDPServerSocket.bind((localIP, localPort))
print("UDP server up and listening") print("UDP server up and listening")
opua=opcua_pack()
sock = opua.connect("opc.tcp://2.2.2.7:53530/OPCUA/SimulationServer")
opua.write_opcua_value(sock,3, 1002, 11)
while (True): while (True):
bytesAddressPair = UDPServerSocket.recvfrom(bufferSize) bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
message = bytesAddressPair[0] message = bytesAddressPair[0]
datatype,value,nodeid = message.decode().split("&") datatype,value,nodeid = message.decode().split("&")
if(datatype=="<class 'float'>"): if(datatype=="<class 'float'>"):
client.get_node(nodeid).set_value(float(value)) opua.write_opcua_value(sock,3, 1002, 11)
if(datatype=="<class 'int'>"): if(datatype=="<class 'int'>"):
v = ua.DataValue(ua.Variant(int(value), ua.VariantType.Int32)) opua.write_opcua_value(sock,3, 1002, 6)
client.get_node(nodeid).set_value(v) \ No newline at end of file
\ No newline at end of file
opcua_subscriber/opcua_subscribe.py 0 → 100644
View file @ df6a7ede
import binascii
import struct
import datetime
import secrets
import socket
import random
from time import sleep
class opcua_pack():
def __init__(self):
self.SecureChannelId=27
self.Security_Token_Id = 1
self.identifier_string = ""
self.int_chunk_seq = 5
def helf(self,address):
MSG_HEL = "HEL"
chunk_type = "F"
protocol_version = 0
ReceiveBufferSize = 2147483647
SendBufferSize = 2147483647
max_message_size = 0
max_chunk_count = 0
endpoint_url = address
endpoint_url_len = len(endpoint_url)
message_size=int(8+len(protocol_version.to_bytes(4, byteorder='little').hex()+SendBufferSize.to_bytes(4, byteorder='little').hex()+ReceiveBufferSize.to_bytes(4, byteorder='little').hex()+max_message_size.to_bytes(4, byteorder='little').hex()+max_chunk_count.to_bytes(4, byteorder='little').hex()+endpoint_url_len.to_bytes(4, byteorder='little').hex()+endpoint_url.encode().hex())/2)
return MSG_HEL.encode()+chunk_type.encode()+message_size.to_bytes(4, byteorder='little')+protocol_version.to_bytes(4, byteorder='little')+SendBufferSize.to_bytes(4, byteorder='little')+ReceiveBufferSize.to_bytes(4, byteorder='little')+max_message_size.to_bytes(4, byteorder='little')+max_chunk_count.to_bytes(4, byteorder='little')+endpoint_url_len.to_bytes(4, byteorder='little')+endpoint_url.encode()
def opnf(self):
MSG_OPN = "OPN"
chunk_type = "F"
Message_Size = 132
SecureChannelId = 0
SecurityPolicyUri = 'http://opcfoundation.org/UA/SecurityPolicy#None'
SecurityPolicyUrilen=len(SecurityPolicyUri)
SenderCertificate = binascii.unhexlify('ffffffff')
ReceiverCertificateThumbprint = binascii.unhexlify('ffffffff')
SequenceNumber = 1
RequestId= 1
NodeId_EncodingMask= 1
NodeId_Namespace_Index= 0
NodeId_Identifier_Numeric= 446
auth_EncodingMask= 0
Identifier_Numeric= 0
now = datetime.datetime.utcnow()
win32_epoch = datetime.datetime(1601, 1, 1)
interval = int((now - win32_epoch).total_seconds() * 10000000)
timestamp_bytes = struct.pack('<Q', interval)
Timestamp= timestamp_bytes
RequestHandle= 1
SymbolicId= 0
LocalizedText= 0
AdditionalInfo= 0
Inner_StatusCode= 0
Inner_Diagnostics= 0
op_SymbolicId= 0
op_LocalizedText= 0
op_AdditionalInfo= 0
op_Inner_StatusCode= 0
op_Inner_Diagnostics= 0
Return_Diagnostics = binascii.unhexlify(hex(int(str('000000')+str(op_Inner_Diagnostics)+str(op_Inner_StatusCode)+ str(op_AdditionalInfo)+str(op_LocalizedText)+str(op_SymbolicId)+str(Inner_Diagnostics)+str(Inner_StatusCode)+str(AdditionalInfo)+str(LocalizedText)+str(SymbolicId),2))[2:].zfill(8))
AuditEntryId= binascii.unhexlify('ffffffff')
TimeoutHint= 1000
ah_EncodingMask= '0000'
has_server_index= 0
has_namespace_uri= 0
additional_header_enc_mask=binascii.unhexlify(hex(int(str(has_namespace_uri)+str(has_server_index)+str('00')+str(ah_EncodingMask),2))[2:].zfill(2))
ah_Identifier_Numeric=0
has_binary_body = 0
has_xml_body = 0
ah_EncodingMask2 = binascii.unhexlify(hex(int(str('000000')+str(has_xml_body)+str(has_binary_body),2))[2:].zfill(2))
ClientProtocolVersion=0
SecurityTokenRequestType=0
MessageSecurityMode= 1
ClientNonce= 0
RequestedLifetime= 3600000
opnfp=MSG_OPN.encode()+chunk_type.encode()+Message_Size.to_bytes(4, byteorder='little')+SecureChannelId.to_bytes(4, byteorder='little')+SecurityPolicyUrilen.to_bytes(4, byteorder='little')+SecurityPolicyUri.encode()+SenderCertificate+ReceiverCertificateThumbprint+SequenceNumber.to_bytes(4, byteorder='little')+RequestId.to_bytes(4, byteorder='little')+NodeId_EncodingMask.to_bytes(1,byteorder='little')+NodeId_Namespace_Index.to_bytes(1,byteorder='little')+NodeId_Identifier_Numeric.to_bytes(2,byteorder='little')+auth_EncodingMask.to_bytes(1,byteorder='little')+Identifier_Numeric.to_bytes(1,byteorder='little')+Timestamp+RequestHandle.to_bytes(4,byteorder='little')+Return_Diagnostics+AuditEntryId+TimeoutHint.to_bytes(4,byteorder='little')+additional_header_enc_mask+ah_Identifier_Numeric.to_bytes(1,byteorder='little')+ah_EncodingMask2+ClientProtocolVersion.to_bytes(4, byteorder='little')+SecurityTokenRequestType.to_bytes(4, byteorder='little')+MessageSecurityMode.to_bytes(4, byteorder='little')+ClientNonce.to_bytes(4, byteorder='little')+RequestedLifetime.to_bytes(4, byteorder='little')
return opnfp
def create_session(self,secure_id,token_id):
MSG_MSG = "MSG"
chunk_type = "F"
Message_Size = 291
SecureChannelId = secure_id
Security_Token_Id = token_id
Security_Sequence_Number = 2
Security_RequestId = 2
NodeId_EncodingMask = 1
NodeId_Namespace_Index = 0
NodeId_Identifier_Numeric = 461
auth_EncodingMask = 0
Identifier_Numeric = 0
now = datetime.datetime.utcnow()
win32_epoch = datetime.datetime(1601, 1, 1)
interval = int((now - win32_epoch).total_seconds() * 10000000)
timestamp_bytes = struct.pack('<Q', interval)
Timestamp = timestamp_bytes
RequestHandle = 2
SymbolicId = 0
LocalizedText = 0
AdditionalInfo = 0
Inner_StatusCode = 0
Inner_Diagnostics = 0
op_SymbolicId = 0
op_LocalizedText = 0
op_AdditionalInfo = 0
op_Inner_StatusCode = 0
op_Inner_Diagnostics = 0
Return_Diagnostics = binascii.unhexlify(hex(int(
str('000000') + str(op_Inner_Diagnostics) + str(op_Inner_StatusCode) + str(op_AdditionalInfo) + str(
op_LocalizedText) + str(op_SymbolicId) + str(Inner_Diagnostics) + str(Inner_StatusCode) + str(
AdditionalInfo) + str(LocalizedText) + str(SymbolicId), 2))[2:].zfill(8))
AuditEntryId = binascii.unhexlify('ffffffff')
TimeoutHint = 1000
ah_EncodingMask = '0000'
has_server_index = 0
has_namespace_uri = 0
additional_header_enc_mask = binascii.unhexlify(
hex(int(str(has_namespace_uri) + str(has_server_index) + str('00') + str(ah_EncodingMask), 2))[2:].zfill(2))
ah_Identifier_Numeric = 0
has_binary_body = 0
has_xml_body = 0
ah_EncodingMask2 = binascii.unhexlify(
hex(int(str('000000') + str(has_xml_body) + str(has_binary_body), 2))[2:].zfill(2))
ApplicationUri="urn:freeopcua:client"
ApplicationUrilen=len(ApplicationUri.encode()).to_bytes(4,byteorder="little")
ProductUri = "urn:freeopcua.github.io:client"
ProductUrilen=len(ProductUri.encode()).to_bytes(4,byteorder="little")
has_locale_information=0
has_text=1
Application_name = binascii.unhexlify(
hex(int(str('000000') + str(has_text) + str(has_locale_information), 2))[2:].zfill(2))
Text = "Pure Python Client"
Textlen = len(Text.encode()).to_bytes(4,byteorder="little")
ApplicationType = binascii.unhexlify("01000000")
GatewayServerUri = binascii.unhexlify("ffffffff")
DiscoveryProfileUri = binascii.unhexlify("ffffffff")
ArraySize = 0
ServerUri= binascii.unhexlify("ffffffff")
EndpointUrl= "opc.tcp://2.2.2.7:53530/OPCUA/SimulationServer"
EndpointUrllen= len(EndpointUrl.encode()).to_bytes(4,byteorder="little")
SessionName= "Pure Python Client Session1"
SessionNamelen=len(SessionName.encode()).to_bytes(4,byteorder="little")
client_nonce = secrets.token_bytes(32)
client_noncelen = len(client_nonce).to_bytes(4,byteorder="little")
ClientCertificate = binascii.unhexlify("ffffffff")
RequestedSessionTimeout= binascii.unhexlify("0000000040774B41")
MaxResponseMessageSize= 0
session= MSG_MSG.encode()+\
chunk_type.encode() +\
Message_Size.to_bytes(4,byteorder='little')+ \
SecureChannelId.to_bytes(4,byteorder='little')+ \
Security_Token_Id.to_bytes(4, byteorder='little')+ \
Security_Sequence_Number.to_bytes(4, byteorder='little')+ \
Security_RequestId.to_bytes(4, byteorder='little')+\
NodeId_EncodingMask.to_bytes(1, byteorder='little')+\
NodeId_Namespace_Index.to_bytes(1, byteorder='little')+\
NodeId_Identifier_Numeric.to_bytes(2, byteorder='little')+\
auth_EncodingMask.to_bytes(1, byteorder='little') +\
Identifier_Numeric.to_bytes(1, byteorder='little')+ \
Timestamp+ \
RequestHandle.to_bytes(4, byteorder='little')+\
Return_Diagnostics+\
AuditEntryId+\
TimeoutHint.to_bytes(4, byteorder='little')+\
additional_header_enc_mask+ \
ah_Identifier_Numeric.to_bytes(1,byteorder="little")+\
ah_EncodingMask2+ \
ApplicationUrilen+\
ApplicationUri.encode()+\
ProductUrilen+\
ProductUri.encode()+\
Application_name+\
Textlen+\
Text.encode()+\
ApplicationType+\
GatewayServerUri+\
DiscoveryProfileUri+\
ArraySize.to_bytes(4,byteorder="little")+\
ServerUri+ \
EndpointUrllen+\
EndpointUrl.encode()+\
SessionNamelen+\
SessionName.encode()+\
client_noncelen+\
client_nonce+\
ClientCertificate+\
RequestedSessionTimeout+ \
MaxResponseMessageSize.to_bytes(4,byteorder="little")
return session
def start_session(self,secure_id,token_id,identifier_string):
MSG_MSG = "MSG"
chunk_type = "F"
Message_Size = 188
SecureChannelId = secure_id
Security_Token_Id = token_id
Security_Sequence_Number = 3
Security_RequestId = 3
NodeId_EncodingMask = 1
NodeId_Namespace_Index = 0
NodeId_Identifier_Numeric = 467
auth_EncodingMask = 5
Namespace_Index= 0
identifier_bytestring = binascii.unhexlify(identifier_string)
identifier_bytestringlen= len(identifier_bytestring).to_bytes(4,byteorder="little")
now = datetime.datetime.utcnow()
win32_epoch = datetime.datetime(1601, 1, 1)
interval = int((now - win32_epoch).total_seconds() * 10000000)
timestamp_bytes = struct.pack('<Q', interval)
Timestamp = timestamp_bytes
Request_handle = 3
SymbolicId = 0
LocalizedText = 0
AdditionalInfo = 0
Inner_StatusCode = 0
Inner_Diagnostics = 0
op_SymbolicId = 0
op_LocalizedText = 0
op_AdditionalInfo = 0
op_Inner_StatusCode = 0
op_Inner_Diagnostics = 0
Return_Diagnostics = binascii.unhexlify(hex(int(
str('000000') + str(op_Inner_Diagnostics) + str(op_Inner_StatusCode) + str(op_AdditionalInfo) + str(
op_LocalizedText) + str(op_SymbolicId) + str(Inner_Diagnostics) + str(Inner_StatusCode) + str(
AdditionalInfo) + str(LocalizedText) + str(SymbolicId), 2))[2:].zfill(8))
AuditEntryId = binascii.unhexlify('ffffffff')
TimeoutHint = 1000
ah_EncodingMask="0000"
has_server_index=0
has_namespace_uri=0
additional_header_enc_mask=binascii.unhexlify(
hex(int( str(has_namespace_uri) + str(has_server_index)+str(ah_EncodingMask), 2))[2:].zfill(2))
Identifier_Numeric= 0
has_binary_body = 0
has_xml_body = 0
ah_EncodingMask2 = binascii.unhexlify(
hex(int(str('000000') + str(has_xml_body) + str(has_binary_body), 2))[2:].zfill(2))
Algorithm="http://www.w3.org/2000/09/xmldsig#rsa-sha1"
Algorithmlen=len(Algorithm.encode()).to_bytes(4,byteorder="little")
Signature=int(0).to_bytes(4,byteorder="little")
client_ArraySize = 0
locale_ArraySize = 1
LocaleIds = "en"
LocaleIdslen = len(LocaleIds.encode()).to_bytes(4,byteorder="little")
uit_encoding_mask='0001'
has_server_index= 0
has_namespace_uri=0
uit_token=binascii.unhexlify(
hex(int(str(has_namespace_uri)+str(has_server_index)+str('00')+str(uit_encoding_mask), 2))[2:].zfill(2))
uit_Namespace_Index = 0
uit_Identifier_Numeric = 321
uit_has_binary_body = 1
uit_has_xml_body = 0
uit_EncodingMask2 = binascii.unhexlify(
hex(int(str('000000') + str(uit_has_xml_body) + str(uit_has_binary_body), 2))[2:].zfill(2))
PolicyId= "anonymous"
PolicyIdlen=len(PolicyId.encode()).to_bytes(4,byteorder="little")
aitlen=(len(PolicyIdlen)+len(PolicyId.encode())).to_bytes(4,byteorder="little")
uts_algorithm=binascii.unhexlify("ffffffff")
uts_signature=binascii.unhexlify("ffffffff")
session = MSG_MSG.encode() + \
chunk_type.encode() + \
Message_Size.to_bytes(4, byteorder='little') + \
SecureChannelId.to_bytes(4, byteorder='little') + \
Security_Token_Id.to_bytes(4, byteorder='little') + \
Security_Sequence_Number.to_bytes(4, byteorder='little') + \
Security_RequestId.to_bytes(4, byteorder='little') + \
NodeId_EncodingMask.to_bytes(1, byteorder='little') + \
NodeId_Namespace_Index.to_bytes(1, byteorder='little') + \
NodeId_Identifier_Numeric.to_bytes(2, byteorder='little') + \
auth_EncodingMask.to_bytes(1, byteorder='little')+ \
Namespace_Index.to_bytes(2, byteorder='little')+ \
identifier_bytestringlen+\
identifier_bytestring+\
Timestamp+\
Request_handle.to_bytes(4,byteorder="little")+ \
Return_Diagnostics+ \
AuditEntryId+ \
TimeoutHint.to_bytes(4,byteorder="little")+\
additional_header_enc_mask+\
Identifier_Numeric.to_bytes(1,byteorder="little")+\
ah_EncodingMask2+\
Algorithmlen+\
Algorithm.encode()+\
Signature+\
client_ArraySize.to_bytes(4,byteorder="little")+\
locale_ArraySize.to_bytes(4,byteorder="little")+\
LocaleIdslen+\
LocaleIds.encode()+\
uit_token+\
uit_Namespace_Index.to_bytes(1,byteorder="little")+\
uit_Identifier_Numeric.to_bytes(2,byteorder="little")+\
uit_EncodingMask2+\
aitlen+\
PolicyIdlen+\
PolicyId.encode()+ \
uts_algorithm+ \
uts_signature
return session
def write_request(self,secure_id,token_id,identifier_string,chunk_seq,ns,nodeid,value,datatype):
source_timestamp=b''
MSG_MSG = "MSG"
chunk_type = "F"
SecureChannelId = secure_id
Security_Token_Id = token_id
Security_Sequence_Number = chunk_seq
Security_RequestId = chunk_seq
NodeId_EncodingMask = 1
NodeId_Namespace_Index = 0
NodeId_Identifier_Numeric = 673
auth_EncodingMask = 5
Namespace_Index = 0
identifier_bytestring = binascii.unhexlify(identifier_string)
identifier_bytestringlen = len(identifier_bytestring).to_bytes(4, byteorder="little")
now = datetime.datetime.utcnow()
win32_epoch = datetime.datetime(1601, 1, 1)
interval = int((now - win32_epoch).total_seconds() * 10000000)
timestamp_bytes = struct.pack('<Q', interval)
Timestamp = timestamp_bytes
Request_handle = 4
SymbolicId = 0
LocalizedText = 0
AdditionalInfo = 0
Inner_StatusCode = 0
Inner_Diagnostics = 0
op_SymbolicId = 0
op_LocalizedText = 0
op_AdditionalInfo = 0
op_Inner_StatusCode = 0
op_Inner_Diagnostics = 0
Return_Diagnostics = binascii.unhexlify(hex(int(
str('000000') + str(op_Inner_Diagnostics) + str(op_Inner_StatusCode) + str(op_AdditionalInfo) + str(
op_LocalizedText) + str(op_SymbolicId) + str(Inner_Diagnostics) + str(Inner_StatusCode) + str(
AdditionalInfo) + str(LocalizedText) + str(SymbolicId), 2))[2:].zfill(8))
AuditEntryId = binascii.unhexlify('ffffffff')
TimeoutHint = 1000
ah_EncodingMask = "0000"
has_server_index = 0
has_namespace_uri = 0
additional_header_enc_mask = binascii.unhexlify(
hex(int(str(has_namespace_uri) + str(has_server_index) + str(ah_EncodingMask), 2))[2:].zfill(2))
Identifier_Numeric = 0
has_binary_body = 0
has_xml_body = 0
ah_EncodingMask2 = binascii.unhexlify(
hex(int(str('000000') + str(has_xml_body) + str(has_binary_body), 2))[2:].zfill(2))
ArraySize = 1
wv_encoding_mask = "0010"
wv_encoding_mask_value = binascii.unhexlify(
hex(int(str("0000") + str(wv_encoding_mask) , 2))[2:].zfill(2))
wv_Namespace_Index = ns
wv_Identifier_Numeric = nodeid
AttributeId = 13
IndexRange = binascii.unhexlify("ffffffff")
dv_has_value=1
dv_has_status_code=1
dv_has_source_timestamp = 1 if datatype=="<class 'float'>" else 0
dv_has_server_timestamp = 0
dv_has_source_picoseconds = 0
dv_has_server_picoseconds = 0
data_value=binascii.unhexlify(
hex(int(str("00") + str(dv_has_server_picoseconds)+ str(dv_has_source_picoseconds)+ str(dv_has_server_picoseconds)+ str(dv_has_server_timestamp)+ str(dv_has_source_timestamp)+ str(dv_has_status_code)+ str(dv_has_value), 2))[2:].zfill(2))
if(datatype=="<class 'float'>"):
vt_type=11
vt_value=struct.pack('d', value)
source_timestamp = timestamp_bytes
Message_Size = 135
else:
Message_Size = 123
vt_type=6
vt_value = struct.pack('i', value)
statuscode=binascii.unhexlify("00000000")
session = MSG_MSG.encode() + \
chunk_type.encode() + \
Message_Size.to_bytes(4, byteorder='little') + \
SecureChannelId.to_bytes(4, byteorder='little') + \
Security_Token_Id.to_bytes(4, byteorder='little') + \
Security_Sequence_Number.to_bytes(4, byteorder='little') + \
Security_RequestId.to_bytes(4, byteorder='little') + \
NodeId_EncodingMask.to_bytes(1, byteorder='little') + \
NodeId_Namespace_Index.to_bytes(1, byteorder='little') + \
NodeId_Identifier_Numeric.to_bytes(2, byteorder='little') + \
auth_EncodingMask.to_bytes(1, byteorder='little') + \
Namespace_Index.to_bytes(2, byteorder='little') + \
identifier_bytestringlen + \
identifier_bytestring + \
Timestamp + \
Request_handle.to_bytes(4, byteorder="little") + \
Return_Diagnostics + \
AuditEntryId + \
TimeoutHint.to_bytes(4, byteorder="little") + \
additional_header_enc_mask + \
Identifier_Numeric.to_bytes(1, byteorder="little") + \
ah_EncodingMask2+ \
ArraySize.to_bytes(4,byteorder="little")+ \
wv_encoding_mask_value+ \
wv_Namespace_Index.to_bytes(2,byteorder="little")+ \
wv_Identifier_Numeric.to_bytes(4,byteorder="little")+ \
AttributeId.to_bytes(4,byteorder="little")+\
IndexRange+ \
data_value+ \
vt_type.to_bytes(1,byteorder="little")+\
vt_value+ \
statuscode+ \
source_timestamp
return session
def connect(self,address):
server_address = ('2.2.2.7', 53530)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(server_address)
message = self.helf(address)
sock.sendall(message)
data = sock.recv(10249)
sock.sendall(self.opnf())
data = sock.recv(10249)
self.SecureChannelId = int(data[-24:-23].hex(), 16)
self.TokenId = int(data[-20:-19].hex(), 16)
sock.sendall(self.create_session(self.SecureChannelId, self.TokenId))
count = 0
while True:
try:
sock.settimeout(2)
data = sock.recv(5720)
if not data:
break
if count == 0:
self.identifier_string = data.hex()[156:156 + 64]
count = count + 1
print('Received:', data)
except:
break
data = self.start_session(self.SecureChannelId, self.TokenId, self.identifier_string)
sock.sendall(data)
res = sock.recv(1024)
sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, 4, 3, 1002, 1, "<class 'int'>"))
print(sock.recv(1024))
return sock
def write_opcua_value(self,sock,ns,nodeid,val):
print(self.SecureChannelId, self.TokenId, self.identifier_string, self.int_chunk_seq, ns, nodeid, val, "<class 'int'>")
sock.sendall(self.write_request(self.SecureChannelId, self.TokenId, self.identifier_string, self.int_chunk_seq, ns, nodeid, val, "<class 'int'>"))
print(sock.recv(1024))
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