fmtview 0.3.1

Fast CLI viewer for highlighting, search, and diffs across JSON, JSONL, markup, Markdown, TOML, text, and Jinja
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

use std::{io::Write, time::Duration};

use tempfile::NamedTempFile;

use crate::transform::{FormatKind, FormatOptions};

use super::*;

fn temp_source(contents: &[u8]) -> (NamedTempFile, InputSource) {
    let mut temp = NamedTempFile::new().unwrap();
    temp.write_all(contents).unwrap();
    temp.flush().unwrap();
    let source = InputSource::from_arg(temp.path().to_str().unwrap(), None).unwrap();
    (temp, source)
}

#[test]
fn lazy_load_reads_only_records_needed_for_first_window() {
    let mut data = Vec::new();
    for index in 0..1000 {
        writeln!(
            data,
            "{{\"index\":{index},\"payload\":{{\"name\":\"item\",\"ok\":true}}}}"
        )
        .unwrap();
    }
    let (_temp, source) = temp_source(&data);
    let options = FormatOptions {
        kind: FormatKind::Auto,
        indent: 2,
    };
    let file = LazyTransformedRecordsFile::new(&source, options).unwrap();

    let lines = file.read_window(0, 12).unwrap();

    assert_eq!(lines[0], "{");
    assert!(lines.iter().any(|line| line.contains("\"payload\"")));
    assert!(
        file.loaded_record_count() < 4,
        "first window should not scan all input records"
    );
}

#[test]
fn lazy_load_idle_preload_advances_known_line_count() {
    let mut data = Vec::new();
    for index in 0..10 {
        writeln!(data, "{{\"index\":{index},\"payload\":{{\"ok\":true}}}}").unwrap();
    }
    let (_temp, source) = temp_source(&data);
    let options = FormatOptions {
        kind: FormatKind::Auto,
        indent: 2,
    };
    let file = LazyTransformedRecordsFile::new(&source, options).unwrap();

    file.read_window(0, 4).unwrap();
    let before = file.line_count();
    let changed = file.preload(20, 2, Duration::from_secs(1)).unwrap();
    let after = file.line_count();

    assert!(changed);
    assert!(after > before);
    assert!(!file.line_count_exact());
}

#[test]
fn explicit_jsonl_errors_on_malformed_record() {
    let (_temp, source) = temp_source(b"{\"ok\":true}\n{\"broken\":\n");
    let options = FormatOptions {
        kind: FormatKind::Jsonl,
        indent: 2,
    };
    let file = LazyTransformedRecordsFile::new(&source, options).unwrap();

    let error = file.read_window(0, 20).unwrap_err();

    assert!(error.to_string().contains("failed to parse JSON record"));
}

#[test]
fn lazy_load_reads_spooled_lines_after_preload() {
    let (_temp, source) = temp_source(b"{\"a\":1}\n{\"b\":2}\n{\"c\":3}\n");
    let options = FormatOptions {
        kind: FormatKind::Auto,
        indent: 2,
    };
    let file = LazyTransformedRecordsFile::new(&source, options).unwrap();

    assert!(file.preload(20, 3, Duration::from_secs(1)).unwrap());
    assert!(file.indexed_line_count() > 6);
    assert!(file.read_window(0, 1).unwrap()[0].contains('{'));
    assert!(
        file.read_window(file.indexed_line_count().saturating_sub(2), 2)
            .unwrap()
            .iter()
            .any(|line| line.contains("\"c\""))
    );
}