xvc-core 0.7.0

Xvc core for common elements for all commands
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

//! Various utility functions
pub mod completer;
pub mod file;
pub mod git;
pub mod pmp;
pub mod serde;
pub mod store;
pub mod xvcignore;

use std::collections::HashMap;
use std::io::{self, Read};
use std::thread::sleep;
use std::time::Duration;

use crossbeam_channel::{bounded, Receiver};

use crate::error::Result;
use crate::{XvcMetadata, XvcPath, CHANNEL_BOUND};

/// A hashmap to store [XvcMetadata] for [XvcPath]
pub type XvcPathMetadataMap = HashMap<XvcPath, XvcMetadata>;

/// Converts stdin input to a channel.
///
/// It works by creating a thread inside.
///
/// WARNING:
///     Stdin is normally blocking the thread.
///     The thread may continue to live if there is no input in stdin.
///     A future version may also return the thread handle to prevent this.
pub fn stdin_channel() -> Receiver<String> {
    let (input_snd, input_rec) = bounded::<String>(CHANNEL_BOUND);
    crossbeam::scope(|s| {
        s.spawn(move |_| -> Result<()> {
            let stdin = io::stdin();
            loop {
                if input_snd.try_send("".into()).is_err() {
                    break;
                }
                let mut input = stdin.lock();
                let mut buf = Vec::<u8>::new();
                let read_bytes = input.read(&mut buf)?;
                if read_bytes > 0 {
                    let s = String::from_utf8(buf);
                    input_snd
                        .send(s.unwrap_or_else(|_| "[ERROR] Requires UTF-8 Input".into()))
                        .unwrap();
                }
                drop(input);
                sleep(Duration::from_millis(10));
            }

            Ok(())
        });
    })
    .unwrap();

    input_rec
}