Fix issue with notes being unimplemented. Use background tasks for sc…

…heduling whatsapp response

- Need to use backgroundtasks because the webhook expects a response within a few seconds. If not delivered, it will keep resending until it's acked. This is problematic for queries taht take a longer response time. Hence, use bg tasks to schedule the work after returning a response to the API

src/flint/helpers.py

@@ -28,7 +28,7 @@
 }
 
 UNIMPLEMENTED_COMMANDS = {
-    "/notes": "/notes",
+    "/speak": "/speak",
 }
 
 

src/flint/routers/api.py

@@ -1,5 +1,4 @@
 # Standard Packages
-import asyncio
 import logging
 import os
 import requests
@@ -9,7 +8,7 @@
 from typing import Optional
 
 # External Packages
-from fastapi import APIRouter, status, Request
+from fastapi import APIRouter, status, Request, BackgroundTasks
 from fastapi.responses import Response
 from fastapi.params import Form
 from fastapi import Body
@@ -27,9 +26,6 @@
     KHOJ_FAILED_AUDIO_TRANSCRIPTION_MESSAGE,
 )
 
-# Keep Django module import here to avoid import ordering errors
-
-
 # Initialize Router
 api = APIRouter()
 logger = logging.getLogger(__name__)
@@ -84,9 +80,11 @@ async def whatsapp_chat(
 @api.post("/whatsapp_chat", status_code=status.HTTP_200_OK)
 async def whatsapp_chat_post(
     request: Request,
+    background_tasks: BackgroundTasks,
     body=Body(...),
 ):
-    asyncio.create_task(handle_message(body=body))
+    background_tasks.add_task(handle_message, body)
+    return
 
 
 def verified_body(body):