@@ 12127-12191 (lines=65) @@ | ||
12124 | return b''.join(packet) |
|
12125 | ||
12126 | @staticmethod |
|
12127 | def from_binary(data): |
|
12128 | obj = SetPublishingModeResponse() |
|
12129 | obj.TypeId = NodeId.from_binary(data) |
|
12130 | obj.ResponseHeader = ResponseHeader.from_binary(data) |
|
12131 | obj.Parameters = SetPublishingModeResult.from_binary(data) |
|
12132 | return obj |
|
12133 | ||
12134 | def __str__(self): |
|
12135 | return 'SetPublishingModeResponse(' + 'TypeId:' + str(self.TypeId) + ', ' + \ |
|
12136 | 'ResponseHeader:' + str(self.ResponseHeader) + ', ' + \ |
|
12137 | 'Parameters:' + str(self.Parameters) + ')' |
|
12138 | ||
12139 | __repr__ = __str__ |
|
12140 | ||
12141 | ||
12142 | class NotificationMessage(FrozenClass): |
|
12143 | ''' |
|
12144 | :ivar SequenceNumber: |
|
12145 | :vartype SequenceNumber: UInt32 |
|
12146 | :ivar PublishTime: |
|
12147 | :vartype PublishTime: DateTime |
|
12148 | :ivar NotificationData: |
|
12149 | :vartype NotificationData: ExtensionObject |
|
12150 | ''' |
|
12151 | ||
12152 | ua_types = [ |
|
12153 | ('SequenceNumber', 'UInt32'), |
|
12154 | ('PublishTime', 'DateTime'), |
|
12155 | ('NotificationData', 'ListOfExtensionObject'), |
|
12156 | ] |
|
12157 | ||
12158 | def __init__(self): |
|
12159 | self.SequenceNumber = 0 |
|
12160 | self.PublishTime = datetime.utcnow() |
|
12161 | self.NotificationData = [] |
|
12162 | self._freeze = True |
|
12163 | ||
12164 | def to_binary(self): |
|
12165 | packet = [] |
|
12166 | packet.append(uabin.Primitives.UInt32.pack(self.SequenceNumber)) |
|
12167 | packet.append(uabin.Primitives.DateTime.pack(self.PublishTime)) |
|
12168 | packet.append(uabin.Primitives.Int32.pack(len(self.NotificationData))) |
|
12169 | for fieldname in self.NotificationData: |
|
12170 | packet.append(uabin.extensionobject_to_binary(fieldname)) |
|
12171 | return b''.join(packet) |
|
12172 | ||
12173 | @staticmethod |
|
12174 | def from_binary(data): |
|
12175 | obj = NotificationMessage() |
|
12176 | self.SequenceNumber = uabin.Primitives.UInt32.unpack(data) |
|
12177 | self.PublishTime = uabin.Primitives.DateTime.unpack(data) |
|
12178 | length = uabin.Primitives.Int32.unpack(data) |
|
12179 | array = [] |
|
12180 | if length != -1: |
|
12181 | for _ in range(0, length): |
|
12182 | array.append(uabin.extensionobject_from_binary(data)) |
|
12183 | obj.NotificationData = array |
|
12184 | return obj |
|
12185 | ||
12186 | def __str__(self): |
|
12187 | return 'NotificationMessage(' + 'SequenceNumber:' + str(self.SequenceNumber) + ', ' + \ |
|
12188 | 'PublishTime:' + str(self.PublishTime) + ', ' + \ |
|
12189 | 'NotificationData:' + str(self.NotificationData) + ')' |
|
12190 | ||
12191 | __repr__ = __str__ |
|
12192 | ||
12193 | ||
12194 | class NotificationData(FrozenClass): |
|
@@ 11915-11979 (lines=65) @@ | ||
11912 | __repr__ = __str__ |
|
11913 | ||
11914 | ||
11915 | class ModifySubscriptionResponse(FrozenClass): |
|
11916 | ''' |
|
11917 | :ivar TypeId: |
|
11918 | :vartype TypeId: NodeId |
|
11919 | :ivar ResponseHeader: |
|
11920 | :vartype ResponseHeader: ResponseHeader |
|
11921 | :ivar Parameters: |
|
11922 | :vartype Parameters: ModifySubscriptionResult |
|
11923 | ''' |
|
11924 | ||
11925 | ua_types = [ |
|
11926 | ('TypeId', 'NodeId'), |
|
11927 | ('ResponseHeader', 'ResponseHeader'), |
|
11928 | ('Parameters', 'ModifySubscriptionResult'), |
|
11929 | ] |
|
11930 | ||
11931 | def __init__(self): |
|
11932 | self.TypeId = FourByteNodeId(ObjectIds.ModifySubscriptionResponse_Encoding_DefaultBinary) |
|
11933 | self.ResponseHeader = ResponseHeader() |
|
11934 | self.Parameters = ModifySubscriptionResult() |
|
11935 | self._freeze = True |
|
11936 | ||
11937 | def to_binary(self): |
|
11938 | packet = [] |
|
11939 | packet.append(self.TypeId.to_binary()) |
|
11940 | packet.append(self.ResponseHeader.to_binary()) |
|
11941 | packet.append(self.Parameters.to_binary()) |
|
11942 | return b''.join(packet) |
|
11943 | ||
11944 | @staticmethod |
|
11945 | def from_binary(data): |
|
11946 | obj = ModifySubscriptionResponse() |
|
11947 | obj.TypeId = NodeId.from_binary(data) |
|
11948 | obj.ResponseHeader = ResponseHeader.from_binary(data) |
|
11949 | obj.Parameters = ModifySubscriptionResult.from_binary(data) |
|
11950 | return obj |
|
11951 | ||
11952 | def __str__(self): |
|
11953 | return 'ModifySubscriptionResponse(' + 'TypeId:' + str(self.TypeId) + ', ' + \ |
|
11954 | 'ResponseHeader:' + str(self.ResponseHeader) + ', ' + \ |
|
11955 | 'Parameters:' + str(self.Parameters) + ')' |
|
11956 | ||
11957 | __repr__ = __str__ |
|
11958 | ||
11959 | ||
11960 | class SetPublishingModeParameters(FrozenClass): |
|
11961 | ''' |
|
11962 | :ivar PublishingEnabled: |
|
11963 | :vartype PublishingEnabled: Boolean |
|
11964 | :ivar SubscriptionIds: |
|
11965 | :vartype SubscriptionIds: UInt32 |
|
11966 | ''' |
|
11967 | ||
11968 | ua_types = [ |
|
11969 | ('PublishingEnabled', 'Boolean'), |
|
11970 | ('SubscriptionIds', 'ListOfUInt32'), |
|
11971 | ] |
|
11972 | ||
11973 | def __init__(self): |
|
11974 | self.PublishingEnabled = True |
|
11975 | self.SubscriptionIds = [] |
|
11976 | self._freeze = True |
|
11977 | ||
11978 | def to_binary(self): |
|
11979 | packet = [] |
|
11980 | packet.append(uabin.Primitives.Boolean.pack(self.PublishingEnabled)) |
|
11981 | packet.append(uabin.Primitives.Int32.pack(len(self.SubscriptionIds))) |
|
11982 | for fieldname in self.SubscriptionIds: |