Software /
code /
verse
Annotate
plugins/pubsub.lua @ 438:98dc1750584d 0.10.0
pubsub: Support for 'notify' in retract and purge operations
This is a slight API change for :retract(), but should be backwards-compatible.
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Mon, 06 Dec 2021 09:09:50 +0000 (2021-12-06) |
parent | 437:2762abec4c63 |
child | 468:fae5ae0ddb84 |
rev | line source |
---|---|
250 | 1 local verse = require "verse"; |
2 | |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
3 local t_insert = table.insert; |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
4 |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
5 local xmlns_pubsub = "http://jabber.org/protocol/pubsub"; |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
6 local xmlns_pubsub_owner = "http://jabber.org/protocol/pubsub#owner"; |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
7 local xmlns_pubsub_event = "http://jabber.org/protocol/pubsub#event"; |
395 | 8 -- local xmlns_pubsub_errors = "http://jabber.org/protocol/pubsub#errors"; |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
9 |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
10 local pubsub = {}; |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
11 local pubsub_mt = { __index = pubsub }; |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
12 |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
13 function verse.plugins.pubsub(stream) |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
14 stream.pubsub = setmetatable({ stream = stream }, pubsub_mt); |
159
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
15 stream:hook("message", function (message) |
283
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
16 local m_from = message.attr.from; |
193
fa6e1e65cb3c
plugins.pubsub: Fix to use :childtags() for iterating through items in a pubsub notification (:matching_tags() was removed from Prosody)
Matthew Wild <mwild1@gmail.com>
parents:
165
diff
changeset
|
17 for pubsub_event in message:childtags("event", xmlns_pubsub_event) do |
159
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
18 local items = pubsub_event:get_child("items"); |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
19 if items then |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
20 local node = items.attr.node; |
193
fa6e1e65cb3c
plugins.pubsub: Fix to use :childtags() for iterating through items in a pubsub notification (:matching_tags() was removed from Prosody)
Matthew Wild <mwild1@gmail.com>
parents:
165
diff
changeset
|
21 for item in items:childtags("item") do |
159
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
22 stream:event("pubsub/event", { |
283
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
23 from = m_from; |
159
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
24 node = node; |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
25 item = item; |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
26 }); |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
27 end |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
28 end |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
29 end |
88cc513e81c8
plugins.pubsub: Fire pubsub/event on incoming pubsub notifications
Matthew Wild <mwild1@gmail.com>
parents:
154
diff
changeset
|
30 end); |
165
8c67ea868c06
plugins.pubsub: Return true to indicate success loading
Matthew Wild <mwild1@gmail.com>
parents:
159
diff
changeset
|
31 return true; |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
32 end |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
33 |
248
c4b55b0dc6ba
plugins.pubsub: Make the old functions wrap the new.
Kim Alvefur <zash@zash.se>
parents:
222
diff
changeset
|
34 -- COMPAT |
221
efb4f60ba36e
plugins.pubsub: implement node creation
Kim Alvefur <zash@zash.se>
parents:
193
diff
changeset
|
35 function pubsub:create(server, node, callback) |
265
2a2326a8f9e8
plugins.pubsub: Fix to use correct method in backwards-compatibility code
Matthew Wild <mwild1@gmail.com>
parents:
264
diff
changeset
|
36 return self:service(server):node(node):create(nil, callback); |
221
efb4f60ba36e
plugins.pubsub: implement node creation
Kim Alvefur <zash@zash.se>
parents:
193
diff
changeset
|
37 end |
efb4f60ba36e
plugins.pubsub: implement node creation
Kim Alvefur <zash@zash.se>
parents:
193
diff
changeset
|
38 |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
39 function pubsub:subscribe(server, node, jid, callback) |
265
2a2326a8f9e8
plugins.pubsub: Fix to use correct method in backwards-compatibility code
Matthew Wild <mwild1@gmail.com>
parents:
264
diff
changeset
|
40 return self:service(server):node(node):subscribe(jid, nil, callback); |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
41 end |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
42 |
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
43 function pubsub:publish(server, node, id, item, callback) |
265
2a2326a8f9e8
plugins.pubsub: Fix to use correct method in backwards-compatibility code
Matthew Wild <mwild1@gmail.com>
parents:
264
diff
changeset
|
44 return self:service(server):node(node):publish(id, nil, item, callback); |
154
a4dc96890729
plugins.pubsub, squishy: New pubsub plugin (basic)
Matthew Wild <mwild1@gmail.com>
parents:
diff
changeset
|
45 end |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
46 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
47 -------------------------------------------------------------------------- |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
48 ---------------------New and improved PubSub interface-------------------- |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
49 -------------------------------------------------------------------------- |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
50 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
51 local pubsub_service = {}; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
52 local pubsub_service_mt = { __index = pubsub_service }; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
53 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
54 -- TODO should the property be named 'jid' instead? |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
55 function pubsub:service(service) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
56 return setmetatable({ stream = self.stream, service = service }, pubsub_service_mt) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
57 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
58 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
59 -- Helper function for iq+pubsub tags |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
60 |
437
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
61 local function pubsub_iq(iq_type, to, ns, op, node, jid, item_id, op_attr_extra) |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
62 local st = verse.iq{ type = iq_type or "get", to = to } |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
63 :tag("pubsub", { xmlns = ns or xmlns_pubsub }) -- ns would be ..#owner |
437
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
64 local op_attr = { node = node, jid = jid }; |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
65 if op_attr_extra then |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
66 for k, v in pairs(op_attr_extra) do |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
67 op_attr[k] = v; |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
68 end |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
69 end |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
70 if op then st:tag(op, op_attr); end |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
71 if item_id then |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
72 st:tag("item", { id = item_id ~= true and item_id or nil }); |
2762abec4c63
pubsub: Allow setting additional attributes in pubsub action elements
Matthew Wild <mwild1@gmail.com>
parents:
395
diff
changeset
|
73 end |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
74 return st; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
75 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
76 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
77 -- http://xmpp.org/extensions/xep-0060.html#entity-subscriptions |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
78 function pubsub_service:subscriptions(callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
79 self.stream:send_iq(pubsub_iq(nil, self.service, nil, "subscriptions") |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
80 , callback and function (result) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
81 if result.attr.type == "result" then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
82 local ps = result:get_child("pubsub", xmlns_pubsub); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
83 local subs = ps and ps:get_child("subscriptions"); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
84 local nodes = {}; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
85 if subs then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
86 for sub in subs:childtags("subscription") do |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
87 local node = self:node(sub.attr.node) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
88 node.subscription = sub; |
337
8dce8240a77c
plugins.pubsub: Collect the subscribed jid
Kim Alvefur <zash@zash.se>
parents:
333
diff
changeset
|
89 node.subscribed_jid = sub.attr.jid; |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
90 t_insert(nodes, node); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
91 -- FIXME Good enough? |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
92 -- Or how about: |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
93 -- nodes[node] = sub; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
94 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
95 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
96 callback(nodes); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
97 else |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
98 callback(false, result:get_error()); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
99 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
100 end or nil); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
101 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
102 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
103 -- http://xmpp.org/extensions/xep-0060.html#entity-affiliations |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
104 function pubsub_service:affiliations(callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
105 self.stream:send_iq(pubsub_iq(nil, self.service, nil, "affiliations") |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
106 , callback and function (result) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
107 if result.attr.type == "result" then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
108 local ps = result:get_child("pubsub", xmlns_pubsub); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
109 local affils = ps and ps:get_child("affiliations") or {}; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
110 local nodes = {}; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
111 if affils then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
112 for affil in affils:childtags("affiliation") do |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
113 local node = self:node(affil.attr.node) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
114 node.affiliation = affil; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
115 t_insert(nodes, node); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
116 -- nodes[node] = affil; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
117 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
118 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
119 callback(nodes); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
120 else |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
121 callback(false, result:get_error()); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
122 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
123 end or nil); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
124 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
125 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
126 function pubsub_service:nodes(callback) |
346
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
127 self.stream:disco_items(self.service, nil, function(items, ...) |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
128 if items then |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
129 for i=1,#items do |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
130 items[i] = self:node(items[i].node); |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
131 end |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
132 end |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
133 callback(items, ...) |
f7854dd16ed3
plugins.pubsub: Implement node discovery
Kim Alvefur <zash@zash.se>
parents:
338
diff
changeset
|
134 end); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
135 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
136 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
137 local pubsub_node = {}; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
138 local pubsub_node_mt = { __index = pubsub_node }; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
139 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
140 function pubsub_service:node(node) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
141 return setmetatable({ stream = self.stream, service = self.service, node = node }, pubsub_node_mt) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
142 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
143 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
144 function pubsub_mt:__call(service, node) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
145 local s = self:service(service); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
146 return node and s:node(node) or s; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
147 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
148 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
149 function pubsub_node:hook(callback, prio) |
347
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
150 self._hooks = self._hooks or setmetatable({}, { __mode = 'kv' }); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
151 local function hook(event) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
152 -- FIXME service == nil would mean anyone, |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
153 -- publishing would be go to your bare jid. |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
154 -- So if you're only interestied in your own |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
155 -- events, hook your own bare jid. |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
156 if (not event.service or event.from == self.service) and event.node == self.node then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
157 return callback(event) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
158 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
159 end |
347
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
160 self._hooks[callback] = hook; |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
161 self.stream:hook("pubsub/event", hook, prio); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
162 return hook; |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
163 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
164 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
165 function pubsub_node:unhook(callback) |
347
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
166 if callback then |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
167 local hook = self._hooks[callback]; |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
168 self.stream:unhook("pubsub/event", hook); |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
169 elseif self._hooks then |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
170 for hook in pairs(self._hooks) do |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
171 self.stream:unhook("pubsub/event", hook); |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
172 end |
48cc6cad9bd6
plugins.pubsub: Keep track of wrapped callbacks
Kim Alvefur <zash@zash.se>
parents:
346
diff
changeset
|
173 end |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
174 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
175 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
176 function pubsub_node:create(config, callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
177 if config ~= nil then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
178 error("Not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
179 else |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
180 self.stream:send_iq(pubsub_iq("set", self.service, nil, "create", self.node), callback); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
181 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
182 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
183 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
184 -- <configure/> and <default/> rolled into one |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
185 function pubsub_node:configure(config, callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
186 if config ~= nil then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
187 error("Not implemented yet."); |
283
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
188 --[[ |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
189 if config == true then |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
190 self.stream:send_iq(pubsub_iq("get", self.service, nil, "configure", self.node) |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
191 , function(reply) |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
192 local form = reply:get_child("pubsub"):get_child("configure"):get_cild("x"); |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
193 local config = callback(require"util.dataforms".something(form)) |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
194 self.stream:send_iq(pubsub_iq("set", config, ...)) |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
195 end); |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
196 end |
39ce7535887c
plugins.pubsub: Add a local variable to save some table lookups
Kim Alvefur <zash@zash.se>
parents:
272
diff
changeset
|
197 --]] |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
198 -- fetch form and pass it to the callback |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
199 -- which would process it and pass it back |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
200 -- and then we submit it |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
201 -- elseif type(config) == "table" then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
202 -- it's a form or stanza that we submit |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
203 -- end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
204 -- this would be done for everything that needs a config |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
205 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
206 self.stream:send_iq(pubsub_iq("set", self.service, nil, config == nil and "default" or "configure", self.node), callback); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
207 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
208 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
209 function pubsub_node:publish(id, options, node, callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
210 if options ~= nil then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
211 error("Node configuration is not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
212 end |
263
598e9f93de78
plugins.pubsub: Fix missing <item/> when publishing.
Kim Alvefur <zash@zash.se>
parents:
250
diff
changeset
|
213 self.stream:send_iq(pubsub_iq("set", self.service, nil, "publish", self.node, nil, id or true) |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
214 :add_child(node) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
215 , callback); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
216 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
217 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
218 function pubsub_node:subscribe(jid, options, callback) |
332
6ecf44918156
plugins.pubsub: Explicitly subscribe with our current full jid as default
Kim Alvefur <zash@zash.se>
parents:
283
diff
changeset
|
219 jid = jid or self.stream.jid; |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
220 if options ~= nil then |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
221 error("Subscription configuration is not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
222 end |
395 | 223 self.stream:send_iq(pubsub_iq("set", self.service, nil, "subscribe", self.node, jid) |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
224 , callback); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
225 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
226 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
227 function pubsub_node:subscription(callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
228 error("Not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
229 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
230 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
231 function pubsub_node:affiliation(callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
232 error("Not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
233 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
234 |
272
e1833e9bd25b
plugins.pubsub: Implement unsubscribe.
Kim Alvefur <zash@zash.se>
parents:
265
diff
changeset
|
235 function pubsub_node:unsubscribe(jid, callback) |
338
957704bbe9a1
plugins.pubsub: If no jid given to unsubscribe with, default to what was subscribed to (if given) or the bound jid
Kim Alvefur <zash@zash.se>
parents:
337
diff
changeset
|
236 jid = jid or self.subscribed_jid or self.stream.jid; |
272
e1833e9bd25b
plugins.pubsub: Implement unsubscribe.
Kim Alvefur <zash@zash.se>
parents:
265
diff
changeset
|
237 self.stream:send_iq(pubsub_iq("set", self.service, nil, "unsubscribe", self.node, jid) |
e1833e9bd25b
plugins.pubsub: Implement unsubscribe.
Kim Alvefur <zash@zash.se>
parents:
265
diff
changeset
|
238 , callback); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
239 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
240 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
241 function pubsub_node:configure_subscription(options, callback) |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
242 error("Not implemented yet."); |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
243 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
244 |
348
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
245 function pubsub_node:items(full, callback) |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
246 if full then |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
247 self.stream:send_iq(pubsub_iq("get", self.service, nil, "items", self.node) |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
248 , callback); |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
249 else |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
250 self.stream:disco_items(self.service, self.node, callback); |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
251 end |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
252 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
253 |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
254 function pubsub_node:item(id, callback) |
348
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
255 self.stream:send_iq(pubsub_iq("get", self.service, nil, "items", self.node, nil, id) |
34b878d58948
plugins.pubsub: Implement fetching of items
Kim Alvefur <zash@zash.se>
parents:
347
diff
changeset
|
256 , callback); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
257 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
258 |
438
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
259 function pubsub_node:retract(id, notify, callback) |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
260 if type(notify) == "function" then -- COMPAT w/ older versions before 'notify' was added |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
261 notify, callback = false, notify; |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
262 end |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
263 self.stream:send_iq( |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
264 pubsub_iq( |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
265 "set", |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
266 self.service, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
267 nil, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
268 "retract", |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
269 self.node, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
270 nil, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
271 id, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
272 { notify = notify and "1" or nil } |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
273 ), |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
274 callback |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
275 ); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
276 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
277 |
333
36e9d5a2ae79
plugins.pubsub: Implement retract, purge and delete operations
Kim Alvefur <zash@zash.se>
parents:
332
diff
changeset
|
278 function pubsub_node:purge(notify, callback) |
438
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
279 self.stream:send_iq( |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
280 pubsub_iq( |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
281 "set", |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
282 self.service, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
283 xmlns_pubsub_owner, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
284 "purge", |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
285 self.node, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
286 nil, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
287 nil, |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
288 { notify = notify and "1" or nil } |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
289 ), |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
290 callback |
98dc1750584d
pubsub: Support for 'notify' in retract and purge operations
Matthew Wild <mwild1@gmail.com>
parents:
437
diff
changeset
|
291 ); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
292 end |
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
293 |
333
36e9d5a2ae79
plugins.pubsub: Implement retract, purge and delete operations
Kim Alvefur <zash@zash.se>
parents:
332
diff
changeset
|
294 function pubsub_node:delete(redirect_uri, callback) |
36e9d5a2ae79
plugins.pubsub: Implement retract, purge and delete operations
Kim Alvefur <zash@zash.se>
parents:
332
diff
changeset
|
295 assert(not redirect_uri, "Not implemented yet."); |
36e9d5a2ae79
plugins.pubsub: Implement retract, purge and delete operations
Kim Alvefur <zash@zash.se>
parents:
332
diff
changeset
|
296 self.stream:send_iq(pubsub_iq("set", self.service, xmlns_pubsub_owner, "delete", self.node) |
36e9d5a2ae79
plugins.pubsub: Implement retract, purge and delete operations
Kim Alvefur <zash@zash.se>
parents:
332
diff
changeset
|
297 , callback); |
222
3c257afd68e7
plugins.pubsub: New, OOP-ish, PubSub interface. Beware of stubs.
Kim Alvefur <zash@zash.se>
parents:
221
diff
changeset
|
298 end |