35 lines
1.2 KiB
Python
35 lines
1.2 KiB
Python
from datetime import datetime
|
|
from typing import List
|
|
|
|
from fastapi import APIRouter, Depends
|
|
from loguru import logger
|
|
|
|
from app.common.daos.hello_world import get_hello_world_dao, HelloWorldDao
|
|
from app.common.models.deployment.deployment import Deployment, InitDeploymentRequest
|
|
from app.routes.deployment.service import DeploymentService, get_deployment_service
|
|
|
|
router = APIRouter(prefix="/deployment")
|
|
|
|
@router.post("/initDeployment")
|
|
## insert a new Deployment object to db
|
|
async def init_deployment(
|
|
request: InitDeploymentRequest,
|
|
service: DeploymentService = Depends(get_deployment_service)
|
|
) -> Deployment:
|
|
return await service.init_deployment(request)
|
|
|
|
@router.post("/updateDeploymentStatus")
|
|
async def update_deployment(
|
|
request: Deployment,
|
|
service: DeploymentService = Depends(get_deployment_service)
|
|
) -> bool:
|
|
return await service.update_deployment_status(request)
|
|
|
|
@router.get("/checkDeploymentStatus")
|
|
async def check_deployment_status(
|
|
deployment_id: str,
|
|
service: DeploymentService = Depends(get_deployment_service)
|
|
) -> List[Deployment]:
|
|
return await service.check_deployment_status(deployment_id)
|
|
|