diff options
Diffstat (limited to 'vala-xmpp/src/module/xep/0045_muc/module.vala')
| -rw-r--r-- | vala-xmpp/src/module/xep/0045_muc/module.vala | 244 |
1 files changed, 0 insertions, 244 deletions
diff --git a/vala-xmpp/src/module/xep/0045_muc/module.vala b/vala-xmpp/src/module/xep/0045_muc/module.vala deleted file mode 100644 index f9ed9539..00000000 --- a/vala-xmpp/src/module/xep/0045_muc/module.vala +++ /dev/null @@ -1,244 +0,0 @@ -using Gee; - -using Xmpp.Core; - -namespace Xmpp.Xep.Muc { - -private const string NS_URI = "http://jabber.org/protocol/muc"; -private const string NS_URI_ADMIN = NS_URI + "#admin"; -private const string NS_URI_USER = NS_URI + "#user"; - -public const string AFFILIATION_ADMIN = "admin"; -public const string AFFILIATION_MEMBER = "member"; -public const string AFFILIATION_NONE = "none"; -public const string AFFILIATION_OUTCAST = "outcast"; -public const string AFFILIATION_OWNER = "owner"; - -public const string ROLE_MODERATOR = "moderator"; -public const string ROLE_NONE = "none"; -public const string ROLE_PARTICIPANT = "participant"; -public const string ROLE_VISITOR = "visitor"; - -public enum MucEnterError { - PASSWORD_REQUIRED, - NOT_IN_MEMBER_LIST, - BANNED, - NICK_CONFLICT, - OCCUPANT_LIMIT_REACHED, - ROOM_DOESNT_EXIST -} - -public class Module : XmppStreamModule { - public const string ID = "0045_muc_module"; - - public signal void received_occupant_affiliation(XmppStream stream, string jid, string? affiliation); - public signal void received_occupant_jid(XmppStream stream, string jid, string? real_jid); - public signal void received_occupant_role(XmppStream stream, string jid, string? role); - public signal void subject_set(XmppStream stream, string subject, string jid); - - public void enter(XmppStream stream, string bare_jid, string nick, string? password, MucEnterListener listener) { - Presence.Stanza presence = new Presence.Stanza(); - presence.to = bare_jid + "/" + nick; - StanzaNode x_node = new StanzaNode.build("x", NS_URI).add_self_xmlns(); - if (password != null) { - x_node.put_node(new StanzaNode.build("password", NS_URI).put_node(new StanzaNode.text(password))); - } - presence.stanza.put_node(x_node); - - Muc.Flag.get_flag(stream).start_muc_enter(bare_jid, presence.id, listener); - - Presence.Module.get_module(stream).send_presence(stream, presence); - } - - public void exit(XmppStream stream, string jid) { - string nick = Flag.get_flag(stream).get_muc_nick(jid); - Presence.Stanza presence = new Presence.Stanza(); - presence.to = jid + "/" + nick; - presence.type_ = Presence.Stanza.TYPE_UNAVAILABLE; - Presence.Module.get_module(stream).send_presence(stream, presence); - } - - public void change_subject(XmppStream stream, string jid, string subject) { - Message.Stanza message = new Message.Stanza(); - message.to = jid; - message.type_ = Message.Stanza.TYPE_GROUPCHAT; - message.stanza.put_node((new StanzaNode.build("subject")).put_node(new StanzaNode.text(subject))); - Message.Module.get_module(stream).send_message(stream, message); - } - - public void change_nick(XmppStream stream, string jid, string new_nick) { - Presence.Stanza presence = new Presence.Stanza(); - presence.to = jid + "/" + new_nick; - Presence.Module.get_module(stream).send_presence(stream, presence); - } - - public void kick(XmppStream stream, string jid, string nick) { - change_role(stream, jid, nick, "none"); - } - - public override void attach(XmppStream stream) { - stream.add_flag(new Muc.Flag()); - Message.Module.require(stream); - Message.Module.get_module(stream).received_message.connect(on_received_message); - Presence.Module.require(stream); - Presence.Module.get_module(stream).received_presence.connect(on_received_presence); - Presence.Module.get_module(stream).received_available.connect(on_received_available); - Presence.Module.get_module(stream).received_unavailable.connect(on_received_unavailable); - if (ServiceDiscovery.Module.get_module(stream) != null) { - ServiceDiscovery.Module.get_module(stream).add_feature(stream, NS_URI); - } - } - - public override void detach(XmppStream stream) { - Message.Module.get_module(stream).received_message.disconnect(on_received_message); - Presence.Module.get_module(stream).received_presence.disconnect(on_received_presence); - Presence.Module.get_module(stream).received_available.disconnect(on_received_available); - Presence.Module.get_module(stream).received_unavailable.disconnect(on_received_unavailable); - } - - public static Module? get_module(XmppStream stream) { - return (Module?) stream.get_module(NS_URI, ID); - } - - public static void require(XmppStream stream) { - Presence.Module.require(stream); - if (get_module(stream) == null) stream.add_module(new Muc.Module()); - } - - public override string get_ns() { return NS_URI; } - public override string get_id() { return ID; } - - private void change_role(XmppStream stream, string jid, string nick, string new_role) { - StanzaNode query = new StanzaNode.build("query", NS_URI_ADMIN).add_self_xmlns(); - query.put_node(new StanzaNode.build("item", NS_URI_ADMIN).put_attribute("nick", nick, NS_URI_ADMIN).put_attribute("role", new_role, NS_URI_ADMIN)); - Iq.Stanza iq = new Iq.Stanza.set(query); - iq.to = jid; - Iq.Module.get_module(stream).send_iq(stream, iq); - } - - private void on_received_message(XmppStream stream, Message.Stanza message) { - if (message.type_ == Message.Stanza.TYPE_GROUPCHAT) { - StanzaNode? subject_node = message.stanza.get_subnode("subject"); - if (subject_node != null) { - string subject = subject_node.get_string_content(); - Muc.Flag.get_flag(stream).set_muc_subject(message.from, subject); - subject_set(stream, subject, message.from); - } - } - } - - private void on_received_presence(XmppStream stream, Presence.Stanza presence) { - Flag flag = Flag.get_flag(stream); - if (presence.is_error() && flag.is_muc_enter_outstanding() && flag.is_occupant(presence.from)) { - string bare_jid = get_bare_jid(presence.from); - ErrorStanza? error_stanza = presence.get_error(); - if (flag.get_enter_id(bare_jid) == error_stanza.original_id) { - MucEnterListener listener = flag.get_enter_listener(bare_jid); - if (error_stanza.condition == ErrorStanza.CONDITION_NOT_AUTHORIZED && ErrorStanza.TYPE_AUTH == error_stanza.type_) { - listener.on_error(MucEnterError.PASSWORD_REQUIRED); - } else if (ErrorStanza.CONDITION_REGISTRATION_REQUIRED == error_stanza.condition && ErrorStanza.TYPE_AUTH == error_stanza.type_) { - listener.on_error(MucEnterError.NOT_IN_MEMBER_LIST); - } else if (ErrorStanza.CONDITION_FORBIDDEN == error_stanza.condition && ErrorStanza.TYPE_AUTH == error_stanza.type_) { - listener.on_error(MucEnterError.BANNED); - } else if (ErrorStanza.CONDITION_CONFLICT == error_stanza.condition && ErrorStanza.TYPE_CANCEL == error_stanza.type_) { - listener.on_error(MucEnterError.NICK_CONFLICT); - } else if (ErrorStanza.CONDITION_SERVICE_UNAVAILABLE == error_stanza.condition && ErrorStanza.TYPE_WAIT == error_stanza.type_) { - listener.on_error(MucEnterError.OCCUPANT_LIMIT_REACHED); - } else if (ErrorStanza.CONDITION_ITEM_NOT_FOUND == error_stanza.condition && ErrorStanza.TYPE_CANCEL == error_stanza.type_) { - listener.on_error(MucEnterError.ROOM_DOESNT_EXIST); - } - flag.finish_muc_enter(bare_jid); - } - } - } - - private void on_received_available(XmppStream stream, Presence.Stanza presence) { - Flag flag = Flag.get_flag(stream); - if (flag.is_occupant(presence.from)) { - StanzaNode? x_node = presence.stanza.get_subnode("x", NS_URI_USER); - if (x_node != null) { - ArrayList<int> status_codes = get_status_codes(x_node); - if (status_codes.contains(StatusCode.SELF_PRESENCE)) { - string bare_jid = get_bare_jid(presence.from); - flag.get_enter_listener(bare_jid).on_success(); - flag.finish_muc_enter(bare_jid, get_resource_part(presence.from)); - } - string? affiliation = x_node["item", "affiliation"].val; - if (affiliation != null) { - received_occupant_affiliation(stream, presence.from, affiliation); - } - string? jid = x_node["item", "jid"].val; - if (jid != null) { - flag.set_real_jid(presence.from, jid); - received_occupant_jid(stream, presence.from, jid); - } - string? role = x_node["item", "role"].val; - if (role != null) { - received_occupant_role(stream, presence.from, role); - } - } - } - } - - private void on_received_unavailable(XmppStream stream, string jid) { - Flag flag = Flag.get_flag(stream); - if (flag.is_occupant(jid)) { - flag.remove_occupant_info(jid); - } - } - - private ArrayList<int> get_status_codes(StanzaNode x_node) { - ArrayList<int> ret = new ArrayList<int>(); - foreach (StanzaNode status_node in x_node.get_subnodes("status", NS_URI_USER)) { - ret.add(int.parse(status_node.get_attribute("code"))); - } - return ret; - } -} - -public enum StatusCode { - /** Inform user that any occupant is allowed to see the user's full JID */ - JID_VISIBLE = 100, - /** Inform user that his or her affiliation changed while not in the room */ - AFFILIATION_CHANGED = 101, - /** Inform occupants that room now shows unavailable members */ - SHOWS_UNAVIABLE_MEMBERS = 102, - /** Inform occupants that room now does not show unavailable members */ - SHOWS_UNAVIABLE_MEMBERS_NOT = 103, - /** Inform occupants that a non-privacy-related room configuration change has occurred */ - CONFIG_CHANGE_NON_PRIVACY = 104, - /** Inform user that presence refers to itself */ - SELF_PRESENCE = 110, - /** Inform occupants that room logging is now enabled */ - LOGGING_ENABLED = 170, - /** Inform occupants that room logging is now disabled */ - LOGGING_DISABLED = 171, - /** Inform occupants that the room is now non-anonymous */ - NON_ANONYMOUS = 172, - /** Inform occupants that the room is now semi-anonymous */ - SEMI_ANONYMOUS = 173, - /** Inform user that a new room has been created */ - NEW_ROOM_CREATED = 201, - /** Inform user that service has assigned or modified occupant's roomnick */ - MODIFIED_NICK = 210, - /** Inform user that he or she has been banned from the room */ - BANNED = 301, - /** Inform all occupants of new room nickname */ - ROOM_NICKNAME = 303, - /** Inform user that he or she has been kicked from the room */ - KICKED = 307, - /** Inform user that he or she is being removed from the room */ - REMOVED_AFFILIATION_CHANGE = 321, - /** Inform user that he or she is being removed from the room because the room has been changed to members-only - and the user is not a member */ - REMOVED_MEMBERS_ONLY = 322, - /** Inform user that he or she is being removed from the room because the MUC service is being shut down */ - REMOVED_SHUTDOWN = 332 -} - -public interface MucEnterListener : Object { - public abstract void on_success(); - public abstract void on_error(MucEnterError error); -} - -} |