|
@@ 1504-1572 (lines=69) @@
|
| 1501 |
|
:vartype TypeId: NodeId |
| 1502 |
|
:ivar RequestHeader: |
| 1503 |
|
:vartype RequestHeader: RequestHeader |
| 1504 |
|
:ivar Parameters: |
| 1505 |
|
:vartype Parameters: FindServersParameters |
| 1506 |
|
''' |
| 1507 |
|
|
| 1508 |
|
ua_types = [ |
| 1509 |
|
('TypeId', 'NodeId'), |
| 1510 |
|
('RequestHeader', 'RequestHeader'), |
| 1511 |
|
('Parameters', 'FindServersParameters'), |
| 1512 |
|
] |
| 1513 |
|
|
| 1514 |
|
def __init__(self): |
| 1515 |
|
self.TypeId = FourByteNodeId(ObjectIds.FindServersRequest_Encoding_DefaultBinary) |
| 1516 |
|
self.RequestHeader = RequestHeader() |
| 1517 |
|
self.Parameters = FindServersParameters() |
| 1518 |
|
self._freeze = True |
| 1519 |
|
|
| 1520 |
|
def to_binary(self): |
| 1521 |
|
packet = [] |
| 1522 |
|
packet.append(self.TypeId.to_binary()) |
| 1523 |
|
packet.append(self.RequestHeader.to_binary()) |
| 1524 |
|
packet.append(self.Parameters.to_binary()) |
| 1525 |
|
return b''.join(packet) |
| 1526 |
|
|
| 1527 |
|
@staticmethod |
| 1528 |
|
def from_binary(data): |
| 1529 |
|
obj = FindServersRequest() |
| 1530 |
|
obj.TypeId = NodeId.from_binary(data) |
| 1531 |
|
obj.RequestHeader = RequestHeader.from_binary(data) |
| 1532 |
|
obj.Parameters = FindServersParameters.from_binary(data) |
| 1533 |
|
return obj |
| 1534 |
|
|
| 1535 |
|
def __str__(self): |
| 1536 |
|
return 'FindServersRequest(' + 'TypeId:' + str(self.TypeId) + ', ' + \ |
| 1537 |
|
'RequestHeader:' + str(self.RequestHeader) + ', ' + \ |
| 1538 |
|
'Parameters:' + str(self.Parameters) + ')' |
| 1539 |
|
|
| 1540 |
|
__repr__ = __str__ |
| 1541 |
|
|
| 1542 |
|
|
| 1543 |
|
class FindServersResponse(FrozenClass): |
| 1544 |
|
''' |
| 1545 |
|
Finds the servers known to the discovery server. |
| 1546 |
|
|
| 1547 |
|
:ivar TypeId: |
| 1548 |
|
:vartype TypeId: NodeId |
| 1549 |
|
:ivar ResponseHeader: |
| 1550 |
|
:vartype ResponseHeader: ResponseHeader |
| 1551 |
|
:ivar Servers: |
| 1552 |
|
:vartype Servers: ApplicationDescription |
| 1553 |
|
''' |
| 1554 |
|
|
| 1555 |
|
ua_types = [ |
| 1556 |
|
('TypeId', 'NodeId'), |
| 1557 |
|
('ResponseHeader', 'ResponseHeader'), |
| 1558 |
|
('Servers', 'ListOfApplicationDescription'), |
| 1559 |
|
] |
| 1560 |
|
|
| 1561 |
|
def __init__(self): |
| 1562 |
|
self.TypeId = FourByteNodeId(ObjectIds.FindServersResponse_Encoding_DefaultBinary) |
| 1563 |
|
self.ResponseHeader = ResponseHeader() |
| 1564 |
|
self.Servers = [] |
| 1565 |
|
self._freeze = True |
| 1566 |
|
|
| 1567 |
|
def to_binary(self): |
| 1568 |
|
packet = [] |
| 1569 |
|
packet.append(self.TypeId.to_binary()) |
| 1570 |
|
packet.append(self.ResponseHeader.to_binary()) |
| 1571 |
|
packet.append(uabin.Primitives.Int32.pack(len(self.Servers))) |
| 1572 |
|
for fieldname in self.Servers: |
| 1573 |
|
packet.append(fieldname.to_binary()) |
| 1574 |
|
return b''.join(packet) |
| 1575 |
|
|
|
@@ 8898-8962 (lines=65) @@
|
| 8895 |
|
self.NodesToRead = [] |
| 8896 |
|
self._freeze = True |
| 8897 |
|
|
| 8898 |
|
def to_binary(self): |
| 8899 |
|
packet = [] |
| 8900 |
|
packet.append(uabin.extensionobject_to_binary(self.HistoryReadDetails)) |
| 8901 |
|
packet.append(uabin.Primitives.UInt32.pack(self.TimestampsToReturn.value)) |
| 8902 |
|
packet.append(uabin.Primitives.Boolean.pack(self.ReleaseContinuationPoints)) |
| 8903 |
|
packet.append(uabin.Primitives.Int32.pack(len(self.NodesToRead))) |
| 8904 |
|
for fieldname in self.NodesToRead: |
| 8905 |
|
packet.append(fieldname.to_binary()) |
| 8906 |
|
return b''.join(packet) |
| 8907 |
|
|
| 8908 |
|
@staticmethod |
| 8909 |
|
def from_binary(data): |
| 8910 |
|
obj = HistoryReadParameters() |
| 8911 |
|
obj.HistoryReadDetails = uabin.extensionobject_from_binary(data) |
| 8912 |
|
self.TimestampsToReturn = TimestampsToReturn(uabin.Primitives.UInt32.unpack(data)) |
| 8913 |
|
self.ReleaseContinuationPoints = uabin.Primitives.Boolean.unpack(data) |
| 8914 |
|
length = uabin.Primitives.Int32.unpack(data) |
| 8915 |
|
array = [] |
| 8916 |
|
if length != -1: |
| 8917 |
|
for _ in range(0, length): |
| 8918 |
|
array.append(HistoryReadValueId.from_binary(data)) |
| 8919 |
|
obj.NodesToRead = array |
| 8920 |
|
return obj |
| 8921 |
|
|
| 8922 |
|
def __str__(self): |
| 8923 |
|
return 'HistoryReadParameters(' + 'HistoryReadDetails:' + str(self.HistoryReadDetails) + ', ' + \ |
| 8924 |
|
'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
| 8925 |
|
'ReleaseContinuationPoints:' + str(self.ReleaseContinuationPoints) + ', ' + \ |
| 8926 |
|
'NodesToRead:' + str(self.NodesToRead) + ')' |
| 8927 |
|
|
| 8928 |
|
__repr__ = __str__ |
| 8929 |
|
|
| 8930 |
|
|
| 8931 |
|
class HistoryReadRequest(FrozenClass): |
| 8932 |
|
''' |
| 8933 |
|
:ivar TypeId: |
| 8934 |
|
:vartype TypeId: NodeId |
| 8935 |
|
:ivar RequestHeader: |
| 8936 |
|
:vartype RequestHeader: RequestHeader |
| 8937 |
|
:ivar Parameters: |
| 8938 |
|
:vartype Parameters: HistoryReadParameters |
| 8939 |
|
''' |
| 8940 |
|
|
| 8941 |
|
ua_types = [ |
| 8942 |
|
('TypeId', 'NodeId'), |
| 8943 |
|
('RequestHeader', 'RequestHeader'), |
| 8944 |
|
('Parameters', 'HistoryReadParameters'), |
| 8945 |
|
] |
| 8946 |
|
|
| 8947 |
|
def __init__(self): |
| 8948 |
|
self.TypeId = FourByteNodeId(ObjectIds.HistoryReadRequest_Encoding_DefaultBinary) |
| 8949 |
|
self.RequestHeader = RequestHeader() |
| 8950 |
|
self.Parameters = HistoryReadParameters() |
| 8951 |
|
self._freeze = True |
| 8952 |
|
|
| 8953 |
|
def to_binary(self): |
| 8954 |
|
packet = [] |
| 8955 |
|
packet.append(self.TypeId.to_binary()) |
| 8956 |
|
packet.append(self.RequestHeader.to_binary()) |
| 8957 |
|
packet.append(self.Parameters.to_binary()) |
| 8958 |
|
return b''.join(packet) |
| 8959 |
|
|
| 8960 |
|
@staticmethod |
| 8961 |
|
def from_binary(data): |
| 8962 |
|
obj = HistoryReadRequest() |
| 8963 |
|
obj.TypeId = NodeId.from_binary(data) |
| 8964 |
|
obj.RequestHeader = RequestHeader.from_binary(data) |
| 8965 |
|
obj.Parameters = HistoryReadParameters.from_binary(data) |