import uuid
from typing import Optional

from fastapi import APIRouter, File, UploadFile, Body
from fastapi.exceptions import HTTPException

from ... import Runtime400Exception
from ...models import FlowModel
from ...models.status import FlowStoreStatus, FlowItemStatus
from ...stores import flow_store as store

router = APIRouter(prefix='/flows', tags=['flows'])


@router.get(
    path='',
    summary='Get all alive Flows\' status',
    response_model=FlowStoreStatus
)
async def _get_items():
    return store.status


@router.get(
    path='/arguments',
    summary='Get all accept arguments of a Flow'
)
async def _fetch_flow_params():
    return FlowModel.schema()['properties']


@router.post(
    path='',
    summary='Create a Flow from a YAML config',
    status_code=201,
    response_model=uuid.UUID
)
async def _create(
        flow: UploadFile = File(...),
        workspace_id: Optional[uuid.UUID] = Body(None)
):
    try:
        return store.add(flow.file, workspace_id)
    except Exception as ex:
        raise Runtime400Exception from ex


# order matters! this must be put in front of del {id}
#  https://fastapi.tiangolo.com/tutorial/path-params/?h=+path#order-matters
@router.delete(
    path='',
    summary='Terminate all running Flows',
)
async def _clear_all():
    store.clear()


@router.delete(
    path='/{id}',
    summary='Terminate a running Flow',
    description='Terminate a running Flow and release its resources'
)
async def _delete(
        id: uuid.UUID,
        workspace: bool = False
):
    try:
        store.delete(id=id, workspace=workspace)
    except KeyError:
        raise HTTPException(status_code=404, detail=f'{id} not found in {store!r}')


@router.get(
    path='/{id}',
    summary='Get the status of a running Flow',
    response_model=FlowItemStatus
)
async def _status(
        id: 'uuid.UUID',
):
    try:
        return store[id]
    except KeyError:
        raise HTTPException(status_code=404, detail=f'{id} not found in {store!r}')


@router.on_event('shutdown')
def _shutdown():
    store.reset()

e4cac5bc304d509a03cfba46e894bb9045fdd641
<mask token>

<mask token>


@router.get(path='', summary="Get all alive Flows' status", response_model=
    FlowStoreStatus)
async def _get_items():
    return store.status


@router.get(path='/arguments', summary='Get all accept arguments of a Flow')
async def _fetch_flow_params():
    return FlowModel.schema()['properties']


@router.post(path='', summary='Create a Flow from a YAML config',
    status_code=201, response_model=uuid.UUID)
async def _create(flow: UploadFile=File(...), workspace_id: Optional[uuid.
    UUID]=Body(None)):
    try:
        return store.add(flow.file, workspace_id)
    except Exception as ex:
        raise Runtime400Exception from ex


@router.delete(path='', summary='Terminate all running Flows')
async def _clear_all():
    store.clear()


@router.delete(path='/{id}', summary='Terminate a running Flow',
    description='Terminate a running Flow and release its resources')
async def _delete(id: uuid.UUID, workspace: bool=False):
    try:
        store.delete(id=id, workspace=workspace)
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.get(path='/{id}', summary='Get the status of a running Flow',
    response_model=FlowItemStatus)
async def _status(id: 'uuid.UUID'):
    try:
        return store[id]
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.on_event('shutdown')
def _shutdown():
    store.reset()

<mask token>
router = APIRouter(prefix='/flows', tags=['flows'])


@router.get(path='', summary="Get all alive Flows' status", response_model=
    FlowStoreStatus)
async def _get_items():
    return store.status


@router.get(path='/arguments', summary='Get all accept arguments of a Flow')
async def _fetch_flow_params():
    return FlowModel.schema()['properties']


@router.post(path='', summary='Create a Flow from a YAML config',
    status_code=201, response_model=uuid.UUID)
async def _create(flow: UploadFile=File(...), workspace_id: Optional[uuid.
    UUID]=Body(None)):
    try:
        return store.add(flow.file, workspace_id)
    except Exception as ex:
        raise Runtime400Exception from ex


@router.delete(path='', summary='Terminate all running Flows')
async def _clear_all():
    store.clear()


