qq-cli 0.1.0

A modular Rust QQ task interface for coding agents
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

use super::*;

#[test]
fn lifecycle_lock_blocks_uninstall_before_registry_or_directory_changes() {
    let temp = tempfile::tempdir().unwrap();
    let store = Store::new(temp.path().join("state"));
    let refs = References::with_key(store.root().join("references"), [42; 32]);
    let end = Instant::now() + Duration::from_secs(3);
    let held = operation_lock(&store, end).unwrap();
    let error = crate::napcat::install::installation::uninstall(
        &store,
        "original-target",
        &refs,
        Instant::now() + Duration::from_millis(30),
    )
    .err()
    .unwrap();
    assert_eq!(error.code, "START_BUSY");
    assert!(!store.root().join("registry.json").exists());
    assert!(!store.root().join("installation-operations").exists());
    drop(held);
    let error =
        crate::napcat::install::installation::uninstall(&store, "original-target", &refs, end)
            .err()
            .unwrap();
    assert_eq!(error.code, "INSTALLATION_NOT_FOUND");
}

#[test]
fn startup_lock_serializes_creation_without_blocking_state_observation() {
    let temp = tempfile::tempdir().unwrap();
    let store = Store::new(temp.path().join("state"));
    let end = Instant::now() + Duration::from_secs(3);
    let held = operation_lock(&store, end).unwrap();
    assert!(store.read().unwrap().instances.is_empty());
    let tx = store.transaction(end).unwrap();
    drop(tx);
    let error = operation_lock(&store, Instant::now() + Duration::from_millis(25))
        .err()
        .unwrap();
    assert_eq!(error.code, "START_BUSY");
    assert!(error.retry_safe);
    drop(held);
    operation_lock(&store, end).unwrap();
}