utils.js 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286
  1. (function (root, factory) {
  2. define(['converse', 'es6-promise', 'mock', 'wait-until-promise'], factory);
  3. }(this, function (converse_api, Promise, mock, waitUntilPromise) {
  4. var _ = converse_api.env._;
  5. var $msg = converse_api.env.$msg;
  6. var $pres = converse_api.env.$pres;
  7. var $iq = converse_api.env.$iq;
  8. var Strophe = converse_api.env.Strophe;
  9. var u = converse_api.env.utils;
  10. var utils = {};
  11. if (typeof window.Promise === 'undefined') {
  12. waitUntilPromise.setPromiseImplementation(Promise);
  13. }
  14. utils.waitUntil = waitUntilPromise.default;
  15. utils.waitUntilDiscoConfirmed = function (_converse, entity_jid, identities, features, items, type) {
  16. if (_.isNil(type)) {
  17. type = 'info';
  18. }
  19. var IQ_disco, stanza;
  20. return utils.waitUntil(function () {
  21. IQ_disco = _.filter(_converse.connection.IQ_stanzas, function (iq) {
  22. return iq.nodeTree.querySelector('query[xmlns="http://jabber.org/protocol/disco#'+type+'"]') &&
  23. iq.nodeTree.getAttribute('to') === entity_jid;
  24. }).pop();
  25. return !_.isUndefined(IQ_disco);
  26. }, 300).then(function () {
  27. var info_IQ_id = IQ_disco.nodeTree.getAttribute('id');
  28. var stanza = $iq({
  29. 'type': 'result',
  30. 'from': entity_jid,
  31. 'to': 'dummy@localhost/resource',
  32. 'id': info_IQ_id
  33. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#'+type});
  34. _.forEach(identities, function (identity) {
  35. stanza.c('identity', {'category': identity.category, 'type': identity.type}).up()
  36. });
  37. _.forEach(features, function (feature) {
  38. stanza.c('feature', {'var': feature}).up();
  39. });
  40. _.forEach(items, function (item) {
  41. stanza.c('item', {'jid': item}).up();
  42. });
  43. _converse.connection._dataRecv(utils.createRequest(stanza));
  44. }).catch(_.partial(console.error, _));
  45. }
  46. utils.createRequest = function (iq) {
  47. iq = typeof iq.tree == "function" ? iq.tree() : iq;
  48. var req = new Strophe.Request(iq, function() {});
  49. req.getResponse = function () {
  50. var env = new Strophe.Builder('env', {type: 'mock'}).tree();
  51. env.appendChild(iq);
  52. return env;
  53. };
  54. return req;
  55. };
  56. utils.closeAllChatBoxes = function (converse) {
  57. var i, chatbox;
  58. for (i=converse.chatboxes.models.length-1; i>-1; i--) {
  59. chatbox = converse.chatboxes.models[i];
  60. converse.chatboxviews.get(chatbox.get('id')).close();
  61. }
  62. return this;
  63. };
  64. utils.openControlBox = function () {
  65. var toggle = document.querySelector(".toggle-controlbox");
  66. if (!u.isVisible(document.querySelector("#controlbox"))) {
  67. if (!u.isVisible(toggle)) {
  68. u.removeClass('hidden', toggle);
  69. }
  70. toggle.click();
  71. }
  72. return this;
  73. };
  74. utils.closeControlBox = function () {
  75. var controlbox = document.querySelector("#controlbox");
  76. if (u.isVisible(controlbox)) {
  77. var button = controlbox.querySelector(".close-chatbox-button");
  78. if (!_.isNull(button)) {
  79. button.click();
  80. }
  81. }
  82. return this;
  83. };
  84. utils.openChatBoxes = function (converse, amount) {
  85. var i = 0, jid, views = [];
  86. for (i; i<amount; i++) {
  87. jid = mock.cur_names[i].replace(/ /g,'.').toLowerCase() + '@localhost';
  88. views[i] = converse.roster.get(jid).trigger("open");
  89. }
  90. return views;
  91. };
  92. utils.openChatBoxFor = function (converse, jid) {
  93. return converse.roster.get(jid).trigger("open");
  94. };
  95. utils.openChatRoomViaModal = function (_converse, jid, nick) {
  96. // Opens a new chatroom
  97. return new Promise(function (resolve, reject) {
  98. utils.openControlBox(_converse);
  99. var roomspanel = _converse.chatboxviews.get('controlbox').roomspanel;
  100. roomspanel.el.querySelector('.trigger-add-chatrooms-modal').click();
  101. utils.closeControlBox(_converse);
  102. const modal = roomspanel.add_room_modal;
  103. utils.waitUntil(function () {
  104. return u.isVisible(modal.el);
  105. }, 1000).then(function () {
  106. modal.el.querySelector('input[name="chatroom"]').value = jid;
  107. modal.el.querySelector('form input[type="submit"]').click();
  108. resolve();
  109. }).catch(_.partial(console.error, _));
  110. }).catch(_.partial(console.error, _));
  111. };
  112. utils.openChatRoom = function (_converse, room, server, nick) {
  113. _converse.api.rooms.open(`${room}@${server}`);
  114. };
  115. utils.openAndEnterChatRoom = function (_converse, room, server, nick) {
  116. let last_stanza;
  117. return new Promise(function (resolve, reject) {
  118. _converse.api.rooms.open(`${room}@${server}`);
  119. const view = _converse.chatboxviews.get((room+'@'+server).toLowerCase());
  120. // We pretend this is a new room, so no disco info is returned.
  121. let last_stanza = _.last(_converse.connection.IQ_stanzas).nodeTree;
  122. const IQ_id = last_stanza.getAttribute('id');
  123. const features_stanza = $iq({
  124. 'from': room+'@'+server,
  125. 'id': IQ_id,
  126. 'to': nick+'@'+server,
  127. 'type': 'error'
  128. }).c('error', {'type': 'cancel'})
  129. .c('item-not-found', {'xmlns': "urn:ietf:params:xml:ns:xmpp-stanzas"});
  130. _converse.connection._dataRecv(utils.createRequest(features_stanza));
  131. utils.waitUntil(() => {
  132. return _.filter(
  133. _converse.connection.IQ_stanzas, (node) => {
  134. const query = node.nodeTree.querySelector('query');
  135. if (query && query.getAttribute('node') === 'x-roomuser-item') {
  136. last_stanza = node.nodeTree;
  137. return true;
  138. }
  139. }).length
  140. }).then(function () {
  141. // The XMPP server returns the reserved nick for this user.
  142. const IQ_id = last_stanza.getAttribute('id');
  143. const stanza = $iq({
  144. 'type': 'result',
  145. 'id': IQ_id,
  146. 'from': view.model.get('jid'),
  147. 'to': _converse.connection.jid
  148. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info', 'node': 'x-roomuser-item'})
  149. .c('identity', {'category': 'conference', 'name': nick, 'type': 'text'});
  150. _converse.connection._dataRecv(utils.createRequest(stanza));
  151. // The user has just entered the room (because join was called)
  152. // and receives their own presence from the server.
  153. // See example 24: http://xmpp.org/extensions/xep-0045.html#enter-pres
  154. var presence = $pres({
  155. to: _converse.connection.jid,
  156. from: room+'@'+server+'/'+nick,
  157. id: 'DC352437-C019-40EC-B590-AF29E879AF97'
  158. }).c('x').attrs({xmlns:'http://jabber.org/protocol/muc#user'})
  159. .c('item').attrs({
  160. affiliation: 'member',
  161. jid: _converse.bare_jid,
  162. role: 'participant'
  163. }).up()
  164. .c('status').attrs({code:'110'});
  165. _converse.connection._dataRecv(utils.createRequest(presence));
  166. resolve();
  167. }).catch(_.partial(console.error, _));
  168. }).catch(_.partial(console.error, _));
  169. };
  170. utils.clearBrowserStorage = function () {
  171. window.localStorage.clear();
  172. window.sessionStorage.clear();
  173. return this;
  174. };
  175. utils.clearChatBoxMessages = function (converse, jid) {
  176. var view = converse.chatboxviews.get(jid);
  177. view.el.querySelector('.chat-content').innerHTML = '';
  178. view.model.messages.reset();
  179. view.model.messages.browserStorage._clear();
  180. };
  181. utils.createContacts = function (converse, type, length) {
  182. /* Create current (as opposed to requesting or pending) contacts
  183. * for the user's roster.
  184. *
  185. * These contacts are not grouped. See below.
  186. */
  187. var names, jid, subscription, requesting, ask;
  188. if (type === 'requesting') {
  189. names = mock.req_names;
  190. subscription = 'none';
  191. requesting = true;
  192. ask = null;
  193. } else if (type === 'pending') {
  194. names = mock.pend_names;
  195. subscription = 'none';
  196. requesting = false;
  197. ask = 'subscribe';
  198. } else if (type === 'current') {
  199. names = mock.cur_names;
  200. subscription = 'both';
  201. requesting = false;
  202. ask = null;
  203. } else if (type === 'all') {
  204. this.createContacts(converse, 'current')
  205. .createContacts(converse, 'requesting')
  206. .createContacts(converse, 'pending');
  207. return this;
  208. } else {
  209. throw Error("Need to specify the type of contact to create");
  210. }
  211. if (typeof length === 'undefined') {
  212. length = names.length;
  213. }
  214. for (var i=0; i<length; i++) {
  215. jid = names[i].replace(/ /g,'.').toLowerCase() + '@localhost';
  216. if (!converse.roster.get(jid)) {
  217. converse.roster.create({
  218. 'ask': ask,
  219. 'fullname': names[i],
  220. 'jid': jid,
  221. 'requesting': requesting,
  222. 'subscription': subscription
  223. });
  224. }
  225. }
  226. return this;
  227. };
  228. utils.createGroupedContacts = function (converse) {
  229. /* Create grouped contacts
  230. */
  231. var i=0, j=0;
  232. _.each(_.keys(mock.groups), function (name) {
  233. j = i;
  234. for (i=j; i<j+mock.groups[name]; i++) {
  235. converse.roster.create({
  236. jid: mock.cur_names[i].replace(/ /g,'.').toLowerCase() + '@localhost',
  237. subscription: 'both',
  238. ask: null,
  239. groups: name === 'ungrouped'? [] : [name],
  240. fullname: mock.cur_names[i]
  241. });
  242. }
  243. });
  244. };
  245. utils.createChatMessage = function (_converse, sender_jid, message) {
  246. return $msg({
  247. from: sender_jid,
  248. to: _converse.connection.jid,
  249. type: 'chat',
  250. id: (new Date()).getTime()
  251. })
  252. .c('body').t(message).up()
  253. .c('active', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  254. }
  255. utils.sendMessage = function (chatboxview, message) {
  256. chatboxview.el.querySelector('.chat-textarea').value = message;
  257. chatboxview.keyPressed({
  258. target: chatboxview.el.querySelector('textarea.chat-textarea'),
  259. preventDefault: _.noop,
  260. keyCode: 13
  261. });
  262. };
  263. return utils;
  264. }));