Skip to content

Commit 958b457

Browse files
authored
fix support for intermediate chunks (#396)
* fix support for intermediate chunks
1 parent 3daa2df commit 958b457

1 file changed

Lines changed: 3 additions & 4 deletions

File tree

opcua/server/uaprocessor.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,17 +85,16 @@ def process(self, header, body):
8585

8686
elif header.MessageType == ua.MessageType.SecureMessage:
8787
return self.process_message(msg.SecurityHeader(), msg.SequenceHeader(), msg.body())
88-
8988
elif isinstance(msg, ua.Hello):
9089
ack = ua.Acknowledge()
9190
ack.ReceiveBufferSize = msg.ReceiveBufferSize
9291
ack.SendBufferSize = msg.SendBufferSize
9392
data = self._connection.tcp_to_binary(ua.MessageType.Acknowledge, ack)
9493
self.socket.write(data)
95-
9694
elif isinstance(msg, ua.ErrorMessage):
9795
self.logger.warning("Received an error message type")
98-
96+
elif msg is None:
97+
pass # msg is a ChunkType.Intermediate of an ua.MessageType.SecureMessage
9998
else:
10099
self.logger.warning("Unsupported message type: %s", header.MessageType)
101100
raise utils.ServiceError(ua.StatusCodes.BadTcpMessageTypeInvalid)
@@ -131,7 +130,7 @@ def _process_message(self, typeid, requesthdr, algohdr, seqhdr, body):
131130
data = params.ClientNonce
132131
else:
133132
data = self._connection._security_policy.server_certificate + params.ClientNonce
134-
response.Parameters.ServerSignature.Signature =\
133+
response.Parameters.ServerSignature.Signature = \
135134
self._connection._security_policy.asymmetric_cryptography.signature(data)
136135

137136
response.Parameters.ServerSignature.Algorithm = "http://www.w3.org/2000/09/xmldsig#rsa-sha1"

0 commit comments

Comments
 (0)