fix: items per page

Author: giancarloromeo

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/storage/simcore_s3.py

@@ -34,7 +34,7 @@ async def start_export_data(
     *,
     paths_to_export: list[PathToExport],
     export_as: Literal["path", "download_link"],
-    job_filter: AsyncJobFilter
+    job_filter: AsyncJobFilter,
 ) -> tuple[AsyncJobGet, AsyncJobFilter]:
     async_job_rpc_get = await submit(
         rabbitmq_rpc_client,
@@ -52,12 +52,14 @@ async def start_search(
     *,
     job_filter: AsyncJobFilter,
     name_pattern: str,
+    items_per_page: int,
 ) -> tuple[AsyncJobGet, AsyncJobFilter]:
     async_job_rpc_get = await submit(
         rabbitmq_rpc_client,
         rpc_namespace=STORAGE_RPC_NAMESPACE,
         method_name=TypeAdapter(RPCMethodName).validate_python("start_search"),
         job_filter=job_filter,
         name_pattern=name_pattern,
+        items_per_page=items_per_page,
     )
     return async_job_rpc_get, job_filter

services/storage/src/simcore_service_storage/api/_worker_tasks/_simcore_s3.py

@@ -139,6 +139,7 @@ async def search(
     user_id: UserID,
     project_id: ProjectID | None,
     name_pattern: str,
+    items_per_page: int,
 ) -> None:
     with log_context(
         _logger,
@@ -156,6 +157,7 @@ async def search(
             user_id=user_id,
             project_id=project_id,
             name_pattern=name_pattern,
+            items_per_page=items_per_page,
         ):
             data = [
                 SearchResult(

services/web/server/src/simcore_service_webserver/storage/_rest.py

@@ -558,7 +558,7 @@ class _PathParams(BaseModel):
 
     rabbitmq_rpc_client = get_rabbitmq_rpc_client(request.app)
     _req_ctx = AuthenticatedRequestContext.model_validate(request)
-    parse_request_path_parameters_as(_PathParams, request)
+    path_params = parse_request_path_parameters_as(_PathParams, request)
     search_body = await parse_request_body_as(
         model_schema_cls=SearchBodyParams, request=request
     )
@@ -569,14 +569,15 @@ class _PathParams(BaseModel):
             product_name=_req_ctx.product_name,
         ),
         name_pattern=search_body.name_pattern,
+        items_per_page=search_body.items_per_page,
     )
     _job_id = f"{async_job_rpc_get.job_id}"
     return create_data_response(
         TaskGet(
             task_id=_job_id,
             status_href=f"{request.url.with_path(str(request.app.router['get_async_job_status'].url_for(task_id=_job_id)))}",
             abort_href=f"{request.url.with_path(str(request.app.router['cancel_async_job'].url_for(task_id=_job_id)))}",
-            result_href=f"{request.url.with_path(str(request.app.router['get_async_job_result'].url_for(task_id=_job_id)))}",
+            result_stream_href=f"{request.url.with_path(str(request.app.router['stream_search'].url_for(location_id=str(path_params.location_id), job_id=_job_id)))}",
         ),
         status=status.HTTP_202_ACCEPTED,
     )