Skip to content

C
converse.js
Commit c8e6f53e authored by JC Brand's avatar JC Brand
Browse files
Options

Remove require.js stuff (we'll have to use shims) and update to newest versions

parent ba201a76
Hide whitespace changes
Inline Side-by-side
Showing with 1351 additions and 1309 deletions
Libraries/strophe.muc.js
View file @ c8e6f53e
// Generated by CoffeeScript 1.3.3
/* /*
*Plugin to implement the MUC extension. *Plugin to implement the MUC extension.
http://xmpp.org/extensions/xep-0045.html http://xmpp.org/extensions/xep-0045.html
...@@ -7,949 +7,1005 @@ ...@@ -7,949 +7,1005 @@
*Complete CoffeeScript rewrite: *Complete CoffeeScript rewrite:
Andreas Guth <guth@dbis.rwth-aachen.de> Andreas Guth <guth@dbis.rwth-aachen.de>
*/ */
// AMD/global registrations
(function (root, factory) { var Occupant, RoomConfig, XmppRoom,
if (typeof define === 'function' && define.amd) { __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; };
define([
"Libraries/strophe" Strophe.addConnectionPlugin('muc', {
], function () { _connection: null,
return factory(jQuery, console); rooms: [],
} /*Function
); Initialize the MUC plugin. Sets the correct connection object and
extends the namesace.
*/
init: function(conn) {
this._connection = conn;
this._muc_handler = null;
Strophe.addNamespace('MUC_OWNER', Strophe.NS.MUC + "#owner");
Strophe.addNamespace('MUC_ADMIN', Strophe.NS.MUC + "#admin");
Strophe.addNamespace('MUC_USER', Strophe.NS.MUC + "#user");
return Strophe.addNamespace('MUC_ROOMCONF', Strophe.NS.MUC + "#roomconfig");
},
/*Function
Join a multi-user chat room
Parameters:
(String) room - The multi-user chat room to join.
(String) nick - The nickname to use in the chat room. Optional
(Function) msg_handler_cb - The function call to handle messages from the
specified chat room.
(Function) pres_handler_cb - The function call back to handle presence
in the chat room.
(String) password - The optional password to use. (password protected
rooms only)
*/
join: function(room, nick, msg_handler_cb, pres_handler_cb, roster_cb, password) {
var msg, room_nick, _base, _ref, _ref1,
_this = this;
room_nick = this.test_append_nick(room, nick);
msg = $pres({
from: this._connection.jid,
to: room_nick
}).c("x", {
xmlns: Strophe.NS.MUC
});
if (password != null) {
msg.cnode(Strophe.xmlElement("password", [], password));
} }
}(this, function ($, console) { if ((_ref = this._muc_handler) == null) {
this._muc_handler = this._connection.addHandler(function(stanza) {
(function() { var from, handler, handlers, id, roomname, x, xmlns, xquery, _i, _len;
var Occupant, RoomConfig, XmppRoom, from = stanza.getAttribute('from');
__bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; }; if (!from) {
return true;
Strophe.addConnectionPlugin('muc', {
_connection: null,
rooms: [],
/*Function
Initialize the MUC plugin. Sets the correct connection object and
extends the namesace.
*/
init: function(conn) {
this._connection = conn;
this._muc_handler = null;
Strophe.addNamespace('MUC_OWNER', Strophe.NS.MUC + "#owner");
Strophe.addNamespace('MUC_ADMIN', Strophe.NS.MUC + "#admin");
Strophe.addNamespace('MUC_USER', Strophe.NS.MUC + "#user");
return Strophe.addNamespace('MUC_ROOMCONF', Strophe.NS.MUC + "#roomconfig");
},
/*Function
Join a multi-user chat room
Parameters:
(String) room - The multi-user chat room to join.
(String) nick - The nickname to use in the chat room. Optional
(Function) msg_handler_cb - The function call to handle messages from the
specified chat room.
(Function) pres_handler_cb - The function call back to handle presence
in the chat room.
(String) password - The optional password to use. (password protected
rooms only)
*/
join: function(room, nick, msg_handler_cb, pres_handler_cb, roster_cb, password) {
var msg, room_nick, _base,
_this = this;
room_nick = this.test_append_nick(room, nick);
msg = $pres({
from: this._connection.jid,
to: room_nick
}).c("x", {
xmlns: Strophe.NS.MUC
});
if (password != null) {
msg.cnode(Strophe.xmlElement("password", [], password));
}
if (this._muc_handler == null) {
this._muc_handler = this._connection.addHandler(function(stanza) {
var from, handler, handlers, id, roomname, x, xmlns, xquery, _i, _len;
from = stanza.getAttribute('from');
roomname = from.split("/")[0];
if (!_this.rooms[roomname]) return true;
room = _this.rooms[roomname];
handlers = {};
if (stanza.nodeName === "message") {
handlers = room._message_handlers;
} else if (stanza.nodeName === "presence") {
xquery = stanza.getElementsByTagName("x");
if (xquery.length > 0) {
for (_i = 0, _len = xquery.length; _i < _len; _i++) {
x = xquery[_i];
xmlns = x.getAttribute("xmlns");
if (xmlns && xmlns.match(Strophe.NS.MUC)) {
handlers = room._presence_handlers;
break;
}
}
}
}
for (id in handlers) {
handler = handlers[id];
if (!handler(stanza, room)) delete handlers[id];
}
return true;
});
}
if ((_base = this.rooms)[room] == null) {
_base[room] = new XmppRoom(this, room, nick, password);
}
if (pres_handler_cb) {
this.rooms[room].addHandler('presence', pres_handler_cb);
}
if (msg_handler_cb) this.rooms[room].addHandler('message', msg_handler_cb);
if (roster_cb) this.rooms[room].addHandler('roster', roster_cb);
return this._connection.send(msg);
},
/*Function
Leave a multi-user chat room
Parameters:
(String) room - The multi-user chat room to leave.
(String) nick - The nick name used in the room.
(Function) handler_cb - Optional function to handle the successful leave.
(String) exit_msg - optional exit message.
Returns:
iqid - The unique id for the room leave.
*/
leave: function(room, nick, handler_cb, exit_msg) {
var presence, presenceid, room_nick;
delete this.rooms[room];
if (this.rooms.length === 0) {
this._connection.deleteHandler(this._muc_handler);
this._muc_handler = null;
} }
room_nick = this.test_append_nick(room, nick); roomname = from.split("/")[0];
presenceid = this._connection.getUniqueId(); if (!_this.rooms[roomname]) {
presence = $pres({ return true;
type: "unavailable",
id: presenceid,
from: this._connection.jid,
to: room_nick
});
if (exit_msg != null) presence.c("status", exit_msg);
if (handler_cb != null) {
this._connection.addHandler(handler_cb, null, "presence", null, presenceid);
} }
this._connection.send(presence); room = _this.rooms[roomname];
return presenceid; handlers = {};
}, if (stanza.nodeName === "message") {
/*Function handlers = room._message_handlers;
Parameters: } else if (stanza.nodeName === "presence") {
(String) room - The multi-user chat room name. xquery = stanza.getElementsByTagName("x");
(String) nick - The nick name used in the chat room. if (xquery.length > 0) {
(String) message - The plaintext message to send to the room. for (_i = 0, _len = xquery.length; _i < _len; _i++) {
(String) html_message - The message to send to the room with html markup. x = xquery[_i];
(String) type - "groupchat" for group chat messages o xmlns = x.getAttribute("xmlns");
"chat" for private chat messages if (xmlns && xmlns.match(Strophe.NS.MUC)) {
Returns: handlers = room._presence_handlers;
msgiq - the unique id used to send the message break;
*/ }
message: function(room, nick, message, html_message, type) {
var msg, msgid, parent, room_nick;
room_nick = this.test_append_nick(room, nick);
type = type || (nick != null ? "chat" : "groupchat");
msgid = this._connection.getUniqueId();
msg = $msg({
to: room_nick,
from: this._connection.jid,
type: type,
id: msgid
}).c("body", {
xmlns: Strophe.NS.CLIENT
}).t(message);
msg.up();
if (html_message != null) {
msg.c("html", {
xmlns: Strophe.NS.XHTML_IM
}).c("body", {
xmlns: Strophe.NS.XHTML
}).h(html_message);
if (msg.node.childNodes.length === 0) {
parent = msg.node.parentNode;
msg.up().up();
msg.node.removeChild(parent);
} else {
msg.up().up();
} }
}
} }
msg.c("x", { for (id in handlers) {
xmlns: "jabber:x:event" handler = handlers[id];
}).c("composing"); if (!handler(stanza, room)) {
this._connection.send(msg); delete handlers[id];
return msgid; }
},
/*Function
Convenience Function to send a Message to all Occupants
Parameters:
(String) room - The multi-user chat room name.
(String) message - The plaintext message to send to the room.
(String) html_message - The message to send to the room with html markup.
Returns:
msgiq - the unique id used to send the message
*/
groupchat: function(room, message, html_message) {
return this.message(room, null, message, html_message);
},
/*Function
Send a mediated invitation.
Parameters:
(String) room - The multi-user chat room name.
(String) receiver - The invitation's receiver.
(String) reason - Optional reason for joining the room.
Returns:
msgiq - the unique id used to send the invitation
*/
invite: function(room, receiver, reason) {
var invitation, msgid;
msgid = this._connection.getUniqueId();
invitation = $msg({
from: this._connection.jid,
to: room,
id: msgid
}).c('x', {
xmlns: Strophe.NS.MUC_USER
}).c('invite', {
to: receiver
});
if (reason != null) invitation.c('reason', reason);
this._connection.send(invitation);
return msgid;
},
/*Function
Send a direct invitation.
Parameters:
(String) room - The multi-user chat room name.
(String) receiver - The invitation's receiver.
(String) reason - Optional reason for joining the room.
(String) password - Optional password for the room.
Returns:
msgiq - the unique id used to send the invitation
*/
directInvite: function(room, receiver, reason, password) {
var attrs, invitation, msgid;
msgid = this._connection.getUniqueId();
attrs = {
xmlns: 'jabber:x:conference',
jid: room
};
if (reason != null) attrs.reason = reason;
if (password != null) attrs.password = password;
invitation = $msg({
from: this._connection.jid,
to: receiver,
id: msgid
}).c('x', attrs);
this._connection.send(invitation);
return msgid;
},
/*Function
Queries a room for a list of occupants
(String) room - The multi-user chat room name.
(Function) success_cb - Optional function to handle the info.
(Function) error_cb - Optional function to handle an error.
Returns:
id - the unique id used to send the info request
*/
queryOccupants: function(room, success_cb, error_cb) {
var attrs, info;
attrs = {
xmlns: Strophe.NS.DISCO_ITEMS
};
info = $iq({
from: this._connection.jid,
to: room,
type: 'get'
}).c('query', attrs);
return this._connection.sendIQ(info, success_cb, error_cb);
},
/*Function
Start a room configuration.
Parameters:
(String) room - The multi-user chat room name.
(Function) handler_cb - Optional function to handle the config form.
Returns:
id - the unique id used to send the configuration request
*/
configure: function(room, handler_cb) {
var config, id, stanza;
config = $iq({
to: room,
type: "get"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
});
stanza = config.tree();
id = this._connection.sendIQ(stanza);
if (handler_cb != null) {
this._connection.addHandler(function(stanza) {
handler_cb(stanza);
return false;
}, Strophe.NS.MUC_OWNER, "iq", null, id);
}
return id;
},
/*Function
Cancel the room configuration
Parameters:
(String) room - The multi-user chat room name.
Returns:
id - the unique id used to cancel the configuration.
*/
cancelConfigure: function(room) {
var config, stanza;
config = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
}).c("x", {
xmlns: "jabber:x:data",
type: "cancel"
});
stanza = config.tree();
return this._connection.sendIQ(stanza);
},
/*Function
Save a room configuration.
Parameters:
(String) room - The multi-user chat room name.
(Array) configarray - an array of form elements used to configure the room.
Returns:
id - the unique id used to save the configuration.
*/
saveConfiguration: function(room, configarray) {
var conf, config, stanza, _i, _len;
config = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
}).c("x", {
xmlns: "jabber:x:data",
type: "submit"
});
for (_i = 0, _len = configarray.length; _i < _len; _i++) {
conf = configarray[_i];
config.cnode(conf).up();
}
stanza = config.tree();
return this._connection.sendIQ(stanza);
},
/*Function
Parameters:
(String) room - The multi-user chat room name.
Returns:
id - the unique id used to create the chat room.
*/
createInstantRoom: function(room) {
var roomiq;
roomiq = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
}).c("x", {
xmlns: "jabber:x:data",
type: "submit"
});
return this._connection.sendIQ(roomiq.tree());
},
/*Function
Set the topic of the chat room.
Parameters:
(String) room - The multi-user chat room name.
(String) topic - Topic message.
*/
setTopic: function(room, topic) {
var msg;
msg = $msg({
to: room,
from: this._connection.jid,
type: "groupchat"
}).c("subject", {
xmlns: "jabber:client"
}).t(topic);
return this._connection.send(msg.tree());
},
/*Function
Internal Function that Changes the role or affiliation of a member
of a MUC room. This function is used by modifyRole and modifyAffiliation.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(Object) item - Object with nick and role or jid and affiliation attribute
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) errer_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
_modifyPrivilege: function(room, item, reason, handler_cb, error_cb) {
var iq;
iq = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_ADMIN
}).cnode(item.node);
if (reason != null) iq.c("reason", reason);
return this._connection.sendIQ(iq.tree(), handler_cb, error_cb);
},
/*Function
Changes the role of a member of a MUC room.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(String) nick - The nick name of the user to modify.
(String) role - The new role of the user.
(String) affiliation - The new affiliation of the user.
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) errer_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
modifyRole: function(room, nick, role, reason, handler_cb, error_cb) {
var item;
item = $build("item", {
nick: nick,
role: role
});
return this._modifyPrivilege(room, item, reason, handler_cb, error_cb);
},
kick: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'none', reason, handler_cb, error_cb);
},
voice: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'participant', reason, handler_cb, error_cb);
},
mute: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'visitor', reason, handler_cb, error_cb);
},
op: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'moderator', reason, handler_cb, error_cb);
},
deop: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'participant', reason, handler_cb, error_cb);
},
/*Function
Changes the affiliation of a member of a MUC room.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(String) jid - The jid of the user to modify.
(String) affiliation - The new affiliation of the user.
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) errer_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
modifyAffiliation: function(room, jid, affiliation, reason, handler_cb, error_cb) {
var item;
item = $build("item", {
jid: jid,
affiliation: affiliation
});
return this._modifyPrivilege(room, item, reason, handler_cb, error_cb);
},
ban: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'outcast', reason, handler_cb, error_cb);
},
member: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'member', reason, handler_cb, error_cb);
},
revoke: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'none', reason, handler_cb, error_cb);
},
owner: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'owner', reason, handler_cb, error_cb);
},
admin: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'admin', reason, handler_cb, error_cb);
},
/*Function
Change the current users nick name.
Parameters:
(String) room - The multi-user chat room name.
(String) user - The new nick name.
*/
changeNick: function(room, user) {
var presence, room_nick;
room_nick = this.test_append_nick(room, user);
presence = $pres({
from: this._connection.jid,
to: room_nick,
id: this._connection.getUniqueId()
});
return this._connection.send(presence.tree());
},
/*Function
Change the current users status.
Parameters:
(String) room - The multi-user chat room name.
(String) user - The current nick.
(String) show - The new show-text.
(String) status - The new status-text.
*/
setStatus: function(room, user, show, status) {
var presence, room_nick;
room_nick = this.test_append_nick(room, user);
presence = $pres({
from: this._connection.jid,
to: room_nick
});
if (show != null) presence.c('show', show).up();
if (status != null) presence.c('status', status);
return this._connection.send(presence.tree());
},
/*Function
List all chat room available on a server.
Parameters:
(String) server - name of chat server.
(String) handle_cb - Function to call for room list return.
*/
listRooms: function(server, handle_cb) {
var iq;
iq = $iq({
to: server,
from: this._connection.jid,
type: "get"
}).c("query", {
xmlns: Strophe.NS.DISCO_ITEMS
});
return this._connection.sendIQ(iq, handle_cb);
},
test_append_nick: function(room, nick) {
return room + (nick != null ? "/" + (Strophe.escapeNode(nick)) : "");
} }
return true;
});
}
if ((_ref1 = (_base = this.rooms)[room]) == null) {
_base[room] = new XmppRoom(this, room, nick, password);
}
if (pres_handler_cb) {
this.rooms[room].addHandler('presence', pres_handler_cb);
}
if (msg_handler_cb) {
this.rooms[room].addHandler('message', msg_handler_cb);
}
if (roster_cb) {
this.rooms[room].addHandler('roster', roster_cb);
}
return this._connection.send(msg);
},
/*Function
Leave a multi-user chat room
Parameters:
(String) room - The multi-user chat room to leave.
(String) nick - The nick name used in the room.
(Function) handler_cb - Optional function to handle the successful leave.
(String) exit_msg - optional exit message.
Returns:
iqid - The unique id for the room leave.
*/
leave: function(room, nick, handler_cb, exit_msg) {
var presence, presenceid, room_nick;
delete this.rooms[room];
if (this.rooms.length === 0) {
this._connection.deleteHandler(this._muc_handler);
this._muc_handler = null;
}
room_nick = this.test_append_nick(room, nick);
presenceid = this._connection.getUniqueId();
presence = $pres({
type: "unavailable",
id: presenceid,
from: this._connection.jid,
to: room_nick
}); });
if (exit_msg != null) {
presence.c("status", exit_msg);
}
if (handler_cb != null) {
this._connection.addHandler(handler_cb, null, "presence", null, presenceid);
}
this._connection.send(presence);
return presenceid;
},
/*Function
Parameters:
(String) room - The multi-user chat room name.
(String) nick - The nick name used in the chat room.
(String) message - The plaintext message to send to the room.
(String) html_message - The message to send to the room with html markup.
(String) type - "groupchat" for group chat messages o
"chat" for private chat messages
Returns:
msgiq - the unique id used to send the message
*/
message: function(room, nick, message, html_message, type) {
var msg, msgid, parent, room_nick;
room_nick = this.test_append_nick(room, nick);
type = type || (nick != null ? "chat" : "groupchat");
msgid = this._connection.getUniqueId();
msg = $msg({
to: room_nick,
from: this._connection.jid,
type: type,
id: msgid
}).c("body", {
xmlns: Strophe.NS.CLIENT
}).t(message);
msg.up();
if (html_message != null) {
msg.c("html", {
xmlns: Strophe.NS.XHTML_IM
}).c("body", {
xmlns: Strophe.NS.XHTML
}).h(html_message);
if (msg.node.childNodes.length === 0) {
parent = msg.node.parentNode;
msg.up().up();
msg.node.removeChild(parent);
} else {
msg.up().up();
}
}
msg.c("x", {
xmlns: "jabber:x:event"
}).c("composing");
this._connection.send(msg);
return msgid;
},
/*Function
Convenience Function to send a Message to all Occupants
Parameters:
(String) room - The multi-user chat room name.
(String) message - The plaintext message to send to the room.
(String) html_message - The message to send to the room with html markup.
Returns:
msgiq - the unique id used to send the message
*/
groupchat: function(room, message, html_message) {
return this.message(room, null, message, html_message);
},
/*Function
Send a mediated invitation.
Parameters:
(String) room - The multi-user chat room name.
(String) receiver - The invitation's receiver.
(String) reason - Optional reason for joining the room.
Returns:
msgiq - the unique id used to send the invitation
*/
invite: function(room, receiver, reason) {
var invitation, msgid;
msgid = this._connection.getUniqueId();
invitation = $msg({
from: this._connection.jid,
to: room,
id: msgid
}).c('x', {
xmlns: Strophe.NS.MUC_USER
}).c('invite', {
to: receiver
});
if (reason != null) {
invitation.c('reason', reason);
}
this._connection.send(invitation);
return msgid;
},
/*Function
Send a direct invitation.
Parameters:
(String) room - The multi-user chat room name.
(String) receiver - The invitation's receiver.
(String) reason - Optional reason for joining the room.
(String) password - Optional password for the room.
Returns:
msgiq - the unique id used to send the invitation
*/
directInvite: function(room, receiver, reason, password) {
var attrs, invitation, msgid;
msgid = this._connection.getUniqueId();
attrs = {
xmlns: 'jabber:x:conference',
jid: room
};
if (reason != null) {
attrs.reason = reason;
}
if (password != null) {
attrs.password = password;
}
invitation = $msg({
from: this._connection.jid,
to: receiver,
id: msgid
}).c('x', attrs);
this._connection.send(invitation);
return msgid;
},
/*Function
Queries a room for a list of occupants
(String) room - The multi-user chat room name.
(Function) success_cb - Optional function to handle the info.
(Function) error_cb - Optional function to handle an error.
Returns:
id - the unique id used to send the info request
*/
queryOccupants: function(room, success_cb, error_cb) {
var attrs, info;
attrs = {
xmlns: Strophe.NS.DISCO_ITEMS
};
info = $iq({
from: this._connection.jid,
to: room,
type: 'get'
}).c('query', attrs);
return this._connection.sendIQ(info, success_cb, error_cb);
},
/*Function
Start a room configuration.
Parameters:
(String) room - The multi-user chat room name.
(Function) handler_cb - Optional function to handle the config form.
Returns:
id - the unique id used to send the configuration request
*/
configure: function(room, handler_cb, error_cb) {
var config, stanza;
config = $iq({
to: room,
type: "get"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
});
stanza = config.tree();
return this._connection.sendIQ(stanza, handler_cb, error_cb);
},
/*Function
Cancel the room configuration
Parameters:
(String) room - The multi-user chat room name.
Returns:
id - the unique id used to cancel the configuration.
*/
cancelConfigure: function(room) {
var config, stanza;
config = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
}).c("x", {
xmlns: "jabber:x:data",
type: "cancel"
});
stanza = config.tree();
return this._connection.sendIQ(stanza);
},
/*Function
Save a room configuration.
Parameters:
(String) room - The multi-user chat room name.
(Array) config- Form Object or an array of form elements used to configure the room.
Returns:
id - the unique id used to save the configuration.
*/
saveConfiguration: function(room, config, success_cb, error_cb) {
var conf, iq, stanza, _i, _len;
iq = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
});
if (config instanceof Form) {
config.type = "submit";
iq.cnode(config.toXML());
} else {
iq.c("x", {
xmlns: "jabber:x:data",
type: "submit"
});
for (_i = 0, _len = config.length; _i < _len; _i++) {
conf = config[_i];
iq.cnode(conf).up();
}
}
stanza = iq.tree();
return this._connection.sendIQ(stanza, success_cb, error_cb);
},
/*Function
Parameters:
(String) room - The multi-user chat room name.
Returns:
id - the unique id used to create the chat room.
*/
createInstantRoom: function(room, success_cb, error_cb) {
var roomiq;
roomiq = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_OWNER
}).c("x", {
xmlns: "jabber:x:data",
type: "submit"
});
return this._connection.sendIQ(roomiq.tree(), success_cb, error_cb);
},
/*Function
Set the topic of the chat room.
Parameters:
(String) room - The multi-user chat room name.
(String) topic - Topic message.
*/
setTopic: function(room, topic) {
var msg;
msg = $msg({
to: room,
from: this._connection.jid,
type: "groupchat"
}).c("subject", {
xmlns: "jabber:client"
}).t(topic);
return this._connection.send(msg.tree());
},
/*Function
Internal Function that Changes the role or affiliation of a member
of a MUC room. This function is used by modifyRole and modifyAffiliation.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(Object) item - Object with nick and role or jid and affiliation attribute
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) error_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
_modifyPrivilege: function(room, item, reason, handler_cb, error_cb) {
var iq;
iq = $iq({
to: room,
type: "set"
}).c("query", {
xmlns: Strophe.NS.MUC_ADMIN
}).cnode(item.node);
if (reason != null) {
iq.c("reason", reason);
}
return this._connection.sendIQ(iq.tree(), handler_cb, error_cb);
},
/*Function
Changes the role of a member of a MUC room.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(String) nick - The nick name of the user to modify.
(String) role - The new role of the user.
(String) affiliation - The new affiliation of the user.
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) error_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
modifyRole: function(room, nick, role, reason, handler_cb, error_cb) {
var item;
item = $build("item", {
nick: nick,
role: role
});
return this._modifyPrivilege(room, item, reason, handler_cb, error_cb);
},
kick: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'none', reason, handler_cb, error_cb);
},
voice: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'participant', reason, handler_cb, error_cb);
},
mute: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'visitor', reason, handler_cb, error_cb);
},
op: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'moderator', reason, handler_cb, error_cb);
},
deop: function(room, nick, reason, handler_cb, error_cb) {
return this.modifyRole(room, nick, 'participant', reason, handler_cb, error_cb);
},
/*Function
Changes the affiliation of a member of a MUC room.
The modification can only be done by a room moderator. An error will be
returned if the user doesn't have permission.
Parameters:
(String) room - The multi-user chat room name.
(String) jid - The jid of the user to modify.
(String) affiliation - The new affiliation of the user.
(String) reason - Optional reason for the change.
(Function) handler_cb - Optional callback for success
(Function) error_cb - Optional callback for error
Returns:
iq - the id of the mode change request.
*/
modifyAffiliation: function(room, jid, affiliation, reason, handler_cb, error_cb) {
var item;
item = $build("item", {
jid: jid,
affiliation: affiliation
});
return this._modifyPrivilege(room, item, reason, handler_cb, error_cb);
},
ban: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'outcast', reason, handler_cb, error_cb);
},
member: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'member', reason, handler_cb, error_cb);
},
revoke: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'none', reason, handler_cb, error_cb);
},
owner: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'owner', reason, handler_cb, error_cb);
},
admin: function(room, jid, reason, handler_cb, error_cb) {
return this.modifyAffiliation(room, jid, 'admin', reason, handler_cb, error_cb);
},
/*Function
Change the current users nick name.
Parameters:
(String) room - The multi-user chat room name.
(String) user - The new nick name.
*/
changeNick: function(room, user) {
var presence, room_nick;
room_nick = this.test_append_nick(room, user);
presence = $pres({
from: this._connection.jid,
to: room_nick,
id: this._connection.getUniqueId()
});
return this._connection.send(presence.tree());
},
/*Function
Change the current users status.
Parameters:
(String) room - The multi-user chat room name.
(String) user - The current nick.
(String) show - The new show-text.
(String) status - The new status-text.
*/
setStatus: function(room, user, show, status) {
var presence, room_nick;
room_nick = this.test_append_nick(room, user);
presence = $pres({
from: this._connection.jid,
to: room_nick
});
if (show != null) {
presence.c('show', show).up();
}
if (status != null) {
presence.c('status', status);
}
return this._connection.send(presence.tree());
},
/*Function
List all chat room available on a server.
Parameters:
(String) server - name of chat server.
(String) handle_cb - Function to call for room list return.
(String) error_cb - Function to call on error.
*/
listRooms: function(server, handle_cb, error_cb) {
var iq;
iq = $iq({
to: server,
from: this._connection.jid,
type: "get"
}).c("query", {
xmlns: Strophe.NS.DISCO_ITEMS
});
return this._connection.sendIQ(iq, handle_cb, error_cb);
},
test_append_nick: function(room, nick) {
return room + (nick != null ? "/" + (Strophe.escapeNode(nick)) : "");
}
});
XmppRoom = (function() { XmppRoom = (function() {
XmppRoom.prototype.roster = {}; XmppRoom.prototype.roster = {};
XmppRoom.prototype._message_handlers = {}; XmppRoom.prototype._message_handlers = {};
XmppRoom.prototype._presence_handlers = {}; XmppRoom.prototype._presence_handlers = {};
XmppRoom.prototype._roster_handlers = {}; XmppRoom.prototype._roster_handlers = {};
XmppRoom.prototype._handler_ids = 0; XmppRoom.prototype._handler_ids = 0;
function XmppRoom(client, name, nick, password) { function XmppRoom(client, name, nick, password) {
this.client = client; this.client = client;
this.name = name; this.name = name;
this.nick = nick; this.nick = nick;
this.password = password; this.password = password;
this._roomRosterHandler = __bind(this._roomRosterHandler, this); this._roomRosterHandler = __bind(this._roomRosterHandler, this);
this._addOccupant = __bind(this._addOccupant, this);
if (client.muc) this.client = client.muc;
this.name = Strophe.getBareJidFromJid(name);
this.client.rooms[this.name] = this;
this.addHandler('presence', this._roomRosterHandler);
}
XmppRoom.prototype.join = function(msg_handler_cb, pres_handler_cb) { this._addOccupant = __bind(this._addOccupant, this);
if (!this.client.rooms[this.name]) {
return this.client.join(this.name, this.nick, msg_handler_cb, pres_handler_cb, this.password);
}
};
XmppRoom.prototype.leave = function(handler_cb, message) { if (client.muc) {
this.client.leave(this.name, this.nick, handler_cb, message); this.client = client.muc;
return delete this.client.rooms[this.name]; }
}; this.name = Strophe.getBareJidFromJid(name);
this.client.rooms[this.name] = this;
XmppRoom.prototype.message = function(nick, message, html_message, type) { this.addHandler('presence', this._roomRosterHandler);
return this.client.message(this.name, nick, message, html_message, type); }
};
XmppRoom.prototype.join = function(msg_handler_cb, pres_handler_cb, roster_cb) {
XmppRoom.prototype.groupchat = function(message, html_message) { return this.client.join(this.name, this.nick, msg_handler_cb, pres_handler_cb, roster_cb, this.password);
return this.client.groupchat(this.name, message, html_message); };
};
XmppRoom.prototype.leave = function(handler_cb, message) {
XmppRoom.prototype.invite = function(receiver, reason) { this.client.leave(this.name, this.nick, handler_cb, message);
return this.client.invite(this.name, receiver, reason); return delete this.client.rooms[this.name];
}; };
XmppRoom.prototype.directInvite = function(receiver, reason) { XmppRoom.prototype.message = function(nick, message, html_message, type) {
return this.client.directInvite(this.name, receiver, reason, this.password); return this.client.message(this.name, nick, message, html_message, type);
}; };
XmppRoom.prototype.configure = function(handler_cb) { XmppRoom.prototype.groupchat = function(message, html_message) {
return this.client.configure(this.name, handler_cb); return this.client.groupchat(this.name, message, html_message);
}; };
XmppRoom.prototype.cancelConfigure = function() { XmppRoom.prototype.invite = function(receiver, reason) {
return this.client.cancelConfigure(this.name); return this.client.invite(this.name, receiver, reason);
}; };
XmppRoom.prototype.saveConfiguration = function(configarray) { XmppRoom.prototype.directInvite = function(receiver, reason) {
return this.client.saveConfiguration(this.name, configarray); return this.client.directInvite(this.name, receiver, reason, this.password);
}; };
XmppRoom.prototype.queryOccupants = function(success_cb, error_cb) { XmppRoom.prototype.configure = function(handler_cb) {
return this.client.queryOccupants(this.name, success_cb, error_cb); return this.client.configure(this.name, handler_cb);
}; };
XmppRoom.prototype.setTopic = function(topic) { XmppRoom.prototype.cancelConfigure = function() {
return this.client.setTopic(this.name, topic); return this.client.cancelConfigure(this.name);
}; };
XmppRoom.prototype.modifyRole = function(nick, role, reason, success_cb, error_cb) { XmppRoom.prototype.saveConfiguration = function(config) {
return this.client.modifyRole(this.name, nick, role, reason, success_cb, error_cb); return this.client.saveConfiguration(this.name, config);
}; };
XmppRoom.prototype.kick = function(nick, reason, handler_cb, error_cb) { XmppRoom.prototype.queryOccupants = function(success_cb, error_cb) {
return this.client.kick(this.name, nick, reason, handler_cb, error_cb); return this.client.queryOccupants(this.name, success_cb, error_cb);
}; };
XmppRoom.prototype.voice = function(nick, reason, handler_cb, error_cb) { XmppRoom.prototype.setTopic = function(topic) {
return this.client.voice(this.name, nick, reason, handler_cb, error_cb); return this.client.setTopic(this.name, topic);
}; };
XmppRoom.prototype.mute = function(nick, reason, handler_cb, error_cb) { XmppRoom.prototype.modifyRole = function(nick, role, reason, success_cb, error_cb) {
return this.client.mute(this.name, nick, reason, handler_cb, error_cb); return this.client.modifyRole(this.name, nick, role, reason, success_cb, error_cb);
}; };
XmppRoom.prototype.op = function(nick, reason, handler_cb, error_cb) { XmppRoom.prototype.kick = function(nick, reason, handler_cb, error_cb) {
return this.client.op(this.name, nick, reason, handler_cb, error_cb); return this.client.kick(this.name, nick, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.deop = function(nick, reason, handler_cb, error_cb) { XmppRoom.prototype.voice = function(nick, reason, handler_cb, error_cb) {
return this.client.deop(this.name, nick, reason, handler_cb, error_cb); return this.client.voice(this.name, nick, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.modifyAffiliation = function(jid, affiliation, reason, success_cb, error_cb) { XmppRoom.prototype.mute = function(nick, reason, handler_cb, error_cb) {
return this.client.modifyAffiliation(this.name, jid, affiliation, reason, success_cb, error_cb); return this.client.mute(this.name, nick, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.ban = function(jid, reason, handler_cb, error_cb) { XmppRoom.prototype.op = function(nick, reason, handler_cb, error_cb) {
return this.client.ban(this.name, jid, reason, handler_cb, error_cb); return this.client.op(this.name, nick, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.member = function(jid, reason, handler_cb, error_cb) { XmppRoom.prototype.deop = function(nick, reason, handler_cb, error_cb) {
return this.client.member(this.name, jid, reason, handler_cb, error_cb); return this.client.deop(this.name, nick, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.revoke = function(jid, reason, handler_cb, error_cb) { XmppRoom.prototype.modifyAffiliation = function(jid, affiliation, reason, success_cb, error_cb) {
return this.client.revoke(this.name, jid, reason, handler_cb, error_cb); return this.client.modifyAffiliation(this.name, jid, affiliation, reason, success_cb, error_cb);
}; };
XmppRoom.prototype.owner = function(jid, reason, handler_cb, error_cb) { XmppRoom.prototype.ban = function(jid, reason, handler_cb, error_cb) {
return this.client.owner(this.name, jid, reason, handler_cb, error_cb); return this.client.ban(this.name, jid, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.admin = function(jid, reason, handler_cb, error_cb) { XmppRoom.prototype.member = function(jid, reason, handler_cb, error_cb) {
return this.client.admin(this.name, jid, reason, handler_cb, error_cb); return this.client.member(this.name, jid, reason, handler_cb, error_cb);
}; };
XmppRoom.prototype.changeNick = function(nick) { XmppRoom.prototype.revoke = function(jid, reason, handler_cb, error_cb) {
this.nick = nick; return this.client.revoke(this.name, jid, reason, handler_cb, error_cb);
return this.client.changeNick(this.name, nick); };
};
XmppRoom.prototype.owner = function(jid, reason, handler_cb, error_cb) {
XmppRoom.prototype.setStatus = function(show, status) { return this.client.owner(this.name, jid, reason, handler_cb, error_cb);
return this.client.setStatus(this.name, this.nick, show, status); };
};
XmppRoom.prototype.admin = function(jid, reason, handler_cb, error_cb) {
/*Function return this.client.admin(this.name, jid, reason, handler_cb, error_cb);
Adds a handler to the MUC room. };
Parameters:
(String) handler_type - 'message', 'presence' or 'roster'. XmppRoom.prototype.changeNick = function(nick) {
(Function) handler - The handler function. this.nick = nick;
Returns: return this.client.changeNick(this.name, nick);
id - the id of handler. };
*/
XmppRoom.prototype.setStatus = function(show, status) {
XmppRoom.prototype.addHandler = function(handler_type, handler) { return this.client.setStatus(this.name, this.nick, show, status);
var id; };
id = this._handler_ids++;
switch (handler_type) { /*Function
case 'presence': Adds a handler to the MUC room.
this._presence_handlers[id] = handler; Parameters:
break; (String) handler_type - 'message', 'presence' or 'roster'.
case 'message': (Function) handler - The handler function.
this._message_handlers[id] = handler; Returns:
break; id - the id of handler.
case 'roster': */
this._roster_handlers[id] = handler;
break;
default: XmppRoom.prototype.addHandler = function(handler_type, handler) {
this._handler_ids--; var id;
return null; id = this._handler_ids++;
switch (handler_type) {
case 'presence':
this._presence_handlers[id] = handler;
break;
case 'message':
this._message_handlers[id] = handler;
break;
case 'roster':
this._roster_handlers[id] = handler;
break;
default:
this._handler_ids--;
return null;
}
return id;
};
/*Function
Removes a handler from the MUC room.
This function takes ONLY ids returned by the addHandler function
of this room. passing handler ids returned by connection.addHandler
may brake things!
Parameters:
(number) id - the id of the handler
*/
XmppRoom.prototype.removeHandler = function(id) {
delete this._presence_handlers[id];
delete this._message_handlers[id];
return delete this._roster_handlers[id];
};
/*Function
Creates and adds an Occupant to the Room Roster.
Parameters:
(Object) data - the data the Occupant is filled with
Returns:
occ - the created Occupant.
*/
XmppRoom.prototype._addOccupant = function(data) {
var occ;
occ = new Occupant(data, this);
this.roster[occ.nick] = occ;
return occ;
};
/*Function
The standard handler that managed the Room Roster.
Parameters:
(Object) pres - the presence stanza containing user information
*/
XmppRoom.prototype._roomRosterHandler = function(pres) {
var data, handler, id, newnick, nick, _ref;
data = XmppRoom._parsePresence(pres);
nick = data.nick;
newnick = data.newnick || null;
switch (data.type) {
case 'error':
return;
case 'unavailable':
if (newnick) {
data.nick = newnick;
if (this.roster[nick] && this.roster[newnick]) {
this.roster[nick].update(this.roster[newnick]);
this.roster[newnick] = this.roster[nick];
}
if (this.roster[nick] && !this.roster[newnick]) {
this.roster[newnick] = this.roster[nick].update(data);
}
} }
return id; delete this.roster[nick];
}; break;
default:
/*Function if (this.roster[nick]) {
Removes a handler from the MUC room. this.roster[nick].update(data);
This function takes ONLY ids returned by the addHandler function } else {
of this room. passing handler ids returned by connection.addHandler this._addOccupant(data);
may brake things! }
Parameters: }
(number) id - the id of the handler _ref = this._roster_handlers;
*/ for (id in _ref) {
handler = _ref[id];
XmppRoom.prototype.removeHandler = function(id) { if (!handler(this.roster, this)) {
delete this._presence_handlers[id]; delete this._roster_handlers[id];
delete this._message_handlers[id]; }
return delete this._roster_handlers[id]; }
}; return true;
};
/*Function
Creates and adds an Occupant to the Room Roster. /*Function
Parameters: Parses a presence stanza
(Object) data - the data the Occupant is filled with Parameters:
Returns: (Object) data - the data extracted from the presence stanza
occ - the created Occupant. */
*/
XmppRoom.prototype._addOccupant = function(data) { XmppRoom._parsePresence = function(pres) {
var occ; var a, c, c2, data, _i, _j, _len, _len1, _ref, _ref1, _ref2, _ref3, _ref4, _ref5, _ref6, _ref7;
occ = new Occupant(data, this); data = {};
this.roster[occ.nick] = occ; a = pres.attributes;
return occ; data.nick = Strophe.getResourceFromJid(a.from.textContent);
}; data.type = ((_ref = a.type) != null ? _ref.textContent : void 0) || null;
data.states = [];
/*Function _ref1 = pres.childNodes;
The standard handler that managed the Room Roster. for (_i = 0, _len = _ref1.length; _i < _len; _i++) {
Parameters: c = _ref1[_i];
(Object) pres - the presence stanza containing user information switch (c.nodeName) {
*/ case "status":
data.status = c.textContent || null;
XmppRoom.prototype._roomRosterHandler = function(pres) { break;
var data, handler, id, newnick, nick, _ref; case "show":
data = XmppRoom._parsePresence(pres); data.show = c.textContent || null;
nick = data.nick; break;
newnick = data.newnick || null; case "x":
switch (data.type) { a = c.attributes;
case 'error': if (((_ref2 = a.xmlns) != null ? _ref2.textContent : void 0) === Strophe.NS.MUC_USER) {
return; _ref3 = c.childNodes;
case 'unavailable': for (_j = 0, _len1 = _ref3.length; _j < _len1; _j++) {
if (newnick) { c2 = _ref3[_j];
data.nick = newnick; switch (c2.nodeName) {
if (this.roster[nick] && this.roster[newnick]) { case "item":
this.roster[nick].update(this.roster[newnick]); a = c2.attributes;
this.roster[newnick] = this.roster[nick]; data.affiliation = ((_ref4 = a.affiliation) != null ? _ref4.textContent : void 0) || null;
} data.role = ((_ref5 = a.role) != null ? _ref5.textContent : void 0) || null;
if (this.roster[nick] && !this.roster[newnick]) { data.jid = ((_ref6 = a.jid) != null ? _ref6.textContent : void 0) || null;
this.roster[newnick] = this.roster[nick].update(data); data.newnick = ((_ref7 = a.nick) != null ? _ref7.textContent : void 0) || null;
} break;
case "status":
if (c2.attributes.code) {
data.states.push(c2.attributes.code.textContent);
}
}
} }
delete this.roster[nick]; }
}
}
return data;
};
return XmppRoom;
})();
RoomConfig = (function() {
function RoomConfig(info) {
this.parse = __bind(this.parse, this);
if (info != null) {
this.parse(info);
}
}
RoomConfig.prototype.parse = function(result) {
var attr, attrs, child, field, identity, query, _i, _j, _k, _len, _len1, _len2, _ref;
query = result.getElementsByTagName("query")[0].childNodes;
this.identities = [];
this.features = [];
this.x = [];
for (_i = 0, _len = query.length; _i < _len; _i++) {
child = query[_i];
attrs = child.attributes;
switch (child.nodeName) {
case "identity":
identity = {};
for (_j = 0, _len1 = attrs.length; _j < _len1; _j++) {
attr = attrs[_j];
identity[attr.name] = attr.textContent;
}
this.identities.push(identity);
break;
case "feature":
this.features.push(attrs["var"].textContent);
break;
case "x":
attrs = child.childNodes[0].attributes;
if ((!attrs["var"].textContent === 'FORM_TYPE') || (!attrs.type.textContent === 'hidden')) {
break; break;
default: }
if (this.roster[nick]) { _ref = child.childNodes;
this.roster[nick].update(data); for (_k = 0, _len2 = _ref.length; _k < _len2; _k++) {
} else { field = _ref[_k];
this._addOccupant(data); if (!(!field.attributes.type)) {
} continue;
}
_ref = this._roster_handlers;
for (id in _ref) {
handler = _ref[id];
if (!handler(this.roster, this)) delete this._roster_handlers[id];
}
return true;
};
/*Function
Parses a presence stanza
Parameters:
(Object) data - the data extracted from the presence stanza
*/
XmppRoom._parsePresence = function(pres) {
var a, c, c2, data, _i, _j, _len, _len2, _ref, _ref2, _ref3, _ref4, _ref5, _ref6, _ref7, _ref8;
data = {};
a = pres.attributes;
data.nick = Strophe.getResourceFromJid(a.from.textContent);
data.type = ((_ref = a.type) != null ? _ref.textContent : void 0) || null;
data.states = [];
_ref2 = pres.childNodes;
for (_i = 0, _len = _ref2.length; _i < _len; _i++) {
c = _ref2[_i];
switch (c.nodeName) {
case "status":
data.status = c.textContent || null;
break;
case "show":
data.show = c.textContent || null;
break;
case "x":
a = c.attributes;
if (((_ref3 = a.xmlns) != null ? _ref3.textContent : void 0) === Strophe.NS.MUC_USER) {
_ref4 = c.childNodes;
for (_j = 0, _len2 = _ref4.length; _j < _len2; _j++) {
c2 = _ref4[_j];
switch (c2.nodeName) {
case "item":
a = c2.attributes;
data.affiliation = ((_ref5 = a.affiliation) != null ? _ref5.textContent : void 0) || null;
data.role = ((_ref6 = a.role) != null ? _ref6.textContent : void 0) || null;
data.jid = ((_ref7 = a.jid) != null ? _ref7.textContent : void 0) || null;
data.newnick = ((_ref8 = a.nick) != null ? _ref8.textContent : void 0) || null;
break;
case "status":
if (c2.attributes.code) {
data.states.push(c2.attributes.code.textContent);
}
}
}
}
} }
} attrs = field.attributes;
return data; this.x.push({
}; "var": attrs["var"].textContent,
label: attrs.label.textContent || "",
value: field.firstChild.textContent || ""
});
}
}
}
return {
"identities": this.identities,
"features": this.features,
"x": this.x
};
};
return XmppRoom; return RoomConfig;
})(); })();
RoomConfig = (function() { Occupant = (function() {
function RoomConfig(info) { function Occupant(data, room) {
this.parse = __bind(this.parse, this); if (info != null) this.parse(info); this.room = room;
} this.update = __bind(this.update, this);
RoomConfig.prototype.parse = function(result) { this.admin = __bind(this.admin, this);
var attr, attrs, child, field, identity, query, _i, _j, _k, _len, _len2, _len3, _ref;
query = result.getElementsByTagName("query")[0].childNodes; this.owner = __bind(this.owner, this);
this.identities = [];
this.features = []; this.revoke = __bind(this.revoke, this);
this.x = [];
for (_i = 0, _len = query.length; _i < _len; _i++) { this.member = __bind(this.member, this);
child = query[_i];
attrs = child.attributes; this.ban = __bind(this.ban, this);
switch (child.nodeName) {
case "identity": this.modifyAffiliation = __bind(this.modifyAffiliation, this);
identity = {};
for (_j = 0, _len2 = attrs.length; _j < _len2; _j++) { this.deop = __bind(this.deop, this);
attr = attrs[_j];
identity[attr.name] = attr.textContent; this.op = __bind(this.op, this);
}
this.identities.push(identity); this.mute = __bind(this.mute, this);
break;
case "feature": this.voice = __bind(this.voice, this);
this.features.push(attrs["var"].textContent);
break; this.kick = __bind(this.kick, this);
case "x":
attrs = child.childNodes[0].attributes; this.modifyRole = __bind(this.modifyRole, this);
if ((!attrs["var"].textContent === 'FORM_TYPE') || (!attrs.type.textContent === 'hidden')) {
break;
}
_ref = child.childNodes;
for (_k = 0, _len3 = _ref.length; _k < _len3; _k++) {
field = _ref[_k];
if (!(!field.attributes.type)) continue;
attrs = field.attributes;
this.x.push({
"var": attrs["var"].textContent,
label: attrs.label.textContent || "",
value: field.firstChild.textContent || ""
});
}
}
}
return {
"identities": this.identities,
"features": this.features,
"x": this.x
};
};
return RoomConfig;
})();
Occupant = (function() {
function Occupant(data, room) {
this.room = room;
this.update = __bind(this.update, this);
this.admin = __bind(this.admin, this);
this.owner = __bind(this.owner, this);
this.revoke = __bind(this.revoke, this);
this.member = __bind(this.member, this);
this.ban = __bind(this.ban, this);
this.modifyAffiliation = __bind(this.modifyAffiliation, this);
this.deop = __bind(this.deop, this);
this.op = __bind(this.op, this);
this.mute = __bind(this.mute, this);
this.voice = __bind(this.voice, this);
this.kick = __bind(this.kick, this);
this.modifyRole = __bind(this.modifyRole, this);
this.update(data);
}
Occupant.prototype.modifyRole = function(role, reason, success_cb, error_cb) { this.update(data);
return this.room.modifyRole(this.nick, role, reason, success_cb, error_cb); }
};
Occupant.prototype.kick = function(reason, handler_cb, error_cb) { Occupant.prototype.modifyRole = function(role, reason, success_cb, error_cb) {
return this.room.kick(this.nick, reason, handler_cb, error_cb); return this.room.modifyRole(this.nick, role, reason, success_cb, error_cb);
}; };
Occupant.prototype.voice = function(reason, handler_cb, error_cb) { Occupant.prototype.kick = function(reason, handler_cb, error_cb) {
return this.room.voice(this.nick, reason, handler_cb, error_cb); return this.room.kick(this.nick, reason, handler_cb, error_cb);
}; };
Occupant.prototype.mute = function(reason, handler_cb, error_cb) { Occupant.prototype.voice = function(reason, handler_cb, error_cb) {
return this.room.mute(this.nick, reason, handler_cb, error_cb); return this.room.voice(this.nick, reason, handler_cb, error_cb);
}; };
Occupant.prototype.op = function(reason, handler_cb, error_cb) { Occupant.prototype.mute = function(reason, handler_cb, error_cb) {
return this.room.op(this.nick, reason, handler_cb, error_cb); return this.room.mute(this.nick, reason, handler_cb, error_cb);
}; };
Occupant.prototype.deop = function(reason, handler_cb, error_cb) { Occupant.prototype.op = function(reason, handler_cb, error_cb) {
return this.room.deop(this.nick, reason, handler_cb, error_cb); return this.room.op(this.nick, reason, handler_cb, error_cb);
}; };
Occupant.prototype.modifyAffiliation = function(affiliation, reason, success_cb, error_cb) { Occupant.prototype.deop = function(reason, handler_cb, error_cb) {
return this.room.modifyAffiliation(this.jid, affiliation, reason, success_cb, error_cb); return this.room.deop(this.nick, reason, handler_cb, error_cb);
}; };
Occupant.prototype.ban = function(reason, handler_cb, error_cb) { Occupant.prototype.modifyAffiliation = function(affiliation, reason, success_cb, error_cb) {
return this.room.ban(this.jid, reason, handler_cb, error_cb); return this.room.modifyAffiliation(this.jid, affiliation, reason, success_cb, error_cb);
}; };
Occupant.prototype.member = function(reason, handler_cb, error_cb) { Occupant.prototype.ban = function(reason, handler_cb, error_cb) {
return this.room.member(this.jid, reason, handler_cb, error_cb); return this.room.ban(this.jid, reason, handler_cb, error_cb);
}; };
Occupant.prototype.revoke = function(reason, handler_cb, error_cb) { Occupant.prototype.member = function(reason, handler_cb, error_cb) {
return this.room.revoke(this.jid, reason, handler_cb, error_cb); return this.room.member(this.jid, reason, handler_cb, error_cb);
}; };
Occupant.prototype.owner = function(reason, handler_cb, error_cb) { Occupant.prototype.revoke = function(reason, handler_cb, error_cb) {
return this.room.owner(this.jid, reason, handler_cb, error_cb); return this.room.revoke(this.jid, reason, handler_cb, error_cb);
}; };
Occupant.prototype.admin = function(reason, handler_cb, error_cb) { Occupant.prototype.owner = function(reason, handler_cb, error_cb) {
return this.room.admin(this.jid, reason, handler_cb, error_cb); return this.room.owner(this.jid, reason, handler_cb, error_cb);
}; };
Occupant.prototype.update = function(data) { Occupant.prototype.admin = function(reason, handler_cb, error_cb) {
this.nick = data.nick || null; return this.room.admin(this.jid, reason, handler_cb, error_cb);
this.affiliation = data.affiliation || null; };
this.role = data.role || null;
this.jid = data.jid || null;
this.status = data.status || null;
this.show = data.show || null;
return this;
};
return Occupant; Occupant.prototype.update = function(data) {
this.nick = data.nick || null;
this.affiliation = data.affiliation || null;
this.role = data.role || null;
this.jid = data.jid || null;
this.status = data.status || null;
this.show = data.show || null;
return this;
};
})(); return Occupant;
}).call(this); })();
}));
Libraries/strophe.roster.js
View file @ c8e6f53e
...@@ -13,440 +13,426 @@ ...@@ -13,440 +13,426 @@
* * authorize/unauthorize * * authorize/unauthorize
* * roster versioning (xep 237) * * roster versioning (xep 237)
*/ */
Strophe.addConnectionPlugin('roster',
{
_connection: null,
_callbacks : [],
// AMD/global registrations /** Property: items
(function (root, factory) { * Roster items
if (typeof define === 'function' && define.amd) { * [
define([ * {
"Libraries/strophe" * name : "",
], function () { * jid : "",
return factory(jQuery, console); * subscription : "",
} * ask : "",
); * groups : ["", ""],
} * resources : {
}(this, function ($, console) { * myresource : {
Strophe.addConnectionPlugin('roster', * show : "",
* status : "",
* priority : ""
* }
* }
* }
* ]
*/
items : [],
/** Property: ver
* current roster revision
* always null if server doesn't support xep 237
*/
ver : null,
/** Function: init
* Plugin init
*
* Parameters:
* (Strophe.Connection) conn - Strophe connection
*/
init: function(conn)
{ {
_connection: null, this._connection = conn;
this.items = [];
_callbacks : [], // Override the connect and attach methods to always add presence and roster handlers.
/** Property: items // They are removed when the connection disconnects, so must be added on connection.
* Roster items var oldCallback, roster = this, _connect = conn.connect, _attach = conn.attach;
* [ var newCallback = function(status)
* {
* name : "",
* jid : "",
* subscription : "",
* ask : "",
* groups : ["", ""],
* resources : {
* myresource : {
* show : "",
* status : "",
* priority : ""
* }
* }
* }
* ]
*/
items : [],
/** Property: ver
* current roster revision
* always null if server doesn't support xep 237
*/
ver : null,
/** Function: init
* Plugin init
*
* Parameters:
* (Strophe.Connection) conn - Strophe connection
*/
init: function(conn)
{
this._connection = conn;
this.items = [];
// Override the connect and attach methods to always add presence and roster handlers.
// They are removed when the connection disconnects, so must be added on connection.
var oldCallback, roster = this, _connect = conn.connect, _attach = conn.attach;
var newCallback = function(status)
{
if (status == Strophe.Status.ATTACHED || status == Strophe.Status.CONNECTED)
{
try
{
// Presence subscription
conn.addHandler(roster._onReceivePresence.bind(roster), null, 'presence', null, null, null);
conn.addHandler(roster._onReceiveIQ.bind(roster), Strophe.NS.ROSTER, 'iq', "set", null, null);
}
catch (e)
{
Strophe.error(e);
}
}
if (oldCallback !== null)
oldCallback.apply(this, arguments);
};
conn.connect = function(jid, pass, callback, wait, hold)
{
oldCallback = callback;
if (typeof arguments[0] == "undefined")
arguments[0] = null;
if (typeof arguments[1] == "undefined")
arguments[1] = null;
arguments[2] = newCallback;
_connect.apply(conn, arguments);
};
conn.attach = function(jid, sid, rid, callback, wait, hold, wind)
{
oldCallback = callback;
if (typeof arguments[0] == "undefined")
arguments[0] = null;
if (typeof arguments[1] == "undefined")
arguments[1] = null;
if (typeof arguments[2] == "undefined")
arguments[2] = null;
arguments[3] = newCallback;
_attach.apply(conn, arguments);
};
Strophe.addNamespace('ROSTER_VER', 'urn:xmpp:features:rosterver');
},
/** Function: supportVersioning
* return true if roster versioning is enabled on server
*/
supportVersioning: function()
{
return (this._connection.features && this._connection.features.getElementsByTagName('ver').length > 0);
},
/** Function: get
* Get Roster on server
*
* Parameters:
* (Function) userCallback - callback on roster result
* (String) ver - current rev of roster
* (only used if roster versioning is enabled)
* (Array) items - initial items of ver
* (only used if roster versioning is enabled)
* In browser context you can use sessionStorage
* to store your roster in json (JSON.stringify())
*/
get: function(userCallback, ver, items)
{
var attrs = {xmlns: Strophe.NS.ROSTER};
this.items = [];
if (this.supportVersioning())
{
// empty rev because i want an rev attribute in the result
attrs.ver = ver || '';
this.items = items || [];
}
var iq = $iq({type: 'get', 'id' : this._connection.getUniqueId('roster')}).c('query', attrs);
this._connection.sendIQ(iq,
this._onReceiveRosterSuccess.bind(this, userCallback),
this._onReceiveRosterError.bind(this, userCallback));
},
/** Function: registerCallback
* register callback on roster (presence and iq)
*
* Parameters:
* (Function) call_back
*/
registerCallback: function(call_back)
{
this._callbacks.push(call_back);
},
/** Function: findItem
* Find item by JID
*
* Parameters:
* (String) jid
*/
findItem : function(jid)
{ {
for (var i = 0; i < this.items.length; i++) if (status == Strophe.Status.ATTACHED || status == Strophe.Status.CONNECTED)
{ {
if (this.items[i] && this.items[i].jid == jid) try
{ {
return this.items[i]; // Presence subscription
conn.addHandler(roster._onReceivePresence.bind(roster), null, 'presence', null, null, null);
conn.addHandler(roster._onReceiveIQ.bind(roster), Strophe.NS.ROSTER, 'iq', "set", null, null);
} }
} catch (e)
return false;
},
/** Function: removeItem
* Remove item by JID
*
* Parameters:
* (String) jid
*/
removeItem : function(jid)
{
for (var i = 0; i < this.items.length; i++)
{
if (this.items[i] && this.items[i].jid == jid)
{ {
this.items.splice(i, 1); Strophe.error(e);
return true;
} }
} }
return false; if (oldCallback !== null)
}, oldCallback.apply(this, arguments);
/** Function: subscribe };
* Subscribe presence conn.connect = function(jid, pass, callback, wait, hold)
*
* Parameters:
* (String) jid
* (String) message
*/
subscribe: function(jid, message)
{
var pres = $pres({to: jid, type: "subscribe"});
if (message && message != "")
pres.c("status").t(message);
this._connection.send(pres);
},
/** Function: unsubscribe
* Unsubscribe presence
*
* Parameters:
* (String) jid
* (String) message
*/
unsubscribe: function(jid, message)
{ {
var pres = $pres({to: jid, type: "unsubscribe"}); oldCallback = callback;
if (message && message != "") if (typeof arguments[0] == "undefined")
pres.c("status").t(message); arguments[0] = null;
this._connection.send(pres); if (typeof arguments[1] == "undefined")
}, arguments[1] = null;
/** Function: authorize arguments[2] = newCallback;
* Authorize presence subscription _connect.apply(conn, arguments);
* };
* Parameters: conn.attach = function(jid, sid, rid, callback, wait, hold, wind)
* (String) jid
* (String) message
*/
authorize: function(jid, message)
{ {
var pres = $pres({to: jid, type: "subscribed"}); oldCallback = callback;
if (message && message != "") if (typeof arguments[0] == "undefined")
pres.c("status").t(message); arguments[0] = null;
this._connection.send(pres); if (typeof arguments[1] == "undefined")
}, arguments[1] = null;
/** Function: unauthorize if (typeof arguments[2] == "undefined")
* Unauthorize presence subscription arguments[2] = null;
* arguments[3] = newCallback;
* Parameters: _attach.apply(conn, arguments);
* (String) jid };
* (String) message
*/ Strophe.addNamespace('ROSTER_VER', 'urn:xmpp:features:rosterver');
unauthorize: function(jid, message) },
/** Function: supportVersioning
* return true if roster versioning is enabled on server
*/
supportVersioning: function()
{
return (this._connection.features && this._connection.features.getElementsByTagName('ver').length > 0);
},
/** Function: get
* Get Roster on server
*
* Parameters:
* (Function) userCallback - callback on roster result
* (String) ver - current rev of roster
* (only used if roster versioning is enabled)
* (Array) items - initial items of ver
* (only used if roster versioning is enabled)
* In browser context you can use sessionStorage
* to store your roster in json (JSON.stringify())
*/
get: function(userCallback, ver, items)
{
var attrs = {xmlns: Strophe.NS.ROSTER};
this.items = [];
if (this.supportVersioning())
{ {
var pres = $pres({to: jid, type: "unsubscribed"}); // empty rev because i want an rev attribute in the result
if (message && message != "") attrs.ver = ver || '';
pres.c("status").t(message); this.items = items || [];
this._connection.send(pres); }
}, var iq = $iq({type: 'get', 'id' : this._connection.getUniqueId('roster')}).c('query', attrs);
/** Function: add return this._connection.sendIQ(iq,
* Add roster item this._onReceiveRosterSuccess.bind(this, userCallback),
* this._onReceiveRosterError.bind(this, userCallback));
* Parameters: },
* (String) jid - item jid /** Function: registerCallback
* (String) name - name * register callback on roster (presence and iq)
* (Array) groups *
* (Function) call_back * Parameters:
*/ * (Function) call_back
add: function(jid, name, groups, call_back) */
registerCallback: function(call_back)
{
this._callbacks.push(call_back);
},
/** Function: findItem
* Find item by JID
*
* Parameters:
* (String) jid
*/
findItem : function(jid)
{
for (var i = 0; i < this.items.length; i++)
{ {
var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: jid, if (this.items[i] && this.items[i].jid == jid)
name: name});
for (var i = 0; i < groups.length; i++)
{ {
iq.c('group').t(groups[i]).up(); return this.items[i];
} }
this._connection.sendIQ(iq, call_back, call_back); }
}, return false;
/** Function: update },
* Update roster item /** Function: removeItem
* * Remove item by JID
* Parameters: *
* (String) jid - item jid * Parameters:
* (String) name - name * (String) jid
* (Array) groups */
* (Function) call_back removeItem : function(jid)
*/ {
update: function(jid, name, groups, call_back) for (var i = 0; i < this.items.length; i++)
{ {
var item = this.findItem(jid); if (this.items[i] && this.items[i].jid == jid)
if (!item)
{
throw "item not found";
}
var newName = name || item.name;
var newGroups = groups || item.groups;
var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: item.jid,
name: newName});
for (var i = 0; i < newGroups.length; i++)
{ {
iq.c('group').t(newGroups[i]).up(); this.items.splice(i, 1);
return true;
} }
this._connection.sendIQ(iq, call_back, call_back); }
}, return false;
/** Function: remove },
* Remove roster item /** Function: subscribe
* * Subscribe presence
* Parameters: *
* (String) jid - item jid * Parameters:
* (Function) call_back * (String) jid
*/ * (String) message
remove: function(jid, call_back) */
subscribe: function(jid, message)
{
var pres = $pres({to: jid, type: "subscribe"});
if (message && message != "")
pres.c("status").t(message);
this._connection.send(pres);
},
/** Function: unsubscribe
* Unsubscribe presence
*
* Parameters:
* (String) jid
* (String) message
*/
unsubscribe: function(jid, message)
{
var pres = $pres({to: jid, type: "unsubscribe"});
if (message && message != "")
pres.c("status").t(message);
this._connection.send(pres);
},
/** Function: authorize
* Authorize presence subscription
*
* Parameters:
* (String) jid
* (String) message
*/
authorize: function(jid, message)
{
var pres = $pres({to: jid, type: "subscribed"});
if (message && message != "")
pres.c("status").t(message);
this._connection.send(pres);
},
/** Function: unauthorize
* Unauthorize presence subscription
*
* Parameters:
* (String) jid
* (String) message
*/
unauthorize: function(jid, message)
{
var pres = $pres({to: jid, type: "unsubscribed"});
if (message && message != "")
pres.c("status").t(message);
this._connection.send(pres);
},
/** Function: add
* Add roster item
*
* Parameters:
* (String) jid - item jid
* (String) name - name
* (Array) groups
* (Function) call_back
*/
add: function(jid, name, groups, call_back)
{
var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: jid,
name: name});
for (var i = 0; i < groups.length; i++)
{ {
var item = this.findItem(jid); iq.c('group').t(groups[i]).up();
if (!item) }
{ this._connection.sendIQ(iq, call_back, call_back);
throw "item not found"; },
} /** Function: update
var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: item.jid, * Update roster item
subscription: "remove"}); *
this._connection.sendIQ(iq, call_back, call_back); * Parameters:
}, * (String) jid - item jid
/** PrivateFunction: _onReceiveRosterSuccess * (String) name - name
* * (Array) groups
*/ * (Function) call_back
_onReceiveRosterSuccess: function(userCallback, stanza) */
update: function(jid, name, groups, call_back)
{
var item = this.findItem(jid);
if (!item)
{
throw "item not found";
}
var newName = name || item.name;
var newGroups = groups || item.groups;
var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: item.jid,
name: newName});
for (var i = 0; i < newGroups.length; i++)
{ {
this._updateItems(stanza); iq.c('group').t(newGroups[i]).up();
userCallback(this.items); }
}, return this._connection.sendIQ(iq, call_back, call_back);
/** PrivateFunction: _onReceiveRosterError },
* /** Function: remove
*/ * Remove roster item
_onReceiveRosterError: function(userCallback, stanza) *
* Parameters:
* (String) jid - item jid
* (Function) call_back
*/
remove: function(jid, call_back)
{
var item = this.findItem(jid);
if (!item)
{ {
userCallback(this.items); throw "item not found";
}, }
/** PrivateFunction: _onReceivePresence var iq = $iq({type: 'set'}).c('query', {xmlns: Strophe.NS.ROSTER}).c('item', {jid: item.jid,
* Handle presence subscription: "remove"});
*/ this._connection.sendIQ(iq, call_back, call_back);
_onReceivePresence : function(presence) },
/** PrivateFunction: _onReceiveRosterSuccess
*
*/
_onReceiveRosterSuccess: function(userCallback, stanza)
{
this._updateItems(stanza);
userCallback(this.items);
},
/** PrivateFunction: _onReceiveRosterError
*
*/
_onReceiveRosterError: function(userCallback, stanza)
{
userCallback(this.items);
},
/** PrivateFunction: _onReceivePresence
* Handle presence
*/
_onReceivePresence : function(presence)
{
// TODO: from is optional
var jid = presence.getAttribute('from');
var from = Strophe.getBareJidFromJid(jid);
var item = this.findItem(from);
// not in roster
if (!item)
{ {
// TODO: from is optional
var jid = presence.getAttribute('from');
var from = Strophe.getBareJidFromJid(jid);
var item = this.findItem(from);
// not in roster
if (!item)
{
return true;
}
var type = presence.getAttribute('type');
if (type == 'unavailable')
{
delete item.resources[Strophe.getResourceFromJid(jid)];
}
else if (!type)
{
// TODO: add timestamp
item.resources[Strophe.getResourceFromJid(jid)] = {
show : (presence.getElementsByTagName('show').length != 0) ? Strophe.getText(presence.getElementsByTagName('show')[0]) : "",
status : (presence.getElementsByTagName('status').length != 0) ? Strophe.getText(presence.getElementsByTagName('status')[0]) : "",
priority : (presence.getElementsByTagName('priority').length != 0) ? Strophe.getText(presence.getElementsByTagName('priority')[0]) : ""
};
}
else
{
// Stanza is not a presence notification. (It's probably a subscription type stanza.)
return true;
}
this._call_backs(this.items, item);
return true; return true;
}, }
/** PrivateFunction: _call_backs var type = presence.getAttribute('type');
* if (type == 'unavailable')
*/
_call_backs : function(items, item)
{ {
for (var i = 0; i < this._callbacks.length; i++) // [].forEach my love ... delete item.resources[Strophe.getResourceFromJid(jid)];
{ }
this._callbacks[i](items, item); else if (!type)
}
},
/** PrivateFunction: _onReceiveIQ
* Handle roster push.
*/
_onReceiveIQ : function(iq)
{ {
var id = iq.getAttribute('id'); // TODO: add timestamp
var from = iq.getAttribute('from'); item.resources[Strophe.getResourceFromJid(jid)] = {
// Receiving client MUST ignore stanza unless it has no from or from = user's JID. show : (presence.getElementsByTagName('show').length != 0) ? Strophe.getText(presence.getElementsByTagName('show')[0]) : "",
if (from && from != "" && from != this._connection.jid && from != Strophe.getBareJidFromJid(this._connection.jid)) status : (presence.getElementsByTagName('status').length != 0) ? Strophe.getText(presence.getElementsByTagName('status')[0]) : "",
return true; priority : (presence.getElementsByTagName('priority').length != 0) ? Strophe.getText(presence.getElementsByTagName('priority')[0]) : ""
var iqresult = $iq({type: 'result', id: id, from: this._connection.jid}); };
this._connection.send(iqresult); }
this._updateItems(iq); else
{
// Stanza is not a presence notification. (It's probably a subscription type stanza.)
return true; return true;
}, }
/** PrivateFunction: _updateItems this._call_backs(this.items, item);
* Update items from iq return true;
*/ },
_updateItems : function(iq) /** PrivateFunction: _call_backs
*
*/
_call_backs : function(items, item)
{
for (var i = 0; i < this._callbacks.length; i++) // [].forEach my love ...
{ {
var query = iq.getElementsByTagName('query'); this._callbacks[i](items, item);
if (query.length != 0) }
{ },
this.ver = query.item(0).getAttribute('ver'); /** PrivateFunction: _onReceiveIQ
var self = this; * Handle roster push.
Strophe.forEachChild(query.item(0), 'item', */
function (item) _onReceiveIQ : function(iq)
{ {
self._updateItem(item); var id = iq.getAttribute('id');
} var from = iq.getAttribute('from');
); // Receiving client MUST ignore stanza unless it has no from or from = user's JID.
} if (from && from != "" && from != this._connection.jid && from != Strophe.getBareJidFromJid(this._connection.jid))
this._call_backs(this.items); return true;
}, var iqresult = $iq({type: 'result', id: id, from: this._connection.jid});
/** PrivateFunction: _updateItem this._connection.send(iqresult);
* Update internal representation of roster item this._updateItems(iq);
*/ return true;
_updateItem : function(item) },
/** PrivateFunction: _updateItems
* Update items from iq
*/
_updateItems : function(iq)
{
var query = iq.getElementsByTagName('query');
if (query.length != 0)
{ {
var jid = item.getAttribute("jid"); this.ver = query.item(0).getAttribute('ver');
var name = item.getAttribute("name"); var self = this;
var subscription = item.getAttribute("subscription"); Strophe.forEachChild(query.item(0), 'item',
var ask = item.getAttribute("ask"); function (item)
var groups = [];
Strophe.forEachChild(item, 'group',
function(group)
{ {
groups.push(Strophe.getText(group)); self._updateItem(item);
} }
); );
}
if (subscription == "remove") this._call_backs(this.items);
},
/** PrivateFunction: _updateItem
* Update internal representation of roster item
*/
_updateItem : function(item)
{
var jid = item.getAttribute("jid");
var name = item.getAttribute("name");
var subscription = item.getAttribute("subscription");
var ask = item.getAttribute("ask");
var groups = [];
Strophe.forEachChild(item, 'group',
function(group)
{ {
this.removeItem(jid); groups.push(Strophe.getText(group));
return;
} }
);
var item = this.findItem(jid); if (subscription == "remove")
if (!item) {
{ this.removeItem(jid);
this.items.push({ return;
name : name,
jid : jid,
subscription : subscription,
ask : ask,
groups : groups,
resources : {}
});
}
else
{
item.name = name;
item.subscription = subscription;
item.ask = ask;
item.groups = groups;
}
} }
});
})); var item = this.findItem(jid);
if (!item)
{
this.items.push({
name : name,
jid : jid,
subscription : subscription,
ask : ask,
groups : groups,
resources : {}
});
}
else
{
item.name = name;
item.subscription = subscription;
item.ask = ask;
item.groups = groups;
}
}
});
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7