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
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
use crate::cursorfile;
use crate::utils::stdioutils;
use crate::KhResult;
use crate::seqfile;
use structopt::StructOpt;
#[derive(Debug, StructOpt)]
pub struct CursorArgs {
/// Move the cursor on the selection.
#[structopt(name = "direction", raw(possible_values = "&CursorDirection::variants()"))]
pub direction: Option<CursorDirection>,
}
arg_enum! {
#[derive(Debug)]
pub enum CursorDirection {
Next,
Prev,
}
}
enum Direction {
Up,
Down,
}
pub fn do_cursor(args: &CursorArgs) -> KhResult<()> {
if !stdioutils::is_stdin_tty() {
write_stdin_to_cursorfile()?;
} else {
//println!("stdin is tty")
if let Some(direction) = &args.direction {
match direction {
CursorDirection::Prev => return cursor_sequence_move(&Direction::Up),
CursorDirection::Next => return cursor_sequence_move(&Direction::Down),
}
};
}
if !stdioutils::is_stdout_tty() || stdioutils::is_stdin_tty() {
write_cursorfile_to_stdout();
}
Ok(())
}
fn write_stdin_to_cursorfile() -> KhResult<()> {
let lines = stdioutils::read_lines_from_stdin()?;
if lines.len() > 1 {
Err("Too many lines on stdin")?;
};
cursorfile::write_cursorfile(&lines[0])?;
Ok(())
}
fn write_cursorfile_to_stdout() {
if let Ok(cursor) = cursorfile::read_cursorfile() {
khprintln!("{}", cursor);
}
}
fn cursor_sequence_move(direction: &Direction) -> KhResult<()> {
let cursor_event = cursorfile::read_cursorfile()?;
let mut seq = seqfile::read_seqfile_khlines()?;
let next_elem = match direction {
Direction::Up => {
let mut seq_rev = seq.rev();
seq_rev.find(|line| line == &cursor_event);
seq_rev.next()
},
Direction::Down => {
seq.find(|line| line == &cursor_event);
seq.next()
}
};
match next_elem {
Some(next_elem) => cursorfile::write_cursorfile(&next_elem.to_string()),
None => {
warn!("Already at end of sequence");
Ok(())
}
}
}
#[cfg(test)]
mod integration {
use super::*;
use crate::testutils;
use assert_fs::prelude::*;
use predicates::prelude::*;
#[test]
fn test_with_stdin() {
let testdir = testutils::prepare_testdir_empty();
let expected_str = "hi there";
stdioutils::test_stdin_write(expected_str);
let args = CursorArgs{direction: None};
do_cursor(&args).unwrap();
testdir.child(".khaleesi/cursor").assert(expected_str);
}
#[test]
fn test_cursor_sequence_move_next() {
let testdir = testutils::prepare_testdir("testdir_with_seq_and_cursor");
let args = CursorArgs{direction: Some(CursorDirection::Next)};
do_cursor(&args).unwrap();
let out = "1182988800 rfc_multi_day_allday.ics";
let predicate = predicate::str::similar(out);
testdir.child(".khaleesi/cursor").assert(predicate);
}
#[test]
fn test_cursor_sequence_move_prev_at_end() {
let testdir = testutils::prepare_testdir("testdir_with_seq_and_cursor");
let args = CursorArgs{direction: Some(CursorDirection::Prev)};
do_cursor(&args).unwrap();
let out = "1544740200 twodaysacrossbuckets.ics\n";
let predicate = predicate::str::similar(out);
testdir.child(".khaleesi/cursor").assert(predicate);
}
#[test]
fn test_with_stdin_linebreak() {
let _testdir = testutils::prepare_testdir_empty();
let expected_str = "hi\nthere";
stdioutils::test_stdin_write(expected_str);
let args = CursorArgs {direction: None};
let result = do_cursor(&args);
assert!(result.is_err());
//testdir.child(".khaleesi/cursor").assert(expected_str);
}
#[test]
fn test_no_stdin() {
let testdir = testutils::prepare_testdir("testdir_with_cursor");
let args = CursorArgs {direction: None};
do_cursor(&args).unwrap();
let out = stdioutils::test_stdout_clear();
let predicate = predicate::str::similar(out);
testdir.child(".khaleesi/cursor").assert(predicate);
}
}
|
