# HG changeset patch # User Matthew Wild # Date 1243687778 -3600 # Node ID be8b51a8ab03627a893a5c6384fc486ace08212d # Parent 0ff02499f05c5b3834b184127dda99a5934e380c# Parent 53555f58586f0f0d31a3761d500f900f35e4de93 Automated merge with http://waqas.ath.cx:8000/ diff -r 53555f58586f -r be8b51a8ab03 core/modulemanager.lua --- a/core/modulemanager.lua Fri May 29 22:11:44 2009 +0100 +++ b/core/modulemanager.lua Sat May 30 13:49:38 2009 +0100 @@ -354,6 +354,14 @@ return eventmanager.fire_event(...); end +function api:hook(event, handler) + if self.host ~= '*' then + hosts[self.host].events.add_handler(event, handler); + else + self:log("error", "Global module attempting to hook a host-specific event: %s", event); + end +end + -------------------------------------------------------------------- local actions = {}; diff -r 53555f58586f -r be8b51a8ab03 plugins/mod_iq.lua --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/plugins/mod_iq.lua Sat May 30 13:49:38 2009 +0100 @@ -0,0 +1,33 @@ + +local full_sessions = full_sessions; +local bare_sessions = bare_sessions; + +module:hook("iq/full", function(data) + -- IQ to full JID recieved + local origin, stanza = data.origin, data.stanza; + + local session = full_sessions[stanza.attr.to]; + if session then + -- TODO fire post processing event + session.send(stanza); + return true; + else -- resource not online + -- TODO error reply + end +end); + +module:hook("iq/bare", function(data) + -- IQ to bare JID recieved + local origin, stanza = data.origin, data.stanza; + + -- TODO if not user exists, return an error + -- TODO fire post processing events + -- TODO fire event with the xmlns:tag of the child, or with the id of errors and results +end); + +module:hook("iq/host", function(data) + -- IQ to a local host recieved + local origin, stanza = data.origin, data.stanza; + + -- TODO fire event with the xmlns:tag of the child, or with the id of errors and results +end); diff -r 53555f58586f -r be8b51a8ab03 plugins/mod_message.lua --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/plugins/mod_message.lua Sat May 30 13:49:38 2009 +0100 @@ -0,0 +1,41 @@ + +local full_sessions = full_sessions; +local bare_sessions = bare_sessions; + +local jid_bare = require "util.jid".bare; +local user_exists = require "core.usermanager".user_exists; + +module:hook("message/full", function(data) + -- message to full JID recieved + local origin, stanza = data.origin, data.stanza; + + local session = full_sessions[stanza.attr.to]; + if session then + -- TODO fire post processing event + session.send(stanza); + return true; + else -- resource not online + -- TODO fire event to send to bare JID + end +end); + +module:hook("message/bare", function(data) + -- message to bare JID recieved + local origin, stanza = data.origin, data.stanza; + + local sessions = bare_sessions[stanza.attr.to]; + if sessions then sessions = sessions.sessions; end + + if sessions then + -- some resources are online + -- TODO find top resources willing to accept this message + -- TODO then send them each the stanza + else + -- no resources are online + -- TODO check if the user exists + -- TODO if it doesn't, return an error reply + -- TODO otherwise, apply the default privacy list + -- TODO and store into offline storage + -- TODO or maybe the offline store can apply privacy lists + end +end);