increment neon_mq_connector to 0.7.2a7 (#112)

* Incremented neon mq connector dependency and small fix on client * Improved expired session verification by introducing a separate exception for invalid token
NeonGeckoCom · Dec 5, 2024 · 83bf100 · 83bf100
1 parent c358195
commit 83bf100
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 7 deletions.
diff --git a/chat_client/static/js/http_utils.js b/chat_client/static/js/http_utils.js
@@ -36,7 +36,7 @@ const fetchServer = async (urlSuffix, method=REQUEST_METHODS.GET, body=null, jso
     return fetch(`${configData["CHAT_SERVER_URL_BASE"]}/${urlSuffix}`, options).then(async response => {
         if (response.status === 401){
             const responseJson = await response.json();
-            if (responseJson['msg'] === 'Requested user is not authorized to perform this action'){
+            if (responseJson['msg'] === 'Session token is invalid or expired'){
                 localStorage.removeItem('session');
                 location.reload();
             }

diff --git a/chat_server/server_utils/auth.py b/chat_server/server_utils/auth.py
@@ -34,7 +34,10 @@
 from fastapi import Request
 
 from chat_server.server_utils.enums import UserRoles
-from chat_server.server_utils.http_exceptions import UserUnauthorizedException
+from chat_server.server_utils.http_exceptions import (
+    UserUnauthorizedException,
+    InvalidSessionTokenException,
+)
 from utils.database_utils.mongo_utils import MongoFilter, MongoLogicalOperators
 from utils.database_utils.mongo_utils.queries.wrapper import MongoDocumentsAPI
 from utils.logging_utils import LOG
@@ -269,6 +272,6 @@ def validate_session(
             return "OK", 200
         else:
             LOG.warning("Session expired")
-            raise UserUnauthorizedException()
+            raise InvalidSessionTokenException()
     LOG.warning("Session header missing")
-    raise UserUnauthorizedException()
+    raise InvalidSessionTokenException()
diff --git a/chat_server/server_utils/http_exceptions.py b/chat_server/server_utils/http_exceptions.py
@@ -45,10 +45,15 @@ def to_http_response(self):
 
 
 class UserUnauthorizedException(KlatAPIException):
-    HTTP_CODE = http.HTTPStatus.FORBIDDEN
+    HTTP_CODE = http.HTTPStatus.UNAUTHORIZED
     MESSAGE = "Requested user is not authorized to perform this action"
 
 
+class InvalidSessionTokenException(KlatAPIException):
+    HTTP_CODE = http.HTTPStatus.UNAUTHORIZED
+    MESSAGE = "Session token is invalid or expired"
+
+
 class ItemNotFoundException(KlatAPIException):
     HTTP_CODE = http.HTTPStatus.NOT_FOUND
     MESSAGE = "Requested item not found"

diff --git a/requirements/requirements.txt b/requirements/requirements.txt
@@ -7,7 +7,7 @@ httpx==0.27.0  # required by FastAPI
 Jinja2==3.1.3
 jsbeautifier==1.15.1
 kubernetes==29.0.0
-neon-mq-connector==0.7.2a5
+neon-mq-connector==0.7.2a7
 neon-sftp~=0.1
 neon_utils[sentry]==1.11.1a5
 pre-commit==3.7.0

diff --git a/requirements/services/observer.txt b/requirements/services/observer.txt
@@ -1,3 +1,3 @@
-neon-mq-connector==0.7.2a5
+neon-mq-connector==0.7.2a7
 websocket-client==1.7.0
 websockets==12.0