5 function verse.plugins.pep(stream) |
5 function verse.plugins.pep(stream) |
6 stream:add_plugin("pubsub"); |
6 stream:add_plugin("pubsub"); |
7 stream.pep = {}; |
7 stream.pep = {}; |
8 |
8 |
9 stream:hook("pubsub/event", function(event) |
9 stream:hook("pubsub/event", function(event) |
10 return stream:event("pep/"..event.node, { from = event.from, item = event.item[1] } ); |
10 return stream:event("pep/"..event.node, { from = event.from, item = event.item.tags[1] } ); |
11 end); |
11 end); |
12 |
12 |
13 function stream:hook_pep(node, callback, priority) |
13 function stream:hook_pep(node, callback, priority) |
14 local handlers = stream.events._handlers["pep/"..node]; |
14 local handlers = stream.events._handlers["pep/"..node]; |
15 if not(handlers) or #handlers == 0 then |
15 if not(handlers) or #handlers == 0 then |