mirror of
https://github.com/BEDOLAGA-DEV/remnawave-bedolaga-telegram-bot.git
synced 2026-03-01 07:42:30 +00:00
Merge pull request #532 from Fr1ngg/revert-529-revert-527-bedolaga/add-api-interaction-for-remnawave-components
Revert "Revert "Add RemnaWave management endpoints to web API""
This commit is contained in:
Egor
@@ -10,6 +10,7 @@ from .routes import (
|
||||
config,
|
||||
health,
|
||||
promo_groups,
|
||||
remnawave,
|
||||
stats,
|
||||
subscriptions,
|
||||
tickets,
|
||||
@@ -52,5 +53,6 @@ def create_web_api_app() -> FastAPI:
|
||||
app.include_router(transactions.router, prefix="/transactions", tags=["transactions"])
|
||||
app.include_router(promo_groups.router, prefix="/promo-groups", tags=["promo-groups"])
|
||||
app.include_router(tokens.router, prefix="/tokens", tags=["auth"])
|
||||
app.include_router(remnawave.router)
|
||||
|
||||
return app
|
||||
|
||||
426
app/webapi/routes/remnawave.py
Normal file
426
app/webapi/routes/remnawave.py
Normal file
@@ -0,0 +1,426 @@
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import datetime, timedelta
|
||||
from typing import Any, Dict, List, Optional
|
||||
|
||||
from fastapi import APIRouter, Depends, HTTPException, Query, Security, status
|
||||
from sqlalchemy.ext.asyncio import AsyncSession
|
||||
|
||||
from app.services.remnawave_service import RemnaWaveConfigurationError, RemnaWaveService
|
||||
|
||||
from ..dependencies import get_db_session, require_api_token
|
||||
from ..schemas.remnawave import (
|
||||
RemnaWaveConnectionStatus,
|
||||
RemnaWaveGenericSyncResponse,
|
||||
RemnaWaveInboundsResponse,
|
||||
RemnaWaveNode,
|
||||
RemnaWaveNodeActionRequest,
|
||||
RemnaWaveNodeActionResponse,
|
||||
RemnaWaveNodeListResponse,
|
||||
RemnaWaveNodeStatisticsResponse,
|
||||
RemnaWaveNodeUsageResponse,
|
||||
RemnaWaveOperationResponse,
|
||||
RemnaWaveSquad,
|
||||
RemnaWaveSquadActionRequest,
|
||||
RemnaWaveSquadCreateRequest,
|
||||
RemnaWaveSquadListResponse,
|
||||
RemnaWaveSquadUpdateRequest,
|
||||
RemnaWaveStatusResponse,
|
||||
RemnaWaveSystemStatsResponse,
|
||||
RemnaWaveSyncFromPanelRequest,
|
||||
RemnaWaveUserTrafficResponse,
|
||||
)
|
||||
|
||||
|
||||
router = APIRouter(prefix="/remnawave", tags=["remnawave"])
|
||||
|
||||
|
||||
def _ensure_service_configured(service: RemnaWaveService) -> None:
|
||||
if not service.is_configured:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_503_SERVICE_UNAVAILABLE,
|
||||
detail=service.configuration_error or "RemnaWave API не настроен",
|
||||
)
|
||||
|
||||
|
||||
def _serialize_node(node_data: Dict[str, Any]) -> RemnaWaveNode:
|
||||
return RemnaWaveNode(
|
||||
uuid=node_data.get("uuid", ""),
|
||||
name=node_data.get("name", ""),
|
||||
address=node_data.get("address", ""),
|
||||
country_code=node_data.get("country_code"),
|
||||
is_connected=bool(node_data.get("is_connected")),
|
||||
is_disabled=bool(node_data.get("is_disabled")),
|
||||
is_node_online=bool(node_data.get("is_node_online")),
|
||||
is_xray_running=bool(node_data.get("is_xray_running")),
|
||||
users_online=node_data.get("users_online"),
|
||||
traffic_used_bytes=node_data.get("traffic_used_bytes"),
|
||||
traffic_limit_bytes=node_data.get("traffic_limit_bytes"),
|
||||
)
|
||||
|
||||
|
||||
def _parse_last_updated(value: Any) -> Optional[datetime]:
|
||||
if isinstance(value, datetime):
|
||||
return value
|
||||
if isinstance(value, str):
|
||||
try:
|
||||
return datetime.fromisoformat(value)
|
||||
except ValueError:
|
||||
return None
|
||||
return None
|
||||
|
||||
|
||||
@router.get("/status", response_model=RemnaWaveStatusResponse)
|
||||
async def get_remnawave_status(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveStatusResponse:
|
||||
service = RemnaWaveService()
|
||||
|
||||
connection_info: Optional[RemnaWaveConnectionStatus] = None
|
||||
connection_result = await service.test_api_connection()
|
||||
|
||||
if connection_result:
|
||||
connection_info = RemnaWaveConnectionStatus(**connection_result)
|
||||
|
||||
return RemnaWaveStatusResponse(
|
||||
is_configured=service.is_configured,
|
||||
configuration_error=service.configuration_error,
|
||||
connection=connection_info,
|
||||
)
|
||||
|
||||
|
||||
@router.get("/system", response_model=RemnaWaveSystemStatsResponse)
|
||||
async def get_system_statistics(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveSystemStatsResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.get_system_statistics()
|
||||
if not stats or "system" not in stats:
|
||||
raise HTTPException(status.HTTP_502_BAD_GATEWAY, "Не удалось получить статистику RemnaWave")
|
||||
|
||||
stats["last_updated"] = _parse_last_updated(stats.get("last_updated"))
|
||||
return RemnaWaveSystemStatsResponse(**stats)
|
||||
|
||||
|
||||
@router.get("/nodes", response_model=RemnaWaveNodeListResponse)
|
||||
async def list_nodes(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNodeListResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
nodes = await service.get_all_nodes()
|
||||
serialized = [_serialize_node(node) for node in nodes]
|
||||
return RemnaWaveNodeListResponse(items=serialized, total=len(serialized))
|
||||
|
||||
|
||||
@router.get("/nodes/realtime", response_model=List[Dict[str, Any]])
|
||||
async def get_nodes_realtime_usage(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> List[Dict[str, Any]]:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
return await service.get_nodes_realtime_usage()
|
||||
|
||||
|
||||
@router.get("/nodes/{node_uuid}", response_model=RemnaWaveNode)
|
||||
async def get_node_details(
|
||||
node_uuid: str,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNode:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
node = await service.get_node_details(node_uuid)
|
||||
if not node:
|
||||
raise HTTPException(status.HTTP_404_NOT_FOUND, "Нода не найдена")
|
||||
return _serialize_node(node)
|
||||
|
||||
|
||||
@router.get("/nodes/{node_uuid}/statistics", response_model=RemnaWaveNodeStatisticsResponse)
|
||||
async def get_node_statistics(
|
||||
node_uuid: str,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNodeStatisticsResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.get_node_statistics(node_uuid)
|
||||
if not stats or not stats.get("node"):
|
||||
raise HTTPException(status.HTTP_404_NOT_FOUND, "Не удалось получить информацию по ноде")
|
||||
|
||||
node_data = _serialize_node(stats["node"])
|
||||
usage_history = stats.get("usage_history") or []
|
||||
realtime = stats.get("realtime")
|
||||
last_updated = _parse_last_updated(stats.get("last_updated"))
|
||||
|
||||
return RemnaWaveNodeStatisticsResponse(
|
||||
node=node_data,
|
||||
realtime=realtime,
|
||||
usage_history=usage_history,
|
||||
last_updated=last_updated,
|
||||
)
|
||||
|
||||
|
||||
@router.get("/nodes/{node_uuid}/usage", response_model=RemnaWaveNodeUsageResponse)
|
||||
async def get_node_usage_range(
|
||||
node_uuid: str,
|
||||
start: Optional[datetime] = Query(default=None),
|
||||
end: Optional[datetime] = Query(default=None),
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNodeUsageResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
end_dt = end or datetime.utcnow()
|
||||
start_dt = start or (end_dt - timedelta(days=7))
|
||||
|
||||
if start_dt >= end_dt:
|
||||
raise HTTPException(status.HTTP_400_BAD_REQUEST, "Некорректный диапазон дат")
|
||||
|
||||
usage = await service.get_node_user_usage_by_range(node_uuid, start_dt, end_dt)
|
||||
return RemnaWaveNodeUsageResponse(items=usage or [])
|
||||
|
||||
|
||||
@router.post("/nodes/{node_uuid}/actions", response_model=RemnaWaveNodeActionResponse)
|
||||
async def manage_node(
|
||||
node_uuid: str,
|
||||
payload: RemnaWaveNodeActionRequest,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNodeActionResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
success = await service.manage_node(node_uuid, payload.action)
|
||||
detail = None
|
||||
if success:
|
||||
if payload.action == "enable":
|
||||
detail = "Нода включена"
|
||||
elif payload.action == "disable":
|
||||
detail = "Нода отключена"
|
||||
elif payload.action == "restart":
|
||||
detail = "Команда перезапуска отправлена"
|
||||
else:
|
||||
detail = "Не удалось выполнить действие"
|
||||
|
||||
return RemnaWaveNodeActionResponse(success=success, detail=detail)
|
||||
|
||||
|
||||
@router.post("/nodes/restart", response_model=RemnaWaveNodeActionResponse)
|
||||
async def restart_all_nodes(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveNodeActionResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
success = await service.restart_all_nodes()
|
||||
detail = "Команда перезапуска отправлена" if success else "Не удалось перезапустить ноды"
|
||||
return RemnaWaveNodeActionResponse(success=success, detail=detail)
|
||||
|
||||
|
||||
@router.get("/squads", response_model=RemnaWaveSquadListResponse)
|
||||
async def list_squads(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveSquadListResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
squads = await service.get_all_squads()
|
||||
serialized = [RemnaWaveSquad(**squad) for squad in squads]
|
||||
return RemnaWaveSquadListResponse(items=serialized, total=len(serialized))
|
||||
|
||||
|
||||
@router.get("/squads/{squad_uuid}", response_model=RemnaWaveSquad)
|
||||
async def get_squad_details(
|
||||
squad_uuid: str,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveSquad:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
squad = await service.get_squad_details(squad_uuid)
|
||||
if not squad:
|
||||
raise HTTPException(status.HTTP_404_NOT_FOUND, "Сквад не найден")
|
||||
return RemnaWaveSquad(**squad)
|
||||
|
||||
|
||||
@router.post("/squads", response_model=RemnaWaveOperationResponse, status_code=status.HTTP_201_CREATED)
|
||||
async def create_squad(
|
||||
payload: RemnaWaveSquadCreateRequest,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveOperationResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
success = await service.create_squad(payload.name, payload.inbound_uuids)
|
||||
detail = "Сквад успешно создан" if success else "Не удалось создать сквад"
|
||||
return RemnaWaveOperationResponse(success=success, detail=detail)
|
||||
|
||||
|
||||
@router.patch("/squads/{squad_uuid}", response_model=RemnaWaveOperationResponse)
|
||||
async def update_squad(
|
||||
squad_uuid: str,
|
||||
payload: RemnaWaveSquadUpdateRequest,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveOperationResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
success = False
|
||||
detail = "Необходимо указать новые данные"
|
||||
|
||||
if payload.name is not None or payload.inbound_uuids is not None:
|
||||
success = await service.update_squad(
|
||||
squad_uuid,
|
||||
name=payload.name,
|
||||
inbounds=payload.inbound_uuids,
|
||||
)
|
||||
detail = "Сквад обновлен" if success else "Не удалось обновить сквад"
|
||||
|
||||
return RemnaWaveOperationResponse(success=success, detail=detail)
|
||||
|
||||
|
||||
@router.post("/squads/{squad_uuid}/actions", response_model=RemnaWaveOperationResponse)
|
||||
async def squad_actions(
|
||||
squad_uuid: str,
|
||||
payload: RemnaWaveSquadActionRequest,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveOperationResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
action = payload.action
|
||||
success = False
|
||||
detail = "Неизвестное действие"
|
||||
|
||||
if action == "add_all_users":
|
||||
success = await service.add_all_users_to_squad(squad_uuid)
|
||||
detail = "Пользователи добавлены" if success else "Не удалось добавить пользователей"
|
||||
elif action == "remove_all_users":
|
||||
success = await service.remove_all_users_from_squad(squad_uuid)
|
||||
detail = "Пользователи удалены" if success else "Не удалось удалить пользователей"
|
||||
elif action == "delete":
|
||||
success = await service.delete_squad(squad_uuid)
|
||||
detail = "Сквад удален" if success else "Не удалось удалить сквад"
|
||||
elif action == "rename":
|
||||
if not payload.name:
|
||||
raise HTTPException(status.HTTP_400_BAD_REQUEST, "Необходимо указать новое имя")
|
||||
success = await service.rename_squad(squad_uuid, payload.name)
|
||||
detail = "Сквад переименован" if success else "Не удалось переименовать сквад"
|
||||
elif action == "update_inbounds":
|
||||
if not payload.inbound_uuids:
|
||||
raise HTTPException(status.HTTP_400_BAD_REQUEST, "Необходимо указать inbound_uuids")
|
||||
success = await service.update_squad_inbounds(squad_uuid, payload.inbound_uuids)
|
||||
detail = "Инбаунды обновлены" if success else "Не удалось обновить инбаунды"
|
||||
|
||||
return RemnaWaveOperationResponse(success=success, detail=detail)
|
||||
|
||||
|
||||
@router.get("/inbounds", response_model=RemnaWaveInboundsResponse)
|
||||
async def list_inbounds(
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveInboundsResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
inbounds = await service.get_all_inbounds()
|
||||
return RemnaWaveInboundsResponse(items=inbounds or [])
|
||||
|
||||
|
||||
@router.get("/users/{telegram_id}/traffic", response_model=RemnaWaveUserTrafficResponse)
|
||||
async def get_user_traffic(
|
||||
telegram_id: int,
|
||||
_: Any = Security(require_api_token),
|
||||
) -> RemnaWaveUserTrafficResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.get_user_traffic_stats(telegram_id)
|
||||
if not stats:
|
||||
raise HTTPException(status.HTTP_404_NOT_FOUND, "Пользователь не найден в RemnaWave")
|
||||
|
||||
return RemnaWaveUserTrafficResponse(telegram_id=telegram_id, **stats)
|
||||
|
||||
|
||||
@router.post("/sync/from-panel", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def sync_from_panel(
|
||||
payload: RemnaWaveSyncFromPanelRequest,
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
try:
|
||||
stats = await service.sync_users_from_panel(db, payload.mode)
|
||||
detail = "Синхронизация из панели выполнена"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=stats)
|
||||
except RemnaWaveConfigurationError as exc:
|
||||
raise HTTPException(status.HTTP_503_SERVICE_UNAVAILABLE, str(exc)) from exc
|
||||
|
||||
|
||||
@router.post("/sync/to-panel", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def sync_to_panel(
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.sync_users_to_panel(db)
|
||||
detail = "Синхронизация в панель выполнена"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=stats)
|
||||
|
||||
|
||||
@router.post("/sync/subscriptions/validate", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def validate_and_fix_subscriptions(
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.validate_and_fix_subscriptions(db)
|
||||
detail = "Подписки проверены"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=stats)
|
||||
|
||||
|
||||
@router.post("/sync/subscriptions/cleanup", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def cleanup_orphaned_subscriptions(
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.cleanup_orphaned_subscriptions(db)
|
||||
detail = "Очистка завершена"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=stats)
|
||||
|
||||
|
||||
@router.post("/sync/subscriptions/statuses", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def sync_subscription_statuses(
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
stats = await service.sync_subscription_statuses(db)
|
||||
detail = "Статусы подписок синхронизированы"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=stats)
|
||||
|
||||
|
||||
@router.get("/sync/recommendations", response_model=RemnaWaveGenericSyncResponse)
|
||||
async def get_sync_recommendations(
|
||||
_: Any = Security(require_api_token),
|
||||
db: AsyncSession = Depends(get_db_session),
|
||||
) -> RemnaWaveGenericSyncResponse:
|
||||
service = RemnaWaveService()
|
||||
_ensure_service_configured(service)
|
||||
|
||||
data = await service.get_sync_recommendations(db)
|
||||
detail = "Рекомендации получены"
|
||||
return RemnaWaveGenericSyncResponse(success=True, detail=detail, data=data)
|
||||
171
app/webapi/schemas/remnawave.py
Normal file
171
app/webapi/schemas/remnawave.py
Normal file
@@ -0,0 +1,171 @@
|
||||
from __future__ import annotations
|
||||
|
||||
from datetime import datetime
|
||||
from typing import Any, Dict, List, Literal, Optional
|
||||
|
||||
from pydantic import BaseModel, Field
|
||||
|
||||
|
||||
class RemnaWaveConnectionStatus(BaseModel):
|
||||
status: str
|
||||
message: str
|
||||
api_url: Optional[str] = None
|
||||
status_code: Optional[int] = None
|
||||
system_info: Optional[Dict[str, Any]] = None
|
||||
|
||||
|
||||
class RemnaWaveStatusResponse(BaseModel):
|
||||
is_configured: bool
|
||||
configuration_error: Optional[str] = None
|
||||
connection: Optional[RemnaWaveConnectionStatus] = None
|
||||
|
||||
|
||||
class RemnaWaveNode(BaseModel):
|
||||
uuid: str
|
||||
name: str
|
||||
address: str
|
||||
country_code: Optional[str] = None
|
||||
is_connected: bool
|
||||
is_disabled: bool
|
||||
is_node_online: bool
|
||||
is_xray_running: bool
|
||||
users_online: Optional[int] = None
|
||||
traffic_used_bytes: Optional[int] = None
|
||||
traffic_limit_bytes: Optional[int] = None
|
||||
|
||||
|
||||
class RemnaWaveNodeListResponse(BaseModel):
|
||||
items: List[RemnaWaveNode]
|
||||
total: int
|
||||
|
||||
|
||||
class RemnaWaveNodeActionRequest(BaseModel):
|
||||
action: Literal["enable", "disable", "restart"]
|
||||
|
||||
|
||||
class RemnaWaveNodeActionResponse(BaseModel):
|
||||
success: bool
|
||||
detail: Optional[str] = None
|
||||
|
||||
|
||||
class RemnaWaveNodeStatisticsResponse(BaseModel):
|
||||
node: RemnaWaveNode
|
||||
realtime: Optional[Dict[str, Any]] = None
|
||||
usage_history: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
last_updated: Optional[datetime] = None
|
||||
|
||||
|
||||
class RemnaWaveNodeUsageResponse(BaseModel):
|
||||
items: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
|
||||
|
||||
class RemnaWaveBandwidth(BaseModel):
|
||||
realtime_download: int
|
||||
realtime_upload: int
|
||||
realtime_total: int
|
||||
|
||||
|
||||
class RemnaWaveTrafficPeriod(BaseModel):
|
||||
current: int
|
||||
previous: int
|
||||
difference: Optional[str] = None
|
||||
|
||||
|
||||
class RemnaWaveTrafficPeriods(BaseModel):
|
||||
last_2_days: RemnaWaveTrafficPeriod
|
||||
last_7_days: RemnaWaveTrafficPeriod
|
||||
last_30_days: RemnaWaveTrafficPeriod
|
||||
current_month: RemnaWaveTrafficPeriod
|
||||
current_year: RemnaWaveTrafficPeriod
|
||||
|
||||
|
||||
class RemnaWaveSystemSummary(BaseModel):
|
||||
users_online: int
|
||||
total_users: int
|
||||
active_connections: int
|
||||
nodes_online: int
|
||||
users_last_day: int
|
||||
users_last_week: int
|
||||
users_never_online: int
|
||||
total_user_traffic: int
|
||||
|
||||
|
||||
class RemnaWaveServerInfo(BaseModel):
|
||||
cpu_cores: int
|
||||
cpu_physical_cores: int
|
||||
memory_total: int
|
||||
memory_used: int
|
||||
memory_free: int
|
||||
memory_available: int
|
||||
uptime_seconds: int
|
||||
|
||||
|
||||
class RemnaWaveSystemStatsResponse(BaseModel):
|
||||
system: RemnaWaveSystemSummary
|
||||
users_by_status: Dict[str, int]
|
||||
server_info: RemnaWaveServerInfo
|
||||
bandwidth: RemnaWaveBandwidth
|
||||
traffic_periods: RemnaWaveTrafficPeriods
|
||||
nodes_realtime: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
nodes_weekly: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
last_updated: Optional[datetime] = None
|
||||
|
||||
|
||||
class RemnaWaveSquad(BaseModel):
|
||||
uuid: str
|
||||
name: str
|
||||
members_count: int
|
||||
inbounds_count: int
|
||||
inbounds: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
|
||||
|
||||
class RemnaWaveSquadListResponse(BaseModel):
|
||||
items: List[RemnaWaveSquad]
|
||||
total: int
|
||||
|
||||
|
||||
class RemnaWaveSquadCreateRequest(BaseModel):
|
||||
name: str
|
||||
inbound_uuids: List[str] = Field(default_factory=list)
|
||||
|
||||
|
||||
class RemnaWaveSquadUpdateRequest(BaseModel):
|
||||
name: Optional[str] = None
|
||||
inbound_uuids: Optional[List[str]] = None
|
||||
|
||||
|
||||
class RemnaWaveSquadActionRequest(BaseModel):
|
||||
action: Literal["add_all_users", "remove_all_users", "delete", "rename", "update_inbounds"]
|
||||
name: Optional[str] = None
|
||||
inbound_uuids: Optional[List[str]] = None
|
||||
|
||||
|
||||
class RemnaWaveOperationResponse(BaseModel):
|
||||
success: bool
|
||||
detail: Optional[str] = None
|
||||
data: Optional[Dict[str, Any]] = None
|
||||
|
||||
|
||||
class RemnaWaveInboundsResponse(BaseModel):
|
||||
items: List[Dict[str, Any]] = Field(default_factory=list)
|
||||
|
||||
|
||||
class RemnaWaveUserTrafficResponse(BaseModel):
|
||||
telegram_id: int
|
||||
used_traffic_bytes: int
|
||||
used_traffic_gb: float
|
||||
lifetime_used_traffic_bytes: int
|
||||
lifetime_used_traffic_gb: float
|
||||
traffic_limit_bytes: int
|
||||
traffic_limit_gb: float
|
||||
subscription_url: Optional[str] = None
|
||||
|
||||
|
||||
class RemnaWaveSyncFromPanelRequest(BaseModel):
|
||||
mode: Literal["all", "new_only", "update_only"] = "all"
|
||||
|
||||
|
||||
class RemnaWaveGenericSyncResponse(BaseModel):
|
||||
success: bool
|
||||
detail: Optional[str] = None
|
||||
data: Optional[Dict[str, Any]] = None
|
||||
Reference in New Issue
Block a user