Errors fixed & Tests passed

Author: Saiyashwanth7

src/app/api/dependencies.py

@@ -34,7 +34,11 @@ async def get_current_user(
         user = await crud_users.get(db=db, username=token_data.username_or_email, is_deleted=False)
 
     if user:
-        return user
+        # Ensure consistent return type - always return dict
+        if hasattr(user, 'model_dump'):  # It's a Pydantic model
+            return user.model_dump()
+        else:  # It's already a dict
+            return user
 
     raise UnauthorizedException("User not authenticated.")
 

src/app/core/utils/cache.py

@@ -171,6 +171,9 @@ async def _delete_keys_by_pattern(pattern: str) -> None:
     - Be cautious with patterns that could match a large number of keys, as deleting
       many keys simultaneously may impact the performance of the Redis server.
     """
+    if client is None:
+        return
+    
     cursor = 0  # Make sure cursor starts at 0
     while True:
         cursor, keys = await client.scan(cursor, match=pattern, count=100)

tests/test_user.py

@@ -117,11 +117,14 @@ class TestPatchUser:
     async def test_patch_user_success(self, mock_db, current_user_dict, sample_user_read):
         """Test successful user update."""
         username = current_user_dict["username"]
-        sample_user_read.username = username  # Make sure usernames match
         user_update = UserUpdate(name="New Name")
+        
+        # Convert the UserRead model to a dictionary for the mock
+        user_dict = sample_user_read.model_dump()
+        user_dict["username"] = username
 
         with patch("src.app.api.v1.users.crud_users") as mock_crud:
-            mock_crud.get = AsyncMock(return_value=sample_user_read)
+            mock_crud.get = AsyncMock(return_value=user_dict)  # Return dict instead of UserRead
             mock_crud.exists = AsyncMock(return_value=False)  # No conflicts
             mock_crud.update = AsyncMock(return_value=None)
 
@@ -134,11 +137,13 @@ async def test_patch_user_success(self, mock_db, current_user_dict, sample_user_
     async def test_patch_user_forbidden(self, mock_db, current_user_dict, sample_user_read):
         """Test user update when user tries to update another user."""
         username = "different_user"
-        sample_user_read.username = username
         user_update = UserUpdate(name="New Name")
+        # Convert the UserRead model to a dictionary for the mock
+        user_dict = sample_user_read.model_dump()
+        user_dict["username"] = username
 
         with patch("src.app.api.v1.users.crud_users") as mock_crud:
-            mock_crud.get = AsyncMock(return_value=sample_user_read)
+            mock_crud.get = AsyncMock(return_value=user_dict)  # Return dict instead of UserRead
 
             with pytest.raises(ForbiddenException):
                 await patch_user(Mock(), user_update, username, current_user_dict, mock_db)