Redis + Websocket

app.py

@@ -156,11 +156,11 @@ async def vote_by_voter(vote_request: VoteRequest):
         raise HTTPException(status_code=500, detail=str(e))
 
 @app.get("/get-voter")
-async def get_voter(voter_id: str):
+async def get_voter(id: str):
     try:
         # Check cache
         try:
-            cached_voter = redis_client.get(f'voter:{voter_id}')
+            cached_voter = redis_client.get(f'voter:{id}')
             if cached_voter:
                 return json.loads(cached_voter)
         except RedisError as redis_err:
@@ -168,7 +168,7 @@ async def get_voter(voter_id: str):
             # Continue without cache if Redis fails
             pass
 
-        voter = voter_collection.find_one({'_id': ObjectId(voter_id)})
+        voter = voter_collection.find_one({'_id': ObjectId(id)})
         if not voter:
             raise HTTPException(status_code=404, detail="Voter not found")
         
@@ -182,7 +182,7 @@ async def get_voter(voter_id: str):
         
         # Try to save to cache
         try:
-            redis_client.setex(f'voter:{voter_id}', CACHE_EXPIRE_TIME, json.dumps(voter_data))
+            redis_client.setex(f'voter:{id}', CACHE_EXPIRE_TIME, json.dumps(voter_data))
         except RedisError as redis_err:
             print(f"Redis caching error: {redis_err}")
             # Continue even if caching fails
@@ -190,6 +190,7 @@ async def get_voter(voter_id: str):
 
         return voter_data
     except Exception as e:
+        print(f"Error in get_voter: {str(e)}")
         raise HTTPException(status_code=500, detail=str(e))
 
 @socket_manager.on('connect')