@@ 12518-12568 (lines=51) @@ | ||
12515 | __repr__ = __str__ |
|
12516 | ||
12517 | ||
12518 | class NotificationMessage(FrozenClass): |
|
12519 | ''' |
|
12520 | :ivar SequenceNumber: |
|
12521 | :vartype SequenceNumber: UInt32 |
|
12522 | :ivar PublishTime: |
|
12523 | :vartype PublishTime: DateTime |
|
12524 | :ivar NotificationData: |
|
12525 | :vartype NotificationData: ExtensionObject |
|
12526 | ''' |
|
12527 | ||
12528 | ua_types = [ |
|
12529 | ||
12530 | ('SequenceNumber', 'UInt32'), |
|
12531 | ('PublishTime', 'DateTime'), |
|
12532 | ('NotificationData', 'ListOfExtensionObject'), |
|
12533 | ] |
|
12534 | ||
12535 | def __init__(self): |
|
12536 | self.SequenceNumber = 0 |
|
12537 | self.PublishTime = datetime.utcnow() |
|
12538 | self.NotificationData = [] |
|
12539 | self._freeze = True |
|
12540 | ||
12541 | def to_binary(self): |
|
12542 | packet = [] |
|
12543 | packet.append(uabin.Primitives.UInt32.pack(self.SequenceNumber)) |
|
12544 | packet.append(uabin.Primitives.DateTime.pack(self.PublishTime)) |
|
12545 | packet.append(uabin.Primitives.Int32.pack(len(self.NotificationData))) |
|
12546 | for fieldname in self.NotificationData: |
|
12547 | packet.append(extensionobject_to_binary(fieldname)) |
|
12548 | return b''.join(packet) |
|
12549 | ||
12550 | @staticmethod |
|
12551 | def from_binary(data): |
|
12552 | obj = NotificationMessage() |
|
12553 | self.SequenceNumber = uabin.Primitives.UInt32.unpack(data) |
|
12554 | self.PublishTime = uabin.Primitives.DateTime.unpack(data) |
|
12555 | length = uabin.Primitives.Int32.unpack(data) |
|
12556 | array = [] |
|
12557 | if length != -1: |
|
12558 | for _ in range(0, length): |
|
12559 | array.append(extensionobject_from_binary(data)) |
|
12560 | obj.NotificationData = array |
|
12561 | return obj |
|
12562 | ||
12563 | def __str__(self): |
|
12564 | return 'NotificationMessage(' + 'SequenceNumber:' + str(self.SequenceNumber) + ', ' + \ |
|
12565 | 'PublishTime:' + str(self.PublishTime) + ', ' + \ |
|
12566 | 'NotificationData:' + str(self.NotificationData) + ')' |
|
12567 | ||
12568 | __repr__ = __str__ |
|
12569 | ||
12570 | ||
12571 | class NotificationData(FrozenClass): |
|
@@ 11172-11222 (lines=51) @@ | ||
11169 | __repr__ = __str__ |
|
11170 | ||
11171 | ||
11172 | class ModifyMonitoredItemsParameters(FrozenClass): |
|
11173 | ''' |
|
11174 | :ivar SubscriptionId: |
|
11175 | :vartype SubscriptionId: UInt32 |
|
11176 | :ivar TimestampsToReturn: |
|
11177 | :vartype TimestampsToReturn: TimestampsToReturn |
|
11178 | :ivar ItemsToModify: |
|
11179 | :vartype ItemsToModify: MonitoredItemModifyRequest |
|
11180 | ''' |
|
11181 | ||
11182 | ua_types = [ |
|
11183 | ||
11184 | ('SubscriptionId', 'UInt32'), |
|
11185 | ('TimestampsToReturn', 'TimestampsToReturn'), |
|
11186 | ('ItemsToModify', 'ListOfMonitoredItemModifyRequest'), |
|
11187 | ] |
|
11188 | ||
11189 | def __init__(self): |
|
11190 | self.SubscriptionId = 0 |
|
11191 | self.TimestampsToReturn = TimestampsToReturn(0) |
|
11192 | self.ItemsToModify = [] |
|
11193 | self._freeze = True |
|
11194 | ||
11195 | def to_binary(self): |
|
11196 | packet = [] |
|
11197 | packet.append(uabin.Primitives.UInt32.pack(self.SubscriptionId)) |
|
11198 | packet.append(uabin.Primitives.UInt32.pack(self.TimestampsToReturn.value)) |
|
11199 | packet.append(uabin.Primitives.Int32.pack(len(self.ItemsToModify))) |
|
11200 | for fieldname in self.ItemsToModify: |
|
11201 | packet.append(fieldname.to_binary()) |
|
11202 | return b''.join(packet) |
|
11203 | ||
11204 | @staticmethod |
|
11205 | def from_binary(data): |
|
11206 | obj = ModifyMonitoredItemsParameters() |
|
11207 | self.SubscriptionId = uabin.Primitives.UInt32.unpack(data) |
|
11208 | self.TimestampsToReturn = TimestampsToReturn(uabin.Primitives.UInt32.unpack(data)) |
|
11209 | length = uabin.Primitives.Int32.unpack(data) |
|
11210 | array = [] |
|
11211 | if length != -1: |
|
11212 | for _ in range(0, length): |
|
11213 | array.append(MonitoredItemModifyRequest.from_binary(data)) |
|
11214 | obj.ItemsToModify = array |
|
11215 | return obj |
|
11216 | ||
11217 | def __str__(self): |
|
11218 | return 'ModifyMonitoredItemsParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
11219 | 'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
|
11220 | 'ItemsToModify:' + str(self.ItemsToModify) + ')' |
|
11221 | ||
11222 | __repr__ = __str__ |
|
11223 | ||
11224 | ||
11225 | class ModifyMonitoredItemsRequest(FrozenClass): |
|
@@ 10914-10964 (lines=51) @@ | ||
10911 | __repr__ = __str__ |
|
10912 | ||
10913 | ||
10914 | class CreateMonitoredItemsParameters(FrozenClass): |
|
10915 | ''' |
|
10916 | :ivar SubscriptionId: |
|
10917 | :vartype SubscriptionId: UInt32 |
|
10918 | :ivar TimestampsToReturn: |
|
10919 | :vartype TimestampsToReturn: TimestampsToReturn |
|
10920 | :ivar ItemsToCreate: |
|
10921 | :vartype ItemsToCreate: MonitoredItemCreateRequest |
|
10922 | ''' |
|
10923 | ||
10924 | ua_types = [ |
|
10925 | ||
10926 | ('SubscriptionId', 'UInt32'), |
|
10927 | ('TimestampsToReturn', 'TimestampsToReturn'), |
|
10928 | ('ItemsToCreate', 'ListOfMonitoredItemCreateRequest'), |
|
10929 | ] |
|
10930 | ||
10931 | def __init__(self): |
|
10932 | self.SubscriptionId = 0 |
|
10933 | self.TimestampsToReturn = TimestampsToReturn(0) |
|
10934 | self.ItemsToCreate = [] |
|
10935 | self._freeze = True |
|
10936 | ||
10937 | def to_binary(self): |
|
10938 | packet = [] |
|
10939 | packet.append(uabin.Primitives.UInt32.pack(self.SubscriptionId)) |
|
10940 | packet.append(uabin.Primitives.UInt32.pack(self.TimestampsToReturn.value)) |
|
10941 | packet.append(uabin.Primitives.Int32.pack(len(self.ItemsToCreate))) |
|
10942 | for fieldname in self.ItemsToCreate: |
|
10943 | packet.append(fieldname.to_binary()) |
|
10944 | return b''.join(packet) |
|
10945 | ||
10946 | @staticmethod |
|
10947 | def from_binary(data): |
|
10948 | obj = CreateMonitoredItemsParameters() |
|
10949 | self.SubscriptionId = uabin.Primitives.UInt32.unpack(data) |
|
10950 | self.TimestampsToReturn = TimestampsToReturn(uabin.Primitives.UInt32.unpack(data)) |
|
10951 | length = uabin.Primitives.Int32.unpack(data) |
|
10952 | array = [] |
|
10953 | if length != -1: |
|
10954 | for _ in range(0, length): |
|
10955 | array.append(MonitoredItemCreateRequest.from_binary(data)) |
|
10956 | obj.ItemsToCreate = array |
|
10957 | return obj |
|
10958 | ||
10959 | def __str__(self): |
|
10960 | return 'CreateMonitoredItemsParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
10961 | 'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
|
10962 | 'ItemsToCreate:' + str(self.ItemsToCreate) + ')' |
|
10963 | ||
10964 | __repr__ = __str__ |
|
10965 | ||
10966 | ||
10967 | class CreateMonitoredItemsRequest(FrozenClass): |
|
@@ 9646-9696 (lines=51) @@ | ||
9643 | __repr__ = __str__ |
|
9644 | ||
9645 | ||
9646 | class UpdateStructureDataDetails(FrozenClass): |
|
9647 | ''' |
|
9648 | :ivar NodeId: |
|
9649 | :vartype NodeId: NodeId |
|
9650 | :ivar PerformInsertReplace: |
|
9651 | :vartype PerformInsertReplace: PerformUpdateType |
|
9652 | :ivar UpdateValues: |
|
9653 | :vartype UpdateValues: DataValue |
|
9654 | ''' |
|
9655 | ||
9656 | ua_types = [ |
|
9657 | ||
9658 | ('NodeId', 'NodeId'), |
|
9659 | ('PerformInsertReplace', 'PerformUpdateType'), |
|
9660 | ('UpdateValues', 'ListOfDataValue'), |
|
9661 | ] |
|
9662 | ||
9663 | def __init__(self): |
|
9664 | self.NodeId = NodeId() |
|
9665 | self.PerformInsertReplace = PerformUpdateType(0) |
|
9666 | self.UpdateValues = [] |
|
9667 | self._freeze = True |
|
9668 | ||
9669 | def to_binary(self): |
|
9670 | packet = [] |
|
9671 | packet.append(self.NodeId.to_binary()) |
|
9672 | packet.append(uabin.Primitives.UInt32.pack(self.PerformInsertReplace.value)) |
|
9673 | packet.append(uabin.Primitives.Int32.pack(len(self.UpdateValues))) |
|
9674 | for fieldname in self.UpdateValues: |
|
9675 | packet.append(fieldname.to_binary()) |
|
9676 | return b''.join(packet) |
|
9677 | ||
9678 | @staticmethod |
|
9679 | def from_binary(data): |
|
9680 | obj = UpdateStructureDataDetails() |
|
9681 | obj.NodeId = NodeId.from_binary(data) |
|
9682 | self.PerformInsertReplace = PerformUpdateType(uabin.Primitives.UInt32.unpack(data)) |
|
9683 | length = uabin.Primitives.Int32.unpack(data) |
|
9684 | array = [] |
|
9685 | if length != -1: |
|
9686 | for _ in range(0, length): |
|
9687 | array.append(DataValue.from_binary(data)) |
|
9688 | obj.UpdateValues = array |
|
9689 | return obj |
|
9690 | ||
9691 | def __str__(self): |
|
9692 | return 'UpdateStructureDataDetails(' + 'NodeId:' + str(self.NodeId) + ', ' + \ |
|
9693 | 'PerformInsertReplace:' + str(self.PerformInsertReplace) + ', ' + \ |
|
9694 | 'UpdateValues:' + str(self.UpdateValues) + ')' |
|
9695 | ||
9696 | __repr__ = __str__ |
|
9697 | ||
9698 | ||
9699 | class UpdateEventDetails(FrozenClass): |
|
@@ 9593-9643 (lines=51) @@ | ||
9590 | __repr__ = __str__ |
|
9591 | ||
9592 | ||
9593 | class UpdateDataDetails(FrozenClass): |
|
9594 | ''' |
|
9595 | :ivar NodeId: |
|
9596 | :vartype NodeId: NodeId |
|
9597 | :ivar PerformInsertReplace: |
|
9598 | :vartype PerformInsertReplace: PerformUpdateType |
|
9599 | :ivar UpdateValues: |
|
9600 | :vartype UpdateValues: DataValue |
|
9601 | ''' |
|
9602 | ||
9603 | ua_types = [ |
|
9604 | ||
9605 | ('NodeId', 'NodeId'), |
|
9606 | ('PerformInsertReplace', 'PerformUpdateType'), |
|
9607 | ('UpdateValues', 'ListOfDataValue'), |
|
9608 | ] |
|
9609 | ||
9610 | def __init__(self): |
|
9611 | self.NodeId = NodeId() |
|
9612 | self.PerformInsertReplace = PerformUpdateType(0) |
|
9613 | self.UpdateValues = [] |
|
9614 | self._freeze = True |
|
9615 | ||
9616 | def to_binary(self): |
|
9617 | packet = [] |
|
9618 | packet.append(self.NodeId.to_binary()) |
|
9619 | packet.append(uabin.Primitives.UInt32.pack(self.PerformInsertReplace.value)) |
|
9620 | packet.append(uabin.Primitives.Int32.pack(len(self.UpdateValues))) |
|
9621 | for fieldname in self.UpdateValues: |
|
9622 | packet.append(fieldname.to_binary()) |
|
9623 | return b''.join(packet) |
|
9624 | ||
9625 | @staticmethod |
|
9626 | def from_binary(data): |
|
9627 | obj = UpdateDataDetails() |
|
9628 | obj.NodeId = NodeId.from_binary(data) |
|
9629 | self.PerformInsertReplace = PerformUpdateType(uabin.Primitives.UInt32.unpack(data)) |
|
9630 | length = uabin.Primitives.Int32.unpack(data) |
|
9631 | array = [] |
|
9632 | if length != -1: |
|
9633 | for _ in range(0, length): |
|
9634 | array.append(DataValue.from_binary(data)) |
|
9635 | obj.UpdateValues = array |
|
9636 | return obj |
|
9637 | ||
9638 | def __str__(self): |
|
9639 | return 'UpdateDataDetails(' + 'NodeId:' + str(self.NodeId) + ', ' + \ |
|
9640 | 'PerformInsertReplace:' + str(self.PerformInsertReplace) + ', ' + \ |
|
9641 | 'UpdateValues:' + str(self.UpdateValues) + ')' |
|
9642 | ||
9643 | __repr__ = __str__ |
|
9644 | ||
9645 | ||
9646 | class UpdateStructureDataDetails(FrozenClass): |
|
@@ 8494-8544 (lines=51) @@ | ||
8491 | __repr__ = __str__ |
|
8492 | ||
8493 | ||
8494 | class ReadParameters(FrozenClass): |
|
8495 | ''' |
|
8496 | :ivar MaxAge: |
|
8497 | :vartype MaxAge: Double |
|
8498 | :ivar TimestampsToReturn: |
|
8499 | :vartype TimestampsToReturn: TimestampsToReturn |
|
8500 | :ivar NodesToRead: |
|
8501 | :vartype NodesToRead: ReadValueId |
|
8502 | ''' |
|
8503 | ||
8504 | ua_types = [ |
|
8505 | ||
8506 | ('MaxAge', 'Double'), |
|
8507 | ('TimestampsToReturn', 'TimestampsToReturn'), |
|
8508 | ('NodesToRead', 'ListOfReadValueId'), |
|
8509 | ] |
|
8510 | ||
8511 | def __init__(self): |
|
8512 | self.MaxAge = 0 |
|
8513 | self.TimestampsToReturn = TimestampsToReturn(0) |
|
8514 | self.NodesToRead = [] |
|
8515 | self._freeze = True |
|
8516 | ||
8517 | def to_binary(self): |
|
8518 | packet = [] |
|
8519 | packet.append(uabin.Primitives.Double.pack(self.MaxAge)) |
|
8520 | packet.append(uabin.Primitives.UInt32.pack(self.TimestampsToReturn.value)) |
|
8521 | packet.append(uabin.Primitives.Int32.pack(len(self.NodesToRead))) |
|
8522 | for fieldname in self.NodesToRead: |
|
8523 | packet.append(fieldname.to_binary()) |
|
8524 | return b''.join(packet) |
|
8525 | ||
8526 | @staticmethod |
|
8527 | def from_binary(data): |
|
8528 | obj = ReadParameters() |
|
8529 | self.MaxAge = uabin.Primitives.Double.unpack(data) |
|
8530 | self.TimestampsToReturn = TimestampsToReturn(uabin.Primitives.UInt32.unpack(data)) |
|
8531 | length = uabin.Primitives.Int32.unpack(data) |
|
8532 | array = [] |
|
8533 | if length != -1: |
|
8534 | for _ in range(0, length): |
|
8535 | array.append(ReadValueId.from_binary(data)) |
|
8536 | obj.NodesToRead = array |
|
8537 | return obj |
|
8538 | ||
8539 | def __str__(self): |
|
8540 | return 'ReadParameters(' + 'MaxAge:' + str(self.MaxAge) + ', ' + \ |
|
8541 | 'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
|
8542 | 'NodesToRead:' + str(self.NodesToRead) + ')' |
|
8543 | ||
8544 | __repr__ = __str__ |
|
8545 | ||
8546 | ||
8547 | class ReadRequest(FrozenClass): |
|
@@ 6067-6117 (lines=51) @@ | ||
6064 | __repr__ = __str__ |
|
6065 | ||
6066 | ||
6067 | class BrowseParameters(FrozenClass): |
|
6068 | ''' |
|
6069 | :ivar View: |
|
6070 | :vartype View: ViewDescription |
|
6071 | :ivar RequestedMaxReferencesPerNode: |
|
6072 | :vartype RequestedMaxReferencesPerNode: UInt32 |
|
6073 | :ivar NodesToBrowse: |
|
6074 | :vartype NodesToBrowse: BrowseDescription |
|
6075 | ''' |
|
6076 | ||
6077 | ua_types = [ |
|
6078 | ||
6079 | ('View', 'ViewDescription'), |
|
6080 | ('RequestedMaxReferencesPerNode', 'UInt32'), |
|
6081 | ('NodesToBrowse', 'ListOfBrowseDescription'), |
|
6082 | ] |
|
6083 | ||
6084 | def __init__(self): |
|
6085 | self.View = ViewDescription() |
|
6086 | self.RequestedMaxReferencesPerNode = 0 |
|
6087 | self.NodesToBrowse = [] |
|
6088 | self._freeze = True |
|
6089 | ||
6090 | def to_binary(self): |
|
6091 | packet = [] |
|
6092 | packet.append(self.View.to_binary()) |
|
6093 | packet.append(uabin.Primitives.UInt32.pack(self.RequestedMaxReferencesPerNode)) |
|
6094 | packet.append(uabin.Primitives.Int32.pack(len(self.NodesToBrowse))) |
|
6095 | for fieldname in self.NodesToBrowse: |
|
6096 | packet.append(fieldname.to_binary()) |
|
6097 | return b''.join(packet) |
|
6098 | ||
6099 | @staticmethod |
|
6100 | def from_binary(data): |
|
6101 | obj = BrowseParameters() |
|
6102 | obj.View = ViewDescription.from_binary(data) |
|
6103 | self.RequestedMaxReferencesPerNode = uabin.Primitives.UInt32.unpack(data) |
|
6104 | length = uabin.Primitives.Int32.unpack(data) |
|
6105 | array = [] |
|
6106 | if length != -1: |
|
6107 | for _ in range(0, length): |
|
6108 | array.append(BrowseDescription.from_binary(data)) |
|
6109 | obj.NodesToBrowse = array |
|
6110 | return obj |
|
6111 | ||
6112 | def __str__(self): |
|
6113 | return 'BrowseParameters(' + 'View:' + str(self.View) + ', ' + \ |
|
6114 | 'RequestedMaxReferencesPerNode:' + str(self.RequestedMaxReferencesPerNode) + ', ' + \ |
|
6115 | 'NodesToBrowse:' + str(self.NodesToBrowse) + ')' |
|
6116 | ||
6117 | __repr__ = __str__ |
|
6118 | ||
6119 | ||
6120 | class BrowseRequest(FrozenClass): |