auth-connector-fix

services/auth.py

@@ -1,40 +1,63 @@
 from functools import wraps
 import aiohttp
 from aiohttp.web import HTTPUnauthorized
+
+from resolvers import get_author_id
 from settings import AUTH_URL
 
 
-async def check_auth(req):
+async def check_auth(req) -> (int | None, bool):
     token = req.headers.get("Authorization")
     if token:
+        # Logging the authentication token
         print(f"[services.auth] checking auth token: {token}")
-
+        query_name = "validate_jwt_token"
-        gql = {
+        headers = {
-            "query": "query ValidateToken($params: ValidateJWTTokenInput!) { validate_jwt_token( params: $params) { is_valid claims } }",
+            "Content-Type": "application/json",
-            "variables": {"params": {"token_type": "access_token", "token": token}},
         }
 
-        async with aiohttp.ClientSession(timeout=aiohttp.ClientTimeout(total=30.0)) as session:
+        variables = {
-            async with session.post(AUTH_URL, json=gql) as response:
+            "params": {
-                response_text = await response.text()
+                "token_type": "access_token",
-                print(f"[services.auth] response text: {response_text}")
+                "token": token,
+            }
+        }
+
+        gql = {
+            "query": f"query ValidateToken($params: ValidateJWTTokenInput!) {{ {query_name}(params: $params) {{ is_valid claims }} }}",
+            "variables": variables,
+        }
+
+        try:
+            # Asynchronous HTTP request to the authentication server
+            async with aiohttp.ClientSession() as session:
+                async with session.post(AUTH_URL, json=gql, headers=headers) as response:
+                    # Logging the GraphQL response
+                    response_text = await response.text()
+                    print(f"GraphQL Response: {response_text}")
+
+                    if response.status == 200:
+                        # Parsing JSON response
+                        data = await response.json()
+                        user_id = data.get("data", {}).get(query_name, {}).get("claims", {}).get("sub")
+
+                        if user_id:
+                            # Logging the retrieved user ID
+                            print(f"User ID retrieved: {user_id}")
+                            # Fetching author information
+                            author = get_author_id(None, None, user_id)
+                            return author.id, True
+                        else:
+                            # Logging when no user ID is found in the response
+                            print("No user ID found in the response")
+                    else:
+                        # Logging when the request to the authentication server fails
+                        print(f"Request failed with status: {response.status}")
+
+        except Exception as e:
+            # Handling and logging exceptions during authentication check
+            print(f"Exception during authentication check: {e}")
 
-                if response.status != 200:
-                    return False, None
-                r = await response.json()
-                print(f"[services.auth] response: {r}")
-                try:
-                    data = r.get("data")
-                    is_authenticated = False
-                    user_id = None
-                    if data:
-                        result = data.get("validate_jwt_token", {})
-                        is_authenticated = result.get("is_valid")
-                        if is_authenticated:
-                            user_id = result.get("claims", {}).get("sub")
-                    return is_authenticated, user_id
-                except Exception as e:
-                    print(f"{e}: {r}")
     return False, None
 
 
@@ -45,12 +68,14 @@ def login_required(f):
         context = info.context
         print(context)
         req = context.get("request")
-        is_authenticated, user_id = await check_auth(req)
+        # Performing authentication check
+        is_authenticated, author_id = await check_auth(req)
         if not is_authenticated:
-            raise Exception("You are not logged in")
+            # Raising an exception if the user is not authenticated
+            raise HTTPUnauthorized(text="Please, login first")
         else:
-            # Add user_id to the context
+            # Adding user_id to the context
-            context["user_id"] = user_id
+            context["author_id"] = author_id
 
         # If the user is authenticated, execute the resolver
         return await f(*args, **kwargs)
@@ -62,11 +87,14 @@ def auth_request(f):
     @wraps(f)
     async def decorated_function(*args, **kwargs):
         req = args[0]
-        is_authenticated, user_id = await check_auth(req)
+        # Performing authentication check
+        is_authenticated, author_id = await check_auth(req)
         if not is_authenticated:
+            # Raising HTTPUnauthorized exception if the user is not authenticated
             raise HTTPUnauthorized(text="Please, login first")
         else:
-            req["user_id"] = user_id
+            # Modifying the req with the author_id
+            req["author_id"] = author_id
         return await f(*args, **kwargs)
 
     return decorated_function