|
@@ 1170-1236 (lines=67) @@
|
| 1167 |
|
__repr__ = __str__ |
| 1168 |
|
|
| 1169 |
|
|
| 1170 |
|
class RequestHeader(FrozenClass): |
| 1171 |
|
''' |
| 1172 |
|
The header passed with every server request. |
| 1173 |
|
|
| 1174 |
|
:ivar AuthenticationToken: |
| 1175 |
|
:vartype AuthenticationToken: NodeId |
| 1176 |
|
:ivar Timestamp: |
| 1177 |
|
:vartype Timestamp: DateTime |
| 1178 |
|
:ivar RequestHandle: |
| 1179 |
|
:vartype RequestHandle: UInt32 |
| 1180 |
|
:ivar ReturnDiagnostics: |
| 1181 |
|
:vartype ReturnDiagnostics: UInt32 |
| 1182 |
|
:ivar AuditEntryId: |
| 1183 |
|
:vartype AuditEntryId: String |
| 1184 |
|
:ivar TimeoutHint: |
| 1185 |
|
:vartype TimeoutHint: UInt32 |
| 1186 |
|
:ivar AdditionalHeader: |
| 1187 |
|
:vartype AdditionalHeader: ExtensionObject |
| 1188 |
|
''' |
| 1189 |
|
def __init__(self, binary=None): |
| 1190 |
|
if binary is not None: |
| 1191 |
|
self._binary_init(binary) |
| 1192 |
|
self._freeze = True |
| 1193 |
|
return |
| 1194 |
|
self.AuthenticationToken = NodeId() |
| 1195 |
|
self.Timestamp = datetime.now() |
| 1196 |
|
self.RequestHandle = 0 |
| 1197 |
|
self.ReturnDiagnostics = 0 |
| 1198 |
|
self.AuditEntryId = '' |
| 1199 |
|
self.TimeoutHint = 0 |
| 1200 |
|
self.AdditionalHeader = None |
| 1201 |
|
self._freeze = True |
| 1202 |
|
|
| 1203 |
|
def to_binary(self): |
| 1204 |
|
packet = [] |
| 1205 |
|
packet.append(self.AuthenticationToken.to_binary()) |
| 1206 |
|
packet.append(pack_datetime(self.Timestamp)) |
| 1207 |
|
packet.append(uatype_UInt32.pack(self.RequestHandle)) |
| 1208 |
|
packet.append(uatype_UInt32.pack(self.ReturnDiagnostics)) |
| 1209 |
|
packet.append(pack_string(self.AuditEntryId)) |
| 1210 |
|
packet.append(uatype_UInt32.pack(self.TimeoutHint)) |
| 1211 |
|
packet.append(extensionobject_to_binary(self.AdditionalHeader)) |
| 1212 |
|
return b''.join(packet) |
| 1213 |
|
|
| 1214 |
|
@staticmethod |
| 1215 |
|
def from_binary(data): |
| 1216 |
|
return RequestHeader(data) |
| 1217 |
|
|
| 1218 |
|
def _binary_init(self, data): |
| 1219 |
|
self.AuthenticationToken = NodeId.from_binary(data) |
| 1220 |
|
self.Timestamp = unpack_datetime(data) |
| 1221 |
|
self.RequestHandle = uatype_UInt32.unpack(data.read(4))[0] |
| 1222 |
|
self.ReturnDiagnostics = uatype_UInt32.unpack(data.read(4))[0] |
| 1223 |
|
self.AuditEntryId = unpack_string(data) |
| 1224 |
|
self.TimeoutHint = uatype_UInt32.unpack(data.read(4))[0] |
| 1225 |
|
self.AdditionalHeader = extensionobject_from_binary(data) |
| 1226 |
|
|
| 1227 |
|
def __str__(self): |
| 1228 |
|
return 'RequestHeader(' + 'AuthenticationToken:' + str(self.AuthenticationToken) + ', ' + \ |
| 1229 |
|
'Timestamp:' + str(self.Timestamp) + ', ' + \ |
| 1230 |
|
'RequestHandle:' + str(self.RequestHandle) + ', ' + \ |
| 1231 |
|
'ReturnDiagnostics:' + str(self.ReturnDiagnostics) + ', ' + \ |
| 1232 |
|
'AuditEntryId:' + str(self.AuditEntryId) + ', ' + \ |
| 1233 |
|
'TimeoutHint:' + str(self.TimeoutHint) + ', ' + \ |
| 1234 |
|
'AdditionalHeader:' + str(self.AdditionalHeader) + ')' |
| 1235 |
|
|
| 1236 |
|
__repr__ = __str__ |
| 1237 |
|
|
| 1238 |
|
|
| 1239 |
|
class ResponseHeader(FrozenClass): |
|
@@ 4631-4691 (lines=61) @@
|
| 4628 |
|
__repr__ = __str__ |
| 4629 |
|
|
| 4630 |
|
|
| 4631 |
|
class AddReferencesItem(FrozenClass): |
| 4632 |
|
''' |
| 4633 |
|
A request to add a reference to the server address space. |
| 4634 |
|
|
| 4635 |
|
:ivar SourceNodeId: |
| 4636 |
|
:vartype SourceNodeId: NodeId |
| 4637 |
|
:ivar ReferenceTypeId: |
| 4638 |
|
:vartype ReferenceTypeId: NodeId |
| 4639 |
|
:ivar IsForward: |
| 4640 |
|
:vartype IsForward: Boolean |
| 4641 |
|
:ivar TargetServerUri: |
| 4642 |
|
:vartype TargetServerUri: String |
| 4643 |
|
:ivar TargetNodeId: |
| 4644 |
|
:vartype TargetNodeId: ExpandedNodeId |
| 4645 |
|
:ivar TargetNodeClass: |
| 4646 |
|
:vartype TargetNodeClass: NodeClass |
| 4647 |
|
''' |
| 4648 |
|
def __init__(self, binary=None): |
| 4649 |
|
if binary is not None: |
| 4650 |
|
self._binary_init(binary) |
| 4651 |
|
self._freeze = True |
| 4652 |
|
return |
| 4653 |
|
self.SourceNodeId = NodeId() |
| 4654 |
|
self.ReferenceTypeId = NodeId() |
| 4655 |
|
self.IsForward = True |
| 4656 |
|
self.TargetServerUri = '' |
| 4657 |
|
self.TargetNodeId = ExpandedNodeId() |
| 4658 |
|
self.TargetNodeClass = NodeClass(0) |
| 4659 |
|
self._freeze = True |
| 4660 |
|
|
| 4661 |
|
def to_binary(self): |
| 4662 |
|
packet = [] |
| 4663 |
|
packet.append(self.SourceNodeId.to_binary()) |
| 4664 |
|
packet.append(self.ReferenceTypeId.to_binary()) |
| 4665 |
|
packet.append(uatype_Boolean.pack(self.IsForward)) |
| 4666 |
|
packet.append(pack_string(self.TargetServerUri)) |
| 4667 |
|
packet.append(self.TargetNodeId.to_binary()) |
| 4668 |
|
packet.append(uatype_UInt32.pack(self.TargetNodeClass.value)) |
| 4669 |
|
return b''.join(packet) |
| 4670 |
|
|
| 4671 |
|
@staticmethod |
| 4672 |
|
def from_binary(data): |
| 4673 |
|
return AddReferencesItem(data) |
| 4674 |
|
|
| 4675 |
|
def _binary_init(self, data): |
| 4676 |
|
self.SourceNodeId = NodeId.from_binary(data) |
| 4677 |
|
self.ReferenceTypeId = NodeId.from_binary(data) |
| 4678 |
|
self.IsForward = uatype_Boolean.unpack(data.read(1))[0] |
| 4679 |
|
self.TargetServerUri = unpack_string(data) |
| 4680 |
|
self.TargetNodeId = ExpandedNodeId.from_binary(data) |
| 4681 |
|
self.TargetNodeClass = NodeClass(uatype_UInt32.unpack(data.read(4))[0]) |
| 4682 |
|
|
| 4683 |
|
def __str__(self): |
| 4684 |
|
return 'AddReferencesItem(' + 'SourceNodeId:' + str(self.SourceNodeId) + ', ' + \ |
| 4685 |
|
'ReferenceTypeId:' + str(self.ReferenceTypeId) + ', ' + \ |
| 4686 |
|
'IsForward:' + str(self.IsForward) + ', ' + \ |
| 4687 |
|
'TargetServerUri:' + str(self.TargetServerUri) + ', ' + \ |
| 4688 |
|
'TargetNodeId:' + str(self.TargetNodeId) + ', ' + \ |
| 4689 |
|
'TargetNodeClass:' + str(self.TargetNodeClass) + ')' |
| 4690 |
|
|
| 4691 |
|
__repr__ = __str__ |
| 4692 |
|
|
| 4693 |
|
|
| 4694 |
|
class AddReferencesRequest(FrozenClass): |