from fastapi import APIRouter, HTTPException, Request
|
|
from app.config import settings
|
from app.models.schemas import InitTaskRequest
|
from app.mqtt.init_dispatcher import InitTaskDispatcher
|
from app.services.course_service import CourseService
|
|
router = APIRouter(prefix="/api/v1", tags=["courses"])
|
course_service = CourseService()
|
|
|
def _get_dispatcher(request: Request) -> InitTaskDispatcher:
|
return request.app.state.init_dispatcher
|
|
|
@router.get("/courses")
|
async def list_courses():
|
return course_service.get_course_index()
|
|
|
@router.get("/courses/base-manifest")
|
async def get_base_courses_manifest():
|
payloads = course_service.build_base_course_sync_payloads(settings.base_url)
|
return {
|
"scope": "base",
|
"course_count": len(payloads),
|
"courses": payloads,
|
}
|
|
|
@router.get("/courses/{course_id}")
|
async def get_course(course_id: str):
|
try:
|
return course_service.get_course(course_id)
|
except FileNotFoundError as exc:
|
raise HTTPException(status_code=404, detail=str(exc)) from exc
|
|
|
@router.get("/tasklist")
|
async def get_tasklist():
|
return course_service.get_tasklist()
|
|
|
@router.get("/courses/{course_id}/tasks")
|
async def get_course_tasks(course_id: str):
|
try:
|
return course_service.get_course_task(course_id)
|
except FileNotFoundError as exc:
|
raise HTTPException(status_code=404, detail=str(exc)) from exc
|
|
|
@router.get("/courses/{course_id}/manifest")
|
async def get_course_manifest(course_id: str):
|
try:
|
payload = course_service.build_course_task_sync_payload(course_id, settings.base_url)
|
return payload
|
except FileNotFoundError as exc:
|
raise HTTPException(status_code=404, detail=str(exc)) from exc
|
|
|
@router.post("/devices/init")
|
async def init_device(request: Request, body: InitTaskRequest):
|
auto_init = request.app.state.auto_init
|
commands, status = auto_init.dispatch_manual_init(body.device_id, force=body.force)
|
return {"device_id": body.device_id, "commands": commands, "status": status}
|
|
|
@router.post("/devices/course-init")
|
async def init_course_on_device(request: Request, body: InitTaskRequest):
|
if not body.course_id:
|
raise HTTPException(status_code=400, detail="course_id is required")
|
dispatcher = _get_dispatcher(request)
|
commands = dispatcher.dispatch_course_init(body.device_id, body.course_id)
|
return {
|
"device_id": body.device_id,
|
"course_id": body.course_id,
|
"commands": commands,
|
"status": "dispatched",
|
}
|
