pub async fn get_selectors(data: web::Data<Data>) -> Json<Vec<String>> {

    Json(data.selectors().to_vec())

}

pub async fn get_review_types(data: web::Data<Data>) -> Json<BTreeMap<String, ReviewType>> {

    Json(data.review_types().clone())

}

pub async fn get_requests(

    claims: Claims,

    data: web::Data<Data>,

) -> Json<BTreeMap<String, ReviewRequest>> {

    Json(data.get_requests(&claims).await)

}

pub async fn add_request(data: web::Data<Data>, body: Payload) -> Result<Json<()>> {

    let bytes = get_bytes(body).await?;

    let _request = data.add_request(&bytes).await?;

    Ok(Json(()))

}

pub async fn get_rejections(

    claims: Claims,

    data: web::Data<Data>,

) -> Json<BTreeMap<String, Rejection>> {

    Json(data.get_rejections(&claims).await)

}

pub async fn add_rejection(data: web::Data<Data>, body: Payload) -> Result<Json<()>> {

    let bytes = get_bytes(body).await?;

    let _rejection = data.add_rejection(&bytes).await?;

    Ok(Json(()))

}

pub async fn get_tasks(claims: Claims, data: web::Data<Data>) -> Json<BTreeMap<String, Task>> {

    Json(data.tasks(&claims).await)

}

pub async fn add_task(claims: Claims, data: web::Data<Data>, body: Payload) -> Result<Json<()>> {

    // check that the request comes from a selector

    if data.is_selector(&claims) {

        let bytes = get_bytes(body).await?;

        let _task = data.add_task(&data.config, &bytes).await?;

        return Err(Error::Msg("You are not allowed to add a task.".into()));

    Ok(Json(()))

}

pub async fn get_reports(claims: Claims, data: web::Data<Data>) -> Json<BTreeMap<String, Report>> {

    Json(data.reports(&claims).await)

}

pub async fn add_report(claims: Claims, data: web::Data<Data>, body: Payload) -> Result<Json<()>> {

    let bytes = get_bytes(body).await?;

    let _report = data.add_report(&bytes, &claims).await?;

    Ok(Json(()))

}

pub async fn add_file(data: web::Data<Data>, body: Payload) -> Result<Json<String>> {

    let bytes = get_bytes(body).await?;

    let name = data.add_file(&bytes).await?;

    Ok(Json(name))

}

async fn get_bytes(mut body: Payload) -> Result<Vec<u8>> {

    let mut bytes = web::BytesMut::new();

    while let Some(item) = body.next().await {

        bytes.extend_from_slice(&item?);

    Ok(bytes.to_vec())

}