irc 0.12.7

A simple, thread-safe, and async-friendly library for IRC clients.
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

extern crate futures;
extern crate irc;

use std::default::Default;
use futures::stream::MergedItem;
use irc::error;
use irc::client::prelude::*;

fn main() {
    let cfg1 = Config {
        nickname: Some("pickles".to_owned()),
        server: Some("irc.fyrechat.net".to_owned()),
        channels: Some(vec!["#irc-crate".to_owned()]),
        ..Default::default()
    };
    let cfg2 = Config {
        nickname: Some("pickles".to_owned()),
        server: Some("irc.pdgn.co".to_owned()),
        channels: Some(vec!["#irc-crate".to_owned()]),
        use_ssl: Some(true),
        ..Default::default()
    };

    let server1 = IrcServer::from_config(cfg1).unwrap();
    let server2 = IrcServer::from_config(cfg2).unwrap();
    server1.identify().unwrap();
    server2.identify().unwrap();

    server1.stream().merge(server2.stream()).for_each(|pair| match pair {
        MergedItem::First(message) => process_msg(&server1, message),
        MergedItem::Second(message) => process_msg(&server2, message),
        MergedItem::Both(msg1, msg2) => {
            process_msg(&server1, msg1).unwrap();
            process_msg(&server2, msg2)
        }
    }).wait().unwrap()
}

fn process_msg(server: &IrcServer, message: Message) -> error::Result<()> {
    print!("{}", message);
    match message.command {
        Command::PRIVMSG(ref target, ref msg) => {
            if msg.contains("pickles") {
                server.send_privmsg(target, "Hi!")?;
            }
        }
        _ => (),
    }
    Ok(())
}