verse
e86144a4eaa1
plugins/pubsub.lua

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

Software / code / verse

Comparison

plugins/pubsub.lua @ 395:e86144a4eaa1

plugins: Cleanup [luacheck]
author Kim Alvefur <zash@zash.se>
date Thu, 03 Sep 2015 22:41:27 +0200
parent 348:34b878d58948
child 437:2762abec4c63
comparison
equal deleted inserted replaced
394:c2e959b60c13 395:e86144a4eaa1
1 local verse = require "verse"; 1 local verse = require "verse";
2 local jid_bare = require "util.jid".bare;
3 2
4 local t_insert = table.insert; 3 local t_insert = table.insert;
5 4
6 local xmlns_pubsub = "http://jabber.org/protocol/pubsub"; 5 local xmlns_pubsub = "http://jabber.org/protocol/pubsub";
7 local xmlns_pubsub_owner = "http://jabber.org/protocol/pubsub#owner"; 6 local xmlns_pubsub_owner = "http://jabber.org/protocol/pubsub#owner";
8 local xmlns_pubsub_event = "http://jabber.org/protocol/pubsub#event"; 7 local xmlns_pubsub_event = "http://jabber.org/protocol/pubsub#event";
9 local xmlns_pubsub_errors = "http://jabber.org/protocol/pubsub#errors"; 8 -- local xmlns_pubsub_errors = "http://jabber.org/protocol/pubsub#errors";
10 9
11 local pubsub = {}; 10 local pubsub = {};
12 local pubsub_mt = { __index = pubsub }; 11 local pubsub_mt = { __index = pubsub };
13 12
14 function verse.plugins.pubsub(stream) 13 function verse.plugins.pubsub(stream)
211 function pubsub_node:subscribe(jid, options, callback) 210 function pubsub_node:subscribe(jid, options, callback)
212 jid = jid or self.stream.jid; 211 jid = jid or self.stream.jid;
213 if options ~= nil then 212 if options ~= nil then
214 error("Subscription configuration is not implemented yet."); 213 error("Subscription configuration is not implemented yet.");
215 end 214 end
216 self.stream:send_iq(pubsub_iq("set", self.service, nil, "subscribe", self.node, jid, id) 215 self.stream:send_iq(pubsub_iq("set", self.service, nil, "subscribe", self.node, jid)
217 , callback); 216 , callback);
218 end 217 end
219 218
220 function pubsub_node:subscription(callback) 219 function pubsub_node:subscription(callback)
221 error("Not implemented yet."); 220 error("Not implemented yet.");