From efaa1d0aa77d6a583f71d0cfa2787369cbf112a5 Mon Sep 17 00:00:00 2001 From: Till Hoeppner Date: Sun, 28 Jun 2015 18:51:59 +0200 Subject: Add example for event API --- examples/02.rs | 40 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 examples/02.rs diff --git a/examples/02.rs b/examples/02.rs new file mode 100644 index 0000000..69c9d0f --- /dev/null +++ b/examples/02.rs @@ -0,0 +1,40 @@ +extern crate irsc; +extern crate openssl; + +use irsc::*; +use irsc::Command::*; +use irsc::Reply::*; + +use openssl::ssl::{ Ssl, SslContext, SslMethod }; + +fn main() { + let mut s = OwnedClient::new(); + let ssl = Ssl::new(&SslContext::new(SslMethod::Tlsv1).unwrap()).unwrap(); + s.connect_ssl("irc.rizon.net", 6697, ssl); + s.register("irsc", "irsc", "Testing for kori", None); + + let mut shared = s.into_shared(); + let _ = shared.commands() + .map(|(mut cl, msg, c)| { + if let PRIVMSG(to, content) = c { + let from = msg.ident().unwrap(); + let response = format!("{} told me: {}", from.nickname, color::bold(&content)); + + // only send to global channels, to prevent recursion when we are pm'ed + // technically, there are other prefixes than '#', but ignoring them is fine + if to.starts_with("#") && content.starts_with("irsc") { + cl.msg(&to, &response); + } + } + }); + + let _b = shared.replies() + .map(|(mut cl, _msg, r)| { + if let RPL_WELCOME(_) = r { + cl.join("#meep!", None); + } + }); + + // Dedicate this thread to listening and event processing + shared.listen_with_events(); +} -- cgit v1.2.3