Function compute_job_info

crates/hyperqueue/src/server/client/mod.rs:662–686

(
    state_ref: &StateRef,
    selector: &IdSelector,
    include_running_tasks: bool,
)

}

fn compute_job_info(
    state_ref: &StateRef,
    selector: &IdSelector,
    include_running_tasks: bool,
) -> ToClientMessage {
    let state = state_ref.get();

    let jobs: Vec<_> = match selector {
        IdSelector::All => state
            .jobs()
            .map(|j| j.make_job_info(include_running_tasks))
            .collect(),
        IdSelector::LastN(n) => state
            .last_n_ids(*n)
            .filter_map(|id| state.get_job(id))
            .map(|j| j.make_job_info(include_running_tasks))
            .collect(),
        IdSelector::Specific(array) => array
            .iter()
            .filter_map(|id| state.get_job(JobId::new(id)))
            .map(|j| j.make_job_info(include_running_tasks))
            .collect(),
    };
    ToClientMessage::JobInfoResponse(JobInfoResponse { jobs })
}

async fn handle_job_cancel(
    state_ref: &StateRef,