migration

Author: pcrespov

packages/postgres-database/src/simcore_postgres_database/migration/versions/8403acca8759_new_users_privacy_hide_username_column.py

@@ -0,0 +1,36 @@
+"""new users.privacy_hide_username column
+
+Revision ID: 8403acca8759
+Revises: f7f3c835f38a
+Create Date: 2025-03-20 14:08:48.321587+00:00
+
+"""
+
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "8403acca8759"
+down_revision = "f7f3c835f38a"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.add_column(
+        "users",
+        sa.Column(
+            "privacy_hide_username",
+            sa.Boolean(),
+            server_default=sa.text("false"),
+            nullable=False,
+        ),
+    )
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_column("users", "privacy_hide_username")
+    # ### end Alembic commands ###

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

@@ -154,7 +154,10 @@ async def get_user_or_raise(
 
 
 async def get_user_primary_group_id(
-    engine: AsyncEngine, connection: AsyncConnection | None = None, *, user_id: UserID
+    engine: AsyncEngine,
+    connection: AsyncConnection | None = None,
+    *,
+    user_id: UserID,
 ) -> GroupID:
     async with pass_or_acquire_connection(engine, connection) as conn:
         primary_gid: GroupID | None = await conn.scalar(
@@ -182,7 +185,7 @@ async def get_users_ids_in_group(
         return {row.uid async for row in result}
 
 
-async def get_user_id_from_pgid(app: web.Application, primary_gid: int) -> UserID:
+async def get_user_id_from_pgid(app: web.Application, *, primary_gid: int) -> UserID:
     async with pass_or_acquire_connection(engine=get_asyncpg_engine(app)) as conn:
         user_id: UserID = await conn.scalar(
             sa.select(

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

@@ -122,7 +122,7 @@ async def get_user_primary_group_id(app: web.Application, user_id: UserID) -> Gr
 
 
 async def get_user_id_from_gid(app: web.Application, primary_gid: GroupID) -> UserID:
-    return await _users_repository.get_user_id_from_pgid(app, primary_gid)
+    return await _users_repository.get_user_id_from_pgid(app, primary_gid=primary_gid)
 
 
 async def search_users(