feat: Webhook listener

onany/__init__.py

@@ -1,26 +1,37 @@
 from threading import Thread
-from onany.manager import OnAny
+from typing import Any, Dict, Union
+from onany.manager import EventManager
+from onany.web import webhook_callback
+
+
+def clear_listeners():
+    EventManager.clear()
 
 
 def dispatch(event: str, *args, **kwargs) -> None:
-    return OnAny.emit(event, *args, **kwargs)
+    return EventManager.emit(event, *args, **kwargs)
 
 
 def disthread(event: str, *args, **kwargs) -> Thread:
     thread: Thread = Thread(
-        target=OnAny.emit,
+        target=EventManager.emit,
         args=(event, *args,),
         kwargs=kwargs)
     thread.start()
 
     return thread
 
 
-def listener(event: str, callback: callable = None) -> callable:
-    if callback:
-        return OnAny.listen(event, callback)
+def listener(event: str, callback: Union[callable, Dict[str, Any]] = None) -> callable:
+    if callable(callback):
+        return EventManager.listen(event, callback)
+
+    if callback and isinstance(callback, dict):
+        return EventManager.listen(
+            event, 
+            webhook_callback(callback))
 
     def wrapper(callback: callable) -> None:
-        return OnAny.listen(event, callback)
+        return EventManager.listen(event, callback)
 
     return wrapper

onany/manager.py

@@ -1,9 +1,13 @@
 from typing import Dict, List
 
 
-class OnAny:
+class EventManager:
     _events_pool: Dict[str, List[callable]] = {}
 
+    @classmethod
+    def clear(cls):
+        cls._events_pool = {}
+
     @classmethod
     def listen(cls, event: str, callback: callable):
         cls._register_event(event)

onany/web.py

@@ -0,0 +1,15 @@
+from typing import Any, Dict
+import requests
+
+
+def webhook_callback(rules: Dict[str, Any]) -> callable:
+    def wrapper(*args, **kwargs):
+        response = requests.post(
+            rules.get("route"),
+            json=kwargs.get("data"),
+            headers=kwargs.get("headers"))
+
+        if rules.get("callback"):
+            rules.get("callback")(response)
+
+    return wrapper

requirements.txt

@@ -0,0 +1 @@
+requests==2.23.0

tests/test_onany.py

@@ -1,11 +1,14 @@
 from typing import Any, Dict
 from unittest import TestCase
 from tests.generators import sprint, get_last_sprint
-from onany import dispatch, disthread, listener
+from onany import clear_listeners, dispatch, disthread, listener
 
 
 class TestOnAny(TestCase):
 
+    def setUp(self):
+        clear_listeners()
+
     def test_dispatch_listen(self):
         callback = self.get_listener()
         params = {
@@ -26,6 +29,19 @@ def test_dispatch_listen_registering_simple_callback(self):
 
         self.assertEqual(get_last_sprint(), "Hello Clark Kent. Welcome to OnAny!")
 
+    def test_dispatch_listen_webhook_callback(self):
+        listener("event.name", {
+            "route": "http://demo2158329.mockable.io/callback",
+            "callback": lambda response: 
+                sprint("API Answered with {}".format(response.status_code))
+        })
+
+        dispatch("event.name", data={
+            "name": "Bruce Wayne"
+        })
+
+        self.assertEqual(get_last_sprint(), "API Answered with 200")
+
     def test_thread_dispatch_listen(self):
         callback = self.get_listener()
         params = {