Skip to content

Commit 432dbb3

Browse files
committed
add test of rest endpoint for getting jobs associated with user
1 parent eec16d8 commit 432dbb3

File tree

1 file changed

+28
-2
lines changed

1 file changed

+28
-2
lines changed

services/web/server/tests/unit/with_dbs/03/test_storage_rpc.py

Lines changed: 28 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,10 @@
3535
get_result,
3636
get_status,
3737
)
38-
from servicelib.rabbitmq.rpc_interfaces.storage.data_export import start_data_export
38+
from servicelib.rabbitmq.rpc_interfaces.storage.data_export import (
39+
get_user_jobs,
40+
start_data_export,
41+
)
3942
from simcore_postgres_database.models.users import UserRole
4043

4144
_faker = Faker()
@@ -50,7 +53,7 @@ def side_effect(*args, **kwargs):
5053
return result_or_exception
5154

5255
mocker.patch(
53-
f"simcore_service_webserver.storage._handlers.{method}",
56+
f"simcore_service_webserver.storage._rest.{method}",
5457
side_effect=side_effect,
5558
)
5659

@@ -186,3 +189,26 @@ async def test_get_async_job_result(
186189
assert response.status == status.HTTP_500_INTERNAL_SERVER_ERROR
187190
else:
188191
raise Exception("Test incorrectly configured")
192+
193+
194+
@pytest.mark.parametrize("user_role", [UserRole.USER])
195+
@pytest.mark.parametrize(
196+
"backend_result_or_exception",
197+
[
198+
[StorageAsyncJobGet(job_id=AsyncJobId(_faker.uuid4()))],
199+
],
200+
ids=lambda x: type(x).__name__,
201+
)
202+
async def test_get_user_async_jobs(
203+
user_role: UserRole,
204+
logged_user: UserInfoDict,
205+
client: TestClient,
206+
create_storage_rpc_client_mock: Callable[[str, Any], None],
207+
backend_result_or_exception: Any,
208+
):
209+
create_storage_rpc_client_mock(get_user_jobs.__name__, backend_result_or_exception)
210+
211+
response = await client.get("/v0/storage/async-jobs")
212+
213+
assert response.status == status.HTTP_200_OK
214+
Envelope[list[StorageAsyncJobGet]].model_validate(await response.json())

0 commit comments

Comments
 (0)