Spaces:
Runtime error
Runtime error
Commit ·
ad024aa
1
Parent(s): b8bc03f
refactor WebRTC and WebSocket services to remove user_id dependency from session management
Browse files
src/services/_web_rtc_service.py
CHANGED
|
@@ -24,7 +24,7 @@ class WebRTCService:
|
|
| 24 |
data = await websocket.receive_text()
|
| 25 |
message = json.loads(data)
|
| 26 |
|
| 27 |
-
# user_status = await redis_client.get(f"session:{
|
| 28 |
# if not user_status:
|
| 29 |
# logger.error("User session has ended")
|
| 30 |
# raise Exception("A max 25 minute session has ended")
|
|
|
|
| 24 |
data = await websocket.receive_text()
|
| 25 |
message = json.loads(data)
|
| 26 |
|
| 27 |
+
# user_status = await redis_client.get(f"session:{conversation_id}")
|
| 28 |
# if not user_status:
|
| 29 |
# logger.error("User session has ended")
|
| 30 |
# raise Exception("A max 25 minute session has ended")
|
src/services/_websocket_service.py
CHANGED
|
@@ -128,7 +128,7 @@ class WebSocketService:
|
|
| 128 |
user_message = json.loads(user_message)["user_message"]
|
| 129 |
|
| 130 |
user_status = await redis_client.get(
|
| 131 |
-
f"session:{
|
| 132 |
)
|
| 133 |
if not user_status:
|
| 134 |
raise Exception("A max 25 minute session has ended")
|
|
|
|
| 128 |
user_message = json.loads(user_message)["user_message"]
|
| 129 |
|
| 130 |
user_status = await redis_client.get(
|
| 131 |
+
f"session:{conversation_id}"
|
| 132 |
)
|
| 133 |
if not user_status:
|
| 134 |
raise Exception("A max 25 minute session has ended")
|