Added debug logs

Author: Amele9

whatsapp_chatbot_python/manager/handler.py

@@ -1,3 +1,5 @@
+import json
+import logging
 from abc import ABC, abstractmethod
 from typing import Any, Callable, Dict, List, Optional, TYPE_CHECKING, Union
 
@@ -140,11 +142,26 @@ def execute_handler(self, observer: "Observer") -> bool:
             observer.event, observer.router.api, observer.state_manager
         )
 
+        filters = json.dumps(self.filters, ensure_ascii=False)
+
+        observer.router.logger.log(
+            logging.DEBUG, f"Checking event by filters: {filters}"
+        )
+
         response = self.check_event(notification)
         if response:
+            observer.router.logger.log(
+                logging.DEBUG, "Event matches filters. Handling event."
+            )
+
             self.handler(notification)
 
             return True
+
+        observer.router.logger.log(
+            logging.DEBUG, "Event does not match filters."
+        )
+
         return False
 
 

whatsapp_chatbot_python/manager/observer.py

@@ -1,3 +1,4 @@
+import logging
 from abc import ABC, abstractmethod
 from typing import Any, Callable, List, TYPE_CHECKING
 
@@ -39,10 +40,30 @@ def add_handler(self, handler: HandlerType, **filters: Any) -> None:
         self.handlers.append(Handler(handler, **filters))
 
     def propagate_event(self) -> None:
+        if not self.handlers:
+            self.router.logger.log(
+                logging.DEBUG, (
+                    "Skipping event because there are no subscribers."
+                )
+            )
+
+            return None
+
         for handler in self.handlers:
             response = handler.execute_handler(self)
             if response:
-                break
+                self.router.logger.log(
+                    logging.DEBUG, "Event has been successfully handled."
+                )
+
+                return None
+
+        self.router.logger.log(
+            logging.DEBUG, (
+                "Event has not been handled "
+                "because all handlers do not match filters."
+            )
+        )
 
     def __call__(self, **filters: Any) -> Callable[[HandlerType], HandlerType]:
         def wrapper(handler: HandlerType) -> HandlerType:

whatsapp_chatbot_python/manager/router.py

@@ -1,3 +1,4 @@
+import json
 import logging
 from typing import Dict, TYPE_CHECKING
 
@@ -31,6 +32,14 @@ def route_event(self, event: dict) -> None:
 
         observer = self.observers.get(type_webhook)
         if observer:
+            data = json.dumps(event, ensure_ascii=False, indent=4)
+
+            self.logger.log(
+                logging.DEBUG, (
+                    f"Routing {type_webhook} event with data: {data}"
+                )
+            )
+
             observer.update_event(event)