mirror of
https://github.com/remnawave/python-sdk.git
synced 2026-05-13 12:16:42 +00:00
0ed1ce92c0
- Added MetadataController for handling user and node metadata. - Implemented models for user and node metadata management. - Created tests for user and node metadata functionalities. - Enhanced authentication settings with passkey and OAuth2 configurations. - Added bulk actions for node updates and responses. - Refactored existing models to accommodate new features and improve structure. - Removed obsolete test_imports.py file. - Updated environment variables for testing. - Improved error handling in subscription tests. - Added new node plugin functionalities including cloning and execution commands.
110 lines
3.9 KiB
Python
110 lines
3.9 KiB
Python
from typing import Annotated, Optional
|
|
|
|
from rapid_api_client import Path, PydanticBody, Query
|
|
|
|
|
|
from remnawave.models import (
|
|
CloneNodePluginRequestDto,
|
|
CloneNodePluginResponseDto,
|
|
CreateNodePluginRequestDto,
|
|
CreateNodePluginResponseDto,
|
|
DeleteNodePluginResponseDto,
|
|
GetNodePluginResponseDto,
|
|
GetNodePluginsResponseDto,
|
|
GetTorrentBlockerReportsResponseDto,
|
|
GetTorrentBlockerReportsStatsResponseDto,
|
|
PluginExecutorRequestDto,
|
|
PluginExecutorResponseDto,
|
|
ReorderNodePluginsRequestDto,
|
|
ReorderNodePluginsResponseDto,
|
|
TruncateTorrentBlockerReportsResponseDto,
|
|
UpdateNodePluginRequestDto,
|
|
UpdateNodePluginResponseDto,
|
|
)
|
|
from remnawave.rapid import BaseController, delete, get, patch, post
|
|
|
|
|
|
class NodePluginsController(BaseController):
|
|
@get("/node-plugins/torrent-blocker", response_class=GetTorrentBlockerReportsResponseDto)
|
|
async def get_torrent_blocker_reports(
|
|
self,
|
|
size: Annotated[Optional[int], Query(default=None, ge=1, description="Page size")] = None,
|
|
start: Annotated[Optional[int], Query(default=None, ge=0, description="Offset")] = None,
|
|
) -> GetTorrentBlockerReportsResponseDto:
|
|
"""Get Torrent Blocker Reports"""
|
|
...
|
|
|
|
@get("/node-plugins/torrent-blocker/stats", response_class=GetTorrentBlockerReportsStatsResponseDto)
|
|
async def get_torrent_blocker_reports_stats(
|
|
self,
|
|
) -> GetTorrentBlockerReportsStatsResponseDto:
|
|
"""Get Torrent Blocker Reports Stats"""
|
|
...
|
|
|
|
@delete("/node-plugins/torrent-blocker/truncate", response_class=TruncateTorrentBlockerReportsResponseDto)
|
|
async def truncate_torrent_blocker_reports(
|
|
self,
|
|
) -> TruncateTorrentBlockerReportsResponseDto:
|
|
"""Truncate Torrent Blocker Reports"""
|
|
...
|
|
|
|
@get("/node-plugins", response_class=GetNodePluginsResponseDto)
|
|
async def get_all_node_plugins(self) -> GetNodePluginsResponseDto:
|
|
"""Get all Node Plugins"""
|
|
...
|
|
|
|
@patch("/node-plugins", response_class=UpdateNodePluginResponseDto)
|
|
async def update_node_plugin(
|
|
self,
|
|
body: Annotated[UpdateNodePluginRequestDto, PydanticBody()],
|
|
) -> UpdateNodePluginResponseDto:
|
|
"""Update Node Plugin"""
|
|
...
|
|
|
|
@post("/node-plugins", response_class=CreateNodePluginResponseDto)
|
|
async def create_node_plugin(
|
|
self,
|
|
body: Annotated[CreateNodePluginRequestDto, PydanticBody()],
|
|
) -> CreateNodePluginResponseDto:
|
|
"""Create Node Plugin"""
|
|
...
|
|
|
|
@get("/node-plugins/{uuid}", response_class=GetNodePluginResponseDto)
|
|
async def get_node_plugin_by_uuid(
|
|
self,
|
|
uuid: Annotated[str, Path(description="Node plugin UUID")],
|
|
) -> GetNodePluginResponseDto:
|
|
"""Get Node Plugin by uuid"""
|
|
...
|
|
|
|
@delete("/node-plugins/{uuid}", response_class=DeleteNodePluginResponseDto)
|
|
async def delete_node_plugin(
|
|
self,
|
|
uuid: Annotated[str, Path(description="Node plugin UUID")],
|
|
) -> DeleteNodePluginResponseDto:
|
|
"""Delete Node Plugin"""
|
|
...
|
|
|
|
@post("/node-plugins/actions/reorder", response_class=ReorderNodePluginsResponseDto)
|
|
async def reorder_node_plugins(
|
|
self,
|
|
body: Annotated[ReorderNodePluginsRequestDto, PydanticBody()],
|
|
) -> ReorderNodePluginsResponseDto:
|
|
"""Reorder Node Plugins"""
|
|
...
|
|
|
|
@post("/node-plugins/actions/clone", response_class=CloneNodePluginResponseDto)
|
|
async def clone_node_plugin(
|
|
self,
|
|
body: Annotated[CloneNodePluginRequestDto, PydanticBody()],
|
|
) -> CloneNodePluginResponseDto:
|
|
"""Clone Node Plugin"""
|
|
...
|
|
|
|
@post("/node-plugins/executor", response_class=PluginExecutorResponseDto)
|
|
async def plugin_executor(
|
|
self,
|
|
body: Annotated[PluginExecutorRequestDto, PydanticBody()],
|
|
) -> PluginExecutorResponseDto:
|
|
"""Execute command on node plugins"""
|
|
...
|