mirror of
https://github.com/fusion44/blitz_api.git
synced 2026-08-13 11:52:45 +02:00
83 lines
2.1 KiB
Python
83 lines
2.1 KiB
Python
from fastapi import APIRouter, HTTPException, status
|
|
from fastapi.params import Depends
|
|
from pydantic import BaseModel
|
|
|
|
import app.repositories.apps as repo
|
|
import app.routers.apps_docs as docs
|
|
from app.auth.auth_bearer import JWTBearer
|
|
from app.external.sse_starlette import EventSourceResponse
|
|
|
|
_PREFIX = "apps"
|
|
|
|
router = APIRouter(prefix=f"/{_PREFIX}", tags=["Apps"])
|
|
|
|
|
|
@router.get(
|
|
"/status",
|
|
name=f"{_PREFIX}/status",
|
|
summary="Get the status available apps.",
|
|
response_description=docs.get_app_status_response_docs,
|
|
dependencies=[Depends(JWTBearer())],
|
|
)
|
|
async def get_status():
|
|
try:
|
|
return await repo.get_app_status()
|
|
except:
|
|
raise HTTPException(
|
|
status.HTTP_500_INTERNAL_SERVER_ERROR, detail="Unknown error"
|
|
)
|
|
|
|
|
|
@router.get(
|
|
"/status/{id}",
|
|
name=f"{_PREFIX}/status",
|
|
summary="Get the status of a single app by id.",
|
|
dependencies=[Depends(JWTBearer())],
|
|
)
|
|
async def get_single_status(id):
|
|
try:
|
|
return await repo.get_app_status_single(id)
|
|
except:
|
|
raise HTTPException(
|
|
status.HTTP_500_INTERNAL_SERVER_ERROR, detail="Unknown error"
|
|
)
|
|
|
|
|
|
@router.get(
|
|
"/status-sub",
|
|
name=f"{_PREFIX}/status-sub",
|
|
summary="Subscribe to status changes of currently installed apps.",
|
|
response_description=docs.get_app_status_sub_response_docs,
|
|
dependencies=[Depends(JWTBearer())],
|
|
)
|
|
async def get_status():
|
|
try:
|
|
return EventSourceResponse(repo.get_app_status_sub())
|
|
except:
|
|
raise HTTPException(
|
|
status.HTTP_500_INTERNAL_SERVER_ERROR, detail="Unknown error"
|
|
)
|
|
|
|
|
|
@router.post(
|
|
"/install/{name}",
|
|
name=f"{_PREFIX}/install",
|
|
summary="Install app",
|
|
dependencies=[Depends(JWTBearer())],
|
|
)
|
|
async def install_app(name: str):
|
|
return await repo.install_app_sub(name)
|
|
|
|
|
|
class UninstallData(BaseModel):
|
|
keepData: bool = True
|
|
|
|
|
|
@router.post(
|
|
"/uninstall/{name}",
|
|
name=f"{_PREFIX}/install",
|
|
summary="Uninstall app",
|
|
dependencies=[Depends(JWTBearer())],
|
|
)
|
|
async def uninstall_app(name: str, data: UninstallData):
|
|
return await repo.uninstall_app_sub(name, data.keepData)
|