rink 0.3.0

Unit conversion tool and library, similar to frink
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

// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.

#[cfg(feature = "ircbot")]
extern crate irc;
#[cfg(feature = "ircbot")]
extern crate glob;
#[cfg(feature = "ircbot")]
extern crate rink;

#[cfg(feature = "ircbot")]
fn main() {
    use irc::client::prelude::*;
    use rink::*;
    use glob::glob;
    use std::thread;

    #[cfg(feature = "sandbox")]
    fn eval(line: &str) -> String {
        one_line_sandbox(line)
    }

    #[cfg(not(feature = "sandbox"))]
    fn eval(line: &str) -> String {
        let mut ctx = load().unwrap();
        ctx.short_output = true;
        match one_line(&mut ctx, line) {
            Ok(v) => v,
            Err(e) => e
        }
    }

    fn run(config: &str) {
        let server = IrcServer::new(config).unwrap();
        server.identify().unwrap();
        let nick = server.config().nickname.clone().unwrap();
        let mut prefix = nick.clone();
        prefix.push(':');
        for message in server.iter() {
            if let Ok(Message { command: Command::PRIVMSG(ref chan, ref message_str), ..}) = message {
                let prefixed = message_str.starts_with(&*prefix);
                if prefixed || &*chan == &*nick {
                    let reply_to = if &*chan == &*nick {
                        message.as_ref().unwrap().source_nickname().unwrap()
                    } else {
                        &*chan
                    };
                    let line = if prefixed {
                        message_str[prefix.len()..].trim()
                    } else {
                        &message_str[..]
                    };
                    let mut i = 0;
                    let reply = eval(line);
                    for line in reply.lines() {
                        if line.trim().len() > 0 {
                            server.send(Command::NOTICE(reply_to.to_owned(), line.to_owned())).unwrap();
                            i += 1;
                        }
                        // cut off early
                        if i > 4 {
                            break;
                        }
                    }
                }
            } else if let Err(e) = message {
                println!("{}", e);
            }
        }
    }

    let mut threads = vec![];
    for config in glob("servers/*.json").expect("Glob failed") {
        match config {
            Ok(config) => threads.push(thread::spawn(move || run(config.to_str().unwrap()))),
            Err(e) => println!("{:?}", e)
        }
    }
    for thread in threads {
        thread.join().unwrap()
    }
}

#[cfg(not(feature = "ircbot"))]
fn main() {
    println!("Rink was not compiled with IRC support.");
}