diff options
Diffstat (limited to 'xmpp-vala/src/module/xep')
| -rw-r--r-- | xmpp-vala/src/module/xep/0334_message_processing_hints.vala | 8 | ||||
| -rw-r--r-- | xmpp-vala/src/module/xep/0353_call_invite_message.vala | 93 | ||||
| -rw-r--r-- | xmpp-vala/src/module/xep/muji_meta.vala | 117 |
3 files changed, 97 insertions, 121 deletions
diff --git a/xmpp-vala/src/module/xep/0334_message_processing_hints.vala b/xmpp-vala/src/module/xep/0334_message_processing_hints.vala index 352e03ac..09fd7dd4 100644 --- a/xmpp-vala/src/module/xep/0334_message_processing_hints.vala +++ b/xmpp-vala/src/module/xep/0334_message_processing_hints.vala @@ -2,10 +2,10 @@ namespace Xmpp.Xep.MessageProcessingHints { private const string NS_URI = "urn:xmpp:hints"; -private const string HINT_NO_PERMANENT_STORE = "no-permanent-store"; -private const string HINT_NO_STORE = "no-store"; -private const string HINT_NO_COPY = "no-copy"; -private const string HINT_STORE = "store"; +public const string HINT_NO_PERMANENT_STORE = "no-permanent-store"; +public const string HINT_NO_STORE = "no-store"; +public const string HINT_NO_COPY = "no-copy"; +public const string HINT_STORE = "store"; public static void set_message_hint(MessageStanza message, string message_hint) { StanzaNode hint_node = (new StanzaNode.build(message_hint, NS_URI)).add_self_xmlns(); diff --git a/xmpp-vala/src/module/xep/0353_call_invite_message.vala b/xmpp-vala/src/module/xep/0353_call_invite_message.vala new file mode 100644 index 00000000..806db5e7 --- /dev/null +++ b/xmpp-vala/src/module/xep/0353_call_invite_message.vala @@ -0,0 +1,93 @@ +using Gee; +namespace Xmpp.Xep.CallInvites { + + public const string NS_URI = "urn:xmpp:call-invites:0"; + + public class Module : XmppStreamModule { + public static ModuleIdentity<Module> IDENTITY = new ModuleIdentity<Module>(NS_URI, "call_invites"); + + public signal void call_proposed(Jid from, Jid to, bool video, Gee.List<StanzaNode> join_methods, MessageStanza message); + public signal void call_retracted(Jid from, Jid to, string invite_id, string message_type); + public signal void call_accepted(Jid from, string invite_id, string message_type); + public signal void call_rejected(Jid from, Jid to, string invite_id, string message_type); + + public void send_invite(XmppStream stream, Jid invitee, Jid muc_jid, bool video, string message_type) { + StanzaNode muji_node = new StanzaNode.build("muji", Muji.NS_URI).add_self_xmlns().put_attribute("room", muc_jid.to_string()); + StanzaNode invite_node = new StanzaNode.build("propose", NS_URI).add_self_xmlns() + .put_attribute("video", video.to_string()) + .put_node(muji_node); + MessageStanza invite_message = new MessageStanza() { to=invitee, type_=message_type }; + MessageProcessingHints.set_message_hint(invite_message, MessageProcessingHints.HINT_STORE); + invite_message.stanza.put_node(invite_node); + stream.get_module(MessageModule.IDENTITY).send_message.begin(stream, invite_message); + } + + public void send_retract(XmppStream stream, Jid to, string invite_id, string message_type) { + send_message(stream, "retract", to, invite_id, message_type); + } + + public void send_accept(XmppStream stream, Jid to, string invite_id, string message_type) { + send_message(stream, "accept", to, invite_id, message_type); + } + + public void send_reject(XmppStream stream, Jid to, string invite_id, string message_type) { + send_message(stream, "reject", to, invite_id, message_type); + } + + private void send_message(XmppStream stream, string action, Jid to, string invite_id, string message_type) { + StanzaNode inner_node = new StanzaNode.build(action, NS_URI).add_self_xmlns().put_attribute("id", invite_id); + MessageStanza message = new MessageStanza() { to=to, type_=message_type }; + message.stanza.put_node(inner_node); + MessageProcessingHints.set_message_hint(message, MessageProcessingHints.HINT_STORE); + stream.get_module(MessageModule.IDENTITY).send_message.begin(stream, message); + } + + private void on_received_message(XmppStream stream, MessageStanza message) { + Xep.MessageArchiveManagement.MessageFlag? mam_flag = Xep.MessageArchiveManagement.MessageFlag.get_flag(message); + if (mam_flag != null) return; + + StanzaNode? relevant_node = null; + + foreach (StanzaNode node in message.stanza.sub_nodes) { + if (node.ns_uri == NS_URI) { + relevant_node = node; + break; + } + } + if (relevant_node == null) return; + + if (relevant_node.name == "propose") { + if (relevant_node.sub_nodes.is_empty) return; + bool video = relevant_node.get_attribute_bool("video", false); + call_proposed(message.from, message.to, video, relevant_node.sub_nodes, message); + return; + } + + string? invite_id = relevant_node.get_attribute("id"); + if (invite_id == null) return; + + switch (relevant_node.name) { + case "accept": + call_accepted(message.from, invite_id, message.type_); + break; + case "retract": + call_retracted(message.from, message.to, invite_id, message.type_); + break; + case "reject": + call_rejected(message.from, message.to, invite_id, message.type_); + break; + } + } + + public override void attach(XmppStream stream) { + stream.get_module(MessageModule.IDENTITY).received_message.connect(on_received_message); + } + + public override void detach(XmppStream stream) { + stream.get_module(MessageModule.IDENTITY).received_message.disconnect(on_received_message); + } + + public override string get_ns() { return NS_URI; } + public override string get_id() { return IDENTITY.id; } + } +}
\ No newline at end of file diff --git a/xmpp-vala/src/module/xep/muji_meta.vala b/xmpp-vala/src/module/xep/muji_meta.vala deleted file mode 100644 index fa161f28..00000000 --- a/xmpp-vala/src/module/xep/muji_meta.vala +++ /dev/null @@ -1,117 +0,0 @@ -using Gee; -namespace Xmpp.Xep.MujiMeta { - - public const string NS_URI = "http://telepathy.freedesktop.org/muji"; - - public class Module : XmppStreamModule { - public static ModuleIdentity<Module> IDENTITY = new ModuleIdentity<Module>(NS_URI, "muji_meta"); - - public signal void call_proposed(Jid from, Jid to, Jid muc_jid, Gee.List<StanzaNode> descriptions, string message_type); - public signal void call_retracted(Jid from, Jid to, Jid muc_jid, string message_type); - public signal void call_accepted(Jid from, Jid muc_jid, string message_type); - public signal void call_rejected(Jid from, Jid to, Jid muc_jid, string message_type); - - public void send_invite(XmppStream stream, Jid invitee, Jid muc_jid, bool video, string message_type) { - var invite_node = new StanzaNode.build("propose", NS_URI).put_attribute("muc", muc_jid.to_string()); - invite_node.put_node(new StanzaNode.build("description", Xep.JingleRtp.NS_URI).add_self_xmlns().put_attribute("media", "audio")); - if (video) { - invite_node.put_node(new StanzaNode.build("description", Xep.JingleRtp.NS_URI).add_self_xmlns().put_attribute("media", "video")); - } - var muji_node = new StanzaNode.build("muji", NS_URI).add_self_xmlns().put_node(invite_node); - MessageStanza invite_message = new MessageStanza() { to=invitee, type_=message_type }; - invite_message.stanza.put_node(muji_node); - stream.get_module(MessageModule.IDENTITY).send_message.begin(stream, invite_message); - } - - public void send_invite_retract_to_peer(XmppStream stream, Jid invitee, Jid muc_jid, string message_type) { - send_jmi_message(stream, "retract", invitee, muc_jid, message_type); - } - - public void send_invite_accept_to_peer(XmppStream stream, Jid invitor, Jid muc_jid, string message_type) { - send_jmi_message(stream, "accept", invitor, muc_jid, message_type); - } - - public void send_invite_accept_to_self(XmppStream stream, Jid muc_jid) { - send_jmi_message(stream, "accept", Bind.Flag.get_my_jid(stream).bare_jid, muc_jid, MessageStanza.TYPE_CHAT); - } - - public void send_invite_reject_to_peer(XmppStream stream, Jid invitor, Jid muc_jid, string message_type) { - send_jmi_message(stream, "reject", invitor, muc_jid, message_type); - } - - public void send_invite_reject_to_self(XmppStream stream, Jid muc_jid) { - send_jmi_message(stream, "reject", Bind.Flag.get_my_jid(stream).bare_jid, muc_jid, MessageStanza.TYPE_CHAT); - } - - private void send_jmi_message(XmppStream stream, string name, Jid to, Jid muc, string message_type) { - var jmi_node = new StanzaNode.build(name, NS_URI).add_self_xmlns().put_attribute("muc", muc.to_string()); - var muji_node = new StanzaNode.build("muji", NS_URI).add_self_xmlns().put_node(jmi_node); - - MessageStanza accepted_message = new MessageStanza() { to=to, type_= message_type ?? MessageStanza.TYPE_CHAT }; - accepted_message.stanza.put_node(muji_node); - stream.get_module(MessageModule.IDENTITY).send_message.begin(stream, accepted_message); - } - - private void on_received_message(XmppStream stream, MessageStanza message) { - Xep.MessageArchiveManagement.MessageFlag? mam_flag = Xep.MessageArchiveManagement.MessageFlag.get_flag(message); - if (mam_flag != null) return; - - var muji_node = message.stanza.get_subnode("muji", NS_URI); - if (muji_node == null) return; - - StanzaNode? mi_node = null; - foreach (StanzaNode node in muji_node.sub_nodes) { - if (node.ns_uri == NS_URI) { - mi_node = node; - } - } - if (mi_node == null) return; - - string? jid_str = mi_node.get_attribute("muc"); - if (jid_str == null) return; - - Jid muc_jid = null; - try { - muc_jid = new Jid(jid_str); - } catch (Error e) { - return; - } - - switch (mi_node.name) { - case "accept": - case "proceed": - call_accepted(message.from, muc_jid, message.type_); - break; - case "propose": - ArrayList<StanzaNode> descriptions = new ArrayList<StanzaNode>(); - - foreach (StanzaNode node in mi_node.sub_nodes) { - if (node.name != "description") continue; - descriptions.add(node); - } - - if (descriptions.size > 0) { - call_proposed(message.from, message.to, muc_jid, descriptions, message.type_); - } - break; - case "retract": - call_retracted(message.from, message.to, muc_jid, message.type_); - break; - case "reject": - call_rejected(message.from, message.to, muc_jid, message.type_); - break; - } - } - - public override void attach(XmppStream stream) { - stream.get_module(MessageModule.IDENTITY).received_message.connect(on_received_message); - } - - public override void detach(XmppStream stream) { - stream.get_module(MessageModule.IDENTITY).received_message.disconnect(on_received_message); - } - - public override string get_ns() { return NS_URI; } - public override string get_id() { return IDENTITY.id; } - } -}
\ No newline at end of file |