Update app.py

app.py

@@ -297,6 +297,29 @@ async def admin_push(title: str = Body(...), body: str = Body(...)):
         send_push(token_entry["token"], title, body)
     return {"message": "Notifications sent"}
 
+@app.post("/api/app/parked")
+async def user_parked(requestBody: InAppEventNotification = Body(...)):
+    send_push(requestBody.token, "WhereIParked", "You parked your car. Timer started!", "app")
+    return {"message": "Notification sent"}
+
+
+@app.post("/api/app/clear-location")
+async def user_cleared(requestBody: InAppEventNotification = Body(...)):
+    send_push(requestBody.token, "WhereIParked", "Parking location cleared. Safe drive!", "app")
+    return {"message": "Notification sent"}
+
+@app.post("/api/app/park-duration")
+async def park_duration(requestBody: InAppEventNotification = Body(...), duration = str):
+    send_push(requestBody.token, "Reminder", "You’ve been parked for over " + duration + " minutes!", "app")
+    return {"message": "Notification sent"}
+
+@app.post("/admin/app/push")
+async def admin_push(title: str = Body(...), body: str = Body(...)):
+    tokens = await db.fcmtokens.find().to_list(length=None)
+    for token_entry in tokens:
+        send_push(token_entry["token"], title, body, "app")
+    return {"message": "Notifications sent"}
+
 
 
 @app.get("/", status_code=status.HTTP_200_OK)