mock.js 27 KB

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