|
@@ 8126-8185 (lines=60) @@
|
| 8123 |
|
|
| 8124 |
|
__repr__ = __str__ |
| 8125 |
|
|
| 8126 |
|
|
| 8127 |
|
class ReadProcessedDetails(FrozenClass): |
| 8128 |
|
''' |
| 8129 |
|
:ivar StartTime: |
| 8130 |
|
:vartype StartTime: DateTime |
| 8131 |
|
:ivar EndTime: |
| 8132 |
|
:vartype EndTime: DateTime |
| 8133 |
|
:ivar ProcessingInterval: |
| 8134 |
|
:vartype ProcessingInterval: Double |
| 8135 |
|
:ivar AggregateType: |
| 8136 |
|
:vartype AggregateType: NodeId |
| 8137 |
|
:ivar AggregateConfiguration: |
| 8138 |
|
:vartype AggregateConfiguration: AggregateConfiguration |
| 8139 |
|
''' |
| 8140 |
|
def __init__(self, binary=None): |
| 8141 |
|
if binary is not None: |
| 8142 |
|
self._binary_init(binary) |
| 8143 |
|
self._freeze = True |
| 8144 |
|
return |
| 8145 |
|
self.StartTime = datetime.now() |
| 8146 |
|
self.EndTime = datetime.now() |
| 8147 |
|
self.ProcessingInterval = 0 |
| 8148 |
|
self.AggregateType = [] |
| 8149 |
|
self.AggregateConfiguration = AggregateConfiguration() |
| 8150 |
|
self._freeze = True |
| 8151 |
|
|
| 8152 |
|
def to_binary(self): |
| 8153 |
|
packet = [] |
| 8154 |
|
packet.append(pack_datetime(self.StartTime)) |
| 8155 |
|
packet.append(pack_datetime(self.EndTime)) |
| 8156 |
|
packet.append(uatype_Double.pack(self.ProcessingInterval)) |
| 8157 |
|
packet.append(uatype_Int32.pack(len(self.AggregateType))) |
| 8158 |
|
for fieldname in self.AggregateType: |
| 8159 |
|
packet.append(fieldname.to_binary()) |
| 8160 |
|
packet.append(self.AggregateConfiguration.to_binary()) |
| 8161 |
|
return b''.join(packet) |
| 8162 |
|
|
| 8163 |
|
@staticmethod |
| 8164 |
|
def from_binary(data): |
| 8165 |
|
return ReadProcessedDetails(data) |
| 8166 |
|
|
| 8167 |
|
def _binary_init(self, data): |
| 8168 |
|
self.StartTime = unpack_datetime(data) |
| 8169 |
|
self.EndTime = unpack_datetime(data) |
| 8170 |
|
self.ProcessingInterval = uatype_Double.unpack(data.read(8))[0] |
| 8171 |
|
length = uatype_Int32.unpack(data.read(4))[0] |
| 8172 |
|
array = [] |
| 8173 |
|
if length != -1: |
| 8174 |
|
for _ in range(0, length): |
| 8175 |
|
array.append(NodeId.from_binary(data)) |
| 8176 |
|
self.AggregateType = array |
| 8177 |
|
self.AggregateConfiguration = AggregateConfiguration.from_binary(data) |
| 8178 |
|
|
| 8179 |
|
def __str__(self): |
| 8180 |
|
return 'ReadProcessedDetails(' + 'StartTime:' + str(self.StartTime) + ', ' + \ |
| 8181 |
|
'EndTime:' + str(self.EndTime) + ', ' + \ |
| 8182 |
|
'ProcessingInterval:' + str(self.ProcessingInterval) + ', ' + \ |
| 8183 |
|
'AggregateType:' + str(self.AggregateType) + ', ' + \ |
| 8184 |
|
'AggregateConfiguration:' + str(self.AggregateConfiguration) + ')' |
| 8185 |
|
|
| 8186 |
|
__repr__ = __str__ |
| 8187 |
|
|
| 8188 |
|
|
|
@@ 7307-7366 (lines=60) @@
|
| 7304 |
|
|
| 7305 |
|
__repr__ = __str__ |
| 7306 |
|
|
| 7307 |
|
|
| 7308 |
|
class QueryFirstParameters(FrozenClass): |
| 7309 |
|
''' |
| 7310 |
|
:ivar View: |
| 7311 |
|
:vartype View: ViewDescription |
| 7312 |
|
:ivar NodeTypes: |
| 7313 |
|
:vartype NodeTypes: NodeTypeDescription |
| 7314 |
|
:ivar Filter: |
| 7315 |
|
:vartype Filter: ContentFilter |
| 7316 |
|
:ivar MaxDataSetsToReturn: |
| 7317 |
|
:vartype MaxDataSetsToReturn: UInt32 |
| 7318 |
|
:ivar MaxReferencesToReturn: |
| 7319 |
|
:vartype MaxReferencesToReturn: UInt32 |
| 7320 |
|
''' |
| 7321 |
|
def __init__(self, binary=None): |
| 7322 |
|
if binary is not None: |
| 7323 |
|
self._binary_init(binary) |
| 7324 |
|
self._freeze = True |
| 7325 |
|
return |
| 7326 |
|
self.View = ViewDescription() |
| 7327 |
|
self.NodeTypes = [] |
| 7328 |
|
self.Filter = ContentFilter() |
| 7329 |
|
self.MaxDataSetsToReturn = 0 |
| 7330 |
|
self.MaxReferencesToReturn = 0 |
| 7331 |
|
self._freeze = True |
| 7332 |
|
|
| 7333 |
|
def to_binary(self): |
| 7334 |
|
packet = [] |
| 7335 |
|
packet.append(self.View.to_binary()) |
| 7336 |
|
packet.append(uatype_Int32.pack(len(self.NodeTypes))) |
| 7337 |
|
for fieldname in self.NodeTypes: |
| 7338 |
|
packet.append(fieldname.to_binary()) |
| 7339 |
|
packet.append(self.Filter.to_binary()) |
| 7340 |
|
packet.append(uatype_UInt32.pack(self.MaxDataSetsToReturn)) |
| 7341 |
|
packet.append(uatype_UInt32.pack(self.MaxReferencesToReturn)) |
| 7342 |
|
return b''.join(packet) |
| 7343 |
|
|
| 7344 |
|
@staticmethod |
| 7345 |
|
def from_binary(data): |
| 7346 |
|
return QueryFirstParameters(data) |
| 7347 |
|
|
| 7348 |
|
def _binary_init(self, data): |
| 7349 |
|
self.View = ViewDescription.from_binary(data) |
| 7350 |
|
length = uatype_Int32.unpack(data.read(4))[0] |
| 7351 |
|
array = [] |
| 7352 |
|
if length != -1: |
| 7353 |
|
for _ in range(0, length): |
| 7354 |
|
array.append(NodeTypeDescription.from_binary(data)) |
| 7355 |
|
self.NodeTypes = array |
| 7356 |
|
self.Filter = ContentFilter.from_binary(data) |
| 7357 |
|
self.MaxDataSetsToReturn = uatype_UInt32.unpack(data.read(4))[0] |
| 7358 |
|
self.MaxReferencesToReturn = uatype_UInt32.unpack(data.read(4))[0] |
| 7359 |
|
|
| 7360 |
|
def __str__(self): |
| 7361 |
|
return 'QueryFirstParameters(' + 'View:' + str(self.View) + ', ' + \ |
| 7362 |
|
'NodeTypes:' + str(self.NodeTypes) + ', ' + \ |
| 7363 |
|
'Filter:' + str(self.Filter) + ', ' + \ |
| 7364 |
|
'MaxDataSetsToReturn:' + str(self.MaxDataSetsToReturn) + ', ' + \ |
| 7365 |
|
'MaxReferencesToReturn:' + str(self.MaxReferencesToReturn) + ')' |
| 7366 |
|
|
| 7367 |
|
__repr__ = __str__ |
| 7368 |
|
|
| 7369 |
|
|
|
@@ 8883-8936 (lines=54) @@
|
| 8880 |
|
|
| 8881 |
|
__repr__ = __str__ |
| 8882 |
|
|
| 8883 |
|
|
| 8884 |
|
class UpdateEventDetails(FrozenClass): |
| 8885 |
|
''' |
| 8886 |
|
:ivar NodeId: |
| 8887 |
|
:vartype NodeId: NodeId |
| 8888 |
|
:ivar PerformInsertReplace: |
| 8889 |
|
:vartype PerformInsertReplace: PerformUpdateType |
| 8890 |
|
:ivar Filter: |
| 8891 |
|
:vartype Filter: EventFilter |
| 8892 |
|
:ivar EventData: |
| 8893 |
|
:vartype EventData: HistoryEventFieldList |
| 8894 |
|
''' |
| 8895 |
|
def __init__(self, binary=None): |
| 8896 |
|
if binary is not None: |
| 8897 |
|
self._binary_init(binary) |
| 8898 |
|
self._freeze = True |
| 8899 |
|
return |
| 8900 |
|
self.NodeId = NodeId() |
| 8901 |
|
self.PerformInsertReplace = PerformUpdateType(0) |
| 8902 |
|
self.Filter = EventFilter() |
| 8903 |
|
self.EventData = [] |
| 8904 |
|
self._freeze = True |
| 8905 |
|
|
| 8906 |
|
def to_binary(self): |
| 8907 |
|
packet = [] |
| 8908 |
|
packet.append(self.NodeId.to_binary()) |
| 8909 |
|
packet.append(uatype_UInt32.pack(self.PerformInsertReplace.value)) |
| 8910 |
|
packet.append(self.Filter.to_binary()) |
| 8911 |
|
packet.append(uatype_Int32.pack(len(self.EventData))) |
| 8912 |
|
for fieldname in self.EventData: |
| 8913 |
|
packet.append(fieldname.to_binary()) |
| 8914 |
|
return b''.join(packet) |
| 8915 |
|
|
| 8916 |
|
@staticmethod |
| 8917 |
|
def from_binary(data): |
| 8918 |
|
return UpdateEventDetails(data) |
| 8919 |
|
|
| 8920 |
|
def _binary_init(self, data): |
| 8921 |
|
self.NodeId = NodeId.from_binary(data) |
| 8922 |
|
self.PerformInsertReplace = PerformUpdateType(uatype_UInt32.unpack(data.read(4))[0]) |
| 8923 |
|
self.Filter = EventFilter.from_binary(data) |
| 8924 |
|
length = uatype_Int32.unpack(data.read(4))[0] |
| 8925 |
|
array = [] |
| 8926 |
|
if length != -1: |
| 8927 |
|
for _ in range(0, length): |
| 8928 |
|
array.append(HistoryEventFieldList.from_binary(data)) |
| 8929 |
|
self.EventData = array |
| 8930 |
|
|
| 8931 |
|
def __str__(self): |
| 8932 |
|
return 'UpdateEventDetails(' + 'NodeId:' + str(self.NodeId) + ', ' + \ |
| 8933 |
|
'PerformInsertReplace:' + str(self.PerformInsertReplace) + ', ' + \ |
| 8934 |
|
'Filter:' + str(self.Filter) + ', ' + \ |
| 8935 |
|
'EventData:' + str(self.EventData) + ')' |
| 8936 |
|
|
| 8937 |
|
__repr__ = __str__ |
| 8938 |
|
|
| 8939 |
|
|
|
@@ 8397-8450 (lines=54) @@
|
| 8394 |
|
|
| 8395 |
|
__repr__ = __str__ |
| 8396 |
|
|
| 8397 |
|
|
| 8398 |
|
class HistoryReadParameters(FrozenClass): |
| 8399 |
|
''' |
| 8400 |
|
:ivar HistoryReadDetails: |
| 8401 |
|
:vartype HistoryReadDetails: ExtensionObject |
| 8402 |
|
:ivar TimestampsToReturn: |
| 8403 |
|
:vartype TimestampsToReturn: TimestampsToReturn |
| 8404 |
|
:ivar ReleaseContinuationPoints: |
| 8405 |
|
:vartype ReleaseContinuationPoints: Boolean |
| 8406 |
|
:ivar NodesToRead: |
| 8407 |
|
:vartype NodesToRead: HistoryReadValueId |
| 8408 |
|
''' |
| 8409 |
|
def __init__(self, binary=None): |
| 8410 |
|
if binary is not None: |
| 8411 |
|
self._binary_init(binary) |
| 8412 |
|
self._freeze = True |
| 8413 |
|
return |
| 8414 |
|
self.HistoryReadDetails = None |
| 8415 |
|
self.TimestampsToReturn = TimestampsToReturn(0) |
| 8416 |
|
self.ReleaseContinuationPoints = True |
| 8417 |
|
self.NodesToRead = [] |
| 8418 |
|
self._freeze = True |
| 8419 |
|
|
| 8420 |
|
def to_binary(self): |
| 8421 |
|
packet = [] |
| 8422 |
|
packet.append(extensionobject_to_binary(self.HistoryReadDetails)) |
| 8423 |
|
packet.append(uatype_UInt32.pack(self.TimestampsToReturn.value)) |
| 8424 |
|
packet.append(uatype_Boolean.pack(self.ReleaseContinuationPoints)) |
| 8425 |
|
packet.append(uatype_Int32.pack(len(self.NodesToRead))) |
| 8426 |
|
for fieldname in self.NodesToRead: |
| 8427 |
|
packet.append(fieldname.to_binary()) |
| 8428 |
|
return b''.join(packet) |
| 8429 |
|
|
| 8430 |
|
@staticmethod |
| 8431 |
|
def from_binary(data): |
| 8432 |
|
return HistoryReadParameters(data) |
| 8433 |
|
|
| 8434 |
|
def _binary_init(self, data): |
| 8435 |
|
self.HistoryReadDetails = extensionobject_from_binary(data) |
| 8436 |
|
self.TimestampsToReturn = TimestampsToReturn(uatype_UInt32.unpack(data.read(4))[0]) |
| 8437 |
|
self.ReleaseContinuationPoints = uatype_Boolean.unpack(data.read(1))[0] |
| 8438 |
|
length = uatype_Int32.unpack(data.read(4))[0] |
| 8439 |
|
array = [] |
| 8440 |
|
if length != -1: |
| 8441 |
|
for _ in range(0, length): |
| 8442 |
|
array.append(HistoryReadValueId.from_binary(data)) |
| 8443 |
|
self.NodesToRead = array |
| 8444 |
|
|
| 8445 |
|
def __str__(self): |
| 8446 |
|
return 'HistoryReadParameters(' + 'HistoryReadDetails:' + str(self.HistoryReadDetails) + ', ' + \ |
| 8447 |
|
'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
| 8448 |
|
'ReleaseContinuationPoints:' + str(self.ReleaseContinuationPoints) + ', ' + \ |
| 8449 |
|
'NodesToRead:' + str(self.NodesToRead) + ')' |
| 8450 |
|
|
| 8451 |
|
__repr__ = __str__ |
| 8452 |
|
|
| 8453 |
|
|
|
@@ 6831-6884 (lines=54) @@
|
| 6828 |
|
|
| 6829 |
|
__repr__ = __str__ |
| 6830 |
|
|
| 6831 |
|
|
| 6832 |
|
class NodeReference(FrozenClass): |
| 6833 |
|
''' |
| 6834 |
|
:ivar NodeId: |
| 6835 |
|
:vartype NodeId: NodeId |
| 6836 |
|
:ivar ReferenceTypeId: |
| 6837 |
|
:vartype ReferenceTypeId: NodeId |
| 6838 |
|
:ivar IsForward: |
| 6839 |
|
:vartype IsForward: Boolean |
| 6840 |
|
:ivar ReferencedNodeIds: |
| 6841 |
|
:vartype ReferencedNodeIds: NodeId |
| 6842 |
|
''' |
| 6843 |
|
def __init__(self, binary=None): |
| 6844 |
|
if binary is not None: |
| 6845 |
|
self._binary_init(binary) |
| 6846 |
|
self._freeze = True |
| 6847 |
|
return |
| 6848 |
|
self.NodeId = NodeId() |
| 6849 |
|
self.ReferenceTypeId = NodeId() |
| 6850 |
|
self.IsForward = True |
| 6851 |
|
self.ReferencedNodeIds = [] |
| 6852 |
|
self._freeze = True |
| 6853 |
|
|
| 6854 |
|
def to_binary(self): |
| 6855 |
|
packet = [] |
| 6856 |
|
packet.append(self.NodeId.to_binary()) |
| 6857 |
|
packet.append(self.ReferenceTypeId.to_binary()) |
| 6858 |
|
packet.append(uatype_Boolean.pack(self.IsForward)) |
| 6859 |
|
packet.append(uatype_Int32.pack(len(self.ReferencedNodeIds))) |
| 6860 |
|
for fieldname in self.ReferencedNodeIds: |
| 6861 |
|
packet.append(fieldname.to_binary()) |
| 6862 |
|
return b''.join(packet) |
| 6863 |
|
|
| 6864 |
|
@staticmethod |
| 6865 |
|
def from_binary(data): |
| 6866 |
|
return NodeReference(data) |
| 6867 |
|
|
| 6868 |
|
def _binary_init(self, data): |
| 6869 |
|
self.NodeId = NodeId.from_binary(data) |
| 6870 |
|
self.ReferenceTypeId = NodeId.from_binary(data) |
| 6871 |
|
self.IsForward = uatype_Boolean.unpack(data.read(1))[0] |
| 6872 |
|
length = uatype_Int32.unpack(data.read(4))[0] |
| 6873 |
|
array = [] |
| 6874 |
|
if length != -1: |
| 6875 |
|
for _ in range(0, length): |
| 6876 |
|
array.append(NodeId.from_binary(data)) |
| 6877 |
|
self.ReferencedNodeIds = array |
| 6878 |
|
|
| 6879 |
|
def __str__(self): |
| 6880 |
|
return 'NodeReference(' + 'NodeId:' + str(self.NodeId) + ', ' + \ |
| 6881 |
|
'ReferenceTypeId:' + str(self.ReferenceTypeId) + ', ' + \ |
| 6882 |
|
'IsForward:' + str(self.IsForward) + ', ' + \ |
| 6883 |
|
'ReferencedNodeIds:' + str(self.ReferencedNodeIds) + ')' |
| 6884 |
|
|
| 6885 |
|
__repr__ = __str__ |
| 6886 |
|
|
| 6887 |
|
|