strop-engine 0.30.0

strop editor engine: documents, grammar dispatch, services, sessions — no terminal
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
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

use super::*;
use crate::editor::io::{IoEvent, OpenIntent};

fn hit(path: &std::path::Path, text: &str) -> Item {
    Item {
        badge: None,
        text: path.display().to_string(),
        payload: Payload::Grep {
            path: path.to_path_buf(),
            line: 1,
            col: 1,
            match_len: 3,
            line_text: text.into(),
        },
    }
}

#[test]
fn collecting_a_filtered_location_list_uses_only_its_visible_workset() {
    let (mut editor, _, _) = fixture();
    let items = editor
        .picker
        .as_ref()
        .unwrap()
        .picker
        .items
        .iter()
        .cloned()
        .collect();
    editor.set_picker(crate::editor::picker::PickerGlue::diagnostics(
        strop_picker::Picker::new(Kind::Locations, items, false),
    ));
    editor.feed_text("a.txt");
    editor.wait_picker();
    editor.feed(crate::editor::Key::CtrlO);
    let text = current_text(&editor);
    assert!(text.contains("alpha one"), "{text}");
    assert!(!text.contains("beta two"), "{text}");
}

#[test]
fn stale_source_load_cannot_complete_a_newer_collection() {
    let dir = tempfile::tempdir().unwrap();
    let old = dir.path().join("old.txt");
    let new = dir.path().join("new.txt");
    std::fs::write(&old, "OLD_SOURCE\n").unwrap();
    std::fs::write(&new, "NEW_SOURCE\n").unwrap();
    let mut editor = Editor::new_in(Buffer::from_text(""), dir.path().to_path_buf());
    editor.open_picker(Kind::Search);
    editor.picker_items_fixture(vec![hit(&old, "OLD_SOURCE")]);
    editor.feed(crate::editor::Key::CtrlO);
    let old_owner = editor.collection_build.as_ref().unwrap().owner;
    editor.open_picker(Kind::Search);
    editor.picker_items_fixture(vec![hit(&new, "NEW_SOURCE")]);
    editor.feed(crate::editor::Key::CtrlO);
    let mut old_event = None;
    let mut new_event = None;
    for _ in 0..2 {
        let event = editor
            .io
            .rx
            .as_ref()
            .unwrap()
            .recv_timeout(std::time::Duration::from_secs(5))
            .unwrap();
        let stale = matches!(&event, IoEvent::Open(completion)
            if matches!(completion.ticket.key.intent, OpenIntent::CollectionSource { owner } if owner == old_owner));
        if stale {
            old_event = Some(event);
        } else {
            new_event = Some(event);
        }
    }
    editor.handle_io(old_event.unwrap());
    assert!(editor.collections.is_empty());
    assert_eq!(
        editor.docs.len(),
        1,
        "an obsolete read cannot publish a document"
    );
    editor.handle_io(new_event.unwrap());
    let text = current_text(&editor);
    assert!(text.contains("NEW_SOURCE"), "{text}");
    assert!(!text.contains("OLD_SOURCE"), "{text}");
}

#[test]
fn a_collection_finishing_after_typing_does_not_steal_the_view() {
    let dir = tempfile::tempdir().unwrap();
    let path = dir.path().join("late.txt");
    std::fs::write(&path, "LATE_SOURCE\n").unwrap();
    let mut editor = Editor::new_in(Buffer::from_text("origin\n"), dir.path().to_path_buf());
    let origin = editor.current();
    editor.open_picker(Kind::Search);
    editor.picker_items_fixture(vec![hit(&path, "LATE_SOURCE")]);
    editor.feed(crate::editor::Key::CtrlO);
    editor.feed_text("iuser <esc>");
    editor.wait_io().unwrap();
    assert_eq!(editor.current(), origin);
    assert_eq!(current_text(&editor), "user origin\n");
    assert_eq!(
        editor.collections.len(),
        1,
        "the requested collection is ready in buffers"
    );
}