Function list

flow-plugins/src/video_server.rs:77–84

(#[data] state: State)

#[get("/list")]
#[openapi(summary = "list all video streams")]
async fn list(#[data] state: State) -> Result<impl Reply, Rejection> {
    let mapping = state.mapping.lock().await;
    let mut videos = vec![];
    for (descp, _) in mapping.values() {
        videos.push(descp);
    }
    Ok(rweb::reply::json(&videos))
}

#[get("/get_msgs/{id}")]
#[openapi(summary = "get messages from video analyze by id")]