Coverage for zenmqtt/__init__.py: 100%

1""" 

2Asyncio MQTT 5 client. 

3 

4 from zenmqtt import MQTTClient 

5 

6 client = MQTTClient("client-id") 

7 await client.connect("tcp://localhost:1883") 

8""" 

9 

10from importlib.metadata import PackageNotFoundError, version 

11 

12from zenmqtt.client import MQTTClient 

13from zenmqtt.exceptions import ( 

14 ClientConnectionError, 

15 ConnectionLostError, 

16 FeatureNotSupportedError, 

17 IncomingPacketTooLargeError, 

18 MalformedPacketError, 

19 MQTTError, 

20 NotConnectedError, 

21 OutgoingPacketTooLargeError, 

22 ProtocolError, 

23 QoSNotSupportedError, 

24 ReceiveMaximumExceededError, 

25 ServerLimitError, 

26 SessionLostError, 

27 TopicAliasInvalidError, 

28) 

29from zenmqtt.instrumentation.metrics import MetricsCollector 

30from zenmqtt.mqtt.connect import ( 

31 ConnectionResult, 

32 ConnectProperties, 

33 DisconnectProperties, 

34 ServerDisconnect, 

35 WillMessage, 

36 WillProperties, 

37) 

38from zenmqtt.mqtt.publish import ( 

39 MQTTMessage, 

40 PubAckResult, 

41 PubCompResult, 

42 PublishAcknowledgement, 

43 PublishProperties, 

44 PubRecResult, 

45 QoS, 

46) 

47from zenmqtt.mqtt.reason_codes import ReasonCode 

48from zenmqtt.mqtt.subscribe import ( 

49 SubscribeResult, 

50 Subscription, 

51 SubscriptionProperties, 

52 SubscriptionRequest, 

53 UnsubscribeProperties, 

54 UnsubscribeResult, 

55) 

56from zenmqtt.reconnect import ReconnectPolicy 

57from zenmqtt.session import ( 

58 BaseSession, 

59 InMemorySession, 

60 MQTTSession, 

61 OutgoingMessage, 

62 OutgoingMessageState, 

63 PacketIdentifier, 

64 SessionOptions, 

65) 

66 

67try: 

68 __version__ = version("zenmqtt") 

69except PackageNotFoundError: # pragma: no cover - running from sources 

70 __version__ = "0+unknown" 

71 

72__all__ = [ 

73 "BaseSession", 

74 "ClientConnectionError", 

75 "ConnectionLostError", 

76 "ConnectionResult", 

77 "ConnectProperties", 

78 "DisconnectProperties", 

79 "FeatureNotSupportedError", 

80 "IncomingPacketTooLargeError", 

81 "InMemorySession", 

82 "MalformedPacketError", 

83 "MetricsCollector", 

84 "MQTTClient", 

85 "MQTTError", 

86 "MQTTMessage", 

87 "MQTTSession", 

88 "NotConnectedError", 

89 "OutgoingMessage", 

90 "OutgoingMessageState", 

91 "OutgoingPacketTooLargeError", 

92 "PacketIdentifier", 

93 "ProtocolError", 

94 "PubAckResult", 

95 "PubCompResult", 

96 "PublishAcknowledgement", 

97 "PublishProperties", 

98 "PubRecResult", 

99 "QoS", 

100 "QoSNotSupportedError", 

101 "ReasonCode", 

102 "ReceiveMaximumExceededError", 

103 "ReconnectPolicy", 

104 "ServerDisconnect", 

105 "ServerLimitError", 

106 "SessionLostError", 

107 "SessionOptions", 

108 "SubscribeResult", 

109 "Subscription", 

110 "SubscriptionProperties", 

111 "SubscriptionRequest", 

112 "TopicAliasInvalidError", 

113 "UnsubscribeProperties", 

114 "UnsubscribeResult", 

115 "WillMessage", 

116 "WillProperties", 

117 "__version__", 

118]