gobby-wiki 0.7.0

Gobby wiki CLI shell
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

use super::*;

#[test]
fn persisted_frame_sources_are_removed_after_successful_loop() {
    let vault = tempfile::tempdir().expect("vault tempdir");
    let record = SourceManifest::register(
        vault.path(),
        SourceDraft {
            location: "/tmp/video.mp4".to_string(),
            kind: SourceKind::Video,
            fetched_at: "2026-05-29T21:30:00Z".to_string(),
            content: Vec::new(),
            title: Some("video.mp4".to_string()),
            citation: None,
            license: None,
            ingestion_method: IngestionMethod::Manual,
            compile_status: CompileStatus::Pending,
        },
    )
    .expect("source record");
    let kept = temp_file_with_bytes(".jpg", b"shared frame").expect("frame temp");
    let kept_path = kept.into_temp_path().keep().expect("keep frame");
    let samples = vec![
        VideoFrameSample {
            timestamp_seconds: 0,
            timestamp: "00:00:00".to_string(),
            source_asset: kept_path.clone(),
            source_reference: path_to_string(&kept_path),
        },
        VideoFrameSample {
            timestamp_seconds: 4,
            timestamp: "00:00:04".to_string(),
            source_asset: kept_path.clone(),
            source_reference: path_to_string(&kept_path),
        },
    ];

    let _persisted = persist_video_frame_assets(
        vault.path(),
        &record,
        "video.mp4",
        samples,
        &[kept_path.clone(), kept_path.clone()],
        &[],
    )
    .expect("persist shared frame source");

    assert!(
        !kept_path.exists(),
        "source temp frame should be removed after all frames are persisted"
    );
}

#[test]
fn persisted_frame_read_failure_drops_remaining_kept_temp_frames() {
    let vault = tempfile::tempdir().expect("vault tempdir");
    let record = SourceManifest::register(
        vault.path(),
        SourceDraft {
            location: "/tmp/video.mp4".to_string(),
            kind: SourceKind::Video,
            fetched_at: "2026-05-29T21:30:00Z".to_string(),
            content: Vec::new(),
            title: Some("video.mp4".to_string()),
            citation: None,
            license: None,
            ingestion_method: IngestionMethod::Manual,
            compile_status: CompileStatus::Pending,
        },
    )
    .expect("source record");
    let missing_path = std::env::temp_dir().join(format!(
        "gwiki-missing-frame-{}-{}.jpg",
        std::process::id(),
        "read-failure"
    ));
    let _ = std::fs::remove_file(&missing_path);
    let kept = temp_file_with_bytes(".jpg", b"kept frame").expect("frame temp");
    let kept_path = kept.into_temp_path().keep().expect("keep frame");
    let samples = vec![
        VideoFrameSample {
            timestamp_seconds: 0,
            timestamp: "00:00:00".to_string(),
            source_asset: missing_path.clone(),
            source_reference: path_to_string(&missing_path),
        },
        VideoFrameSample {
            timestamp_seconds: 4,
            timestamp: "00:00:04".to_string(),
            source_asset: kept_path.clone(),
            source_reference: path_to_string(&kept_path),
        },
    ];

    let error = persist_video_frame_assets(
        vault.path(),
        &record,
        "video.mp4",
        samples,
        &[missing_path, kept_path.clone()],
        &[],
    )
    .expect_err("missing frame read fails");

    assert!(error.to_string().contains("read sampled video frame asset"));
    assert!(
        !kept_path.exists(),
        "remaining kept temp frame should be cleaned"
    );
}