| @@ 297-370 (lines=74) @@ | ||
| 294 | ||
| 295 | ||
| 296 | class AttributeWriteMask(IntEnum): |
|
| 297 | ''' |
|
| 298 | Define bits used to indicate which attributes are writable. |
|
| 299 | ||
| 300 | :ivar None_: |
|
| 301 | :vartype None_: 0 |
|
| 302 | :ivar AccessLevel: |
|
| 303 | :vartype AccessLevel: 1 |
|
| 304 | :ivar ArrayDimensions: |
|
| 305 | :vartype ArrayDimensions: 2 |
|
| 306 | :ivar BrowseName: |
|
| 307 | :vartype BrowseName: 4 |
|
| 308 | :ivar ContainsNoLoops: |
|
| 309 | :vartype ContainsNoLoops: 8 |
|
| 310 | :ivar DataType: |
|
| 311 | :vartype DataType: 16 |
|
| 312 | :ivar Description: |
|
| 313 | :vartype Description: 32 |
|
| 314 | :ivar DisplayName: |
|
| 315 | :vartype DisplayName: 64 |
|
| 316 | :ivar EventNotifier: |
|
| 317 | :vartype EventNotifier: 128 |
|
| 318 | :ivar Executable: |
|
| 319 | :vartype Executable: 256 |
|
| 320 | :ivar Historizing: |
|
| 321 | :vartype Historizing: 512 |
|
| 322 | :ivar InverseName: |
|
| 323 | :vartype InverseName: 1024 |
|
| 324 | :ivar IsAbstract: |
|
| 325 | :vartype IsAbstract: 2048 |
|
| 326 | :ivar MinimumSamplingInterval: |
|
| 327 | :vartype MinimumSamplingInterval: 4096 |
|
| 328 | :ivar NodeClass: |
|
| 329 | :vartype NodeClass: 8192 |
|
| 330 | :ivar NodeId: |
|
| 331 | :vartype NodeId: 16384 |
|
| 332 | :ivar Symmetric: |
|
| 333 | :vartype Symmetric: 32768 |
|
| 334 | :ivar UserAccessLevel: |
|
| 335 | :vartype UserAccessLevel: 65536 |
|
| 336 | :ivar UserExecutable: |
|
| 337 | :vartype UserExecutable: 131072 |
|
| 338 | :ivar UserWriteMask: |
|
| 339 | :vartype UserWriteMask: 262144 |
|
| 340 | :ivar ValueRank: |
|
| 341 | :vartype ValueRank: 524288 |
|
| 342 | :ivar WriteMask: |
|
| 343 | :vartype WriteMask: 1048576 |
|
| 344 | :ivar ValueForVariableType: |
|
| 345 | :vartype ValueForVariableType: 2097152 |
|
| 346 | ''' |
|
| 347 | None_ = 0 |
|
| 348 | AccessLevel = 1 |
|
| 349 | ArrayDimensions = 2 |
|
| 350 | BrowseName = 4 |
|
| 351 | ContainsNoLoops = 8 |
|
| 352 | DataType = 16 |
|
| 353 | Description = 32 |
|
| 354 | DisplayName = 64 |
|
| 355 | EventNotifier = 128 |
|
| 356 | Executable = 256 |
|
| 357 | Historizing = 512 |
|
| 358 | InverseName = 1024 |
|
| 359 | IsAbstract = 2048 |
|
| 360 | MinimumSamplingInterval = 4096 |
|
| 361 | NodeClass = 8192 |
|
| 362 | NodeId = 16384 |
|
| 363 | Symmetric = 32768 |
|
| 364 | UserAccessLevel = 65536 |
|
| 365 | UserExecutable = 131072 |
|
| 366 | UserWriteMask = 262144 |
|
| 367 | ValueRank = 524288 |
|
| 368 | WriteMask = 1048576 |
|
| 369 | ValueForVariableType = 2097152 |
|
| 370 | ||
| 371 | ||
| 372 | class BrowseDirection(IntEnum): |
|
| 373 | ''' |
|
| @@ 805-865 (lines=61) @@ | ||
| 802 | raise UaError("could not guess UA type of variable {0}".format(error_val)) |
|
| 803 | val = val[0] |
|
| 804 | if val is None: |
|
| 805 | return VariantType.Null |
|
| 806 | elif isinstance(val, bool): |
|
| 807 | return VariantType.Boolean |
|
| 808 | elif isinstance(val, float): |
|
| 809 | return VariantType.Double |
|
| 810 | elif isinstance(val, int): |
|
| 811 | return VariantType.Int64 |
|
| 812 | elif type(val) in (str, unicode): |
|
| 813 | return VariantType.String |
|
| 814 | elif isinstance(val, bytes): |
|
| 815 | return VariantType.ByteString |
|
| 816 | elif isinstance(val, datetime): |
|
| 817 | return VariantType.DateTime |
|
| 818 | elif isinstance(val, uuid.UUID): |
|
| 819 | return VariantType.Guid |
|
| 820 | else: |
|
| 821 | if isinstance(val, object): |
|
| 822 | try: |
|
| 823 | return getattr(VariantType, val.__class__.__name__) |
|
| 824 | except AttributeError: |
|
| 825 | return VariantType.ExtensionObject |
|
| 826 | else: |
|
| 827 | raise UaError("Could not guess UA type of {0} with type {1}, specify UA type".format(val, type(val))) |
|
| 828 | ||
| 829 | def __str__(self): |
|
| 830 | return "Variant(val:{0!s},type:{1})".format(self.Value, self.VariantType) |
|
| 831 | __repr__ = __str__ |
|
| 832 | ||
| 833 | def to_binary(self): |
|
| 834 | b = [] |
|
| 835 | encoding = self.VariantType.value & 0b111111 |
|
| 836 | if self.is_array or type(self.Value) in (list, tuple): |
|
| 837 | self.is_array = True |
|
| 838 | encoding = uabin.set_bit(encoding, 7) |
|
| 839 | if self.Dimensions is not None: |
|
| 840 | encoding = uabin.set_bit(encoding, 6) |
|
| 841 | b.append(uabin.Primitives.UInt8.pack(encoding)) |
|
| 842 | b.append(uabin.pack_uatype_array(self.VariantType, flatten(self.Value))) |
|
| 843 | if self.Dimensions is not None: |
|
| 844 | b.append(uabin.pack_uatype_array(VariantType.Int32, self.Dimensions)) |
|
| 845 | else: |
|
| 846 | b.append(uabin.Primitives.UInt8.pack(encoding)) |
|
| 847 | b.append(uabin.pack_uatype(self.VariantType, self.Value)) |
|
| 848 | ||
| 849 | return b"".join(b) |
|
| 850 | ||
| 851 | @staticmethod |
|
| 852 | def from_binary(data): |
|
| 853 | dimensions = None |
|
| 854 | array = False |
|
| 855 | encoding = ord(data.read(1)) |
|
| 856 | int_type = encoding & 0b00111111 |
|
| 857 | vtype = datatype_to_varianttype(int_type) |
|
| 858 | if uabin.test_bit(encoding, 7): |
|
| 859 | value = uabin.unpack_uatype_array(vtype, data) |
|
| 860 | array = True |
|
| 861 | else: |
|
| 862 | value = uabin.unpack_uatype(vtype, data) |
|
| 863 | if uabin.test_bit(encoding, 6): |
|
| 864 | dimensions = uabin.unpack_uatype_array(VariantType.Int32, data) |
|
| 865 | value = reshape(value, dimensions) |
|
| 866 | return Variant(value, vtype, dimensions, is_array=array) |
|
| 867 | ||
| 868 | ||