1use plugin::{PluginProxy};
 2use event::{Event, EventHandler, 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
39impl_plugin!(MessagingPlugin, proxy, [
40    ReceiveElement => Priority::Default,
41]);
42
43impl EventHandler<ReceiveElement> for MessagingPlugin {
44    fn handle(&self, evt: &ReceiveElement) -> Propagation {
45        let elem = &evt.0;
46        if elem.is("message", ns::CLIENT) && elem.attr("type") == Some("chat") {
47            if let Some(body) = elem.get_child("body", ns::CLIENT) {
48                self.proxy.dispatch(MessageEvent { // TODO: safety!!!
49                    from: elem.attr("from").unwrap().parse().unwrap(),
50                    to: elem.attr("to").unwrap().parse().unwrap(),
51                    body: body.text(),
52                });
53            }
54        }
55        Propagation::Continue
56    }
57}