@@ 2162-2209 (lines=48) @@ | ||
2159 | ('ServerType', 'ApplicationType'), |
|
2160 | ('GatewayServerUri', 'String'), |
|
2161 | ('DiscoveryUrls', 'ListOfString'), |
|
2162 | ('SemaphoreFilePath', 'String'), |
|
2163 | ('IsOnline', 'Boolean'), |
|
2164 | ] |
|
2165 | ||
2166 | def __init__(self): |
|
2167 | self.ServerUri = None |
|
2168 | self.ProductUri = None |
|
2169 | self.ServerNames = [] |
|
2170 | self.ServerType = ApplicationType(0) |
|
2171 | self.GatewayServerUri = None |
|
2172 | self.DiscoveryUrls = [] |
|
2173 | self.SemaphoreFilePath = None |
|
2174 | self.IsOnline = True |
|
2175 | self._freeze = True |
|
2176 | ||
2177 | def to_binary(self): |
|
2178 | packet = [] |
|
2179 | packet.append(uabin.Primitives.String.pack(self.ServerUri)) |
|
2180 | packet.append(uabin.Primitives.String.pack(self.ProductUri)) |
|
2181 | packet.append(uabin.Primitives.Int32.pack(len(self.ServerNames))) |
|
2182 | for fieldname in self.ServerNames: |
|
2183 | packet.append(fieldname.to_binary()) |
|
2184 | packet.append(uabin.Primitives.UInt32.pack(self.ServerType.value)) |
|
2185 | packet.append(uabin.Primitives.String.pack(self.GatewayServerUri)) |
|
2186 | packet.append(uabin.Primitives.Int32.pack(len(self.DiscoveryUrls))) |
|
2187 | for fieldname in self.DiscoveryUrls: |
|
2188 | packet.append(uabin.Primitives.String.pack(fieldname)) |
|
2189 | packet.append(uabin.Primitives.String.pack(self.SemaphoreFilePath)) |
|
2190 | packet.append(uabin.Primitives.Boolean.pack(self.IsOnline)) |
|
2191 | return b''.join(packet) |
|
2192 | ||
2193 | @staticmethod |
|
2194 | def from_binary(data): |
|
2195 | obj = RegisteredServer() |
|
2196 | self.ServerUri = uabin.Primitives.String.unpack(data) |
|
2197 | self.ProductUri = uabin.Primitives.String.unpack(data) |
|
2198 | length = uabin.Primitives.Int32.unpack(data) |
|
2199 | array = [] |
|
2200 | if length != -1: |
|
2201 | for _ in range(0, length): |
|
2202 | array.append(LocalizedText.from_binary(data)) |
|
2203 | obj.ServerNames = array |
|
2204 | self.ServerType = ApplicationType(uabin.Primitives.UInt32.unpack(data)) |
|
2205 | self.GatewayServerUri = uabin.Primitives.String.unpack(data) |
|
2206 | obj.DiscoveryUrls = uabin.Primitives.String.unpack_array(data) |
|
2207 | self.SemaphoreFilePath = uabin.Primitives.String.unpack(data) |
|
2208 | self.IsOnline = uabin.Primitives.Boolean.unpack(data) |
|
2209 | return obj |
|
2210 | ||
2211 | def __str__(self): |
|
2212 | return 'RegisteredServer(' + 'ServerUri:' + str(self.ServerUri) + ', ' + \ |
|
@@ 1616-1663 (lines=48) @@ | ||
1613 | ('ServerCapabilities', 'ListOfString'), |
|
1614 | ] |
|
1615 | ||
1616 | def __init__(self): |
|
1617 | self.RecordId = 0 |
|
1618 | self.ServerName = None |
|
1619 | self.DiscoveryUrl = None |
|
1620 | self.ServerCapabilities = [] |
|
1621 | self._freeze = True |
|
1622 | ||
1623 | def to_binary(self): |
|
1624 | packet = [] |
|
1625 | packet.append(uabin.Primitives.UInt32.pack(self.RecordId)) |
|
1626 | packet.append(uabin.Primitives.String.pack(self.ServerName)) |
|
1627 | packet.append(uabin.Primitives.String.pack(self.DiscoveryUrl)) |
|
1628 | packet.append(uabin.Primitives.Int32.pack(len(self.ServerCapabilities))) |
|
1629 | for fieldname in self.ServerCapabilities: |
|
1630 | packet.append(uabin.Primitives.String.pack(fieldname)) |
|
1631 | return b''.join(packet) |
|
1632 | ||
1633 | @staticmethod |
|
1634 | def from_binary(data): |
|
1635 | obj = ServerOnNetwork() |
|
1636 | self.RecordId = uabin.Primitives.UInt32.unpack(data) |
|
1637 | self.ServerName = uabin.Primitives.String.unpack(data) |
|
1638 | self.DiscoveryUrl = uabin.Primitives.String.unpack(data) |
|
1639 | obj.ServerCapabilities = uabin.Primitives.String.unpack_array(data) |
|
1640 | return obj |
|
1641 | ||
1642 | def __str__(self): |
|
1643 | return 'ServerOnNetwork(' + 'RecordId:' + str(self.RecordId) + ', ' + \ |
|
1644 | 'ServerName:' + str(self.ServerName) + ', ' + \ |
|
1645 | 'DiscoveryUrl:' + str(self.DiscoveryUrl) + ', ' + \ |
|
1646 | 'ServerCapabilities:' + str(self.ServerCapabilities) + ')' |
|
1647 | ||
1648 | __repr__ = __str__ |
|
1649 | ||
1650 | ||
1651 | class FindServersOnNetworkParameters(FrozenClass): |
|
1652 | ''' |
|
1653 | :ivar StartingRecordId: |
|
1654 | :vartype StartingRecordId: UInt32 |
|
1655 | :ivar MaxRecordsToReturn: |
|
1656 | :vartype MaxRecordsToReturn: UInt32 |
|
1657 | :ivar ServerCapabilityFilter: |
|
1658 | :vartype ServerCapabilityFilter: String |
|
1659 | ''' |
|
1660 | ||
1661 | ua_types = [ |
|
1662 | ('StartingRecordId', 'UInt32'), |
|
1663 | ('MaxRecordsToReturn', 'UInt32'), |
|
1664 | ('ServerCapabilityFilter', 'ListOfString'), |
|
1665 | ] |
|
1666 | ||
@@ 11338-11383 (lines=46) @@ | ||
11335 | for _ in range(0, length): |
|
11336 | array.append(StatusCode.from_binary(data)) |
|
11337 | obj.RemoveResults = array |
|
11338 | length = uabin.Primitives.Int32.unpack(data) |
|
11339 | array = [] |
|
11340 | if length != -1: |
|
11341 | for _ in range(0, length): |
|
11342 | array.append(DiagnosticInfo.from_binary(data)) |
|
11343 | obj.RemoveDiagnosticInfos = array |
|
11344 | return obj |
|
11345 | ||
11346 | def __str__(self): |
|
11347 | return 'SetTriggeringResult(' + 'AddResults:' + str(self.AddResults) + ', ' + \ |
|
11348 | 'AddDiagnosticInfos:' + str(self.AddDiagnosticInfos) + ', ' + \ |
|
11349 | 'RemoveResults:' + str(self.RemoveResults) + ', ' + \ |
|
11350 | 'RemoveDiagnosticInfos:' + str(self.RemoveDiagnosticInfos) + ')' |
|
11351 | ||
11352 | __repr__ = __str__ |
|
11353 | ||
11354 | ||
11355 | class SetTriggeringResponse(FrozenClass): |
|
11356 | ''' |
|
11357 | :ivar TypeId: |
|
11358 | :vartype TypeId: NodeId |
|
11359 | :ivar ResponseHeader: |
|
11360 | :vartype ResponseHeader: ResponseHeader |
|
11361 | :ivar Parameters: |
|
11362 | :vartype Parameters: SetTriggeringResult |
|
11363 | ''' |
|
11364 | ||
11365 | ua_types = [ |
|
11366 | ('TypeId', 'NodeId'), |
|
11367 | ('ResponseHeader', 'ResponseHeader'), |
|
11368 | ('Parameters', 'SetTriggeringResult'), |
|
11369 | ] |
|
11370 | ||
11371 | def __init__(self): |
|
11372 | self.TypeId = FourByteNodeId(ObjectIds.SetTriggeringResponse_Encoding_DefaultBinary) |
|
11373 | self.ResponseHeader = ResponseHeader() |
|
11374 | self.Parameters = SetTriggeringResult() |
|
11375 | self._freeze = True |
|
11376 | ||
11377 | def to_binary(self): |
|
11378 | packet = [] |
|
11379 | packet.append(self.TypeId.to_binary()) |
|
11380 | packet.append(self.ResponseHeader.to_binary()) |
|
11381 | packet.append(self.Parameters.to_binary()) |
|
11382 | return b''.join(packet) |
|
11383 | ||
11384 | @staticmethod |
|
11385 | def from_binary(data): |
|
11386 | obj = SetTriggeringResponse() |
|
@@ 1824-1869 (lines=46) @@ | ||
1821 | obj.ResponseHeader = ResponseHeader.from_binary(data) |
|
1822 | obj.Parameters = FindServersOnNetworkResult.from_binary(data) |
|
1823 | return obj |
|
1824 | ||
1825 | def __str__(self): |
|
1826 | return 'FindServersOnNetworkResponse(' + 'TypeId:' + str(self.TypeId) + ', ' + \ |
|
1827 | 'ResponseHeader:' + str(self.ResponseHeader) + ', ' + \ |
|
1828 | 'Parameters:' + str(self.Parameters) + ')' |
|
1829 | ||
1830 | __repr__ = __str__ |
|
1831 | ||
1832 | ||
1833 | class UserTokenPolicy(FrozenClass): |
|
1834 | ''' |
|
1835 | Describes a user token that can be used with a server. |
|
1836 | ||
1837 | :ivar PolicyId: |
|
1838 | :vartype PolicyId: String |
|
1839 | :ivar TokenType: |
|
1840 | :vartype TokenType: UserTokenType |
|
1841 | :ivar IssuedTokenType: |
|
1842 | :vartype IssuedTokenType: String |
|
1843 | :ivar IssuerEndpointUrl: |
|
1844 | :vartype IssuerEndpointUrl: String |
|
1845 | :ivar SecurityPolicyUri: |
|
1846 | :vartype SecurityPolicyUri: String |
|
1847 | ''' |
|
1848 | ||
1849 | ua_types = [ |
|
1850 | ('PolicyId', 'String'), |
|
1851 | ('TokenType', 'UserTokenType'), |
|
1852 | ('IssuedTokenType', 'String'), |
|
1853 | ('IssuerEndpointUrl', 'String'), |
|
1854 | ('SecurityPolicyUri', 'String'), |
|
1855 | ] |
|
1856 | ||
1857 | def __init__(self): |
|
1858 | self.PolicyId = None |
|
1859 | self.TokenType = UserTokenType(0) |
|
1860 | self.IssuedTokenType = None |
|
1861 | self.IssuerEndpointUrl = None |
|
1862 | self.SecurityPolicyUri = None |
|
1863 | self._freeze = True |
|
1864 | ||
1865 | def to_binary(self): |
|
1866 | packet = [] |
|
1867 | packet.append(uabin.Primitives.String.pack(self.PolicyId)) |
|
1868 | packet.append(uabin.Primitives.UInt32.pack(self.TokenType.value)) |
|
1869 | packet.append(uabin.Primitives.String.pack(self.IssuedTokenType)) |
|
1870 | packet.append(uabin.Primitives.String.pack(self.IssuerEndpointUrl)) |
|
1871 | packet.append(uabin.Primitives.String.pack(self.SecurityPolicyUri)) |
|
1872 | return b''.join(packet) |