rename FastMqttError to FastMQTTError

fastmqtt/__init__.py

@@ -1,4 +1,4 @@
-from .exceptions import FastMqttError
+from .exceptions import FastMQTTError
 from .fastmqtt import FastMQTT
 from .router import MQTTRouter
 from .types import (
@@ -19,5 +19,5 @@
     "RetainHandling",
     "SubscribeOptions",
     "Subscription",
-    "FastMqttError",
+    "FastMQTTError",
 ]

fastmqtt/exceptions.py

@@ -1,2 +1,2 @@
-class FastMqttError(Exception):
+class FastMQTTError(Exception):
     pass

fastmqtt/message_handler.py

@@ -4,7 +4,7 @@
 
 from .connectors import BaseConnector
 from .encoders import BaseDecoder
-from .exceptions import FastMqttError
+from .exceptions import FastMQTTError
 from .properties import PublishProperties
 from .subscription_manager import Subscription, SubscriptionManager
 from .types import Message, Payload, RawMessage
@@ -59,7 +59,7 @@ async def _handle_result(self, result: Any, message: Message) -> None:
             return
 
         if message.properties.response_topic is None:
-            raise FastMqttError("Callback returned result, but message has no response_topic")
+            raise FastMQTTError("Callback returned result, but message has no response_topic")
 
         response_properties = None
         if message.properties.correlation_data is not None:

fastmqtt/response.py

@@ -3,7 +3,7 @@
 import logging
 from typing import TYPE_CHECKING, Any, Callable
 
-from .exceptions import FastMqttError
+from .exceptions import FastMQTTError
 from .properties import PublishProperties
 from .subscription_manager import SubscriptionWithId
 from .types import Message, RetainHandling
@@ -89,16 +89,16 @@ async def request(
     ) -> Message:
         correlation_data = self._correlation_generator()
         if correlation_data in self._futures:
-            raise FastMqttError(f"correlation_data {correlation_data} already in use")
+            raise FastMQTTError(f"correlation_data {correlation_data} already in use")
 
         if properties is None:
             properties = PublishProperties()
 
         if properties.correlation_data is not None:
-            raise FastMqttError("properties.correlation_data is not allowed in request")
+            raise FastMQTTError("properties.correlation_data is not allowed in request")
 
         if properties.response_topic is not None:
-            raise FastMqttError("properties.response_topic is not allowed in request")
+            raise FastMQTTError("properties.response_topic is not allowed in request")
 
         properties.correlation_data = correlation_data
         properties.response_topic = self._response_topic

fastmqtt/router.py

@@ -1,7 +1,7 @@
 import logging
 from typing import Any, Callable
 
-from .exceptions import FastMqttError
+from .exceptions import FastMQTTError
 from .types import CallbackType, RetainHandling, SubscribeOptions, Subscription
 
 log = logging.getLogger(__name__)
@@ -29,11 +29,11 @@ def merge_subscribe_options(
     options_exist.qos = max(options_exist.qos, options_new.qos)
 
     if options_exist.no_local != options_new.no_local:
-        raise FastMqttError("Different no_local options")
+        raise FastMQTTError("Different no_local options")
     if options_exist.retain_as_published != options_new.retain_as_published:
-        raise FastMqttError("Different retain_as_published options")
+        raise FastMQTTError("Different retain_as_published options")
     if options_exist.retain_handling != options_new.retain_handling:
-        raise FastMqttError("Different retain_handling options")
+        raise FastMQTTError("Different retain_handling options")
 
 
 class MQTTRouter:
@@ -88,7 +88,7 @@ def register(
         retain_handling: RetainHandling | None = None,
     ) -> Subscription:
         if self._included:
-            raise FastMqttError(
+            raise FastMQTTError(
                 "Cannot register new subscriptions after router is included, "
                 "use fastmqtt.subscribe instead"
             )

fastmqtt/subscription_manager.py

@@ -1,7 +1,7 @@
 import asyncio
 
 from .connectors import BaseConnector
-from .exceptions import FastMqttError
+from .exceptions import FastMQTTError
 from .properties import SubscribeProperties
 from .types import CallbackType, Subscription, SubscriptionWithId
 
@@ -70,7 +70,7 @@ async def subscribe_multiple(
         self, subscriptions: list[Subscription]
     ) -> list[SubscriptionWithId]:
         if self._id_manager.get_available_count() < len(subscriptions):
-            raise FastMqttError("Not enough subscription identifiers available")
+            raise FastMQTTError("Not enough subscription identifiers available")
 
         await asyncio.sleep(0.1)
         return await asyncio.gather(
@@ -98,7 +98,7 @@ async def unsubscribe(
             )
 
         if subscription is None:
-            raise FastMqttError("Subscription not found")
+            raise FastMQTTError("Subscription not found")
 
         if callback is not None:
             subscription.callbacks.remove(callback)