feat: add notify_admin

Author: MistEO

.env.sample

@@ -4,4 +4,6 @@ DATABASE_PORT=3306
 DATABASE_USER=""
 DATABASE_PASSWD=""
 
+NOTIFY_ADMIN_URL=""
+
 STATIC_APP_DIR="/app/static"

src/config/__init__.py

@@ -10,6 +10,8 @@ class Settings(BaseSettings):
 
     static_app_dir: str
 
+    notify_admin_url: str
+
     class Config:
         env_file = ".env"
 

src/notify_admin/__init__.py

@@ -0,0 +1,21 @@
+from fastapi import Request, APIRouter
+from aiohttp import ClientSession
+from loguru import logger
+
+from src.config import settings
+
+router = APIRouter()
+
+@router.post("/notify_admin")
+async def notify_admin(request: Request):
+    body = await request.json()
+    logger.info(str(body))
+
+    try:
+        async with ClientSession() as session:
+            async with session.post(
+                settings.notify_admin_url, json=body
+            ) as response:
+                pass
+    except Exception as e:
+        logger.error(f"notify_admin error: {e}, body: f{body}")