mock.js 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756
  1. const mock = {};
  2. window.mock = mock;
  3. let _converse, initConverse;
  4. const converseLoaded = new Promise(resolve => window.addEventListener('converse-loaded', resolve));
  5. jasmine.DEFAULT_TIMEOUT_INTERVAL = 7000;
  6. mock.initConverse = function (promise_names=[], settings=null, func) {
  7. if (typeof promise_names === "function") {
  8. func = promise_names;
  9. promise_names = []
  10. settings = null;
  11. }
  12. return async done => {
  13. if (_converse && _converse.api.connection.connected()) {
  14. await _converse.api.user.logout();
  15. }
  16. const el = document.querySelector('#conversejs');
  17. if (el) {
  18. el.parentElement.removeChild(el);
  19. }
  20. document.title = "Converse Tests";
  21. await converseLoaded;
  22. await initConverse(settings);
  23. await Promise.all((promise_names || []).map(_converse.api.waitUntil));
  24. try {
  25. await func(done, _converse);
  26. } catch(e) {
  27. console.error(e);
  28. fail(e);
  29. await done();
  30. }
  31. }
  32. };
  33. window.addEventListener('converse-loaded', () => {
  34. const { _, u, sizzle, Strophe, dayjs, $iq, $msg, $pres } = converse.env;
  35. mock.waitUntilDiscoConfirmed = async function (_converse, entity_jid, identities, features=[], items=[], type='info') {
  36. const iq = await u.waitUntil(() => {
  37. return _.filter(
  38. _converse.connection.IQ_stanzas,
  39. (iq) => sizzle(`iq[to="${entity_jid}"] query[xmlns="http://jabber.org/protocol/disco#${type}"]`, iq).length
  40. ).pop();
  41. }, 300);
  42. const stanza = $iq({
  43. 'type': 'result',
  44. 'from': entity_jid,
  45. 'to': 'romeo@montague.lit/orchard',
  46. 'id': iq.getAttribute('id'),
  47. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#'+type});
  48. _.forEach(identities, function (identity) {
  49. stanza.c('identity', {'category': identity.category, 'type': identity.type}).up()
  50. });
  51. _.forEach(features, function (feature) {
  52. stanza.c('feature', {'var': feature}).up();
  53. });
  54. _.forEach(items, function (item) {
  55. stanza.c('item', {'jid': item}).up();
  56. });
  57. _converse.connection._dataRecv(mock.createRequest(stanza));
  58. }
  59. mock.createRequest = function (iq) {
  60. iq = typeof iq.tree == "function" ? iq.tree() : iq;
  61. var req = new Strophe.Request(iq, function() {});
  62. req.getResponse = function () {
  63. var env = new Strophe.Builder('env', {type: 'mock'}).tree();
  64. env.appendChild(iq);
  65. return env;
  66. };
  67. return req;
  68. };
  69. mock.closeAllChatBoxes = function (_converse) {
  70. return Promise.all(_converse.chatboxviews.map(view => view.close()));
  71. };
  72. mock.openControlBox = async function (_converse) {
  73. const model = await _converse.api.controlbox.open();
  74. await u.waitUntil(() => model.get('connected'));
  75. var toggle = document.querySelector(".toggle-controlbox");
  76. if (!u.isVisible(document.querySelector("#controlbox"))) {
  77. if (!u.isVisible(toggle)) {
  78. u.removeClass('hidden', toggle);
  79. }
  80. toggle.click();
  81. }
  82. return this;
  83. };
  84. mock.closeControlBox = function () {
  85. const controlbox = document.querySelector("#controlbox");
  86. if (u.isVisible(controlbox)) {
  87. const button = controlbox.querySelector(".close-chatbox-button");
  88. if (!_.isNull(button)) {
  89. button.click();
  90. }
  91. }
  92. return this;
  93. };
  94. mock.waitUntilBookmarksReturned = async function (_converse, bookmarks=[]) {
  95. await mock.waitUntilDiscoConfirmed(
  96. _converse, _converse.bare_jid,
  97. [{'category': 'pubsub', 'type': 'pep'}],
  98. ['http://jabber.org/protocol/pubsub#publish-options']
  99. );
  100. const IQ_stanzas = _converse.connection.IQ_stanzas;
  101. const sent_stanza = await u.waitUntil(
  102. () => IQ_stanzas.filter(s => sizzle('items[node="storage:bookmarks"]', s).length).pop()
  103. );
  104. const stanza = $iq({
  105. 'to': _converse.connection.jid,
  106. 'type':'result',
  107. 'id':sent_stanza.getAttribute('id')
  108. }).c('pubsub', {'xmlns': Strophe.NS.PUBSUB})
  109. .c('items', {'node': 'storage:bookmarks'})
  110. .c('item', {'id': 'current'})
  111. .c('storage', {'xmlns': 'storage:bookmarks'});
  112. bookmarks.forEach(bookmark => {
  113. stanza.c('conference', {
  114. 'name': bookmark.name,
  115. 'autojoin': bookmark.autojoin,
  116. 'jid': bookmark.jid
  117. }).c('nick').t(bookmark.nick).up().up()
  118. });
  119. _converse.connection._dataRecv(mock.createRequest(stanza));
  120. await _converse.api.waitUntil('bookmarksInitialized');
  121. };
  122. mock.openChatBoxes = function (converse, amount) {
  123. for (let i=0; i<amount; i++) {
  124. const jid = mock.cur_names[i].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  125. converse.roster.get(jid).openChat();
  126. }
  127. };
  128. mock.openChatBoxFor = async function (_converse, jid) {
  129. await _converse.api.waitUntil('rosterContactsFetched');
  130. _converse.roster.get(jid).openChat();
  131. return u.waitUntil(() => _converse.chatboxviews.get(jid), 1000);
  132. };
  133. mock.openChatRoomViaModal = async function (_converse, jid, nick='') {
  134. // Opens a new chatroom
  135. const model = await _converse.api.controlbox.open('controlbox');
  136. await u.waitUntil(() => model.get('connected'));
  137. await mock.openControlBox(_converse);
  138. const view = await _converse.chatboxviews.get('controlbox');
  139. const roomspanel = view.roomspanel;
  140. roomspanel.el.querySelector('.show-add-muc-modal').click();
  141. mock.closeControlBox(_converse);
  142. const modal = roomspanel.add_room_modal;
  143. await u.waitUntil(() => u.isVisible(modal.el), 1500)
  144. modal.el.querySelector('input[name="chatroom"]').value = jid;
  145. if (nick) {
  146. modal.el.querySelector('input[name="nickname"]').value = nick;
  147. }
  148. modal.el.querySelector('form input[type="submit"]').click();
  149. await u.waitUntil(() => _converse.chatboxviews.get(jid), 1000);
  150. return _converse.chatboxviews.get(jid);
  151. };
  152. mock.openChatRoom = function (_converse, room, server) {
  153. return _converse.api.rooms.open(`${room}@${server}`);
  154. };
  155. mock.getRoomFeatures = async function (_converse, muc_jid, features=[]) {
  156. const room = Strophe.getNodeFromJid(muc_jid);
  157. muc_jid = muc_jid.toLowerCase();
  158. const stanzas = _converse.connection.IQ_stanzas;
  159. const stanza = await u.waitUntil(() => stanzas.filter(
  160. iq => iq.querySelector(
  161. `iq[to="${muc_jid}"] query[xmlns="http://jabber.org/protocol/disco#info"]`
  162. )).pop()
  163. );
  164. const features_stanza = $iq({
  165. 'from': muc_jid,
  166. 'id': stanza.getAttribute('id'),
  167. 'to': 'romeo@montague.lit/desktop',
  168. 'type': 'result'
  169. }).c('query', { 'xmlns': 'http://jabber.org/protocol/disco#info'})
  170. .c('identity', {
  171. 'category': 'conference',
  172. 'name': room[0].toUpperCase() + room.slice(1),
  173. 'type': 'text'
  174. }).up();
  175. features = features.length ? features : mock.default_muc_features;
  176. features.forEach(f => features_stanza.c('feature', {'var': f}).up());
  177. features_stanza.c('x', { 'xmlns':'jabber:x:data', 'type':'result'})
  178. .c('field', {'var':'FORM_TYPE', 'type':'hidden'})
  179. .c('value').t('http://jabber.org/protocol/muc#roominfo').up().up()
  180. .c('field', {'type':'text-single', 'var':'muc#roominfo_description', 'label':'Description'})
  181. .c('value').t('This is the description').up().up()
  182. .c('field', {'type':'text-single', 'var':'muc#roominfo_occupants', 'label':'Number of occupants'})
  183. .c('value').t(0);
  184. _converse.connection._dataRecv(mock.createRequest(features_stanza));
  185. };
  186. mock.waitForReservedNick = async function (_converse, muc_jid, nick) {
  187. const stanzas = _converse.connection.IQ_stanzas;
  188. const selector = `iq[to="${muc_jid.toLowerCase()}"] query[node="x-roomuser-item"]`;
  189. const iq = await u.waitUntil(() => stanzas.filter(s => sizzle(selector, s).length).pop());
  190. // We remove the stanza, otherwise we might get stale stanzas returned in our filter above.
  191. stanzas.splice(stanzas.indexOf(iq), 1)
  192. // The XMPP server returns the reserved nick for this user.
  193. const IQ_id = iq.getAttribute('id');
  194. const stanza = $iq({
  195. 'type': 'result',
  196. 'id': IQ_id,
  197. 'from': muc_jid,
  198. 'to': _converse.connection.jid
  199. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info', 'node': 'x-roomuser-item'});
  200. if (nick) {
  201. stanza.c('identity', {'category': 'conference', 'name': nick, 'type': 'text'});
  202. }
  203. _converse.connection._dataRecv(mock.createRequest(stanza));
  204. if (nick) {
  205. return u.waitUntil(() => nick);
  206. }
  207. };
  208. mock.returnMemberLists = async function (_converse, muc_jid, members=[], affiliations=['member', 'owner', 'admin']) {
  209. if (affiliations.length === 0) {
  210. return;
  211. }
  212. const stanzas = _converse.connection.IQ_stanzas;
  213. if (affiliations.includes('member')) {
  214. const member_IQ = await u.waitUntil(() => _.filter(
  215. stanzas,
  216. s => sizzle(`iq[to="${muc_jid}"] query[xmlns="${Strophe.NS.MUC_ADMIN}"] item[affiliation="member"]`, s).length
  217. ).pop());
  218. const member_list_stanza = $iq({
  219. 'from': 'coven@chat.shakespeare.lit',
  220. 'id': member_IQ.getAttribute('id'),
  221. 'to': 'romeo@montague.lit/orchard',
  222. 'type': 'result'
  223. }).c('query', {'xmlns': Strophe.NS.MUC_ADMIN});
  224. members.filter(m => m.affiliation === 'member').forEach(m => {
  225. member_list_stanza.c('item', {
  226. 'affiliation': m.affiliation,
  227. 'jid': m.jid,
  228. 'nick': m.nick
  229. });
  230. });
  231. _converse.connection._dataRecv(mock.createRequest(member_list_stanza));
  232. }
  233. if (affiliations.includes('admin')) {
  234. const admin_IQ = await u.waitUntil(() => _.filter(
  235. stanzas,
  236. s => sizzle(`iq[to="${muc_jid}"] query[xmlns="${Strophe.NS.MUC_ADMIN}"] item[affiliation="admin"]`, s).length
  237. ).pop());
  238. const admin_list_stanza = $iq({
  239. 'from': 'coven@chat.shakespeare.lit',
  240. 'id': admin_IQ.getAttribute('id'),
  241. 'to': 'romeo@montague.lit/orchard',
  242. 'type': 'result'
  243. }).c('query', {'xmlns': Strophe.NS.MUC_ADMIN});
  244. members.filter(m => m.affiliation === 'admin').forEach(m => {
  245. admin_list_stanza.c('item', {
  246. 'affiliation': m.affiliation,
  247. 'jid': m.jid,
  248. 'nick': m.nick
  249. });
  250. });
  251. _converse.connection._dataRecv(mock.createRequest(admin_list_stanza));
  252. }
  253. if (affiliations.includes('owner')) {
  254. const owner_IQ = await u.waitUntil(() => _.filter(
  255. stanzas,
  256. s => sizzle(`iq[to="${muc_jid}"] query[xmlns="${Strophe.NS.MUC_ADMIN}"] item[affiliation="owner"]`, s).length
  257. ).pop());
  258. const owner_list_stanza = $iq({
  259. 'from': 'coven@chat.shakespeare.lit',
  260. 'id': owner_IQ.getAttribute('id'),
  261. 'to': 'romeo@montague.lit/orchard',
  262. 'type': 'result'
  263. }).c('query', {'xmlns': Strophe.NS.MUC_ADMIN});
  264. members.filter(m => m.affiliation === 'owner').forEach(m => {
  265. owner_list_stanza.c('item', {
  266. 'affiliation': m.affiliation,
  267. 'jid': m.jid,
  268. 'nick': m.nick
  269. });
  270. });
  271. _converse.connection._dataRecv(mock.createRequest(owner_list_stanza));
  272. }
  273. return new Promise(resolve => _converse.api.listen.on('membersFetched', resolve));
  274. };
  275. mock.receiveOwnMUCPresence = async function (_converse, muc_jid, nick) {
  276. const sent_stanzas = _converse.connection.sent_stanzas;
  277. await u.waitUntil(() => sent_stanzas.filter(iq => sizzle('presence history', iq).length).pop());
  278. const presence = $pres({
  279. to: _converse.connection.jid,
  280. from: `${muc_jid}/${nick}`,
  281. id: u.getUniqueId()
  282. }).c('x').attrs({xmlns:'http://jabber.org/protocol/muc#user'})
  283. .c('item').attrs({
  284. affiliation: 'owner',
  285. jid: _converse.bare_jid,
  286. role: 'moderator'
  287. }).up()
  288. .c('status').attrs({code:'110'});
  289. _converse.connection._dataRecv(mock.createRequest(presence));
  290. };
  291. mock.openAndEnterChatRoom = async function (_converse, muc_jid, nick, features=[], members=[]) {
  292. muc_jid = muc_jid.toLowerCase();
  293. const room_creation_promise = _converse.api.rooms.open(muc_jid);
  294. await mock.getRoomFeatures(_converse, muc_jid, features);
  295. await mock.waitForReservedNick(_converse, muc_jid, nick);
  296. // The user has just entered the room (because join was called)
  297. // and receives their own presence from the server.
  298. // See example 24: https://xmpp.org/extensions/xep-0045.html#enter-pres
  299. await mock.receiveOwnMUCPresence(_converse, muc_jid, nick);
  300. await room_creation_promise;
  301. const view = _converse.chatboxviews.get(muc_jid);
  302. await u.waitUntil(() => (view.model.session.get('connection_status') === converse.ROOMSTATUS.ENTERED));
  303. const affs = _converse.muc_fetch_members;
  304. const all_affiliations = Array.isArray(affs) ? affs : (affs ? ['member', 'admin', 'owner'] : []);
  305. await mock.returnMemberLists(_converse, muc_jid, members, all_affiliations);
  306. await view.model.messages.fetched;
  307. };
  308. mock.createContact = async function (_converse, name, ask, requesting, subscription) {
  309. const jid = name.replace(/ /g,'.').toLowerCase() + '@montague.lit';
  310. if (_converse.roster.get(jid)) {
  311. return Promise.resolve();
  312. }
  313. const contact = await new Promise((success, error) => {
  314. _converse.roster.create({
  315. 'ask': ask,
  316. 'fullname': name,
  317. 'jid': jid,
  318. 'requesting': requesting,
  319. 'subscription': subscription
  320. }, {success, error});
  321. });
  322. return contact;
  323. };
  324. mock.createContacts = async function (_converse, type, length) {
  325. /* Create current (as opposed to requesting or pending) contacts
  326. * for the user's roster.
  327. *
  328. * These contacts are not grouped. See below.
  329. */
  330. await _converse.api.waitUntil('rosterContactsFetched');
  331. let names, subscription, requesting, ask;
  332. if (type === 'requesting') {
  333. names = mock.req_names;
  334. subscription = 'none';
  335. requesting = true;
  336. ask = null;
  337. } else if (type === 'pending') {
  338. names = mock.pend_names;
  339. subscription = 'none';
  340. requesting = false;
  341. ask = 'subscribe';
  342. } else if (type === 'current') {
  343. names = mock.cur_names;
  344. subscription = 'both';
  345. requesting = false;
  346. ask = null;
  347. } else if (type === 'all') {
  348. await this.createContacts(_converse, 'current');
  349. await this.createContacts(_converse, 'requesting')
  350. await this.createContacts(_converse, 'pending');
  351. return this;
  352. } else {
  353. throw Error("Need to specify the type of contact to create");
  354. }
  355. const promises = names.slice(0, length).map(n => this.createContact(_converse, n, ask, requesting, subscription));
  356. await Promise.all(promises);
  357. };
  358. mock.waitForRoster = async function (_converse, type='current', length=-1, include_nick=true, grouped=true) {
  359. const s = `iq[type="get"] query[xmlns="${Strophe.NS.ROSTER}"]`;
  360. const iq = await u.waitUntil(() => _converse.connection.IQ_stanzas.filter(iq => sizzle(s, iq).length).pop());
  361. const result = $iq({
  362. 'to': _converse.connection.jid,
  363. 'type': 'result',
  364. 'id': iq.getAttribute('id')
  365. }).c('query', {
  366. 'xmlns': 'jabber:iq:roster'
  367. });
  368. if (type === 'pending' || type === 'all') {
  369. const pend_names = (length > -1) ? mock.pend_names.slice(0, length) : mock.pend_names;
  370. pend_names.map(name =>
  371. result.c('item', {
  372. jid: name.replace(/ /g,'.').toLowerCase() + '@montague.lit',
  373. name: include_nick ? name : undefined,
  374. subscription: 'none',
  375. ask: 'subscribe'
  376. }).up()
  377. );
  378. }
  379. if (type === 'current' || type === 'all') {
  380. const cur_names = Object.keys(mock.current_contacts_map);
  381. const names = (length > -1) ? cur_names.slice(0, length) : cur_names;
  382. names.forEach(name => {
  383. result.c('item', {
  384. jid: name.replace(/ /g,'.').toLowerCase() + '@montague.lit',
  385. name: include_nick ? name : undefined,
  386. subscription: 'both',
  387. ask: null
  388. });
  389. if (grouped) {
  390. mock.current_contacts_map[name].forEach(g => result.c('group').t(g).up());
  391. }
  392. result.up();
  393. });
  394. }
  395. _converse.connection._dataRecv(mock.createRequest(result));
  396. await _converse.api.waitUntil('rosterContactsFetched');
  397. };
  398. mock.createChatMessage = function (_converse, sender_jid, message) {
  399. return $msg({
  400. from: sender_jid,
  401. to: _converse.connection.jid,
  402. type: 'chat',
  403. id: (new Date()).getTime()
  404. })
  405. .c('body').t(message).up()
  406. .c('active', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  407. }
  408. mock.sendMessage = function (view, message) {
  409. const promise = new Promise(resolve => view.model.messages.once('rendered', resolve));
  410. view.el.querySelector('.chat-textarea').value = message;
  411. view.onKeyDown({
  412. target: view.el.querySelector('textarea.chat-textarea'),
  413. preventDefault: _.noop,
  414. keyCode: 13
  415. });
  416. return promise;
  417. };
  418. window.libsignal = {
  419. 'SignalProtocolAddress': function (name, device_id) {
  420. this.name = name;
  421. this.deviceId = device_id;
  422. },
  423. 'SessionCipher': function (storage, remote_address) {
  424. this.remoteAddress = remote_address;
  425. this.storage = storage;
  426. this.encrypt = () => Promise.resolve({
  427. 'type': 1,
  428. 'body': 'c1ph3R73X7',
  429. 'registrationId': '1337'
  430. });
  431. this.decryptPreKeyWhisperMessage = (key_and_tag) => {
  432. return Promise.resolve(key_and_tag);
  433. };
  434. this.decryptWhisperMessage = (key_and_tag) => {
  435. return Promise.resolve(key_and_tag);
  436. }
  437. },
  438. 'SessionBuilder': function (storage, remote_address) { // eslint-disable-line no-unused-vars
  439. this.processPreKey = function () {
  440. return Promise.resolve();
  441. }
  442. },
  443. 'KeyHelper': {
  444. 'generateIdentityKeyPair': function () {
  445. return Promise.resolve({
  446. 'pubKey': new TextEncoder('utf-8').encode('1234'),
  447. 'privKey': new TextEncoder('utf-8').encode('4321')
  448. });
  449. },
  450. 'generateRegistrationId': function () {
  451. return '123456789';
  452. },
  453. 'generatePreKey': function (keyid) {
  454. return Promise.resolve({
  455. 'keyId': keyid,
  456. 'keyPair': {
  457. 'pubKey': new TextEncoder('utf-8').encode('1234'),
  458. 'privKey': new TextEncoder('utf-8').encode('4321')
  459. }
  460. });
  461. },
  462. 'generateSignedPreKey': function (identity_keypair, keyid) {
  463. return Promise.resolve({
  464. 'signature': new TextEncoder('utf-8').encode('11112222333344445555'),
  465. 'keyId': keyid,
  466. 'keyPair': {
  467. 'pubKey': new TextEncoder('utf-8').encode('1234'),
  468. 'privKey': new TextEncoder('utf-8').encode('4321')
  469. }
  470. });
  471. }
  472. }
  473. };
  474. mock.default_muc_features = [
  475. 'http://jabber.org/protocol/muc',
  476. 'jabber:iq:register',
  477. Strophe.NS.SID,
  478. Strophe.NS.MAM,
  479. 'muc_passwordprotected',
  480. 'muc_hidden',
  481. 'muc_temporary',
  482. 'muc_open',
  483. 'muc_unmoderated',
  484. 'muc_anonymous'
  485. ];
  486. mock.view_mode = 'overlayed';
  487. // Names from http://www.fakenamegenerator.com/
  488. mock.req_names = [
  489. 'Escalus, prince of Verona', 'The Nurse', 'Paris'
  490. ];
  491. mock.pend_names = [
  492. 'Lord Capulet', 'Guard', 'Servant'
  493. ];
  494. mock.current_contacts_map = {
  495. 'Mercutio': ['Colleagues', 'friends & acquaintences'],
  496. 'Juliet Capulet': ['friends & acquaintences'],
  497. 'Lady Montague': ['Colleagues', 'Family'],
  498. 'Lord Montague': ['Family'],
  499. 'Friar Laurence': ['friends & acquaintences'],
  500. 'Tybalt': ['friends & acquaintences'],
  501. 'Lady Capulet': ['ænemies'],
  502. 'Benviolo': ['friends & acquaintences'],
  503. 'Balthasar': ['Colleagues'],
  504. 'Peter': ['Colleagues'],
  505. 'Abram': ['Colleagues'],
  506. 'Sampson': ['Colleagues'],
  507. 'Gregory': ['friends & acquaintences'],
  508. 'Potpan': [],
  509. 'Friar John': []
  510. };
  511. const map = mock.current_contacts_map;
  512. const groups_map = {};
  513. Object.keys(map).forEach(k => {
  514. const groups = map[k].length ? map[k] : ["Ungrouped"];
  515. Object.values(groups).forEach(g => {
  516. groups_map[g] = groups_map[g] ? [...groups_map[g], k] : [k]
  517. });
  518. });
  519. mock.groups_map = groups_map;
  520. mock.cur_names = Object.keys(mock.current_contacts_map);
  521. mock.num_contacts = mock.req_names.length + mock.pend_names.length + mock.cur_names.length;
  522. mock.groups = {
  523. 'colleagues': 3,
  524. 'friends & acquaintences': 3,
  525. 'Family': 4,
  526. 'ænemies': 3,
  527. 'Ungrouped': 2
  528. };
  529. mock.chatroom_names = [
  530. 'Dyon van de Wege',
  531. 'Thomas Kalb',
  532. 'Dirk Theissen',
  533. 'Felix Hofmann',
  534. 'Ka Lek',
  535. 'Anne Ebersbacher'
  536. ];
  537. // TODO: need to also test other roles and affiliations
  538. mock.chatroom_roles = {
  539. 'Anne Ebersbacher': { affiliation: "owner", role: "moderator" },
  540. 'Dirk Theissen': { affiliation: "admin", role: "moderator" },
  541. 'Dyon van de Wege': { affiliation: "member", role: "occupant" },
  542. 'Felix Hofmann': { affiliation: "member", role: "occupant" },
  543. 'Ka Lek': { affiliation: "member", role: "occupant" },
  544. 'Thomas Kalb': { affiliation: "member", role: "occupant" }
  545. };
  546. mock.event = {
  547. 'preventDefault': function () {}
  548. };
  549. const OriginalConnection = Strophe.Connection;
  550. function MockConnection (service, options) {
  551. OriginalConnection.call(this, service, options);
  552. Strophe.Bosh.prototype._processRequest = function () {}; // Don't attempt to send out stanzas
  553. const sendIQ = this.sendIQ;
  554. this.IQ_stanzas = [];
  555. this.IQ_ids = [];
  556. this.sendIQ = function (iq, callback, errback) {
  557. if (!_.isElement(iq)) {
  558. iq = iq.nodeTree;
  559. }
  560. this.IQ_stanzas.push(iq);
  561. const id = sendIQ.bind(this)(iq, callback, errback);
  562. this.IQ_ids.push(id);
  563. return id;
  564. }
  565. const send = this.send;
  566. this.sent_stanzas = [];
  567. this.send = function (stanza) {
  568. if (_.isElement(stanza)) {
  569. this.sent_stanzas.push(stanza);
  570. } else {
  571. this.sent_stanzas.push(stanza.nodeTree);
  572. }
  573. return send.apply(this, arguments);
  574. }
  575. this.features = Strophe.xmlHtmlNode(
  576. '<stream:features xmlns:stream="http://etherx.jabber.org/streams" xmlns="jabber:client">'+
  577. '<ver xmlns="urn:xmpp:features:rosterver"/>'+
  578. '<csi xmlns="urn:xmpp:csi:0"/>'+
  579. '<this xmlns="http://jabber.org/protocol/caps" ver="UwBpfJpEt3IoLYfWma/o/p3FFRo=" hash="sha-1" node="http://prosody.im"/>'+
  580. '<bind xmlns="urn:ietf:params:xml:ns:xmpp-bind">'+
  581. '<required/>'+
  582. '</bind>'+
  583. `<sm xmlns='urn:xmpp:sm:3'/>`+
  584. '<session xmlns="urn:ietf:params:xml:ns:xmpp-session">'+
  585. '<optional/>'+
  586. '</session>'+
  587. '</stream:features>').firstChild;
  588. this._proto._connect = () => {
  589. this.connected = true;
  590. this.mock = true;
  591. this.jid = 'romeo@montague.lit/orchard';
  592. this._changeConnectStatus(Strophe.Status.BINDREQUIRED);
  593. };
  594. this.bind = () => {
  595. this.authenticated = true;
  596. this.authenticated = true;
  597. if (!_converse.no_connection_on_bind) {
  598. this._changeConnectStatus(Strophe.Status.CONNECTED);
  599. }
  600. };
  601. this._proto._disconnect = () => this._onDisconnectTimeout();
  602. this._proto._onDisconnectTimeout = _.noop;
  603. }
  604. MockConnection.prototype = Object.create(OriginalConnection.prototype);
  605. Strophe.Connection = MockConnection;
  606. function clearIndexedDB () {
  607. const promise = u.getResolveablePromise();
  608. const db_request = window.indexedDB.open("converse-test-persistent");
  609. db_request.onsuccess = function () {
  610. const db = db_request.result;
  611. const bare_jid = "romeo@montague.lit";
  612. let store;
  613. try {
  614. store= db.transaction([bare_jid], "readwrite").objectStore(bare_jid);
  615. } catch (e) {
  616. return promise.resolve();
  617. }
  618. const request = store.clear();
  619. request.onsuccess = promise.resolve();
  620. request.onerror = promise.resolve();
  621. };
  622. db_request.onerror = function (ev) {
  623. return promise.reject(ev.target.error);
  624. }
  625. return promise;
  626. }
  627. function clearStores () {
  628. [localStorage, sessionStorage].forEach(
  629. s => Object.keys(s).forEach(k => k.match(/^converse-test-/) && s.removeItem(k))
  630. );
  631. const cache_key = `converse.room-bookmarksromeo@montague.lit`;
  632. window.sessionStorage.removeItem(cache_key+'fetched');
  633. }
  634. initConverse = async (settings) => {
  635. clearStores();
  636. await clearIndexedDB();
  637. _converse = await converse.initialize(Object.assign({
  638. 'animate': false,
  639. 'auto_subscribe': false,
  640. 'bosh_service_url': 'montague.lit/http-bind',
  641. 'discover_connection_methods': false,
  642. 'enable_smacks': false,
  643. 'i18n': 'en',
  644. // 'persistent_store': 'IndexedDB',
  645. 'loglevel': 'warn',
  646. 'no_trimming': true,
  647. 'play_sounds': false,
  648. 'use_emojione': false,
  649. 'view_mode': mock.view_mode
  650. }, settings || {}));
  651. _converse.ChatBoxViews.prototype.trimChat = function () {};
  652. _converse.api.vcard.get = function (model, force) {
  653. let jid;
  654. if (_.isString(model)) {
  655. jid = model;
  656. } else if (!model.get('vcard_updated') || force) {
  657. jid = model.get('jid') || model.get('muc_jid');
  658. }
  659. let fullname;
  660. if (!jid || jid == 'romeo@montague.lit') {
  661. jid = 'romeo@montague.lit';
  662. fullname = 'Romeo Montague' ;
  663. } else {
  664. const name = jid.split('@')[0].replace(/\./g, ' ').split(' ');
  665. const last = name.length-1;
  666. name[0] = name[0].charAt(0).toUpperCase()+name[0].slice(1);
  667. name[last] = name[last].charAt(0).toUpperCase()+name[last].slice(1);
  668. fullname = name.join(' ');
  669. }
  670. const vcard = $iq().c('vCard').c('FN').t(fullname).nodeTree;
  671. return {
  672. 'vcard': vcard,
  673. 'fullname': _.get(vcard.querySelector('FN'), 'textContent'),
  674. 'image': _.get(vcard.querySelector('PHOTO BINVAL'), 'textContent'),
  675. 'image_type': _.get(vcard.querySelector('PHOTO TYPE'), 'textContent'),
  676. 'url': _.get(vcard.querySelector('URL'), 'textContent'),
  677. 'vcard_updated': dayjs().format(),
  678. 'vcard_error': undefined
  679. };
  680. };
  681. if (_.get(settings, 'auto_login') !== false) {
  682. _converse.api.user.login('romeo@montague.lit/orchard', 'secret');
  683. await _converse.api.waitUntil('afterResourceBinding');
  684. }
  685. window.converse_disable_effects = true;
  686. return _converse;
  687. }
  688. });
  689. converse.load();