|
8 | 8 | from ...api.dependencies.authentication import get_current_user_id, get_product_name |
9 | 9 | from ...api.dependencies.webserver_rpc import get_wb_api_rpc_client |
10 | 10 | from ...exceptions.service_errors_utils import DEFAULT_BACKEND_SERVICE_STATUS_CODES |
| 11 | +from ...models.pagination import Page, PaginationParams |
11 | 12 | from ...models.schemas.errors import ErrorGet |
12 | 13 | from ...models.schemas.licensed_items import LicensedItemCheckoutData |
13 | 14 | from ...models.schemas.model_adapter import ( |
14 | 15 | LicensedItemCheckoutGet, |
| 16 | + LicensedItemGet, |
15 | 17 | WalletGetWithAvailableCreditsLegacy, |
16 | 18 | ) |
17 | 19 | from ...services_rpc.wb_api_server import WbApiRpcClient |
@@ -60,26 +62,26 @@ async def get_wallet( |
60 | 62 | return await webserver_api.get_wallet(wallet_id=wallet_id) |
61 | 63 |
|
62 | 64 |
|
63 | | -# @router.get( |
64 | | -# "/{wallet_id}/licensed-items", |
65 | | -# response_model=Page[LicensedItemGet], |
66 | | -# status_code=status.HTTP_200_OK, |
67 | | -# responses=WALLET_STATUS_CODES, |
68 | | -# description="Get all available licensed items for a given wallet", |
69 | | -# ) |
70 | | -# async def get_available_licensed_items_for_wallet( |
71 | | -# wallet_id: int, |
72 | | -# page_params: Annotated[PaginationParams, Depends()], |
73 | | -# web_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)], |
74 | | -# product_name: Annotated[str, Depends(get_product_name)], |
75 | | -# user_id: Annotated[PositiveInt, Depends(get_current_user_id)], |
76 | | -# ): |
77 | | -# return await web_api_rpc.get_available_licensed_items_for_wallet( |
78 | | -# product_name=product_name, |
79 | | -# wallet_id=wallet_id, |
80 | | -# user_id=user_id, |
81 | | -# page_params=page_params, |
82 | | -# ) |
| 65 | +@router.get( |
| 66 | + "/{wallet_id}/licensed-items", |
| 67 | + response_model=Page[LicensedItemGet], |
| 68 | + status_code=status.HTTP_200_OK, |
| 69 | + responses=WALLET_STATUS_CODES, |
| 70 | + description="Get all available licensed items for a given wallet", |
| 71 | +) |
| 72 | +async def get_available_licensed_items_for_wallet( |
| 73 | + wallet_id: int, |
| 74 | + page_params: Annotated[PaginationParams, Depends()], |
| 75 | + web_api_rpc: Annotated[WbApiRpcClient, Depends(get_wb_api_rpc_client)], |
| 76 | + product_name: Annotated[str, Depends(get_product_name)], |
| 77 | + user_id: Annotated[PositiveInt, Depends(get_current_user_id)], |
| 78 | +): |
| 79 | + return await web_api_rpc.get_available_licensed_items_for_wallet( |
| 80 | + product_name=product_name, |
| 81 | + wallet_id=wallet_id, |
| 82 | + user_id=user_id, |
| 83 | + page_params=page_params, |
| 84 | + ) |
83 | 85 |
|
84 | 86 |
|
85 | 87 | @router.post( |
|
0 commit comments