prosody-modules: mod_delegation/mod_delegation.lua annotate

annotate mod_delegation/mod_delegation.lua @ 4764:a754f7e380b2

mod_dnsupdate: Rewrite port config vs DNS comparison code I'm not sure if it was correct, which means it was hard to understand and thus needed to be simplified. Hope this accomplishes that.

author	Kim Alvefur <zash@zash.se>
date	Mon, 08 Nov 2021 23:03:14 +0100
parents	679f1834dbdb
children	7d6ae8bb95dc

rev	line source
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	1 -- XEP-0355 (Namespace Delegation)
2067 107147ca77f7 mod_delegation: date update Goffi <goffi@goffi.org> parents: 1991 diff changeset	2 -- Copyright (C) 2015-2016 Jérôme Poisson
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	3 --
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	4 -- This module is MIT/X11 licensed. Please see the
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	5 -- COPYING file in the source package for more information.
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	6
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	7 -- This module manage namespace delegation, a way to delegate server features
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	8 -- to an external entity/component. Only the admin mode is implemented so far
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	9
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	10 -- TODO: client mode
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	11
1991 a1d5214bd369 mod_delegation: fixed imports, using "/" instead of "." was causing caching issues Goffi <goffi@goffi.org> parents: 1988 diff changeset	12 local jid = require("util.jid")
a1d5214bd369 mod_delegation: fixed imports, using "/" instead of "." was causing caching issues Goffi <goffi@goffi.org> parents: 1988 diff changeset	13 local st = require("util.stanza")
a1d5214bd369 mod_delegation: fixed imports, using "/" instead of "." was causing caching issues Goffi <goffi@goffi.org> parents: 1988 diff changeset	14 local set = require("util.set")
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	15
3317 36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	16 local new_id = require("util.id").short;
36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	17
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	18 local delegation_session = module:shared("/*/delegation/session")
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	19
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	20 -- FIXME: temporarily needed for disco_items_hook, to be removed when clean implementation is done
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	21 local is_contact_subscribed = require "core.rostermanager".is_contact_subscribed;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	22 local jid_split = require "util.jid".split;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	23 local jid_bare = require "util.jid".bare;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	24
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	25 if delegation_session.connected_cb == nil then
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	26 -- set used to have connected event listeners
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	27 -- which allow a host to react on events from
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	28 -- other hosts
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	29 delegation_session.connected_cb = set.new()
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	30 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	31 local connected_cb = delegation_session.connected_cb
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	32
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	33 local _DELEGATION_NS = 'urn:xmpp:delegation:2'
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	34 local _FORWARDED_NS = 'urn:xmpp:forward:0'
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	35 local _DISCO_INFO_NS = 'http://jabber.org/protocol/disco#info'
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	36 local _DISCO_ITEMS_NS = 'http://jabber.org/protocol/disco#items'
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	37 local _DATA_NS = 'jabber:x:data'
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	38
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	39 local _MAIN_SEP = '::'
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	40 local _BARE_SEP = ':bare:'
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	41 local _REMAINING = ':*'
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	42 local _MAIN_PREFIX = _DELEGATION_NS.._MAIN_SEP
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	43 local _BARE_PREFIX = _DELEGATION_NS.._BARE_SEP
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	44 local _DISCO_REMAINING = _BARE_PREFIX.."disco#info".._REMAINING
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	45 local _DISCO_ITEMS_REMAINING = _BARE_PREFIX.."disco#items".._REMAINING
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	46 local _PREFIXES = {_MAIN_PREFIX, _BARE_PREFIX}
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	47
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	48 local disco_nest
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	49
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	50 module:log("debug", "Loading namespace delegation module ")
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	51
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	52 --> Configuration management <--
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	53
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	54 local ns_delegations = module:get_option("delegations", {})
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	55
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	56 local jid2ns = {}
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	57 for namespace, ns_data in pairs(ns_delegations) do
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	58 -- "connected" contain the full jid of connected managing entity
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	59 ns_data.connected = nil
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	60 if ns_data.jid then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	61 if jid2ns[ns_data.jid] == nil then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	62 jid2ns[ns_data.jid] = {}
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	63 end
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	64 jid2ns[ns_data.jid][namespace] = ns_data
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	65 module:log("debug", "Namespace %s is delegated%s to %s", namespace, ns_data.filtering and " (with filtering)" or "", ns_data.jid)
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	66 else
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	67 module:log("warn", "Ignoring delegation for %s: no jid specified", tostring(namespace))
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	68 ns_delegations[namespace] = nil
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	69 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	70 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	71
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	72
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	73 local function advertise_delegations(session, to_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	74 -- send <message/> stanza to advertise delegations
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	75 -- as expained in § 4.2
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	76 local message = st.message({from=module.host, to=to_jid})
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	77 :tag("delegation", {xmlns=_DELEGATION_NS})
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	78
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	79 -- we need to check if a delegation is granted because the configuration
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	80 -- can be complicated if some delegations are granted to bare jid
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	81 -- and other to full jids, and several resources are connected.
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	82 local have_delegation = false
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	83
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	84 for namespace, ns_data in pairs(jid2ns[to_jid]) do
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	85 if ns_data.connected == to_jid then
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	86 have_delegation = true
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	87 message:tag("delegated", {namespace=namespace})
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	88 if type(ns_data.filtering) == "table" then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	89 for _, attribute in pairs(ns_data.filtering) do
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	90 message:tag("attribute", {name=attribute}):up()
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	91 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	92 end
2758 82109d8eca41 mod_delegation: fixed misplaced up() in <message> stanza generation Goffi <goffi@goffi.org> parents: 2752 diff changeset	93 message:up()
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	94 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	95 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	96
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	97 if have_delegation then
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	98 session.send(message)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	99 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	100 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	101
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	102 local function set_connected(entity_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	103 -- set the "connected" key for all namespace managed by entity_jid
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	104 -- if the namespace has already a connected entity, ignore the new one
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	105 local function set_config(jid_)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	106 for namespace, ns_data in pairs(jid2ns[jid_]) do
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	107 if ns_data.connected == nil then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	108 ns_data.connected = entity_jid
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	109 -- disco remaining and disco items remaining are special namespaces
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	110 -- there is no disco nesting for them
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	111 if namespace ~= _DISCO_ITEMS_REMAINING and namespace ~= _DISCO_REMAINING then
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	112 disco_nest(namespace, entity_jid)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	113 end
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	114 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	115 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	116 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	117 local bare_jid = jid.bare(entity_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	118 set_config(bare_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	119 -- We can have a bare jid of a full jid specified in configuration
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	120 -- so we try our luck with both (first connected resource will
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	121 -- manage the namespaces in case of bare jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	122 if bare_jid ~= entity_jid then
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	123 set_config(entity_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	124 jid2ns[entity_jid] = jid2ns[bare_jid]
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	125 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	126 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	127
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	128 local function on_presence(event)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	129 local session = event.origin
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	130 local bare_jid = jid.bare(session.full_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	131
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	132 if jid2ns[bare_jid] or jid2ns[session.full_jid] then
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	133 set_connected(session.full_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	134 advertise_delegations(session, session.full_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	135 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	136 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	137
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	138 local function on_component_connected(event)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	139 -- method called by the module loaded by the component
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	140 -- /!\ the event come from the component host,
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	141 -- not from the host of this module
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	142 local session = event.session
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	143 local bare_jid = jid.join(session.username, session.host)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	144
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	145 local jid_delegations = jid2ns[bare_jid]
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	146 if jid_delegations ~= nil then
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	147 set_connected(bare_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	148 advertise_delegations(session, bare_jid)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	149 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	150 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	151
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	152 local function on_component_auth(event)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	153 -- react to component-authenticated event from this host
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	154 -- and call the on_connected methods from all other hosts
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	155 -- needed for the component to get delegations advertising
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	156 for callback in connected_cb:items() do
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	157 callback(event)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	158 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	159 end
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	160
1776 e7b5ab44339c mod_delegation: fixed bad calling of on_auth for components Goffi <goffi@goffi.org> parents: 1774 diff changeset	161 if module:get_host_type() ~= "component" then
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	162 connected_cb:add(on_component_connected)
1776 e7b5ab44339c mod_delegation: fixed bad calling of on_auth for components Goffi <goffi@goffi.org> parents: 1774 diff changeset	163 end
1709 59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	164 module:hook('component-authenticated', on_component_auth)
59ba224bf145 mod_delegation: XEP-0355 implementation, first draft (configuration management + delegations advertising) Goffi <goffi@goffi.org> parents: diff changeset	165 module:hook('presence/initial', on_presence)
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	166
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	167
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	168 --> delegated namespaces hook <--
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	169
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	170 local managing_ent_error
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	171 local stanza_cache = {} -- we cache original stanza to build reply
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	172
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	173 local function managing_ent_result(event)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	174 -- this function manage iq results from the managing entity
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	175 -- it do a couple of security check before sending the
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	176 -- result to the managed entity
1719 3938496cd4f8 mod_delegation: removed invalid error replies to iq result. Goffi <goffi@goffi.org> parents: 1718 diff changeset	177 local stanza = event.stanza
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	178 if stanza.attr.to ~= module.host then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	179 module:log("warn", 'forwarded stanza result has "to" attribute not addressed to current host, id conflict ?')
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	180 return
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	181 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	182 module:unhook("iq-result/host/"..stanza.attr.id, managing_ent_result)
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	183 module:unhook("iq-error/host/"..stanza.attr.id, managing_ent_error)
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	184
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	185 -- lot of checks to do...
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	186 local delegation = stanza.tags[1]
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	187 if #stanza ~= 1 or delegation.name ~= "delegation" or
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	188 delegation.attr.xmlns ~= _DELEGATION_NS then
1719 3938496cd4f8 mod_delegation: removed invalid error replies to iq result. Goffi <goffi@goffi.org> parents: 1718 diff changeset	189 module:log("warn", "ignoring invalid iq result from managing entity %s", stanza.attr.from)
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	190 stanza_cache[stanza.attr.from][stanza.attr.id] = nil
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	191 return true
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	192 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	193
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	194 local forwarded = delegation.tags[1]
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	195 if #delegation ~= 1 or forwarded.name ~= "forwarded" or
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	196 forwarded.attr.xmlns ~= _FORWARDED_NS then
1719 3938496cd4f8 mod_delegation: removed invalid error replies to iq result. Goffi <goffi@goffi.org> parents: 1718 diff changeset	197 module:log("warn", "ignoring invalid iq result from managing entity %s", stanza.attr.from)
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	198 stanza_cache[stanza.attr.from][stanza.attr.id] = nil
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	199 return true
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	200 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	201
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	202 local iq = forwarded.tags[1]
1723 ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	203 if #forwarded ~= 1 or iq.name ~= "iq" or
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	204 iq.attr.xmlns ~= 'jabber:client' or
1774 7bfc23b2c038 mod_delegation: fixed handling of <iq> results without children Goffi <goffi@goffi.org> parents: 1724 diff changeset	205 (iq.attr.type =='result' and #iq > 1) or
1723 ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	206 (iq.attr.type == 'error' and #iq > 2) then
1719 3938496cd4f8 mod_delegation: removed invalid error replies to iq result. Goffi <goffi@goffi.org> parents: 1718 diff changeset	207 module:log("warn", "ignoring invalid iq result from managing entity %s", stanza.attr.from)
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	208 stanza_cache[stanza.attr.from][stanza.attr.id] = nil
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	209 return true
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	210 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	211
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	212 iq.attr.xmlns = nil
1724 2440a75e868f mod_delegation: managing_ent_* now stop event propagation + forwarded <iq/> xmlns check Goffi <goffi@goffi.org> parents: 1723 diff changeset	213
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	214 local original = stanza_cache[stanza.attr.from][stanza.attr.id]
48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	215 stanza_cache[stanza.attr.from][stanza.attr.id] = nil
1723 ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	216 -- we get namespace from original and not iq
ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	217 -- because the namespace can be lacking in case of error
ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	218 local namespace = original.tags[1].attr.xmlns
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	219
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	220 -- small hack for disco remaining feat
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	221 if namespace == _DISCO_ITEMS_NS then
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	222 namespace = _DISCO_ITEMS_REMAINING
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	223 elseif namespace == _DISCO_INFO_NS then
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	224 namespace = _DISCO_REMAINING
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	225 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	226
1723 ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	227 local ns_data = ns_delegations[namespace]
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	228
1723 ef85c42ad977 mod_delegation: fixed bad handling of error replies from managing entity Goffi <goffi@goffi.org> parents: 1722 diff changeset	229 if stanza.attr.from ~= ns_data.connected or (iq.attr.type ~= "result" and iq.attr.type ~= "error") or
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	230 iq.attr.id ~= original.attr.id or iq.attr.to ~= original.attr.from then
1719 3938496cd4f8 mod_delegation: removed invalid error replies to iq result. Goffi <goffi@goffi.org> parents: 1718 diff changeset	231 module:log("warn", "ignoring forbidden iq result from managing entity %s, please check that the component is no trying to do something bad (stanza: %s)", stanza.attr.from, tostring(stanza))
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	232 module:send(st.error_reply(original, 'cancel', 'service-unavailable'))
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	233 return true
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	234 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	235
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	236 -- at this point eveything is checked,
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	237 -- and we (hopefully) can send the the result safely
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	238 module:send(iq)
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	239 return true
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	240 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	241
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	242 function managing_ent_error(event)
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	243 local stanza = event.stanza
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	244 if stanza.attr.to ~= module.host then
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	245 module:log("warn", 'Stanza result has "to" attribute not addressed to current host, id conflict ?')
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	246 return
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	247 end
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	248 module:unhook("iq-result/host/"..stanza.attr.id, managing_ent_result)
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	249 module:unhook("iq-error/host/"..stanza.attr.id, managing_ent_error)
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	250 local original = stanza_cache[stanza.attr.from][stanza.attr.id]
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	251 stanza_cache[stanza.attr.from][stanza.attr.id] = nil
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	252 module:log("warn", "Got an error after forwarding stanza to "..stanza.attr.from)
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	253 module:send(st.error_reply(original, 'cancel', 'service-unavailable'))
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	254 return true
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	255 end
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	256
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	257 local function forward_iq(stanza, ns_data)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	258 local to_jid = ns_data.connected
1722 c48c7f948cfb mod_delegation: fixed namespace of <forwarded/> child element, as specified in XEP-0297 Goffi <goffi@goffi.org> parents: 1721 diff changeset	259 stanza.attr.xmlns = 'jabber:client'
3317 36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	260 local iq_id = new_id();
36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	261 local iq_stanza = st.iq({ from=module.host, to=to_jid, type="set", id = iq_id })
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	262 :tag("delegation", { xmlns=_DELEGATION_NS })
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	263 :tag("forwarded", { xmlns=_FORWARDED_NS })
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	264 :add_child(stanza)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	265 -- we save the original stanza to check the managing entity result
1720 48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	266 if not stanza_cache[to_jid] then stanza_cache[to_jid] = {} end
48b7e8021afa mod_delegation: original stanza is now cached outside of ns_data, so it can be accessed without knowing the namespace. Goffi <goffi@goffi.org> parents: 1719 diff changeset	267 stanza_cache[to_jid][iq_id] = stanza
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	268 module:hook("iq-result/host/"..iq_id, managing_ent_result)
1721 f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	269 module:hook("iq-error/host/"..iq_id, managing_ent_error)
f49359330493 mod_delegation: handling of error replies from managing entities after forward. Goffi <goffi@goffi.org> parents: 1720 diff changeset	270 module:log("debug", "stanza forwarded")
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	271 module:send(iq_stanza)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	272 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	273
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	274 local function iq_hook(event)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	275 -- general hook for all the iq which forward delegated ones
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	276 -- and continue normal behaviour else. If a namespace is
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	277 -- delegated but managing entity is offline, a service-unavailable
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	278 -- error will be sent, as requested by the XEP
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	279 local session, stanza = event.origin, event.stanza
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	280 if #stanza == 1 and stanza.attr.type == 'get' or stanza.attr.type == 'set' then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	281 local namespace = stanza.tags[1].attr.xmlns
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	282 local ns_data = ns_delegations[namespace]
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	283
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	284 if ns_data then
1715 241c061bb953 mod_delegation: we don't forward stanzas from managing entity itself Goffi <goffi@goffi.org> parents: 1714 diff changeset	285 if stanza.attr.from == ns_data.connected then
241c061bb953 mod_delegation: we don't forward stanzas from managing entity itself Goffi <goffi@goffi.org> parents: 1714 diff changeset	286 -- we don't forward stanzas from managing entity itself
241c061bb953 mod_delegation: we don't forward stanzas from managing entity itself Goffi <goffi@goffi.org> parents: 1714 diff changeset	287 return
241c061bb953 mod_delegation: we don't forward stanzas from managing entity itself Goffi <goffi@goffi.org> parents: 1714 diff changeset	288 end
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	289 if ns_data.filtering then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	290 local first_child = stanza.tags[1]
1988 d7c1daaf2dea mod_delegation: fixed attribute filtering Goffi <goffi@goffi.org> parents: 1776 diff changeset	291 for _, attribute in pairs(ns_data.filtering) do
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	292 -- if any filtered attribute if not present,
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	293 -- we must continue the normal bahaviour
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	294 if not first_child.attr[attribute] then
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	295 -- Filtered attribute is not present, we do normal workflow
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	296 return
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	297 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	298 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	299 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	300 if not ns_data.connected then
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	301 module:log("warn", "No connected entity to manage "..namespace)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	302 session.send(st.error_reply(stanza, 'cancel', 'service-unavailable'))
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	303 else
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	304 forward_iq(stanza, ns_data)
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	305 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	306 return true
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	307 else
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	308 -- we have no delegation, we continue normal behaviour
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	309 return
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	310 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	311 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	312 end
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	313
b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	314 module:hook("iq/self", iq_hook, 2^32)
1718 48be6e7efbe8 mod_delegation: added 'iq/bare' to hooked events. Goffi <goffi@goffi.org> parents: 1717 diff changeset	315 module:hook("iq/bare", iq_hook, 2^32)
1710 b68eed25b880 mod_delegation: iq forwarding to managing entity Goffi <goffi@goffi.org> parents: 1709 diff changeset	316 module:hook("iq/host", iq_hook, 2^32)
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	317
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	318
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	319 --> discovery nesting <--
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	320
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	321 -- disabling internal features/identities
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	322
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	323 local function find_form_type(stanza)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	324 local form_type = nil
2069 cf9cd666ba00 mod_delegation: fixed bad use of period instead of colon Goffi <goffi@goffi.org> parents: 2067 diff changeset	325 for field in stanza:childtags('field', 'jabber:x:data') do
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	326 if field.attr.var=='FORM_TYPE' and field.attr.type=='hidden' then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	327 local value = field:get_child('value')
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	328 if not value then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	329 module:log("warn", "No value found in FORM_TYPE field: "..tostring(stanza))
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	330 else
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	331 form_type=value.get_text()
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	332 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	333 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	334 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	335 return form_type
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	336 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	337
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	338 -- modules whose features/identities are managed by delegation
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	339 local disabled_modules = set.new()
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	340 local disabled_identities = set.new()
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	341
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	342 local function identity_added(event)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	343 local source = event.source
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	344 if disabled_modules:contains(source) then
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	345 local item = event.item
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	346 local category, type_, name = item.category, item.type, item.name
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	347 module:log("debug", "Removing (%s/%s%s) identity because of delegation", category, type_, name and "/"..name or "")
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	348 disabled_identities:add(item)
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	349 source:remove_item("identity", item)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	350 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	351 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	352
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	353 local function feature_added(event)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	354 local source, item = event.source, event.item
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	355 for namespace, _ in pairs(ns_delegations) do
3387 c5e8042b174c mod_delegation: avoid crash on recent prosody versions Goffi <goffi@goffi.org> parents: 3317 diff changeset	356 if source ~= nil and source ~= module and string.sub(item, 1, #namespace) == namespace then
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	357 module:log("debug", "Removing %s feature which is delegated", item)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	358 source:remove_item("feature", item)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	359 disabled_modules:add(source)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	360 if source.items and source.items.identity then
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	361 -- we remove all identities added by the source module
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	362 -- that can cause issues if the module manages several features/identities
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	363 -- but this case is probably rare (or doesn't happen at all)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	364 -- FIXME: any better way ?
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	365 for _, identity in pairs(source.items.identity) do
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	366 identity_added({source=source, item=identity})
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	367 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	368 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	369 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	370 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	371 end
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	372
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	373 local function extension_added(event)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	374 local source, stanza = event.source, event.item
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	375 local form_type = find_form_type(stanza)
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	376 if not form_type then return end
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	377
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	378 for namespace, _ in pairs(ns_delegations) do
3387 c5e8042b174c mod_delegation: avoid crash on recent prosody versions Goffi <goffi@goffi.org> parents: 3317 diff changeset	379 if source ~= nil and source ~= module and string.sub(form_type, 1, #namespace) == namespace then
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	380 module:log("debug", "Removing extension which is delegated: %s", tostring(stanza))
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	381 source:remove_item("extension", stanza)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	382 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	383 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	384 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	385
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	386 -- for disco nesting (see § 7.2) we need to remove internal features
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	387 -- we use handle_items as it allows to remove already added features
1711 55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	388 -- and catch the ones which can come later
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	389 module:handle_items("feature", feature_added, function(_) end)
55b9ac807ac9 mod_delegation: delegated features/identities are removed from disco. Goffi <goffi@goffi.org> parents: 1710 diff changeset	390 module:handle_items("identity", identity_added, function(_) end, false)
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	391 module:handle_items("extension", extension_added, function(_) end)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	392
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	393
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	394 -- managing entity features/identities collection
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	395
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	396 local disco_error
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	397 local bare_features = set.new()
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	398 local bare_identities = {}
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	399 local bare_extensions = {}
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	400
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	401 local function disco_result(event)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	402 -- parse result from disco nesting request
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	403 -- and fill module features/identities and bare_features/bare_identities accordingly
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	404 local session, stanza = event.origin, event.stanza
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	405 if stanza.attr.to ~= module.host then
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	406 module:log("warn", 'Stanza result has "to" attribute not addressed to current host, id conflict ?')
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	407 return
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	408 end
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	409 module:unhook("iq-result/host/"..stanza.attr.id, disco_result)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	410 module:unhook("iq-error/host/"..stanza.attr.id, disco_error)
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	411 local query = stanza:get_child("query", _DISCO_INFO_NS)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	412 if not query or not query.attr.node then
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	413 session.send(st.error_reply(stanza, 'modify', 'not-acceptable'))
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	414 return true
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	415 end
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	416
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	417 local node = query.attr.node
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	418 local main
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	419
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	420 if string.sub(node, 1, #_MAIN_PREFIX) == _MAIN_PREFIX then
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	421 main=true
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	422 elseif string.sub(node, 1, #_BARE_PREFIX) == _BARE_PREFIX then
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	423 main=false
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	424 else
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	425 module:log("warn", "Unexpected node: "..node)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	426 session.send(st.error_reply(stanza, 'modify', 'not-acceptable'))
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	427 return true
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	428 end
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	429
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	430 for feature in query:childtags("feature") do
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	431 local namespace = feature.attr.var
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	432 if main then
1717 e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	433 module:add_feature(namespace)
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	434 else
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	435 bare_features:add(namespace)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	436 end
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	437 end
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	438 for identity in query:childtags("identity") do
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	439 local category, type_, name = identity.attr.category, identity.attr.type, identity.attr.name
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	440 if main then
1717 e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	441 module:add_identity(category, type_, name)
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	442 else
1717 e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	443 table.insert(bare_identities, {category=category, type=type_, name=name})
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	444 end
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	445 end
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	446 for extension in query:childtags("x", _DATA_NS) do
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	447 if main then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	448 module:add_extension(extension)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	449 else
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	450 table.insert(bare_extensions, extension)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	451 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	452 end
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	453 end
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	454
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	455 function disco_error(event)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	456 local stanza = event.stanza
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	457 if stanza.attr.to ~= module.host then
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	458 module:log("warn", 'Stanza result has "to" attribute not addressed to current host, id conflict ?')
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	459 return
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	460 end
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	461 module:unhook("iq-result/host/"..stanza.attr.id, disco_result)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	462 module:unhook("iq-error/host/"..stanza.attr.id, disco_error)
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	463 module:log("warn", "Got an error while requesting disco for nesting to "..stanza.attr.from)
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	464 module:log("warn", "Ignoring disco nesting")
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	465 end
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	466
c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	467 function disco_nest(namespace, entity_jid)
1717 e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	468 -- manage discovery nesting (see § 7.2)
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	469
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	470 -- first we reset the current values
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	471 if module.items then
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	472 module.items['feature'] = nil
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	473 module.items['identity'] = nil
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	474 module.items['extension'] = nil
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	475 bare_features = set.new()
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	476 bare_identities = {}
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	477 bare_extensions = {}
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	478 end
e22cd2205fc1 mod_delegation: reset features/identities/extensions before doing a disco nesting Goffi <goffi@goffi.org> parents: 1716 diff changeset	479
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	480 for _, prefix in ipairs(_PREFIXES) do
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	481 local node = prefix..namespace
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	482
3317 36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	483 local iq_id = new_id();
36a9170352b5 mod_delegation: Update to generate own iq ids Matthew Wild <mwild1@gmail.com> parents: 3271 diff changeset	484 local iq = st.iq({from=module.host, to=entity_jid, type='get', id = iq_id })
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	485 :tag('query', {xmlns=_DISCO_INFO_NS, node=node})
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	486
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	487 module:hook("iq-result/host/"..iq_id, disco_result)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	488 module:hook("iq-error/host/"..iq_id, disco_error)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	489 module:send(iq)
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	490 end
1712 c1973605d096 mod_delegation: disco nesting for host Goffi <goffi@goffi.org> parents: 1711 diff changeset	491 end
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	492
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	493 -- disco to bare jids special cases
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	494
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	495 -- disco#info
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	496
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	497 local function disco_hook(event)
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	498 -- this event is called when a disco info request is done on a bare jid
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	499 -- we get the final reply and filter delegated features/identities/extensions
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	500 local reply = event.reply
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	501 reply.tags[1]:maptags(function(child)
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	502 if child.name == 'feature' then
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	503 local feature_ns = child.attr.var
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	504 for namespace, _ in pairs(ns_delegations) do
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	505 if string.sub(feature_ns, 1, #namespace) == namespace then
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	506 module:log("debug", "Removing feature namespace %s which is delegated", feature_ns)
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	507 return nil
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	508 end
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	509 end
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	510 elseif child.name == 'identity' then
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	511 for item in disabled_identities:items() do
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	512 if item.category == child.attr.category
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	513 and item.type == child.attr.type
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	514 -- we don't check name, because mod_pep use a name for main disco, but not in account-disco-info hook
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	515 -- and item.name == child.attr.name
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	516 then
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	517 module:log("debug", "Removing (%s/%s%s) identity because of delegation", item.category, item.type, item.name and "/"..item.name or "")
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	518 return nil
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	519 end
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	520 end
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	521 elseif child.name == 'x' and child.attr.xmlns == _DATA_NS then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	522 local form_type = find_form_type(child)
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	523 if form_type then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	524 for namespace, _ in pairs(ns_delegations) do
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	525 if string.sub(form_type, 1, #namespace) == namespace then
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	526 module:log("debug", "Removing extension which is delegated: %s", tostring(child))
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	527 return nil
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	528 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	529 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	530 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	531
1713 01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	532 end
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	533 return child
01e9465f8f80 mod_delegation: delegated features/identities removal for disco info requests on bare jid Goffi <goffi@goffi.org> parents: 1712 diff changeset	534 end)
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	535 for feature in bare_features:items() do
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	536 reply:tag('feature', {var=feature}):up()
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	537 end
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	538 for _, item in ipairs(bare_identities) do
1716 29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	539 reply:tag('identity', {category=item.category, type=item.type, name=item.name}):up()
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	540 end
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	541 for _, stanza in ipairs(bare_extensions) do
29dfdfc767b4 mod_delegation: service discovery extensions (xep-0128) management Goffi <goffi@goffi.org> parents: 1715 diff changeset	542 reply:add_child(stanza)
1714 3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	543 end
3d83f5337a73 mod_delegation: disco info request on bare jid is now managed Goffi <goffi@goffi.org> parents: 1713 diff changeset	544
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	545 end
4616 377546ab50f9 mod_delegation: fix bare jid disco nesting Goffi <goffi@goffi.org> parents: 3387 diff changeset	546 module:hook("account-disco-info", disco_hook, -2^32)
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	547
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	548 local function disco_node_hook(event)
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	549 -- we reach this hook if a disco node on account has not been found
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	550 -- we then forward the request to managing entity
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	551 if not event.exists then
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	552 -- this node is not handled by the server
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	553 local ns_data = ns_delegations[_DISCO_REMAINING]
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	554 if ns_data ~= nil then
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	555 -- remaining delegation is requested, we forward
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	556 forward_iq(event.stanza, ns_data)
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	557 -- and stop normal event handling
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	558 return true
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	559 end
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	560 end
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	561 end
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	562 module:hook("account-disco-info-node", disco_node_hook, -2^32)
679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	563
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	564 -- disco#items
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	565
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	566 local function disco_items_node_hook(event)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	567 -- check if node is not handled by server
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	568 -- and forward the disco request to suitable entity
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	569 if not event.exists then
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	570 -- this node is not handled by the server
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	571 local ns_data = ns_delegations[_DISCO_ITEMS_REMAINING]
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	572 if ns_data ~= nil then
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	573 -- remaining delegation is requested, we forward
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	574 forward_iq(event.stanza, ns_data)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	575 -- and stop normal event handling
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	576 return true
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	577 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	578 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	579 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	580 module:hook("account-disco-items-node", disco_items_node_hook, -2^32)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	581
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	582 local function disco_items_hook(event)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	583 -- FIXME: we forward all bare-jid disco-items requests (without node) which will replace any Prosody reply
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	584 -- for now it's OK because Prosody is not returning anything on request on bare jid
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	585 -- but to be properly done, any Prosody reply should be kept and managing entities items should be added (merged) to it.
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	586 -- account-disco-items can't be cancelled (return value of hooks are not checked in mod_disco), so coroutine needs
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	587 -- to be used with util.async (to get the IQ result, merge items then return from the event)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	588 local origin, stanza = event.origin, event.stanza;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	589 local node = stanza.tags[1].attr.node;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	590 local username = jid_split(stanza.attr.to) or origin.username;
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	591 if not stanza.attr.to or is_contact_subscribed(username, module.host, jid_bare(stanza.attr.from)) then
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	592 if node == nil or node == "" then
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	593 local ns_data = ns_delegations[_DISCO_ITEMS_REMAINING]
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	594 if ns_data ~= nil then
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	595 forward_iq(event.stanza, ns_data)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	596 return true
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	597 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	598 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	599 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	600 end
3271 7504f765e767 mod_delegation: Simplify iq handling by hooking on iq-get/ instead of iq/. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 2758 diff changeset	601 module:hook("iq-get/bare/http://jabber.org/protocol/disco#items:query", disco_items_hook, 100)
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	602
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	603 local function disco_items_raw_hook(event)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	604 -- this method is called when account-disco-items-* event are not called
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	605 -- notably when a disco-item is done by an unsubscibed entity
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	606 -- (i.e. an entity doing a disco#item on an entity without having
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	607 -- presence subscription)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	608 -- we forward the request to managing entity
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	609 -- it's the responsability of the managing entity to filter the items
4709 679f1834dbdb mod_delegation: update to XEP-0355 v0.5 Goffi <goffi@goffi.org> parents: 4616 diff changeset	610 local ns_data = ns_delegations[_DISCO_ITEMS_REMAINING]
2752 d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	611 if ns_data ~= nil then
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	612 forward_iq(event.stanza, ns_data)
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	613 return true
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	614 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	615 end
d0e75bf21d30 mod_delegation: added disco#items support Goffi <goffi@goffi.org> parents: 2069 diff changeset	616 module:hook("iq-get/bare/http://jabber.org/protocol/disco#items:query", disco_items_raw_hook, -2^32)

Mercurial > prosody-modules

annotate mod_delegation/mod_delegation.lua @ 4764:a754f7e380b2