Skip to content

Commit b020206

Browse files
committed
@sanderegg review:drop organization and renames
1 parent 92e68b2 commit b020206

File tree

6 files changed

+26
-22
lines changed

6 files changed

+26
-22
lines changed

packages/pytest-simcore/src/pytest_simcore/simcore_webserver_groups_fixtures.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@
2121
from pytest_simcore.helpers.webserver_login import NewUser, UserInfoDict
2222
from simcore_service_webserver.groups._groups_api import (
2323
add_user_in_group,
24-
create_organization,
25-
delete_organization,
24+
create_standard_group,
25+
delete_group,
2626
list_user_groups_with_read_access,
2727
)
2828

@@ -34,7 +34,7 @@ def _groupget_model_dump(group, access_rights) -> dict[str, Any]:
3434
async def _create_organization(
3535
app: web.Application, user_id: UserID, new_group: dict
3636
) -> dict[str, Any]:
37-
group, access_rights = await create_organization(
37+
group, access_rights = await create_standard_group(
3838
app,
3939
user_id=user_id,
4040
create=OrganizationCreate.model_validate(new_group),
@@ -107,10 +107,10 @@ async def standard_groups_owner(
107107
yield owner_user
108108

109109
# clean groups
110-
await delete_organization(
110+
await delete_group(
111111
client.app, user_id=owner_user["id"], group_id=sparc_group["gid"]
112112
)
113-
await delete_organization(
113+
await delete_group(
114114
client.app, user_id=owner_user["id"], group_id=team_black_group["gid"]
115115
)
116116

services/web/server/src/simcore_service_webserver/groups/_groups_api.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ async def get_product_group_for_user(
9191
#
9292

9393

94-
async def create_organization(
94+
async def create_standard_group(
9595
app: web.Application,
9696
*,
9797
user_id: UserID,
@@ -101,7 +101,7 @@ async def create_organization(
101101
raises GroupNotFoundError
102102
raises UserInsufficientRightsError
103103
"""
104-
return await _groups_db.create_user_group(
104+
return await _groups_db.create_standard_group(
105105
app,
106106
user_id=user_id,
107107
create=create,
@@ -123,7 +123,7 @@ async def get_organization(
123123
return await _groups_db.get_user_group(app, user_id=user_id, group_9d=group_id)
124124

125125

126-
async def update_organization(
126+
async def update_group(
127127
app: web.Application,
128128
*,
129129
user_id: UserID,
@@ -144,7 +144,7 @@ async def update_organization(
144144
)
145145

146146

147-
async def delete_organization(
147+
async def delete_group(
148148
app: web.Application, *, user_id: UserID, group_id: GroupID
149149
) -> None:
150150
"""

services/web/server/src/simcore_service_webserver/groups/_groups_db.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
)
1616
from models_library.users import GroupID, UserID
1717
from simcore_postgres_database.errors import UniqueViolation
18+
from simcore_postgres_database.models.groups import GroupType
1819
from simcore_postgres_database.utils_products import execute_get_or_create_product_group
1920
from simcore_postgres_database.utils_repos import (
2021
pass_or_acquire_connection,
@@ -247,7 +248,7 @@ async def get_product_group_for_user(
247248
assert set(OrganizationCreate.model_fields).issubset({c.name for c in groups.columns})
248249

249250

250-
async def create_user_group(
251+
async def create_standard_group(
251252
app: web.Application,
252253
connection: AsyncConnection | None = None,
253254
*,
@@ -265,7 +266,10 @@ async def create_user_group(
265266
result = await conn.stream(
266267
# pylint: disable=no-value-for-parameter
267268
groups.insert()
268-
.values(**create.model_dump(mode="json", exclude_unset=True))
269+
.values(
270+
**create.model_dump(mode="json", exclude_unset=True),
271+
type=GroupType.STANDARD,
272+
)
269273
.returning(*_GROUP_COLUMNS)
270274
)
271275
row = await result.fetchone()

services/web/server/src/simcore_service_webserver/groups/_groups_handlers.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -102,12 +102,12 @@ async def get_group(request: web.Request):
102102
@permission_required("groups.*")
103103
@handle_plugin_requests_exceptions
104104
async def create_group(request: web.Request):
105-
"""Creates organization groups"""
105+
"""Creates standard groups"""
106106
req_ctx = GroupsRequestContext.model_validate(request)
107107

108108
create = await parse_request_body_as(GroupCreate, request)
109109

110-
group, access_rights = await _groups_api.create_organization(
110+
group, access_rights = await _groups_api.create_standard_group(
111111
request.app,
112112
user_id=req_ctx.user_id,
113113
create=create.to_model(),
@@ -122,12 +122,12 @@ async def create_group(request: web.Request):
122122
@permission_required("groups.*")
123123
@handle_plugin_requests_exceptions
124124
async def update_group(request: web.Request):
125-
"""Updates organization groups"""
125+
"""Updates groups metadata"""
126126
req_ctx = GroupsRequestContext.model_validate(request)
127127
path_params = parse_request_path_parameters_as(GroupsPathParams, request)
128128
update: GroupUpdate = await parse_request_body_as(GroupUpdate, request)
129129

130-
group, access_rights = await _groups_api.update_organization(
130+
group, access_rights = await _groups_api.update_group(
131131
request.app,
132132
user_id=req_ctx.user_id,
133133
group_id=path_params.gid,
@@ -147,7 +147,7 @@ async def delete_group(request: web.Request):
147147
req_ctx = GroupsRequestContext.model_validate(request)
148148
path_params = parse_request_path_parameters_as(GroupsPathParams, request)
149149

150-
await _groups_api.delete_organization(
150+
await _groups_api.delete_group(
151151
request.app, user_id=req_ctx.user_id, group_id=path_params.gid
152152
)
153153

services/web/server/tests/integration/01/test_garbage_collection.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
from simcore_service_webserver.director_v2.plugin import setup_director_v2
3737
from simcore_service_webserver.garbage_collector import _core as gc_core
3838
from simcore_service_webserver.garbage_collector.plugin import setup_garbage_collector
39-
from simcore_service_webserver.groups._groups_api import create_organization
39+
from simcore_service_webserver.groups._groups_api import create_standard_group
4040
from simcore_service_webserver.groups.api import add_user_in_group
4141
from simcore_service_webserver.login.plugin import setup_login
4242
from simcore_service_webserver.projects._crud_api_delete import get_scheduled_tasks
@@ -282,7 +282,7 @@ async def get_group(client: TestClient, user: dict):
282282
"""Creates a group for a given user"""
283283
assert client.app
284284

285-
return await create_organization(
285+
return await create_standard_group(
286286
app=client.app,
287287
user_id=user["id"],
288288
create=OrganizationCreate.model_validate(

services/web/server/tests/unit/with_dbs/01/groups/test_groups_handlers_users.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
from simcore_postgres_database.models.users import UserRole
2323
from simcore_service_webserver._meta import API_VTAG
2424
from simcore_service_webserver.groups._groups_api import (
25-
create_organization,
26-
delete_organization,
25+
create_standard_group,
26+
delete_group,
2727
)
2828
from simcore_service_webserver.groups._groups_db import (
2929
_DEFAULT_GROUP_OWNER_ACCESS_RIGHTS,
@@ -460,7 +460,7 @@ async def group_where_logged_user_is_the_owner(
460460
logged_user: UserInfoDict,
461461
) -> AsyncIterator[Group]:
462462
assert client.app
463-
group, _ = await create_organization(
463+
group, _ = await create_standard_group(
464464
app=client.app,
465465
user_id=logged_user["id"],
466466
create=OrganizationCreate.model_validate(
@@ -474,7 +474,7 @@ async def group_where_logged_user_is_the_owner(
474474

475475
yield group
476476

477-
await delete_organization(client.app, user_id=logged_user["id"], group_id=group.gid)
477+
await delete_group(client.app, user_id=logged_user["id"], group_id=group.gid)
478478

479479

480480
@pytest.mark.acceptance_test(

0 commit comments

Comments
 (0)