mirror of
https://github.com/DrizzleTime/Foxel.git
synced 2026-05-10 17:43:35 +08:00
6b2ada0b42
- Updated import statements across multiple modules to use relative imports for better encapsulation. - Consolidated and organized the `__init__.py` files in various domain packages to expose necessary classes and functions. - Improved code readability and maintainability by grouping related imports and removing unused ones. - Ensured consistent import patterns across the domain, enhancing the overall structure of the codebase.
85 lines
2.4 KiB
Python
85 lines
2.4 KiB
Python
from typing import Annotated
|
|
|
|
from fastapi import APIRouter, Depends, Request
|
|
|
|
from api.response import success
|
|
from domain.audit import AuditAction, audit
|
|
from domain.auth import User, get_current_active_user
|
|
from .service import AdapterService
|
|
from .types import AdapterCreate
|
|
|
|
router = APIRouter(prefix="/api/adapters", tags=["adapters"])
|
|
|
|
|
|
@router.post("")
|
|
@audit(
|
|
action=AuditAction.CREATE,
|
|
description="创建存储适配器",
|
|
body_fields=["name", "type", "path", "sub_path", "enabled"],
|
|
)
|
|
async def create_adapter(
|
|
request: Request,
|
|
data: AdapterCreate,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
adapter = await AdapterService.create_adapter(data, current_user)
|
|
return success(adapter)
|
|
|
|
|
|
@router.get("")
|
|
@audit(action=AuditAction.READ, description="获取适配器列表")
|
|
async def list_adapters(
|
|
request: Request,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
adapters = await AdapterService.list_adapters()
|
|
return success(adapters)
|
|
|
|
|
|
@router.get("/available")
|
|
@audit(action=AuditAction.READ, description="获取可用适配器类型")
|
|
async def available_adapter_types(
|
|
request: Request,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
data = await AdapterService.available_adapter_types()
|
|
return success(data)
|
|
|
|
|
|
@router.get("/{adapter_id}")
|
|
@audit(action=AuditAction.READ, description="获取适配器详情")
|
|
async def get_adapter(
|
|
request: Request,
|
|
adapter_id: int,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
adapter = await AdapterService.get_adapter(adapter_id)
|
|
return success(adapter)
|
|
|
|
|
|
@router.put("/{adapter_id}")
|
|
@audit(
|
|
action=AuditAction.UPDATE,
|
|
description="更新存储适配器",
|
|
body_fields=["name", "type", "path", "sub_path", "enabled"],
|
|
)
|
|
async def update_adapter(
|
|
request: Request,
|
|
adapter_id: int,
|
|
data: AdapterCreate,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
adapter = await AdapterService.update_adapter(adapter_id, data, current_user)
|
|
return success(adapter)
|
|
|
|
|
|
@router.delete("/{adapter_id}")
|
|
@audit(action=AuditAction.DELETE, description="删除存储适配器")
|
|
async def delete_adapter(
|
|
request: Request,
|
|
adapter_id: int,
|
|
current_user: Annotated[User, Depends(get_current_active_user)]
|
|
):
|
|
result = await AdapterService.delete_adapter(adapter_id, current_user)
|
|
return success(result)
|