1use plugin::PluginProxy;
 2use event::{Event, ReceiveElement, Priority, Propagation};
 3use minidom::Element;
 4use error::Error;
 5use jid::Jid;
 6use ns;
 7
 8#[derive(Debug)]
 9pub struct MessageEvent {
10    pub from: Jid,
11    pub to: Jid,
12    pub body: String,
13}
14
15impl Event for MessageEvent {}
16
17pub struct MessagingPlugin {
18    proxy: PluginProxy,
19}
20
21impl MessagingPlugin {
22    pub fn new() -> MessagingPlugin {
23        MessagingPlugin {
24            proxy: PluginProxy::new(),
25        }
26    }
27
28    pub fn send_message(&self, to: &Jid, body: &str) -> Result<(), Error> {
29        let mut elem = Element::builder("message")
30                               .attr("type", "chat")
31                               .attr("to", to.to_string())
32                               .build();
33        elem.append_child(Element::builder("body").append(body).build());
34        self.proxy.send(elem);
35        Ok(())
36    }
37
38    fn handle_receive_element(&self, evt: &ReceiveElement) -> Propagation {
39        let elem = &evt.0;
40        if elem.is("message", ns::CLIENT) && elem.attr("type") == Some("chat") {
41            if let Some(body) = elem.get_child("body", ns::CLIENT) {
42                self.proxy.dispatch(MessageEvent { // TODO: safety!!!
43                    from: elem.attr("from").unwrap().parse().unwrap(),
44                    to: elem.attr("to").unwrap().parse().unwrap(),
45                    body: body.text(),
46                });
47            }
48        }
49        Propagation::Continue
50    }
51}
52
53impl_plugin!(MessagingPlugin, proxy, [
54    (ReceiveElement, Priority::Default) => handle_receive_element,
55]);