mish/evo-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 5 Wiki Activity

fix: parse Evotor install/uninstall event structure correctly

Browse Source 
userId is nested inside body.data, and event types are
ApplicationInstalled / ApplicationUninstalled (not install/uninstall).

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
mguschin
2026-05-24 16:53:34 +03:00
parent 052c3b610f
commit 74f613a4c3
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
web/routes/evotor_webhooks.py
View File

@@ -290,12 +290,13 @@ async def user_install(request: Request, db: Session = Depends(get_db)):
except Exception: except Exception:
return JSONResponse({"error": "Invalid JSON"}, status_code=400) return JSONResponse({"error": "Invalid JSON"}, status_code=400)
logger.info("user/install body=%s", body) # userId is nested inside "data"; type is e.g. "ApplicationInstalled" / "ApplicationUninstalled"
data: dict = body.get("data", {})
evotor_user_id: str = body.get("userId", "") evotor_user_id: str = data.get("userId", "") or body.get("userId", "")
event_type: str = body.get("type", "").lower() # "install" or "uninstall" event_type: str = body.get("type", "").lower() # "applicationinstalled" / "applicationuninstalled"
if not evotor_user_id: if not evotor_user_id:
logger.warning("user/install missing userId, body=%s", body)
return JSONResponse({"error": "userId required"}, status_code=400) return JSONResponse({"error": "userId required"}, status_code=400)
logger.info("user/install event type=%s userId=%s", event_type, evotor_user_id) logger.info("user/install event type=%s userId=%s", event_type, evotor_user_id)
@@ -307,7 +308,7 @@ async def user_install(request: Request, db: Session = Depends(get_db)):
now = datetime.now(timezone.utc).replace(tzinfo=None) now = datetime.now(timezone.utc).replace(tzinfo=None)
if event_type == "uninstall": if event_type == "applicationuninstalled":
user.status = UserStatusEnum.suspended user.status = UserStatusEnum.suspended
user.updated_at = now user.updated_at = now
conn = db.query(EvotorConnection).filter( conn = db.query(EvotorConnection).filter(
@@ -319,7 +320,7 @@ async def user_install(request: Request, db: Session = Depends(get_db)):
db.commit() db.commit()
logger.info("user suspended on uninstall: userId=%s", evotor_user_id) logger.info("user suspended on uninstall: userId=%s", evotor_user_id)
elif event_type == "install": elif event_type == "applicationinstalled":
if user.status == UserStatusEnum.suspended: if user.status == UserStatusEnum.suspended:
user.status = UserStatusEnum.active user.status = UserStatusEnum.active
user.updated_at = now user.updated_at = now