[FIX] AMI events not send webhook

Author: shurshilov

const.py

@@ -1 +1 @@
-VERSION = "1.0.6"
+VERSION = "1.0.7"

requirements.txt

@@ -6,5 +6,7 @@ fastapi==0.111.0
 panoramisk==1.4
 pydantic==2.7.1
 pydantic_settings==2.2.1
+# for ami
+requests==2.32.3
 websockets==12.0
 # asterisk-ami==0.1.7

services/ami.py

@@ -4,7 +4,7 @@
 import logging
 import posixpath
 
-import httpx
+import requests
 from panoramisk import Manager
 
 from schemas.config_schema import AmiConfig
@@ -68,7 +68,7 @@ def on_connect(self, mngr):
     async def on_shutdown(self, mngr):
         log.info("AMI shutdown...")
 
-    async def send_webhook_event(self, manager, payload: dict):
+    def send_webhook_event(self, manager, payload: dict):
         """send asterisk ami event to customer webhook url
 
         Arguments:
@@ -77,14 +77,13 @@ async def send_webhook_event(self, manager, payload: dict):
         try:
             log.info("AMI event:")
             log.info(payload)
-            async with httpx.AsyncClient() as client:
-                res = await client.post(
-                    posixpath.join(self.webhook_url, "ami"),
-                    json=payload,
-                    headers={
-                        "Authorization": f"Basic {self.api_key_base64}",
-                    },
-                )
-                res.raise_for_status()
+            res = requests.post(
+                posixpath.join(self.webhook_url, "ami"),
+                json=dict(payload),
+                headers={
+                    "Authorization": f"Basic {self.api_key_base64}",
+                },
+            )
+            res.raise_for_status()
         except Exception as exc:
             log.exception("Unknown AMI send_webhook_event error: %s", exc)

services/websocket.py

@@ -47,7 +47,7 @@ def __init__(
         self.api_key_base64 = api_key_base64
 
         self.websocket_url = (
-            f"{websocket_url}?api_key={api_key}&app=AsteriskAgentPython&subscribeAll=true"
+            f"{websocket_url}?api_key={api_key}&app=AsteriskAgentPythonDev&subscribeAll=true"
         )
         self.webhook_url = webhook_url
         self.timeout = timeout