prosody
e1272aeef31c
plugins/mod_pubsub/mod_pubsub.lua

Find changesets by keywords by author, files, the commit message, revision number or hash, or revset expression.

Software / code / prosody

Comparison

plugins/mod_pubsub/mod_pubsub.lua @ 8213:e1272aeef31c

mod_pubsub: Add item persistence using mod_storage_*’s archive store.
author Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
date Sat, 15 Apr 2017 01:21:55 +0100
parent 8210:352d605b1178
child 8218:2c75a5ba58fc
comparison
equal deleted inserted replaced
8212:66173e4b355a 8213:e1272aeef31c
18 local handlers = lib_pubsub.handlers; 18 local handlers = lib_pubsub.handlers;
19 19
20 module:depends("disco"); 20 module:depends("disco");
21 module:add_identity("pubsub", "service", pubsub_disco_name); 21 module:add_identity("pubsub", "service", pubsub_disco_name);
22 module:add_feature("http://jabber.org/protocol/pubsub"); 22 module:add_feature("http://jabber.org/protocol/pubsub");
23
24 local archive = module:open_store("pubsub", "archive");
23 25
24 function handle_pubsub_iq(event) 26 function handle_pubsub_iq(event)
25 local origin, stanza = event.origin, event.stanza; 27 local origin, stanza = event.origin, event.stanza;
26 local pubsub_tag = stanza.tags[1]; 28 local pubsub_tag = stanza.tags[1];
27 local action = pubsub_tag.tags[1]; 29 local action = pubsub_tag.tags[1];
32 local handler = handlers[stanza.attr.type.."_"..action.name]; 34 local handler = handlers[stanza.attr.type.."_"..action.name];
33 if handler then 35 if handler then
34 handler(origin, stanza, action, service); 36 handler(origin, stanza, action, service);
35 return true; 37 return true;
36 end 38 end
39 end
40
41 local function simple_itemstore(config, node)
42 return lib_pubsub.simple_itemstore(archive, config, node, expose_publisher);
37 end 43 end
38 44
39 function simple_broadcast(kind, node, jids, item, actor) 45 function simple_broadcast(kind, node, jids, item, actor)
40 if item then 46 if item then
41 item = st.clone(item); 47 item = st.clone(item);
222 }; 228 };
223 229
224 autocreate_on_publish = autocreate_on_publish; 230 autocreate_on_publish = autocreate_on_publish;
225 autocreate_on_subscribe = autocreate_on_subscribe; 231 autocreate_on_subscribe = autocreate_on_subscribe;
226 232
233 itemstore = simple_itemstore;
227 broadcaster = simple_broadcast; 234 broadcaster = simple_broadcast;
228 get_affiliation = get_affiliation; 235 get_affiliation = get_affiliation;
229 236
230 normalize_jid = jid_bare; 237 normalize_jid = jid_bare;
231 })); 238 }));