107 lines
4.1 KiB
Python
107 lines
4.1 KiB
Python
from fastapi import APIRouter, Depends, HTTPException, Query
|
|
from pydantic import BaseModel
|
|
from app.api.routes.compile import arduino_cli
|
|
from app.core.hooks import get_current_user_id, warm_library
|
|
|
|
router = APIRouter()
|
|
|
|
class InstallLibraryRequest(BaseModel):
|
|
name: str
|
|
version: str | None = None
|
|
|
|
class SearchResponse(BaseModel):
|
|
success: bool
|
|
libraries: list = []
|
|
error: str | None = None
|
|
|
|
class InstallResponse(BaseModel):
|
|
success: bool
|
|
stdout: str | None = None
|
|
error: str | None = None
|
|
fallback: bool | None = None
|
|
requested_version: str | None = None
|
|
|
|
@router.get("/search", response_model=SearchResponse)
|
|
async def search_libraries(q: str = Query(..., description="Search query for library")):
|
|
"""
|
|
Search for Arduino libraries by name or topic.
|
|
"""
|
|
try:
|
|
result = await arduino_cli.search_libraries(q)
|
|
if not result["success"]:
|
|
raise HTTPException(status_code=500, detail=result.get("error", "Failed to search libraries"))
|
|
return SearchResponse(success=True, libraries=result.get("libraries", []))
|
|
except HTTPException:
|
|
raise
|
|
except Exception as e:
|
|
raise HTTPException(status_code=500, detail=str(e))
|
|
|
|
@router.post("/install", response_model=InstallResponse)
|
|
async def install_library(
|
|
request: InstallLibraryRequest,
|
|
requester_id: str | None = Depends(get_current_user_id),
|
|
):
|
|
"""
|
|
Install a specific Arduino library by name.
|
|
|
|
On velxio.dev this WARMS the shared content-addressed cache (the global
|
|
mutable libraries volume is being retired) rather than mutating that volume;
|
|
the overlay also enforces the anonymous policy. With no overlay (OSS
|
|
self-host) it falls back to the legacy arduino-cli global install.
|
|
"""
|
|
try:
|
|
# P2.1 — prefer warming the content-addressed cache (no global write).
|
|
warmed = await warm_library(request.name, request.version, requester_id)
|
|
if warmed is not None:
|
|
return InstallResponse(
|
|
success=bool(warmed.get("success")),
|
|
error=warmed.get("error"),
|
|
stdout=warmed.get("stdout"),
|
|
fallback=warmed.get("fallback"),
|
|
requested_version=warmed.get("requested_version"),
|
|
)
|
|
# OSS / no overlay: legacy global install (self-host parity).
|
|
spec = f"{request.name}@{request.version}" if request.version else request.name
|
|
result = await arduino_cli.install_library(spec)
|
|
if not result["success"]:
|
|
return InstallResponse(success=False, error=result.get("error"), stdout=result.get("stdout"))
|
|
return InstallResponse(success=True, stdout=result.get("stdout"), fallback=result.get("fallback"), requested_version=result.get("requested_version"))
|
|
except Exception as e:
|
|
raise HTTPException(status_code=500, detail=str(e))
|
|
|
|
class UninstallLibraryRequest(BaseModel):
|
|
name: str
|
|
|
|
class UninstallResponse(BaseModel):
|
|
success: bool
|
|
stdout: str | None = None
|
|
error: str | None = None
|
|
|
|
@router.delete("/uninstall", response_model=UninstallResponse)
|
|
async def uninstall_library(request: UninstallLibraryRequest):
|
|
"""
|
|
Uninstall a specific Arduino library by name.
|
|
"""
|
|
try:
|
|
result = await arduino_cli.uninstall_library(request.name)
|
|
if not result["success"]:
|
|
return UninstallResponse(success=False, error=result.get("error"), stdout=result.get("stdout"))
|
|
return UninstallResponse(success=True, stdout=result.get("stdout"))
|
|
except Exception as e:
|
|
raise HTTPException(status_code=500, detail=str(e))
|
|
|
|
@router.get("/list", response_model=SearchResponse)
|
|
async def list_libraries():
|
|
"""
|
|
List all installed Arduino libraries.
|
|
"""
|
|
try:
|
|
result = await arduino_cli.list_installed_libraries()
|
|
if not result["success"]:
|
|
raise HTTPException(status_code=500, detail=result.get("error", "Failed to list libraries"))
|
|
return SearchResponse(success=True, libraries=result.get("libraries", []))
|
|
except HTTPException:
|
|
raise
|
|
except Exception as e:
|
|
raise HTTPException(status_code=500, detail=str(e))
|