Skip to content

Commit a027ecf

Browse files
committed
connect pieces to expose licensed items
1 parent 6d220d3 commit a027ecf

File tree

3 files changed

+16
-13
lines changed

3 files changed

+16
-13
lines changed
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
from fastapi import FastAPI
2+
from simcore_service_api_server.services_rpc.wb_api_server import WbApiRpcClient
3+
4+
5+
def get_wb_api_rpc_client(app: FastAPI) -> WbApiRpcClient:
6+
assert app.state.wb_api_rpc_client # nosec
7+
return app.state.wb_api_rpc_client

services/api-server/src/simcore_service_api_server/api/routes/licensed_items.py

Lines changed: 8 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,11 @@
22

33
from fastapi import APIRouter, Depends
44
from models_library.api_schemas_webserver.licensed_items import LicensedItemGetPage
5-
from servicelib.rabbitmq._client_rpc import RabbitMQRPCClient
6-
from servicelib.rabbitmq.rpc_interfaces.webserver.licenses.licensed_items import (
7-
get_licensed_items as _get_licensed_items,
8-
)
9-
from simcore_service_api_server.api.dependencies.authentication import get_product_name
10-
from simcore_service_api_server.api.dependencies.rabbitmq import get_rabbitmq_rpc_client
11-
from simcore_service_api_server.models.pagination import PaginationParams
5+
6+
from ...api.dependencies.authentication import get_product_name
7+
from ...api.dependencies.webserver_rpc import get_wb_api_rpc_client
8+
from ...models.pagination import PaginationParams
9+
from ...services_rpc.wb_api_server import WbApiRpcClient
1210

1311
router = APIRouter()
1412

@@ -17,12 +15,10 @@
1715
"/", response_model=LicensedItemGetPage, description="Get all licensed items"
1816
)
1917
async def get_licensed_items(
20-
wallet_id: int,
2118
page_params: Annotated[PaginationParams, Depends()],
22-
webserver_rpc_api: Annotated[RabbitMQRPCClient, Depends(get_rabbitmq_rpc_client)],
19+
web_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)],
2320
product_name: Annotated[str, Depends(get_product_name)],
2421
) -> LicensedItemGetPage:
25-
return await _get_licensed_items(
26-
rabbitmq_rpc_client=webserver_rpc_api,
27-
product_name=product_name,
22+
return await web_api_rpc.get_licensed_items(
23+
product_name=product_name, page_params=page_params
2824
)

services/api-server/src/simcore_service_api_server/api/routes/solvers_jobs_getters.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@
5353
from ..dependencies.database import Engine, get_db_engine
5454
from ..dependencies.rabbitmq import get_log_check_timeout, get_log_distributor
5555
from ..dependencies.services import get_api_client
56-
from ..dependencies.webserver import AuthSession, get_webserver_session
56+
from ..dependencies.webserver_http import AuthSession, get_webserver_session
5757
from ._constants import FMSG_CHANGELOG_NEW_IN_VERSION
5858
from .solvers_jobs import (
5959
JOBS_STATUS_CODES,

0 commit comments

Comments
 (0)