@router.delete(path='/{id}', summary='Terminate a running Flow',
    description='Terminate a running Flow and release its resources')
async def _delete(id: uuid.UUID, workspace: bool=False):
    try:
        store.delete(id=id, workspace=workspace)
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.get(path='/{id}', summary='Get the status of a running Flow',
    response_model=FlowItemStatus)
async def _status(id: 'uuid.UUID'):
    try:
        return store[id]
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.on_event('shutdown')
def _shutdown():
    store.reset()

import uuid
from typing import Optional
from fastapi import APIRouter, File, UploadFile, Body
from fastapi.exceptions import HTTPException
from ... import Runtime400Exception
from ...models import FlowModel
from ...models.status import FlowStoreStatus, FlowItemStatus
from ...stores import flow_store as store
router = APIRouter(prefix='/flows', tags=['flows'])


@router.get(path='', summary="Get all alive Flows' status", response_model=
    FlowStoreStatus)
async def _get_items():
    return store.status


@router.get(path='/arguments', summary='Get all accept arguments of a Flow')
async def _fetch_flow_params():
    return FlowModel.schema()['properties']


@router.post(path='', summary='Create a Flow from a YAML config',
    status_code=201, response_model=uuid.UUID)
async def _create(flow: UploadFile=File(...), workspace_id: Optional[uuid.
    UUID]=Body(None)):
    try:
        return store.add(flow.file, workspace_id)
    except Exception as ex:
        raise Runtime400Exception from ex


@router.delete(path='', summary='Terminate all running Flows')
async def _clear_all():
    store.clear()


@router.delete(path='/{id}', summary='Terminate a running Flow',
    description='Terminate a running Flow and release its resources')
async def _delete(id: uuid.UUID, workspace: bool=False):
    try:
        store.delete(id=id, workspace=workspace)
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.get(path='/{id}', summary='Get the status of a running Flow',
    response_model=FlowItemStatus)
async def _status(id: 'uuid.UUID'):
    try:
        return store[id]
    except KeyError:
        raise HTTPException(status_code=404, detail=
            f'{id} not found in {store!r}')


@router.on_event('shutdown')
def _shutdown():
    store.reset()

import uuid
from typing import Optional

from fastapi import APIRouter, File, UploadFile, Body
from fastapi.exceptions import HTTPException

from ... import Runtime400Exception
from ...models import FlowModel
from ...models.status import FlowStoreStatus, FlowItemStatus
from ...stores import flow_store as store

router = APIRouter(prefix='/flows', tags=['flows'])


@router.get(
    path='',
    summary='Get all alive Flows\' status',
    response_model=FlowStoreStatus
)
async def _get_items():
    return store.status


@router.get(
    path='/arguments',
    summary='Get all accept arguments of a Flow'
)
async def _fetch_flow_params():
    return FlowModel.schema()['properties']


@router.post(
    path='',
    summary='Create a Flow from a YAML config',
    status_code=201,
    response_model=uuid.UUID
)
async def _create(
        flow: UploadFile = File(...),
        workspace_id: Optional[uuid.UUID] = Body(None)
):
    try:
        return store.add(flow.file, workspace_id)
    except Exception as ex:
        raise Runtime400Exception from ex


# order matters! this must be put in front of del {id}
#  https://fastapi.tiangolo.com/tutorial/path-params/?h=+path#order-matters
@router.delete(
    path='',
    summary='Terminate all running Flows',
)
async def _clear_all():
    store.clear()


@router.delete(
    path='/{id}',
    summary='Terminate a running Flow',
    description='Terminate a running Flow and release its resources'
)
async def _delete(
        id: uuid.UUID,
        workspace: bool = False
):
    try:
        store.delete(id=id, workspace=workspace)
    except KeyError:
        raise HTTPException(status_code=404, detail=f'{id} not found in {store!r}')


@router.get(
    path='/{id}',
    summary='Get the status of a running Flow',
    response_model=FlowItemStatus
)
async def _status(
        id: 'uuid.UUID',
):
    try:
        return store[id]
    except KeyError:
        raise HTTPException(status_code=404, detail=f'{id} not found in {store!r}')


@router.on_event('shutdown')
def _shutdown():
    store.reset()
