user service

Author: pcrespov

services/web/server/src/simcore_service_webserver/users/_users_repository.py

@@ -5,6 +5,7 @@
 from aiohttp import web
 from common_library.users_enums import UserRole
 from models_library.groups import GroupID
+from models_library.products import ProductName
 from models_library.users import (
     MyProfile,
     UserBillingDetails,
@@ -461,6 +462,28 @@ async def delete_user_by_id(
         return bool(deleted_user)
 
 
+async def is_user_in_product_name(
+    engine: AsyncEngine,
+    connection: AsyncConnection | None = None,
+    *,
+    user_id: UserID,
+    product_name: ProductName,
+) -> bool:
+    query = (
+        sa.select(users.c.id)
+        .select_from(
+            users.join(
+                user_to_groups,
+                user_to_groups.c.uid == users.c.id,
+            ).join(products, products.c.group_id == user_to_groups.c.gid)
+        )
+        .where((users.c.id == user_id) & (products.c.name == product_name))
+    )
+    async with pass_or_acquire_connection(engine, connection) as conn:
+        got_user_id = await conn.scalar(query)
+        return got_user_id == user_id
+
+
 #
 # USER PROFILE
 #

services/web/server/src/simcore_service_webserver/users/_users_service.py

@@ -180,6 +180,14 @@ async def get_users_in_group(app: web.Application, *, gid: GroupID) -> set[UserI
 get_guest_user_ids_and_names = _users_repository.get_guest_user_ids_and_names
 
 
+async def is_user_in_product(
+    app: web.Application, *, user_id: UserID, product_name: ProductName
+) -> bool:
+    return await _users_repository.is_user_in_product_name(
+        get_asyncpg_engine(app), user_id=user_id, product_name=product_name
+    )
+
+
 #
 # GET USER PROPERTIES
 #

services/web/server/src/simcore_service_webserver/users/api.py

@@ -14,13 +14,17 @@
     get_user_primary_group_id,
     get_user_role,
     get_users_in_group,
+    is_user_in_product,
     set_user_as_deleted,
     update_expired_users,
 )
 
 __all__: tuple[str, ...] = (
+    "FullNameDict",
+    "UserDisplayAndIdNamesTuple",
     "delete_user_without_projects",
     "get_guest_user_ids_and_names",
+    "get_user",
     "get_user_credentials",
     "get_user_display_and_id_names",
     "get_user_fullname",
@@ -29,11 +33,9 @@
     "get_user_name_and_email",
     "get_user_primary_group_id",
     "get_user_role",
-    "get_user",
     "get_users_in_group",
+    "is_user_in_product",
     "set_user_as_deleted",
     "update_expired_users",
-    "FullNameDict",
-    "UserDisplayAndIdNamesTuple",
 )
 # nopycln: file