From 3f0089db86e2057293a33453361678989919147f Mon Sep 17 00:00:00 2001 From: fiaxh Date: Wed, 21 Jun 2017 01:07:06 +0200 Subject: Session establishment --- xmpp-vala/src/module/bind.vala | 4 +-- xmpp-vala/src/module/session.vala | 54 +++++++++++++++++++++++++++++++++++++++ 2 files changed, 56 insertions(+), 2 deletions(-) create mode 100644 xmpp-vala/src/module/session.vala (limited to 'xmpp-vala/src/module') diff --git a/xmpp-vala/src/module/bind.vala b/xmpp-vala/src/module/bind.vala index 5a611875..7b08e0f7 100644 --- a/xmpp-vala/src/module/bind.vala +++ b/xmpp-vala/src/module/bind.vala @@ -35,7 +35,7 @@ namespace Xmpp.Bind { StanzaNode bind_node = new StanzaNode.build("bind", NS_URI).add_self_xmlns(); bind_node.put_node(new StanzaNode.build("resource", NS_URI).put_node(new StanzaNode.text(requested_resource))); stream.get_module(Iq.Module.IDENTITY).send_iq(stream, new Iq.Stanza.set(bind_node), (stream, iq) => { - stream.get_module(Bind.Module.IDENTITY).iq_response_stanza(stream, iq); + stream.get_module(Module.IDENTITY).iq_response_stanza(stream, iq); }); stream.add_flag(flag); } @@ -51,7 +51,7 @@ namespace Xmpp.Bind { } public static void require(XmppStream stream) { - if (stream.get_module(IDENTITY) == null) stream.add_module(new Bind.Module("")); + if (stream.get_module(IDENTITY) == null) stream.add_module(new Module("")); } public override bool mandatory_outstanding(XmppStream stream) { diff --git a/xmpp-vala/src/module/session.vala b/xmpp-vala/src/module/session.vala new file mode 100644 index 00000000..f37e585f --- /dev/null +++ b/xmpp-vala/src/module/session.vala @@ -0,0 +1,54 @@ +using Xmpp.Core; + +namespace Xmpp.Session { +private const string NS_URI = "urn:ietf:params:xml:ns:xmpp-session"; + +public class Module : XmppStreamNegotiationModule { + public static ModuleIdentity IDENTITY = new ModuleIdentity(NS_URI, "session"); + + public override void attach(XmppStream stream) { + Bind.Module.require(stream); + stream.get_module(Bind.Module.IDENTITY).bound_to_resource.connect(on_bound_resource); + } + + public override void detach(XmppStream stream) { + stream.get_module(Bind.Module.IDENTITY).bound_to_resource.disconnect(on_bound_resource); + } + + public static void require(XmppStream stream) { + if (stream.get_module(IDENTITY) == null) stream.add_module(new Module()); + } + + /* the client MUST establish a session if it desires to engage in instant messaging and presence functionality (RFC 3921 3) */ + public override bool mandatory_outstanding(XmppStream stream) { + return !stream.has_flag(Flag.IDENTITY) || !stream.get_flag(Flag.IDENTITY).finished; + } + + public override bool negotiation_active(XmppStream stream) { + return stream.has_flag(Flag.IDENTITY) && !stream.get_flag(Flag.IDENTITY).finished; + } + + public override string get_ns() { return NS_URI; } + public override string get_id() { return IDENTITY.id; } + + private void on_bound_resource(XmppStream stream, string my_jid) { + if (stream.features.get_subnode("session", NS_URI) != null) { + stream.add_flag(new Flag()); + Iq.Stanza iq = new Iq.Stanza.set(new StanzaNode.build("session", NS_URI).add_self_xmlns()) { to=stream.remote_name }; + stream.get_module(Iq.Module.IDENTITY).send_iq(stream, iq, (stream, iq) => { + if (!iq.is_error()) { + stream.get_flag(Flag.IDENTITY).finished = true; + } + }); + } + } +} + +public class Flag : XmppStreamFlag { + public static FlagIdentity IDENTITY = new FlagIdentity(NS_URI, "session"); + public bool finished = false; + + public override string get_ns() { return NS_URI; } + public override string get_id() { return IDENTITY.id; } +} +} -- cgit v1.2.3-70-g09d2