diff mod_archive_muc/mod_archive_muc.lua @ 477:bbe4df968099

mod_archive_muc: A little refactoring to improve code search.
author Waqas Hussain <waqas20@gmail.com>
date Thu, 17 Nov 2011 20:26:49 +0500
parents 2c85635318a5
children
line wrap: on
line diff
--- a/mod_archive_muc/mod_archive_muc.lua	Thu Nov 17 20:24:46 2011 +0500
+++ b/mod_archive_muc/mod_archive_muc.lua	Thu Nov 17 20:26:49 2011 +0500
@@ -7,10 +7,10 @@
 
 local st = require "util.stanza";
 local dm = require "util.datamanager";
-local jid = require "util.jid";
-local datetime = require "util.datetime";
-local um = require "core.usermanager";
-local rom = require "core.rostermanager";
+local jid_compare, jid_split, jid_bare = require "util.jid".compare, require "util.jid".bare, require "util.jid".split;
+local datetime = require "util.datetime".datetime;
+local user_exists = require "core.usermanager".user_exists;
+local is_contact_subscribed = require "core.rostermanager".is_contact_subscribed;
 
 local PREFS_DIR = "archive_muc_prefs";
 local ARCHIVE_DIR = "archive_muc";
@@ -48,10 +48,8 @@
     dm.store(node, host, PREFS_DIR, st.preserialize(data));
 end
 
-local date_time = datetime.datetime;
-
 local function match_jid(rule, id)
-    return not rule or jid.compare(id, rule);
+    return not rule or jid_compare(id, rule);
 end
 
 local function is_earlier(start, coll_start)
@@ -138,10 +136,6 @@
     return false;
 end
 
-local function is_in_roster(node, host, id)
-    return rom.is_contact_subscribed(node, host, jid.bare(id));
-end
-
 local function apply_pref(node, host, jid)
     local pref = load_prefs(node, host);
     if not pref then
@@ -157,7 +151,7 @@
     end
     local default = pref.attr['default'];
     if default == 'roster' then
-        return is_in_roster(node, host, jid);
+        return is_contact_subscribed(node, host, jid_bare(jid));
     elseif default == 'always' then
         return true;
     elseif default == 'never' then
@@ -168,7 +162,7 @@
 
 local function store_msg(msg, node, host)
     local forwarded = st.stanza('forwarded', {xmlns='urn:xmpp:forward:tmp'});
-    forwarded:tag('delay', {xmlns='urn:xmpp:delay',stamp=date_time()}):up();
+    forwarded:tag('delay', {xmlns='urn:xmpp:delay',stamp=datetime()}):up();
     forwarded:add_child(msg);
     dm.list_append(node, host, ARCHIVE_DIR, st.preserialize(forwarded));
 end
@@ -178,12 +172,12 @@
     local origin, stanza = data.origin, data.stanza;
     local body = stanza:child_with_name("body");
     if body then
-        local from_node, from_host = jid.split(stanza.attr.from);
-        local to_node, to_host = jid.split(stanza.attr.to);
-        if um.user_exists(from_node, from_host) and apply_pref(from_node, from_host, stanza.attr.to) then
+        local from_node, from_host = jid_split(stanza.attr.from);
+        local to_node, to_host = jid_split(stanza.attr.to);
+        if user_exists(from_node, from_host) and apply_pref(from_node, from_host, stanza.attr.to) then
             store_msg(stanza, from_node, from_host);
         end
-        if um.user_exists(to_node, to_host) and apply_pref(to_node, to_host, stanza.attr.from) then
+        if user_exists(to_node, to_host) and apply_pref(to_node, to_host, stanza.attr.from) then
             store_msg(stanza, to_node, to_host);
         end
     end