Transforms the Matrix and OpenAI interactor into indepandent services, fikes #2 #3
@@ -90,12 +90,12 @@ async def main() -> None:
|
|||||||
resp = await http.post(f"{AI_HANDLER_URL}/api/v1/message", json=payload, headers=headers)
|
resp = await http.post(f"{AI_HANDLER_URL}/api/v1/message", json=payload, headers=headers)
|
||||||
resp.raise_for_status()
|
resp.raise_for_status()
|
||||||
data = resp.json()
|
data = resp.json()
|
||||||
|
if data.get("reply"):
|
||||||
|
client.send_message(event["room_id"], data["reply"])
|
||||||
except httpx.HTTPStatusError as e:
|
except httpx.HTTPStatusError as e:
|
||||||
logger.error(f"HTTP error: {e.response.status_code} - {e.response.text}")
|
logger.error(f"HTTP error: {e.response.status_code} - {e.response.text}")
|
||||||
except Exception:
|
except Exception:
|
||||||
logger.exception("Error while calling AI handler")
|
logger.exception("Error while calling AI handler")
|
||||||
if data.get("reply"):
|
|
||||||
client.send_message(event["room_id"], data["reply"])
|
|
||||||
|
|
||||||
# --- Initialize the client ---
|
# --- Initialize the client ---
|
||||||
# Create the data directory if it doesn't exist
|
# Create the data directory if it doesn't exist
|
||||||
|
|||||||
Reference in New Issue
Block a user