Function create_datasource

api/handlers/datasources.py:21–34

Create a new datasource. The datasource will be henceforth identified by account/container which must be unique or this function will return a 400.

(
    datasource: DataSource,
    datasources: AgnosticCollection = Depends(datasource_repo.collection),
    current_user: dict = Depends(get_current_user),
)

@router.post("/api/datasources", status_code=201, response_model=DataSource)
async def create_datasource(
    datasource: DataSource,
    datasources: AgnosticCollection = Depends(datasource_repo.collection),
    current_user: dict = Depends(get_current_user),
):
    """
    Create a new datasource. The datasource will be henceforth identified by account/container which
    must be unique or this function will return a 400.
    """
    if await datasource_exists(datasource.account, datasource.container):
        raise HTTPException(status_code=409, detail="Datasource Already Exists")

    datasource = await create(datasource=datasource, user=current_user)
    return datasource


@router.get("/api/datasources", response_model=list[DataSource])