artifactize-core 0.11.0

The library behind artifactize: Artifacts, evals, reviews, the monitor and review models, and the shared operations every interface calls.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

//! Terminal UI setup and cancellation workflows.

use super::{Context, Screens, cancellation_listener};
use std::path::PathBuf;

pub(super) async fn monitor(context: Context, all: bool, screens: Screens) -> Result<u8, String> {
    if context.json {
        return Err("monitor is an interactive terminal UI; --json is not supported.".into());
    }
    if all && context.repo.is_some() {
        return Err("monitor accepts --repo or --all, not both.".into());
    }
    let state = crate::store::state_dir(context.state_dir.as_deref())?;
    let repo = (!all).then(|| context.repo.unwrap_or_else(|| PathBuf::from(".")));
    let (cancellation, listener) = cancellation_listener()?;
    let result = (screens.monitor)(state, repo, cancellation).await;
    listener.abort();
    result?;
    Ok(0)
}

pub(super) async fn review(
    context: Context,
    request: Option<crate::types::RequestId>,
    all: bool,
    reviewer: Option<crate::types::ReviewerId>,
    screens: Screens,
) -> Result<u8, String> {
    if context.json {
        return Err("review is an interactive terminal UI; --json is not supported.".into());
    }
    if all && context.repo.is_some() {
        return Err("review accepts --repo or --all, not both.".into());
    }
    let reviewer = match reviewer {
        Some(reviewer) => Ok(reviewer),
        None => crate::human::default_reviewer(),
    }?;
    let state = crate::store::state_dir(context.state_dir.as_deref())?;
    if let Some(id) = &request {
        crate::store::read_request(&state, id).await?;
    }
    // The list searches every repository; --repo starts it on that repository's term, and
    // --all (the default) stays accepted.
    let repo = context.repo;
    let (cancellation, listener) = cancellation_listener()?;
    let result = (screens.review)(state, repo, reviewer, request, cancellation).await;
    listener.abort();
    result?;
    Ok(0)
}