Update app.py

app.py

@@ -286,48 +286,48 @@ async def save_token(token_model: TokenModel):
 
 @app.post("/api/parked")
 async def user_parked(requestBody: InAppEventNotification = Body(...)):
-    send_push(requestBody.token, "WhereIParked", "You parked your car. Timer started!")
+    await send_push(requestBody.token, "WhereIParked", "You parked your car. Timer started!")
     return {"message": "Notification sent"}
 
 
 @app.post("/api/clear-location")
 async def user_cleared(requestBody: InAppEventNotification = Body(...)):
-    send_push(requestBody.token, "WhereIParked", "Parking location cleared. Safe drive!")
+    await send_push(requestBody.token, "WhereIParked", "Parking location cleared. Safe drive!")
     return {"message": "Notification sent"}
 
 @app.post("/api/park-duration")
 async def park_duration(requestBody: InAppEventNotification = Body(...), duration = str):
-    send_push(requestBody.token, "Reminder", "You’ve been parked for over " + duration + " minutes!")
+    await send_push(requestBody.token, "Reminder", "You’ve been parked for over " + duration + " minutes!")
     return {"message": "Notification sent"}
 
 @app.post("/admin/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)
+        await send_push(token_entry["token"], title, body)
     return {"message": "Notifications sent"}
 
 @app.post("/api/app/parked")
 async def app_user_parked(requestBody: InAppEventNotification = Body(...)):
-    send_push(requestBody.token, "WhereIParked", "You parked your car. Timer started!", "app")
+    await send_push(requestBody.token, "WhereIParked", "You parked your car. Timer started!", "app")
     return {"message": "Notification sent"}
 
 
 @app.post("/api/app/clear-location")
 async def app_user_cleared(requestBody: InAppEventNotification = Body(...)):
-    send_push(requestBody.token, "WhereIParked", "Parking location cleared. Safe drive!", "app")
+    await send_push(requestBody.token, "WhereIParked", "Parking location cleared. Safe drive!", "app")
     return {"message": "Notification sent"}
 
 @app.post("/api/app/park-duration")
 async def app_park_duration(requestBody: InAppEventNotification = Body(...), duration = str):
-    send_push(requestBody.token, "Reminder", "You’ve been parked for over " + duration + " minutes!", "app")
+    await 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 app_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")
+        await send_push(token_entry["token"], title, body, "app")
     return {"message": "Notifications sent"}