Skip to content

Commit 6c3682c

Browse files
committed
update to latest master changes
1 parent 7d4ace4 commit 6c3682c

File tree

4 files changed

+9
-29
lines changed

4 files changed

+9
-29
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
from typing import Annotated, Any
22

33
from fastapi import APIRouter, Depends, status
4+
from models_library.licensed_items import LicensedItemID
45
from pydantic import PositiveInt
56

67
from ...api.dependencies.authentication import get_current_user_id, get_product_name
78
from ...api.dependencies.webserver_rpc import get_wb_api_rpc_client
89
from ...exceptions.service_errors_utils import DEFAULT_BACKEND_SERVICE_STATUS_CODES
910
from ...models.pagination import Page, PaginationParams
10-
from ...models.schemas.licensed_items import LicensedItemReleaseData
1111
from ...models.schemas.model_adapter import LicensedItemCheckoutGet, LicensedItemGet
1212
from ...services_rpc.wb_api_server import WbApiRpcClient
1313

@@ -37,7 +37,7 @@ async def get_licensed_items(
3737

3838

3939
@router.post(
40-
"release",
40+
"{licensed_item_id}/release",
4141
response_model=LicensedItemCheckoutGet,
4242
status_code=status.HTTP_200_OK,
4343
responses=_LICENSE_ITEMS_STATUS_CODES,
@@ -48,10 +48,10 @@ async def release_licensed_item(
4848
web_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)],
4949
product_name: Annotated[str, Depends(get_product_name)],
5050
user_id: Annotated[PositiveInt, Depends(get_current_user_id)],
51-
licensed_item_release_data: LicensedItemReleaseData,
51+
licensed_item_id: LicensedItemID,
5252
):
5353
return await web_api_rpc.release_licensed_item_for_wallet(
5454
product_name=product_name,
5555
user_id=user_id,
56-
licensed_item_checkout_id=licensed_item_release_data.licensed_item_checkout_id,
56+
licensed_item_checkout_id=licensed_item_id,
5757
)
Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,7 @@
1-
from models_library.resource_tracker import ServiceRunId
2-
from models_library.resource_tracker_licensed_items_checkouts import (
3-
LicensedItemCheckoutID,
4-
)
1+
from models_library.services_types import ServiceRunID
52
from pydantic import BaseModel
63

74

85
class LicensedItemCheckoutData(BaseModel):
96
number_of_seats: int
10-
service_run_id: ServiceRunId
11-
12-
13-
class LicensedItemReleaseData(BaseModel):
14-
licensed_item_checkout_id: LicensedItemCheckoutID
7+
service_run_id: ServiceRunID

services/api-server/src/simcore_service_api_server/services_rpc/wb_api_server.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,10 @@
66
from fastapi_pagination import Page, create_page
77
from models_library.api_schemas_webserver.licensed_items import LicensedItemGetPage
88
from models_library.licensed_items import LicensedItemID
9-
from models_library.resource_tracker import ServiceRunId
109
from models_library.resource_tracker_licensed_items_checkouts import (
1110
LicensedItemCheckoutID,
1211
)
12+
from models_library.services_types import ServiceRunID
1313
from models_library.users import UserID
1414
from models_library.wallets import WalletID
1515
from servicelib.rabbitmq._client_rpc import RabbitMQRPCClient
@@ -101,7 +101,7 @@ async def checkout_licensed_item_for_wallet(
101101
wallet_id: WalletID,
102102
licensed_item_id: LicensedItemID,
103103
num_of_seats: int,
104-
service_run_id: ServiceRunId,
104+
service_run_id: ServiceRunID,
105105
) -> LicensedItemCheckoutGet:
106106
licensed_item_checkout_get = await _checkout_licensed_item_for_wallet(
107107
self._client,

services/api-server/tests/unit/test_licensed_items.py

Lines changed: 1 addition & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -21,10 +21,6 @@
2121
from pytest_mock import MockerFixture
2222
from servicelib.rabbitmq._client_rpc import RabbitMQRPCClient
2323
from servicelib.rabbitmq._errors import RemoteMethodNotRegisteredError
24-
from servicelib.rabbitmq.rpc_interfaces.resource_usage_tracker.errors import (
25-
CanNotCheckoutNotEnoughAvailableSeatsError,
26-
NotEnoughAvailableSeatsError,
27-
)
2824
from simcore_service_api_server._meta import API_VTAG
2925
from simcore_service_api_server.api.dependencies.webserver_rpc import (
3026
get_wb_api_rpc_client,
@@ -108,16 +104,7 @@ async def test_get_licensed_items_502(
108104
@pytest.mark.parametrize(
109105
"exception_to_raise,expected_api_server_status_code",
110106
[
111-
(None, status.HTTP_200_OK),
112-
(NotEnoughAvailableSeatsError(), status.HTTP_409_CONFLICT),
113-
(
114-
CanNotCheckoutNotEnoughAvailableSeatsError(
115-
licensed_item_id="2e1af95b-f664-4793-81ae-5512708db3b1",
116-
num_of_seats=3,
117-
available_num_of_seats=2,
118-
),
119-
status.HTTP_409_CONFLICT,
120-
),
107+
(NotImplementedError(), status.HTTP_501_NOT_IMPLEMENTED),
121108
],
122109
)
123110
async def test_get_licensed_items_for_wallet(

0 commit comments

Comments
 (0)