wooo another commit

main.py

@@ -163,9 +163,9 @@ async def user_session_management(request: Request, call_next):
     session = None
 
     # this if statement is not running OR session_id is never saved and found on mongodb
-    if session:
+    if session_id is not None:
         retrieved_session = collection.find_one({"_id": session_id})
-        print("FOUND SESSION:", session is not None)
+        print("FOUND SESSION:", session_id is not None)
         if retrieved_session:
             collection.update_one(
                 {"_id": session_id},
@@ -175,7 +175,7 @@ async def user_session_management(request: Request, call_next):
         #else:
         #    session_id = None
     
-    if session is None:
+    if session_id is None:
         try:
             session_id = str(uuid.uuid4())
             print("CREATING NEW SESSION:", session_id)
@@ -186,12 +186,12 @@ async def user_session_management(request: Request, call_next):
                 "messages": []
             }
             usr_doc = collection.insert_one(session)
-            #new_session = True
+            
 
         except Exception as e:
             print("An error occured when trying to generate a session id / create new session: ", e) 
     
-    request.state.session = session
+    request.state.session_id = session_id
     # forward request to actual endpoint and get the response
     response = await call_next(request)
 
@@ -233,14 +233,14 @@ async def chat_stream(req: ChatRequest, request: Request):
       data: <token>\n\n   — text to append
       data: [DONE]\n\n    — end of stream
     """
-    session = request.state.session
+    session_id = request.state.session_id
 
     async def token_generator():
         # Run the blocking pipeline call in a thread pool so FastAPI
         # stays non-blocking for other concurrent requests
         loop = asyncio.get_event_loop()
         full_reply = await loop.run_in_executor(
-            None, run_query, req.message, req.intent, session["_id"]
+            None, run_query, req.message, req.intent, session_id
         )
         # via mongodb api, insert the msgs and replies  into the docs
         # then in haystack_pipeline.py retrieve the docs and inject them into the prompt