panty 0.6.0

Fast gVim summoner
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


use rustc_serialize::json;
use std::io::{Read, Write};
use unix_socket::{UnixListener, UnixStream};
use std::thread;

use summoner;
use collector;
use spell::Spell::*;
use gvim::SpawnOptions;



pub fn meditate(stocks: collector::Stocks, max_stocks: usize, socket_filepath: String, spawn_options: SpawnOptions) {
    let listener = UnixListener::bind(socket_filepath).unwrap();

    for stream in listener.incoming() {
        let spawn_options = spawn_options.clone();

        match stream {
            Ok(mut stream) => {
                let mut buf: String = "".to_string();
                match stream.read_to_string(&mut buf).unwrap() {
                    _ => {
                        match json::decode(buf.as_str()).expect("Fail: json::decode") {
                            Summon {files, keys, role, nofork} =>
                                summon(
                                    stocks.clone(),
                                    summoner::SummonOptions {files: files, role: role, keys: keys},
                                    spawn_options,
                                    nofork,
                                    stream),
                            Renew =>
                                collector::renew(stocks.clone(), max_stocks, spawn_options),
                            Clean =>
                                collector::clean(stocks.clone())
                        }
                    }
                }
            }
            Err(err) => {
                error!("Error: {}", err);
                break;
            }
        }
    }

    drop(listener);
}


fn summon(stocks: collector::Stocks, summon_options: summoner::SummonOptions, spawn_options: SpawnOptions, nofork: bool, mut stream: UnixStream) {
    let stock = collector::emit(stocks.clone());
    let mut stdout_reader = stock.stdout_reader;
    let servername = stock.servername;
    summoner::summon(servername.clone(), stock.window, summon_options);
    collector::collect(stocks.clone(), 1, spawn_options);
    if nofork {
        thread::spawn(move || {
            let mut output = String::new();
            stdout_reader.read_to_string(&mut output).unwrap();
            debug!("gVim output: {}", output);
            stream.write_fmt(format_args!("{}\n", servername)).unwrap();
        });
    } else {
        stream.write_fmt(format_args!("{}\n", servername)).unwrap();
    }
}