chatbox.js 88 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672
  1. /*global mock */
  2. const _ = converse.env._;
  3. const $msg = converse.env.$msg;
  4. const Strophe = converse.env.Strophe;
  5. const u = converse.env.utils;
  6. const sizzle = converse.env.sizzle;
  7. const original_timeout = jasmine.DEFAULT_TIMEOUT_INTERVAL;
  8. describe("Chatboxes", function () {
  9. beforeEach(() => (jasmine.DEFAULT_TIMEOUT_INTERVAL = 7000));
  10. afterEach(() => (jasmine.DEFAULT_TIMEOUT_INTERVAL = original_timeout));
  11. describe("A Chatbox", function () {
  12. it("has a /help command to show the available commands", mock.initConverse(['rosterGroupsFetched', 'chatBoxesFetched'], {}, async function (done, _converse) {
  13. await mock.waitForRoster(_converse, 'current', 1);
  14. await mock.openControlBox(_converse);
  15. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  16. await mock.openChatBoxFor(_converse, contact_jid);
  17. const view = _converse.chatboxviews.get(contact_jid);
  18. mock.sendMessage(view, '/help');
  19. await u.waitUntil(() => sizzle('.chat-info:not(.chat-date)', view.el).length);
  20. const info_messages = await u.waitUntil(() => sizzle('.chat-info:not(.chat-date)', view.el));
  21. expect(info_messages.length).toBe(4);
  22. expect(info_messages.pop().textContent).toBe('/help: Show this menu');
  23. expect(info_messages.pop().textContent).toBe('/me: Write in the third person');
  24. expect(info_messages.pop().textContent).toBe('/close: Close this chat');
  25. expect(info_messages.pop().textContent).toBe('/clear: Remove messages');
  26. const msg = $msg({
  27. from: contact_jid,
  28. to: _converse.connection.jid,
  29. type: 'chat',
  30. id: u.getUniqueId()
  31. }).c('body').t('hello world').tree();
  32. await _converse.handleMessageStanza(msg);
  33. await u.waitUntil(() => view.content.querySelectorAll('.chat-msg').length);
  34. const msg_txt_sel = 'converse-chat-message:last-child .chat-msg__body';
  35. await u.waitUntil(() => view.el.querySelector(msg_txt_sel).textContent.trim() === 'hello world');
  36. done();
  37. }));
  38. it("has a /clear command", mock.initConverse(['chatBoxesFetched'], {}, async function (done, _converse) {
  39. await mock.waitForRoster(_converse, 'current', 1);
  40. await mock.openControlBox(_converse);
  41. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  42. await mock.openChatBoxFor(_converse, contact_jid);
  43. const view = _converse.chatboxviews.get(contact_jid);
  44. spyOn(window, 'confirm').and.returnValue(true);
  45. for (const i of Array(10).keys()) {
  46. mock.sendMessage(view, `Message ${i}`);
  47. }
  48. await u.waitUntil(() => sizzle('converse-chat-message', view.el).length === 10);
  49. const textarea = view.el.querySelector('textarea.chat-textarea');
  50. textarea.value = '/clear';
  51. view.onKeyDown({
  52. target: textarea,
  53. preventDefault: function preventDefault () {},
  54. keyCode: 13 // Enter
  55. });
  56. expect(window.confirm).toHaveBeenCalled();
  57. await u.waitUntil(() => sizzle('converse-chat-message', view.el).length === 0);
  58. done();
  59. }));
  60. it("supports the /me command", mock.initConverse(['rosterGroupsFetched'], {}, async function (done, _converse) {
  61. await mock.waitForRoster(_converse, 'current');
  62. await mock.waitUntilDiscoConfirmed(_converse, 'montague.lit', [], ['vcard-temp']);
  63. await u.waitUntil(() => _converse.xmppstatus.vcard.get('fullname'));
  64. await mock.openControlBox(_converse);
  65. expect(_converse.chatboxes.length).toEqual(1);
  66. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  67. let message = '/me is tired';
  68. const msg = $msg({
  69. from: sender_jid,
  70. to: _converse.connection.jid,
  71. type: 'chat',
  72. id: u.getUniqueId()
  73. }).c('body').t(message).up()
  74. .c('active', {'xmlns': 'http://jabber.org/protocol/chatstates'}).tree();
  75. await _converse.handleMessageStanza(msg);
  76. const view = _converse.chatboxviews.get(sender_jid);
  77. await u.waitUntil(() => view.el.querySelector('.chat-msg__text'));
  78. expect(view.el.querySelectorAll('.chat-msg--action').length).toBe(1);
  79. expect(view.el.querySelector('.chat-msg__author').textContent.includes('**Mercutio')).toBeTruthy();
  80. expect(view.el.querySelector('.chat-msg__text').textContent).toBe('is tired');
  81. message = '/me is as well';
  82. await mock.sendMessage(view, message);
  83. expect(view.el.querySelectorAll('.chat-msg--action').length).toBe(2);
  84. await u.waitUntil(() => sizzle('.chat-msg__author:last', view.el).pop().textContent.trim() === '**Romeo Montague');
  85. const last_el = sizzle('.chat-msg__text:last', view.el).pop();
  86. await u.waitUntil(() => last_el.textContent === 'is as well');
  87. expect(u.hasClass('chat-msg--followup', last_el)).toBe(false);
  88. // Check that /me messages after a normal message don't
  89. // get the 'chat-msg--followup' class.
  90. message = 'This a normal message';
  91. await mock.sendMessage(view, message);
  92. const msg_txt_sel = 'converse-chat-message:last-child .chat-msg__text';
  93. await u.waitUntil(() => view.el.querySelector(msg_txt_sel).textContent.trim() === message);
  94. let el = view.el.querySelector('converse-chat-message:last-child .chat-msg__body');
  95. expect(u.hasClass('chat-msg--followup', el)).toBeFalsy();
  96. message = '/me wrote a 3rd person message';
  97. await mock.sendMessage(view, message);
  98. await u.waitUntil(() => view.el.querySelector(msg_txt_sel).textContent.trim() === message.replace('/me ', ''));
  99. el = view.el.querySelector('converse-chat-message:last-child .chat-msg__body');
  100. expect(view.el.querySelectorAll('.chat-msg--action').length).toBe(3);
  101. expect(sizzle('.chat-msg__text:last', view.el).pop().textContent).toBe('wrote a 3rd person message');
  102. expect(u.isVisible(sizzle('.chat-msg__author:last', view.el).pop())).toBeTruthy();
  103. done();
  104. }));
  105. it("is created when you click on a roster item", mock.initConverse(
  106. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  107. async function (done, _converse) {
  108. await mock.waitForRoster(_converse, 'current');
  109. await mock.openControlBox(_converse);
  110. // openControlBox was called earlier, so the controlbox is
  111. // visible, but no other chat boxes have been created.
  112. expect(_converse.chatboxes.length).toEqual(1);
  113. spyOn(_converse.chatboxviews, 'trimChats');
  114. expect(document.querySelectorAll("#conversejs .chatbox").length).toBe(1); // Controlbox is open
  115. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group li').length, 700);
  116. const online_contacts = _converse.rosterview.el.querySelectorAll('.roster-group .current-xmpp-contact a.open-chat');
  117. expect(online_contacts.length).toBe(17);
  118. let el = online_contacts[0];
  119. el.click();
  120. await u.waitUntil(() => document.querySelectorAll("#conversejs .chatbox").length == 2);
  121. expect(_converse.chatboxviews.trimChats).toHaveBeenCalled();
  122. online_contacts[1].click();
  123. await u.waitUntil(() => _converse.chatboxes.length == 3);
  124. el = online_contacts[1];
  125. expect(_converse.chatboxviews.trimChats).toHaveBeenCalled();
  126. // Check that new chat boxes are created to the left of the
  127. // controlbox (but to the right of all existing chat boxes)
  128. expect(document.querySelectorAll("#conversejs .chatbox").length).toBe(3);
  129. done();
  130. }));
  131. it("opens when a new message is received", mock.initConverse(
  132. ['rosterGroupsFetched'], {'allow_non_roster_messaging': true},
  133. async function (done, _converse) {
  134. await mock.waitForRoster(_converse, 'current', 0);
  135. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  136. const stanza = u.toStanza(`
  137. <message from="${sender_jid}"
  138. type="chat"
  139. to="romeo@montague.lit/orchard">
  140. <body>Hey\nHave you heard the news?</body>
  141. </message>`);
  142. const message_promise = new Promise(resolve => _converse.api.listen.on('message', resolve));
  143. _converse.connection._dataRecv(mock.createRequest(stanza));
  144. await new Promise(resolve => _converse.api.listen.once('chatBoxViewInitialized', resolve));
  145. await u.waitUntil(() => message_promise);
  146. expect(_converse.chatboxviews.keys().length).toBe(2);
  147. done();
  148. }));
  149. it("doesn't open when a message without body is received", mock.initConverse(
  150. ['rosterGroupsFetched'], {},
  151. async function (done, _converse) {
  152. await mock.waitForRoster(_converse, 'current', 1);
  153. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  154. const stanza = u.toStanza(`
  155. <message from="${sender_jid}"
  156. type="chat"
  157. to="romeo@montague.lit/orchard">
  158. <composing xmlns="http://jabber.org/protocol/chatstates"/>
  159. </message>`);
  160. const message_promise = new Promise(resolve => _converse.api.listen.on('message', resolve))
  161. _converse.connection._dataRecv(mock.createRequest(stanza));
  162. await u.waitUntil(() => message_promise);
  163. expect(_converse.chatboxviews.keys().length).toBe(1);
  164. done();
  165. }));
  166. it("can be trimmed to conserve space",
  167. mock.initConverse(['rosterGroupsFetched'], {},
  168. async function (done, _converse) {
  169. spyOn(_converse.chatboxviews, 'trimChats');
  170. const trimmed_chatboxes = _converse.minimized_chats;
  171. spyOn(trimmed_chatboxes, 'addChat').and.callThrough();
  172. spyOn(trimmed_chatboxes, 'removeChat').and.callThrough();
  173. await mock.waitForRoster(_converse, 'current');
  174. await mock.openControlBox(_converse);
  175. expect(_converse.chatboxviews.trimChats.calls.count()).toBe(1);
  176. let jid, chatboxview;
  177. // openControlBox was called earlier, so the controlbox is
  178. // visible, but no other chat boxes have been created.
  179. expect(_converse.chatboxes.length).toEqual(1);
  180. expect(document.querySelectorAll("#conversejs .chatbox").length).toBe(1); // Controlbox is open
  181. _converse.rosterview.update(); // XXX: Hack to make sure $roster element is attached.
  182. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group li').length);
  183. // Test that they can be maximized again
  184. const online_contacts = _converse.rosterview.el.querySelectorAll('.roster-group .current-xmpp-contact a.open-chat');
  185. expect(online_contacts.length).toBe(17);
  186. let i;
  187. for (i=0; i<online_contacts.length; i++) {
  188. const el = online_contacts[i];
  189. el.click();
  190. }
  191. await u.waitUntil(() => _converse.chatboxes.length == 16);
  192. expect(_converse.chatboxviews.trimChats.calls.count()).toBe(16);
  193. _converse.api.chatviews.get().forEach(v => spyOn(v, 'onMinimized').and.callThrough());
  194. for (i=0; i<online_contacts.length; i++) {
  195. const el = online_contacts[i];
  196. jid = _.trim(el.textContent.trim()).replace(/ /g,'.').toLowerCase() + '@montague.lit';
  197. chatboxview = _converse.chatboxviews.get(jid);
  198. chatboxview.model.set({'minimized': true});
  199. expect(trimmed_chatboxes.addChat).toHaveBeenCalled();
  200. expect(chatboxview.onMinimized).toHaveBeenCalled();
  201. }
  202. await u.waitUntil(() => _converse.chatboxviews.keys().length);
  203. var key = _converse.chatboxviews.keys()[1];
  204. const trimmedview = trimmed_chatboxes.get(key);
  205. const chatbox = trimmedview.model;
  206. spyOn(chatbox, 'maximize').and.callThrough();
  207. spyOn(trimmedview, 'restore').and.callThrough();
  208. trimmedview.delegateEvents();
  209. trimmedview.el.querySelector("a.restore-chat").click();
  210. expect(trimmedview.restore).toHaveBeenCalled();
  211. expect(chatbox.maximize).toHaveBeenCalled();
  212. expect(_converse.chatboxviews.trimChats.calls.count()).toBe(17);
  213. done();
  214. }));
  215. it("can be opened in minimized mode initially",
  216. mock.initConverse(
  217. ['rosterGroupsFetched'], {},
  218. async function (done, _converse) {
  219. await mock.waitForRoster(_converse, 'current');
  220. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  221. await _converse.api.chats.create(sender_jid, {'minimized': true});
  222. await u.waitUntil(() => _converse.chatboxes.length > 1);
  223. const chatBoxView = _converse.chatboxviews.get(sender_jid);
  224. expect(u.isVisible(chatBoxView.el)).toBeFalsy();
  225. const minimized_chat = _converse.minimized_chats.get(sender_jid);
  226. expect(minimized_chat).toBeTruthy();
  227. expect(u.isVisible(minimized_chat.el)).toBeTruthy();
  228. done();
  229. }));
  230. it("is focused if its already open and you click on its corresponding roster item",
  231. mock.initConverse(['rosterGroupsFetched', 'chatBoxesFetched'], {},
  232. async function (done, _converse) {
  233. await mock.waitForRoster(_converse, 'current');
  234. await mock.openControlBox(_converse);
  235. expect(_converse.chatboxes.length).toEqual(1);
  236. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  237. const view = await mock.openChatBoxFor(_converse, contact_jid);
  238. const el = sizzle('a.open-chat:contains("'+view.model.getDisplayName()+'")', _converse.rosterview.el).pop();
  239. await u.waitUntil(() => u.isVisible(el));
  240. const textarea = view.el.querySelector('.chat-textarea');
  241. await u.waitUntil(() => u.isVisible(textarea));
  242. textarea.blur();
  243. spyOn(view.model, 'maybeShow').and.callThrough();
  244. spyOn(view, 'focus').and.callThrough();
  245. el.click();
  246. await u.waitUntil(() => view.model.maybeShow.calls.count(), 1000);
  247. expect(view.model.maybeShow).toHaveBeenCalled();
  248. expect(view.focus).toHaveBeenCalled();
  249. expect(_converse.chatboxes.length).toEqual(2);
  250. done();
  251. }));
  252. it("can be saved to, and retrieved from, browserStorage",
  253. mock.initConverse(
  254. ['rosterGroupsFetched'], {},
  255. async function (done, _converse) {
  256. spyOn(_converse.ChatBoxViews.prototype, 'trimChats');
  257. await mock.waitForRoster(_converse, 'current');
  258. await mock.openControlBox(_converse);
  259. spyOn(_converse.api, "trigger").and.callThrough();
  260. mock.openChatBoxes(_converse, 6);
  261. await u.waitUntil(() => _converse.chatboxes.length == 7);
  262. expect(_converse.chatboxviews.trimChats).toHaveBeenCalled();
  263. // We instantiate a new ChatBoxes collection, which by default
  264. // will be empty.
  265. const newchatboxes = new _converse.ChatBoxes();
  266. expect(newchatboxes.length).toEqual(0);
  267. // The chatboxes will then be fetched from browserStorage inside the
  268. // onConnected method
  269. newchatboxes.onConnected();
  270. await new Promise(resolve => _converse.api.listen.on('chatBoxesFetched', resolve));
  271. expect(newchatboxes.length).toEqual(7);
  272. // Check that the chatboxes items retrieved from browserStorage
  273. // have the same attributes values as the original ones.
  274. const attrs = ['id', 'box_id', 'visible'];
  275. let new_attrs, old_attrs;
  276. for (var i=0; i<attrs.length; i++) {
  277. new_attrs = _.map(_.map(newchatboxes.models, 'attributes'), attrs[i]);
  278. old_attrs = _.map(_.map(_converse.chatboxes.models, 'attributes'), attrs[i]);
  279. expect(_.isEqual(new_attrs, old_attrs)).toEqual(true);
  280. }
  281. _converse.rosterview.render();
  282. done();
  283. }));
  284. it("can be closed by clicking a DOM element with class 'close-chatbox-button'",
  285. mock.initConverse(
  286. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  287. async function (done, _converse) {
  288. await mock.waitForRoster(_converse, 'current');
  289. await mock.openControlBox(_converse);
  290. const contact_jid = mock.cur_names[7].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  291. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  292. await mock.openChatBoxFor(_converse, contact_jid);
  293. const controlview = _converse.chatboxviews.get('controlbox'), // The controlbox is currently open
  294. chatview = _converse.chatboxviews.get(contact_jid);
  295. spyOn(chatview, 'close').and.callThrough();
  296. spyOn(controlview, 'close').and.callThrough();
  297. spyOn(_converse.api, "trigger").and.callThrough();
  298. // We need to rebind all events otherwise our spy won't be called
  299. controlview.delegateEvents();
  300. chatview.delegateEvents();
  301. controlview.el.querySelector('.close-chatbox-button').click();
  302. expect(controlview.close).toHaveBeenCalled();
  303. await new Promise(resolve => _converse.api.listen.once('chatBoxClosed', resolve));
  304. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxClosed', jasmine.any(Object));
  305. chatview.el.querySelector('.close-chatbox-button').click();
  306. expect(chatview.close).toHaveBeenCalled();
  307. await new Promise(resolve => _converse.api.listen.once('chatBoxClosed', resolve));
  308. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxClosed', jasmine.any(Object));
  309. done();
  310. }));
  311. it("can be minimized by clicking a DOM element with class 'toggle-chatbox-button'",
  312. mock.initConverse(
  313. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  314. async function (done, _converse) {
  315. await mock.waitForRoster(_converse, 'current');
  316. await mock.openControlBox(_converse);
  317. const contact_jid = mock.cur_names[7].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  318. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  319. await mock.openChatBoxFor(_converse, contact_jid);
  320. const trimmed_chatboxes = _converse.minimized_chats;
  321. const chatview = _converse.chatboxviews.get(contact_jid);
  322. spyOn(chatview, 'minimize').and.callThrough();
  323. spyOn(_converse.api, "trigger").and.callThrough();
  324. // We need to rebind all events otherwise our spy won't be called
  325. chatview.delegateEvents();
  326. chatview.el.querySelector('.toggle-chatbox-button').click();
  327. expect(chatview.minimize).toHaveBeenCalled();
  328. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxMinimized', jasmine.any(Object));
  329. expect(_converse.api.trigger.calls.count(), 2);
  330. expect(u.isVisible(chatview.el)).toBeFalsy();
  331. expect(chatview.model.get('minimized')).toBeTruthy();
  332. chatview.el.querySelector('.toggle-chatbox-button').click();
  333. const trimmedview = trimmed_chatboxes.get(chatview.model.get('id'));
  334. spyOn(trimmedview, 'restore').and.callThrough();
  335. trimmedview.delegateEvents();
  336. trimmedview.el.querySelector("a.restore-chat").click();
  337. expect(trimmedview.restore).toHaveBeenCalled();
  338. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxMaximized', jasmine.any(Object));
  339. expect(chatview.model.get('minimized')).toBeFalsy();
  340. done();
  341. }));
  342. it("will be removed from browserStorage when closed",
  343. mock.initConverse(
  344. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  345. async function (done, _converse) {
  346. spyOn(_converse.ChatBoxViews.prototype, 'trimChats');
  347. await mock.waitForRoster(_converse, 'current');
  348. await mock.openControlBox(_converse);
  349. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  350. spyOn(_converse.api, "trigger").and.callThrough();
  351. mock.closeControlBox();
  352. await new Promise(resolve => _converse.api.listen.once('chatBoxClosed', resolve));
  353. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxClosed', jasmine.any(Object));
  354. expect(_converse.chatboxes.length).toEqual(1);
  355. expect(_converse.chatboxes.pluck('id')).toEqual(['controlbox']);
  356. mock.openChatBoxes(_converse, 6);
  357. await u.waitUntil(() => _converse.chatboxes.length == 7)
  358. expect(_converse.chatboxviews.trimChats).toHaveBeenCalled();
  359. expect(_converse.chatboxes.length).toEqual(7);
  360. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxViewInitialized', jasmine.any(Object));
  361. await mock.closeAllChatBoxes(_converse);
  362. expect(_converse.chatboxes.length).toEqual(1);
  363. expect(_converse.chatboxes.pluck('id')).toEqual(['controlbox']);
  364. expect(_converse.api.trigger).toHaveBeenCalledWith('chatBoxClosed', jasmine.any(Object));
  365. const newchatboxes = new _converse.ChatBoxes();
  366. expect(newchatboxes.length).toEqual(0);
  367. expect(_converse.chatboxes.pluck('id')).toEqual(['controlbox']);
  368. // onConnected will fetch chatboxes in browserStorage, but
  369. // because there aren't any open chatboxes, there won't be any
  370. // in browserStorage either. XXX except for the controlbox
  371. newchatboxes.onConnected();
  372. await new Promise(resolve => _converse.api.listen.on('chatBoxesFetched', resolve));
  373. expect(newchatboxes.length).toEqual(1);
  374. expect(newchatboxes.models[0].id).toBe("controlbox");
  375. done();
  376. }));
  377. describe("A chat toolbar", function () {
  378. it("shows the remaining character count if a message_limit is configured",
  379. mock.initConverse(
  380. ['rosterGroupsFetched', 'chatBoxesFetched'], {'message_limit': 200},
  381. async function (done, _converse) {
  382. await mock.waitForRoster(_converse, 'current', 3);
  383. await mock.openControlBox(_converse);
  384. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  385. await mock.openChatBoxFor(_converse, contact_jid);
  386. const view = _converse.chatboxviews.get(contact_jid);
  387. const toolbar = view.el.querySelector('.chat-toolbar');
  388. const counter = toolbar.querySelector('.message-limit');
  389. expect(counter.textContent).toBe('200');
  390. view.insertIntoTextArea('hello world');
  391. expect(counter.textContent).toBe('188');
  392. toolbar.querySelector('.toggle-emojis').click();
  393. const picker = await u.waitUntil(() => view.el.querySelector('.emoji-picker__lists'));
  394. const item = await u.waitUntil(() => picker.querySelector('.emoji-picker li.insert-emoji a'));
  395. item.click()
  396. expect(counter.textContent).toBe('179');
  397. const textarea = view.el.querySelector('.chat-textarea');
  398. const ev = {
  399. target: textarea,
  400. preventDefault: function preventDefault () {},
  401. keyCode: 13 // Enter
  402. };
  403. view.onKeyDown(ev);
  404. await new Promise(resolve => view.model.messages.once('rendered', resolve));
  405. view.onKeyUp(ev);
  406. expect(counter.textContent).toBe('200');
  407. textarea.value = 'hello world';
  408. view.onKeyUp(ev);
  409. expect(counter.textContent).toBe('189');
  410. done();
  411. }));
  412. it("does not show a remaining character count if message_limit is zero",
  413. mock.initConverse(
  414. ['rosterGroupsFetched', 'chatBoxesFetched'], {'message_limit': 0},
  415. async function (done, _converse) {
  416. await mock.waitForRoster(_converse, 'current', 3);
  417. await mock.openControlBox(_converse);
  418. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  419. await mock.openChatBoxFor(_converse, contact_jid);
  420. const view = _converse.chatboxviews.get(contact_jid);
  421. const counter = view.el.querySelector('.chat-toolbar .message-limit');
  422. expect(counter).toBe(null);
  423. done();
  424. }));
  425. it("can contain a button for starting a call",
  426. mock.initConverse(
  427. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  428. async function (done, _converse) {
  429. await mock.waitForRoster(_converse, 'current');
  430. await mock.openControlBox(_converse);
  431. let toolbar, call_button;
  432. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  433. spyOn(_converse.api, "trigger").and.callThrough();
  434. // First check that the button doesn't show if it's not enabled
  435. // via "visible_toolbar_buttons"
  436. _converse.visible_toolbar_buttons.call = false;
  437. await mock.openChatBoxFor(_converse, contact_jid);
  438. let view = _converse.chatboxviews.get(contact_jid);
  439. toolbar = view.el.querySelector('.chat-toolbar');
  440. call_button = toolbar.querySelector('.toggle-call');
  441. expect(call_button === null).toBeTruthy();
  442. view.close();
  443. // Now check that it's shown if enabled and that it emits
  444. // callButtonClicked
  445. _converse.visible_toolbar_buttons.call = true; // enable the button
  446. await mock.openChatBoxFor(_converse, contact_jid);
  447. view = _converse.chatboxviews.get(contact_jid);
  448. toolbar = view.el.querySelector('.chat-toolbar');
  449. call_button = toolbar.querySelector('.toggle-call');
  450. call_button.click();
  451. expect(_converse.api.trigger).toHaveBeenCalledWith('callButtonClicked', jasmine.any(Object));
  452. done();
  453. }));
  454. });
  455. describe("A Chat Status Notification", function () {
  456. it("does not open a new chatbox",
  457. mock.initConverse(
  458. ['rosterGroupsFetched'], {},
  459. async function (done, _converse) {
  460. await mock.waitForRoster(_converse, 'current');
  461. await mock.openControlBox(_converse);
  462. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  463. // <composing> state
  464. const stanza = $msg({
  465. 'from': sender_jid,
  466. 'to': _converse.connection.jid,
  467. 'type': 'chat',
  468. 'id': u.getUniqueId()
  469. }).c('composing', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  470. spyOn(_converse.api, "trigger").and.callThrough();
  471. _converse.connection._dataRecv(mock.createRequest(stanza));
  472. await u.waitUntil(() => _converse.api.trigger.calls.count());
  473. expect(_converse.api.trigger).toHaveBeenCalledWith('message', jasmine.any(Object));
  474. expect(_converse.chatboxviews.keys().length).toBe(1);
  475. done();
  476. }));
  477. describe("An active notification", function () {
  478. it("is sent when the user opens a chat box",
  479. mock.initConverse(
  480. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  481. async function (done, _converse) {
  482. await mock.waitForRoster(_converse, 'current');
  483. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  484. await mock.openControlBox(_converse);
  485. u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  486. spyOn(_converse.connection, 'send');
  487. await mock.openChatBoxFor(_converse, contact_jid);
  488. const view = _converse.chatboxviews.get(contact_jid);
  489. expect(view.model.get('chat_state')).toBe('active');
  490. expect(_converse.connection.send).toHaveBeenCalled();
  491. const stanza = _converse.connection.send.calls.argsFor(0)[0].tree();
  492. expect(stanza.getAttribute('to')).toBe(contact_jid);
  493. expect(stanza.childNodes.length).toBe(3);
  494. expect(stanza.childNodes[0].tagName).toBe('active');
  495. expect(stanza.childNodes[1].tagName).toBe('no-store');
  496. expect(stanza.childNodes[2].tagName).toBe('no-permanent-store');
  497. done();
  498. }));
  499. it("is sent when the user maximizes a minimized a chat box", mock.initConverse(
  500. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  501. async function (done, _converse) {
  502. await mock.waitForRoster(_converse, 'current', 1);
  503. await mock.openControlBox(_converse);
  504. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  505. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  506. await mock.openChatBoxFor(_converse, contact_jid);
  507. const view = _converse.chatboxviews.get(contact_jid);
  508. view.model.minimize();
  509. expect(view.model.get('chat_state')).toBe('inactive');
  510. spyOn(_converse.connection, 'send');
  511. view.model.maximize();
  512. await u.waitUntil(() => view.model.get('chat_state') === 'active', 1000);
  513. expect(_converse.connection.send).toHaveBeenCalled();
  514. const calls = _.filter(_converse.connection.send.calls.all(), function (call) {
  515. return call.args[0] instanceof Strophe.Builder;
  516. });
  517. expect(calls.length).toBe(1);
  518. const stanza = calls[0].args[0].tree();
  519. expect(stanza.getAttribute('to')).toBe(contact_jid);
  520. expect(stanza.childNodes.length).toBe(3);
  521. expect(stanza.childNodes[0].tagName).toBe('active');
  522. expect(stanza.childNodes[1].tagName).toBe('no-store');
  523. expect(stanza.childNodes[2].tagName).toBe('no-permanent-store');
  524. done();
  525. }));
  526. });
  527. describe("A composing notification", function () {
  528. it("is sent as soon as the user starts typing a message which is not a command",
  529. mock.initConverse(
  530. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  531. async function (done, _converse) {
  532. await mock.waitForRoster(_converse, 'current');
  533. await mock.openControlBox(_converse);
  534. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  535. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  536. await mock.openChatBoxFor(_converse, contact_jid);
  537. var view = _converse.chatboxviews.get(contact_jid);
  538. expect(view.model.get('chat_state')).toBe('active');
  539. spyOn(_converse.connection, 'send');
  540. spyOn(_converse.api, "trigger").and.callThrough();
  541. view.onKeyDown({
  542. target: view.el.querySelector('textarea.chat-textarea'),
  543. keyCode: 1
  544. });
  545. expect(view.model.get('chat_state')).toBe('composing');
  546. expect(_converse.connection.send).toHaveBeenCalled();
  547. const stanza = _converse.connection.send.calls.argsFor(0)[0].tree();
  548. expect(stanza.getAttribute('to')).toBe(contact_jid);
  549. expect(stanza.childNodes.length).toBe(3);
  550. expect(stanza.childNodes[0].tagName).toBe('composing');
  551. expect(stanza.childNodes[1].tagName).toBe('no-store');
  552. expect(stanza.childNodes[2].tagName).toBe('no-permanent-store');
  553. // The notification is not sent again
  554. view.onKeyDown({
  555. target: view.el.querySelector('textarea.chat-textarea'),
  556. keyCode: 1
  557. });
  558. expect(view.model.get('chat_state')).toBe('composing');
  559. expect(_converse.api.trigger.calls.count(), 1);
  560. done();
  561. }));
  562. it("is NOT sent out if send_chat_state_notifications doesn't allow it",
  563. mock.initConverse(
  564. ['rosterGroupsFetched', 'chatBoxesFetched'], {'send_chat_state_notifications': []},
  565. async function (done, _converse) {
  566. await mock.waitForRoster(_converse, 'current');
  567. await mock.openControlBox(_converse);
  568. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  569. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  570. await mock.openChatBoxFor(_converse, contact_jid);
  571. var view = _converse.chatboxviews.get(contact_jid);
  572. expect(view.model.get('chat_state')).toBe('active');
  573. spyOn(_converse.connection, 'send');
  574. spyOn(_converse.api, "trigger").and.callThrough();
  575. view.onKeyDown({
  576. target: view.el.querySelector('textarea.chat-textarea'),
  577. keyCode: 1
  578. });
  579. expect(view.model.get('chat_state')).toBe('composing');
  580. expect(_converse.connection.send).not.toHaveBeenCalled();
  581. done();
  582. }));
  583. it("will be shown if received",
  584. mock.initConverse(
  585. ['rosterGroupsFetched'], {},
  586. async function (done, _converse) {
  587. await mock.waitForRoster(_converse, 'current');
  588. await mock.openControlBox(_converse);
  589. // See XEP-0085 https://xmpp.org/extensions/xep-0085.html#definitions
  590. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  591. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  592. await mock.openChatBoxFor(_converse, sender_jid);
  593. // <composing> state
  594. let msg = $msg({
  595. from: sender_jid,
  596. to: _converse.connection.jid,
  597. type: 'chat',
  598. id: u.getUniqueId()
  599. }).c('composing', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  600. _converse.connection._dataRecv(mock.createRequest(msg));
  601. const view = _converse.chatboxviews.get(sender_jid);
  602. let csn = mock.cur_names[1] + ' is typing';
  603. await u.waitUntil( () => view.el.querySelector('.chat-content__notifications').innerText === csn);
  604. expect(view.model.messages.length).toEqual(0);
  605. // <paused> state
  606. msg = $msg({
  607. from: sender_jid,
  608. to: _converse.connection.jid,
  609. type: 'chat',
  610. id: u.getUniqueId()
  611. }).c('paused', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  612. _converse.connection._dataRecv(mock.createRequest(msg));
  613. csn = mock.cur_names[1] + ' has stopped typing';
  614. await u.waitUntil( () => view.el.querySelector('.chat-content__notifications').innerText === csn);
  615. msg = $msg({
  616. from: sender_jid,
  617. to: _converse.connection.jid,
  618. type: 'chat',
  619. id: u.getUniqueId()
  620. }).c('body').t('hello world').tree();
  621. await _converse.handleMessageStanza(msg);
  622. const msg_el = await u.waitUntil(() => view.content.querySelector('.chat-msg'));
  623. await u.waitUntil( () => view.el.querySelector('.chat-content__notifications').innerText === '');
  624. expect(msg_el.querySelector('.chat-msg__text').textContent).toBe('hello world');
  625. done();
  626. }));
  627. it("is ignored if it's a composing carbon message sent by this user from a different client",
  628. mock.initConverse(
  629. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  630. async function (done, _converse) {
  631. await mock.waitUntilDiscoConfirmed(_converse, 'montague.lit', [], ['vcard-temp']);
  632. await u.waitUntil(() => _converse.xmppstatus.vcard.get('fullname'));
  633. await mock.waitForRoster(_converse, 'current');
  634. // Send a message from a different resource
  635. const recipient_jid = mock.cur_names[5].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  636. const view = await mock.openChatBoxFor(_converse, recipient_jid);
  637. spyOn(u, 'shouldCreateMessage').and.callThrough();
  638. const msg = $msg({
  639. 'from': _converse.bare_jid,
  640. 'id': u.getUniqueId(),
  641. 'to': _converse.connection.jid,
  642. 'type': 'chat',
  643. 'xmlns': 'jabber:client'
  644. }).c('sent', {'xmlns': 'urn:xmpp:carbons:2'})
  645. .c('forwarded', {'xmlns': 'urn:xmpp:forward:0'})
  646. .c('message', {
  647. 'xmlns': 'jabber:client',
  648. 'from': _converse.bare_jid+'/another-resource',
  649. 'to': recipient_jid,
  650. 'type': 'chat'
  651. }).c('composing', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  652. _converse.connection._dataRecv(mock.createRequest(msg));
  653. await u.waitUntil(() => u.shouldCreateMessage.calls.count());
  654. expect(view.model.messages.length).toEqual(0);
  655. const el = view.el.querySelector('.chat-content__notifications');
  656. expect(el.textContent).toBe('');
  657. done();
  658. }));
  659. });
  660. describe("A paused notification", function () {
  661. it("is sent if the user has stopped typing since 30 seconds",
  662. mock.initConverse(
  663. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  664. async function (done, _converse) {
  665. await mock.waitForRoster(_converse, 'current');
  666. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  667. await mock.openControlBox(_converse);
  668. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group li').length, 700);
  669. _converse.TIMEOUTS.PAUSED = 200; // Make the timeout shorter so that we can test
  670. await mock.openChatBoxFor(_converse, contact_jid);
  671. const view = _converse.chatboxviews.get(contact_jid);
  672. spyOn(_converse.connection, 'send');
  673. spyOn(view.model, 'setChatState').and.callThrough();
  674. expect(view.model.get('chat_state')).toBe('active');
  675. view.onKeyDown({
  676. target: view.el.querySelector('textarea.chat-textarea'),
  677. keyCode: 1
  678. });
  679. expect(view.model.get('chat_state')).toBe('composing');
  680. expect(_converse.connection.send).toHaveBeenCalled();
  681. let stanza = _converse.connection.send.calls.argsFor(0)[0].tree();
  682. expect(stanza.childNodes[0].tagName).toBe('composing');
  683. await u.waitUntil(() => view.model.get('chat_state') === 'paused', 500);
  684. expect(_converse.connection.send).toHaveBeenCalled();
  685. var calls = _.filter(_converse.connection.send.calls.all(), function (call) {
  686. return call.args[0] instanceof Strophe.Builder;
  687. });
  688. expect(calls.length).toBe(2);
  689. stanza = calls[1].args[0].tree();
  690. expect(stanza.getAttribute('to')).toBe(contact_jid);
  691. expect(stanza.childNodes.length).toBe(3);
  692. expect(stanza.childNodes[0].tagName).toBe('paused');
  693. expect(stanza.childNodes[1].tagName).toBe('no-store');
  694. expect(stanza.childNodes[2].tagName).toBe('no-permanent-store');
  695. // Test #359. A paused notification should not be sent
  696. // out if the user simply types longer than the
  697. // timeout.
  698. view.onKeyDown({
  699. target: view.el.querySelector('textarea.chat-textarea'),
  700. keyCode: 1
  701. });
  702. expect(view.model.setChatState).toHaveBeenCalled();
  703. expect(view.model.get('chat_state')).toBe('composing');
  704. view.onKeyDown({
  705. target: view.el.querySelector('textarea.chat-textarea'),
  706. keyCode: 1
  707. });
  708. expect(view.model.get('chat_state')).toBe('composing');
  709. done();
  710. }));
  711. it("will be shown if received",
  712. mock.initConverse(
  713. ['rosterGroupsFetched'], {},
  714. async function (done, _converse) {
  715. await mock.waitForRoster(_converse, 'current');
  716. await mock.openControlBox(_converse);
  717. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  718. // TODO: only show paused state if the previous state was composing
  719. // See XEP-0085 https://xmpp.org/extensions/xep-0085.html#definitions
  720. spyOn(_converse.api, "trigger").and.callThrough();
  721. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  722. const view = await mock.openChatBoxFor(_converse, sender_jid);
  723. // <paused> state
  724. const msg = $msg({
  725. from: sender_jid,
  726. to: _converse.connection.jid,
  727. type: 'chat',
  728. id: u.getUniqueId()
  729. }).c('paused', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  730. _converse.connection._dataRecv(mock.createRequest(msg));
  731. const csn = mock.cur_names[1] + ' has stopped typing';
  732. await u.waitUntil( () => view.el.querySelector('.chat-content__notifications').innerText === csn);
  733. expect(view.model.messages.length).toEqual(0);
  734. done();
  735. }));
  736. it("will not be shown if it's a paused carbon message that this user sent from a different client",
  737. mock.initConverse(
  738. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  739. async function (done, _converse) {
  740. await mock.waitUntilDiscoConfirmed(_converse, 'montague.lit', [], ['vcard-temp']);
  741. await u.waitUntil(() => _converse.xmppstatus.vcard.get('fullname'));
  742. await mock.waitForRoster(_converse, 'current');
  743. // Send a message from a different resource
  744. const recipient_jid = mock.cur_names[5].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  745. spyOn(u, 'shouldCreateMessage').and.callThrough();
  746. const view = await mock.openChatBoxFor(_converse, recipient_jid);
  747. const msg = $msg({
  748. 'from': _converse.bare_jid,
  749. 'id': u.getUniqueId(),
  750. 'to': _converse.connection.jid,
  751. 'type': 'chat',
  752. 'xmlns': 'jabber:client'
  753. }).c('sent', {'xmlns': 'urn:xmpp:carbons:2'})
  754. .c('forwarded', {'xmlns': 'urn:xmpp:forward:0'})
  755. .c('message', {
  756. 'xmlns': 'jabber:client',
  757. 'from': _converse.bare_jid+'/another-resource',
  758. 'to': recipient_jid,
  759. 'type': 'chat'
  760. }).c('paused', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  761. _converse.connection._dataRecv(mock.createRequest(msg));
  762. await u.waitUntil(() => u.shouldCreateMessage.calls.count());
  763. expect(view.model.messages.length).toEqual(0);
  764. const el = view.el.querySelector('.chat-content__notifications');
  765. expect(el.textContent).toBe('');
  766. done();
  767. done();
  768. }));
  769. });
  770. describe("An inactive notification", function () {
  771. it("is sent if the user has stopped typing since 2 minutes",
  772. mock.initConverse(
  773. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  774. async function (done, _converse) {
  775. const sent_stanzas = _converse.connection.sent_stanzas;
  776. // Make the timeouts shorter so that we can test
  777. _converse.TIMEOUTS.PAUSED = 100;
  778. _converse.TIMEOUTS.INACTIVE = 100;
  779. await mock.waitForRoster(_converse, 'current');
  780. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  781. await mock.openControlBox(_converse);
  782. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 1000);
  783. await mock.openChatBoxFor(_converse, contact_jid);
  784. const view = _converse.chatboxviews.get(contact_jid);
  785. await u.waitUntil(() => view.model.get('chat_state') === 'active');
  786. let messages = await u.waitUntil(() => sent_stanzas.filter(s => s.matches('message')));
  787. expect(messages.length).toBe(1);
  788. expect(view.model.get('chat_state')).toBe('active');
  789. view.onKeyDown({
  790. target: view.el.querySelector('textarea.chat-textarea'),
  791. keyCode: 1
  792. });
  793. await u.waitUntil(() => view.model.get('chat_state') === 'composing', 600);
  794. messages = sent_stanzas.filter(s => s.matches('message'));
  795. expect(messages.length).toBe(2);
  796. await u.waitUntil(() => view.model.get('chat_state') === 'paused', 600);
  797. messages = sent_stanzas.filter(s => s.matches('message'));
  798. expect(messages.length).toBe(3);
  799. await u.waitUntil(() => view.model.get('chat_state') === 'inactive', 600);
  800. messages = sent_stanzas.filter(s => s.matches('message'));
  801. expect(messages.length).toBe(4);
  802. expect(Strophe.serialize(messages[0])).toBe(
  803. `<message id="${messages[0].getAttribute('id')}" to="mercutio@montague.lit" type="chat" xmlns="jabber:client">`+
  804. `<active xmlns="http://jabber.org/protocol/chatstates"/>`+
  805. `<no-store xmlns="urn:xmpp:hints"/>`+
  806. `<no-permanent-store xmlns="urn:xmpp:hints"/>`+
  807. `</message>`);
  808. expect(Strophe.serialize(messages[1])).toBe(
  809. `<message id="${messages[1].getAttribute('id')}" to="mercutio@montague.lit" type="chat" xmlns="jabber:client">`+
  810. `<composing xmlns="http://jabber.org/protocol/chatstates"/>`+
  811. `<no-store xmlns="urn:xmpp:hints"/>`+
  812. `<no-permanent-store xmlns="urn:xmpp:hints"/>`+
  813. `</message>`);
  814. expect(Strophe.serialize(messages[2])).toBe(
  815. `<message id="${messages[2].getAttribute('id')}" to="mercutio@montague.lit" type="chat" xmlns="jabber:client">`+
  816. `<paused xmlns="http://jabber.org/protocol/chatstates"/>`+
  817. `<no-store xmlns="urn:xmpp:hints"/>`+
  818. `<no-permanent-store xmlns="urn:xmpp:hints"/>`+
  819. `</message>`);
  820. expect(Strophe.serialize(messages[3])).toBe(
  821. `<message id="${messages[3].getAttribute('id')}" to="mercutio@montague.lit" type="chat" xmlns="jabber:client">`+
  822. `<inactive xmlns="http://jabber.org/protocol/chatstates"/>`+
  823. `<no-store xmlns="urn:xmpp:hints"/>`+
  824. `<no-permanent-store xmlns="urn:xmpp:hints"/>`+
  825. `</message>`);
  826. done();
  827. }));
  828. it("is sent when the user a minimizes a chat box",
  829. mock.initConverse(
  830. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  831. async function (done, _converse) {
  832. await mock.waitForRoster(_converse, 'current');
  833. await mock.openControlBox(_converse);
  834. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  835. await mock.openChatBoxFor(_converse, contact_jid);
  836. const view = _converse.chatboxviews.get(contact_jid);
  837. spyOn(_converse.connection, 'send');
  838. view.minimize();
  839. expect(view.model.get('chat_state')).toBe('inactive');
  840. expect(_converse.connection.send).toHaveBeenCalled();
  841. var stanza = _converse.connection.send.calls.argsFor(0)[0].tree();
  842. expect(stanza.getAttribute('to')).toBe(contact_jid);
  843. expect(stanza.childNodes[0].tagName).toBe('inactive');
  844. done();
  845. }));
  846. it("is sent if the user closes a chat box",
  847. mock.initConverse(
  848. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  849. async function (done, _converse) {
  850. await mock.waitForRoster(_converse, 'current');
  851. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  852. await mock.openControlBox(_converse);
  853. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  854. const view = await mock.openChatBoxFor(_converse, contact_jid);
  855. expect(view.model.get('chat_state')).toBe('active');
  856. spyOn(_converse.connection, 'send');
  857. view.close();
  858. expect(view.model.get('chat_state')).toBe('inactive');
  859. expect(_converse.connection.send).toHaveBeenCalled();
  860. const stanza = _converse.connection.send.calls.argsFor(0)[0].tree();
  861. expect(stanza.getAttribute('to')).toBe(contact_jid);
  862. expect(stanza.childNodes.length).toBe(3);
  863. expect(stanza.childNodes[0].tagName).toBe('inactive');
  864. expect(stanza.childNodes[1].tagName).toBe('no-store');
  865. expect(stanza.childNodes[2].tagName).toBe('no-permanent-store');
  866. done();
  867. }));
  868. it("will clear any other chat status notifications",
  869. mock.initConverse(
  870. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  871. async function (done, _converse) {
  872. await mock.waitForRoster(_converse, 'current');
  873. await mock.openControlBox(_converse);
  874. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  875. // See XEP-0085 https://xmpp.org/extensions/xep-0085.html#definitions
  876. await mock.openChatBoxFor(_converse, sender_jid);
  877. const view = _converse.chatboxviews.get(sender_jid);
  878. expect(view.el.querySelectorAll('.chat-event').length).toBe(0);
  879. // Insert <composing> message, to also check that
  880. // text messages are inserted correctly with
  881. // temporary chat events in the chat contents.
  882. let msg = $msg({
  883. 'to': _converse.bare_jid,
  884. 'xmlns': 'jabber:client',
  885. 'from': sender_jid,
  886. 'type': 'chat'})
  887. .c('composing', {'xmlns': Strophe.NS.CHATSTATES}).up()
  888. .tree();
  889. _converse.connection._dataRecv(mock.createRequest(msg));
  890. const csntext = await u.waitUntil(() => view.el.querySelector('.chat-content__notifications').textContent);
  891. expect(csntext).toEqual(mock.cur_names[1] + ' is typing');
  892. expect(view.model.messages.length).toBe(0);
  893. msg = $msg({
  894. from: sender_jid,
  895. to: _converse.connection.jid,
  896. type: 'chat',
  897. id: u.getUniqueId()
  898. }).c('inactive', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  899. _converse.connection._dataRecv(mock.createRequest(msg));
  900. await u.waitUntil(() => !view.el.querySelector('.chat-content__notifications').textContent);
  901. done();
  902. }));
  903. });
  904. describe("A gone notification", function () {
  905. it("will be shown if received",
  906. mock.initConverse(
  907. ['rosterGroupsFetched'], {},
  908. async function (done, _converse) {
  909. await mock.waitForRoster(_converse, 'current', 3);
  910. await mock.openControlBox(_converse);
  911. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  912. await mock.openChatBoxFor(_converse, sender_jid);
  913. const msg = $msg({
  914. from: sender_jid,
  915. to: _converse.connection.jid,
  916. type: 'chat',
  917. id: u.getUniqueId()
  918. }).c('body').c('gone', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  919. _converse.connection._dataRecv(mock.createRequest(msg));
  920. const view = _converse.chatboxviews.get(sender_jid);
  921. const csntext = await u.waitUntil(() => view.el.querySelector('.chat-content__notifications').textContent);
  922. expect(csntext).toEqual(mock.cur_names[1] + ' has gone away');
  923. done();
  924. }));
  925. });
  926. describe("On receiving a message correction", function () {
  927. it("will be removed",
  928. mock.initConverse(
  929. ['rosterGroupsFetched'], {},
  930. async function (done, _converse) {
  931. await mock.waitForRoster(_converse, 'current');
  932. await mock.openControlBox(_converse);
  933. // See XEP-0085 https://xmpp.org/extensions/xep-0085.html#definitions
  934. const sender_jid = mock.cur_names[1].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  935. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length);
  936. await mock.openChatBoxFor(_converse, sender_jid);
  937. // Original message
  938. const original_id = u.getUniqueId();
  939. const original = $msg({
  940. from: sender_jid,
  941. to: _converse.connection.jid,
  942. type: 'chat',
  943. id: original_id,
  944. body: "Original message",
  945. }).c('active', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  946. spyOn(_converse.api, "trigger").and.callThrough();
  947. _converse.connection._dataRecv(mock.createRequest(original));
  948. await u.waitUntil(() => _converse.api.trigger.calls.count());
  949. expect(_converse.api.trigger).toHaveBeenCalledWith('message', jasmine.any(Object));
  950. const view = _converse.chatboxviews.get(sender_jid);
  951. expect(view).toBeDefined();
  952. // <composing> state
  953. const msg = $msg({
  954. from: sender_jid,
  955. to: _converse.connection.jid,
  956. type: 'chat',
  957. id: u.getUniqueId()
  958. }).c('composing', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  959. _converse.connection._dataRecv(mock.createRequest(msg));
  960. const csntext = await u.waitUntil(() => view.el.querySelector('.chat-content__notifications').textContent);
  961. expect(csntext).toEqual(mock.cur_names[1] + ' is typing');
  962. // Edited message
  963. const edited = $msg({
  964. from: sender_jid,
  965. to: _converse.connection.jid,
  966. type: 'chat',
  967. id: u.getUniqueId(),
  968. body: "Edited message",
  969. })
  970. .c('active', {'xmlns': Strophe.NS.CHATSTATES}).up()
  971. .c('replace', {'xmlns': Strophe.NS.MESSAGE_CORRECT, 'id': original_id }).tree();
  972. await _converse.handleMessageStanza(edited);
  973. await u.waitUntil(() => !view.el.querySelector('.chat-content__notifications').textContent);
  974. done();
  975. }));
  976. });
  977. });
  978. });
  979. describe("Special Messages", function () {
  980. it("'/clear' can be used to clear messages in a conversation",
  981. mock.initConverse(
  982. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  983. async function (done, _converse) {
  984. await mock.waitForRoster(_converse, 'current');
  985. await mock.openControlBox(_converse);
  986. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  987. spyOn(_converse.api, "trigger").and.callThrough();
  988. await mock.openChatBoxFor(_converse, contact_jid);
  989. const view = _converse.chatboxviews.get(contact_jid);
  990. let message = 'This message is another sent from this chatbox';
  991. await mock.sendMessage(view, message);
  992. expect(view.model.messages.length === 1).toBeTruthy();
  993. let stored_messages = await view.model.messages.browserStorage.findAll();
  994. expect(stored_messages.length).toBe(1);
  995. await u.waitUntil(() => view.el.querySelector('.chat-msg'));
  996. message = '/clear';
  997. spyOn(view, 'clearMessages').and.callThrough();
  998. spyOn(window, 'confirm').and.callFake(function () {
  999. return true;
  1000. });
  1001. view.el.querySelector('.chat-textarea').value = message;
  1002. view.onKeyDown({
  1003. target: view.el.querySelector('textarea.chat-textarea'),
  1004. preventDefault: function preventDefault () {},
  1005. keyCode: 13
  1006. });
  1007. expect(view.clearMessages.calls.all().length).toBe(1);
  1008. await view.clearMessages.calls.all()[0].returnValue;
  1009. expect(window.confirm).toHaveBeenCalled();
  1010. expect(view.model.messages.length, 0); // The messages must be removed from the chatbox
  1011. stored_messages = await view.model.messages.browserStorage.findAll();
  1012. expect(stored_messages.length).toBe(0);
  1013. expect(_converse.api.trigger.calls.count(), 1);
  1014. expect(_converse.api.trigger.calls.mostRecent().args, ['messageSend', message]);
  1015. done();
  1016. }));
  1017. });
  1018. describe("A Message Counter", function () {
  1019. it("is incremented when the message is received and the window is not focused",
  1020. mock.initConverse(
  1021. ['rosterGroupsFetched'], {},
  1022. async function (done, _converse) {
  1023. await mock.waitForRoster(_converse, 'current');
  1024. await mock.openControlBox(_converse);
  1025. expect(document.title).toBe('Converse Tests');
  1026. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1027. const previous_state = _converse.windowState;
  1028. const message = 'This message will increment the message counter';
  1029. const msg = $msg({
  1030. from: sender_jid,
  1031. to: _converse.connection.jid,
  1032. type: 'chat',
  1033. id: u.getUniqueId()
  1034. }).c('body').t(message).up()
  1035. .c('active', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  1036. _converse.windowState = 'hidden';
  1037. spyOn(_converse.api, "trigger").and.callThrough();
  1038. spyOn(_converse, 'incrementMsgCounter').and.callThrough();
  1039. spyOn(_converse, 'clearMsgCounter').and.callThrough();
  1040. await _converse.handleMessageStanza(msg);
  1041. expect(_converse.incrementMsgCounter).toHaveBeenCalled();
  1042. expect(_converse.clearMsgCounter).not.toHaveBeenCalled();
  1043. expect(document.title).toBe('Messages (1) Converse Tests');
  1044. expect(_converse.api.trigger).toHaveBeenCalledWith('message', jasmine.any(Object));
  1045. _converse.windowSate = previous_state;
  1046. done();
  1047. }));
  1048. it("is cleared when the window is focused",
  1049. mock.initConverse(
  1050. ['rosterGroupsFetched'], {},
  1051. async function (done, _converse) {
  1052. await mock.waitForRoster(_converse, 'current');
  1053. await mock.openControlBox(_converse);
  1054. _converse.windowState = 'hidden';
  1055. spyOn(_converse, 'clearMsgCounter').and.callThrough();
  1056. _converse.saveWindowState(null, 'focus');
  1057. _converse.saveWindowState(null, 'blur');
  1058. expect(_converse.clearMsgCounter).toHaveBeenCalled();
  1059. done();
  1060. }));
  1061. it("is not incremented when the message is received and the window is focused",
  1062. mock.initConverse(
  1063. ['rosterGroupsFetched'], {},
  1064. async function (done, _converse) {
  1065. await mock.waitForRoster(_converse, 'current');
  1066. await mock.openControlBox(_converse);
  1067. expect(document.title).toBe('Converse Tests');
  1068. spyOn(_converse, 'incrementMsgCounter').and.callThrough();
  1069. _converse.saveWindowState(null, 'focus');
  1070. const message = 'This message will not increment the message counter';
  1071. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit',
  1072. msg = $msg({
  1073. from: sender_jid,
  1074. to: _converse.connection.jid,
  1075. type: 'chat',
  1076. id: u.getUniqueId()
  1077. }).c('body').t(message).up()
  1078. .c('active', {'xmlns': Strophe.NS.CHATSTATES}).tree();
  1079. await _converse.handleMessageStanza(msg);
  1080. expect(_converse.incrementMsgCounter).not.toHaveBeenCalled();
  1081. expect(document.title).toBe('Converse Tests');
  1082. done();
  1083. }));
  1084. it("is incremented from zero when chatbox was closed after viewing previously received messages and the window is not focused now",
  1085. mock.initConverse(
  1086. ['rosterGroupsFetched'], {},
  1087. async function (done, _converse) {
  1088. await mock.waitForRoster(_converse, 'current');
  1089. // initial state
  1090. expect(document.title).toBe('Converse Tests');
  1091. const message = 'This message will always increment the message counter from zero',
  1092. sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit',
  1093. msgFactory = function () {
  1094. return $msg({
  1095. from: sender_jid,
  1096. to: _converse.connection.jid,
  1097. type: 'chat',
  1098. id: u.getUniqueId()
  1099. })
  1100. .c('body').t(message).up()
  1101. .c('active', {'xmlns': Strophe.NS.CHATSTATES})
  1102. .tree();
  1103. };
  1104. // leave converse-chat page
  1105. _converse.windowState = 'hidden';
  1106. await _converse.handleMessageStanza(msgFactory());
  1107. let view = _converse.chatboxviews.get(sender_jid);
  1108. expect(document.title).toBe('Messages (1) Converse Tests');
  1109. // come back to converse-chat page
  1110. _converse.saveWindowState(null, 'focus');
  1111. await u.waitUntil(() => u.isVisible(view.el));
  1112. expect(document.title).toBe('Converse Tests');
  1113. // close chatbox and leave converse-chat page again
  1114. view.close();
  1115. _converse.windowState = 'hidden';
  1116. // check that msg_counter is incremented from zero again
  1117. await _converse.handleMessageStanza(msgFactory());
  1118. view = _converse.chatboxviews.get(sender_jid);
  1119. await u.waitUntil(() => u.isVisible(view.el));
  1120. expect(document.title).toBe('Messages (1) Converse Tests');
  1121. done();
  1122. }));
  1123. });
  1124. describe("A ChatBox's Unread Message Count", function () {
  1125. it("is incremented when the message is received and ChatBoxView is scrolled up",
  1126. mock.initConverse(
  1127. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1128. async function (done, _converse) {
  1129. await mock.waitForRoster(_converse, 'current', 1);
  1130. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit',
  1131. msg = mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1132. const sent_stanzas = [];
  1133. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1134. const view = await mock.openChatBoxFor(_converse, sender_jid)
  1135. spyOn(view.model, 'sendMarker').and.callThrough();
  1136. view.model.save('scrolled', true);
  1137. await _converse.handleMessageStanza(msg);
  1138. await u.waitUntil(() => view.model.messages.length);
  1139. expect(view.model.get('num_unread')).toBe(1);
  1140. const msgid = view.model.messages.last().get('id');
  1141. expect(view.model.get('first_unread_id')).toBe(msgid);
  1142. await u.waitUntil(() => view.model.sendMarker.calls.count() === 1);
  1143. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1144. done();
  1145. }));
  1146. it("is not incremented when the message is received and ChatBoxView is scrolled down",
  1147. mock.initConverse(
  1148. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1149. async function (done, _converse) {
  1150. await mock.waitForRoster(_converse, 'current', 1);
  1151. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1152. const msg = mock.createChatMessage(_converse, sender_jid, 'This message will be read');
  1153. const sent_stanzas = [];
  1154. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1155. await mock.openChatBoxFor(_converse, sender_jid);
  1156. const chatbox = _converse.chatboxes.get(sender_jid);
  1157. spyOn(chatbox, 'sendMarker').and.callThrough();
  1158. await _converse.handleMessageStanza(msg);
  1159. expect(chatbox.get('num_unread')).toBe(0);
  1160. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 2);
  1161. expect(sent_stanzas[1].nodeTree.querySelector('displayed')).toBeDefined();
  1162. done();
  1163. }));
  1164. it("is incremented when message is received, chatbox is scrolled down and the window is not focused",
  1165. mock.initConverse(['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1166. async function (done, _converse) {
  1167. await mock.waitForRoster(_converse, 'current');
  1168. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1169. const msgFactory = function () {
  1170. return mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1171. };
  1172. const sent_stanzas = [];
  1173. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1174. await mock.openChatBoxFor(_converse, sender_jid);
  1175. const chatbox = _converse.chatboxes.get(sender_jid);
  1176. spyOn(chatbox, 'sendMarker').and.callThrough();
  1177. _converse.windowState = 'hidden';
  1178. const msg = msgFactory();
  1179. _converse.handleMessageStanza(msg);
  1180. await u.waitUntil(() => chatbox.messages.length);
  1181. expect(chatbox.get('num_unread')).toBe(1);
  1182. const msgid = chatbox.messages.last().get('id');
  1183. expect(chatbox.get('first_unread_id')).toBe(msgid);
  1184. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 1);
  1185. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1186. done();
  1187. }));
  1188. it("is incremented when message is received, chatbox is scrolled up and the window is not focused",
  1189. mock.initConverse(
  1190. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1191. async function (done, _converse) {
  1192. await mock.waitForRoster(_converse, 'current', 1);
  1193. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1194. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1195. const sent_stanzas = [];
  1196. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1197. await mock.openChatBoxFor(_converse, sender_jid);
  1198. const chatbox = _converse.chatboxes.get(sender_jid);
  1199. spyOn(chatbox, 'sendMarker').and.callThrough();
  1200. chatbox.save('scrolled', true);
  1201. _converse.windowState = 'hidden';
  1202. const msg = msgFactory();
  1203. _converse.handleMessageStanza(msg);
  1204. await u.waitUntil(() => chatbox.messages.length);
  1205. expect(chatbox.get('num_unread')).toBe(1);
  1206. const msgid = chatbox.messages.last().get('id');
  1207. expect(chatbox.get('first_unread_id')).toBe(msgid);
  1208. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 1);
  1209. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1210. done();
  1211. }));
  1212. it("is cleared when ChatBoxView was scrolled down and the window become focused",
  1213. mock.initConverse(
  1214. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1215. async function (done, _converse) {
  1216. await mock.waitForRoster(_converse, 'current', 1);
  1217. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1218. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1219. const sent_stanzas = [];
  1220. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1221. await mock.openChatBoxFor(_converse, sender_jid);
  1222. const chatbox = _converse.chatboxes.get(sender_jid);
  1223. spyOn(chatbox, 'sendMarker').and.callThrough();
  1224. _converse.windowState = 'hidden';
  1225. const msg = msgFactory();
  1226. _converse.handleMessageStanza(msg);
  1227. await u.waitUntil(() => chatbox.messages.length);
  1228. expect(chatbox.get('num_unread')).toBe(1);
  1229. const msgid = chatbox.messages.last().get('id');
  1230. expect(chatbox.get('first_unread_id')).toBe(msgid);
  1231. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 1);
  1232. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1233. _converse.saveWindowState(null, 'focus');
  1234. expect(chatbox.get('num_unread')).toBe(0);
  1235. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 2);
  1236. expect(sent_stanzas[1].nodeTree.querySelector('displayed')).toBeDefined();
  1237. done();
  1238. }));
  1239. it("is not cleared when ChatBoxView was scrolled up and the windows become focused",
  1240. mock.initConverse(
  1241. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1242. async function (done, _converse) {
  1243. await mock.waitForRoster(_converse, 'current', 1);
  1244. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1245. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1246. const sent_stanzas = [];
  1247. spyOn(_converse.connection, 'send').and.callFake(s => sent_stanzas.push(s));
  1248. await mock.openChatBoxFor(_converse, sender_jid);
  1249. const chatbox = _converse.chatboxes.get(sender_jid);
  1250. spyOn(chatbox, 'sendMarker').and.callThrough();
  1251. chatbox.save('scrolled', true);
  1252. _converse.windowState = 'hidden';
  1253. const msg = msgFactory();
  1254. _converse.handleMessageStanza(msg);
  1255. await u.waitUntil(() => chatbox.messages.length);
  1256. expect(chatbox.get('num_unread')).toBe(1);
  1257. const msgid = chatbox.messages.last().get('id');
  1258. expect(chatbox.get('first_unread_id')).toBe(msgid);
  1259. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 1);
  1260. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1261. _converse.saveWindowState(null, 'focus');
  1262. await u.waitUntil(() => chatbox.get('num_unread') === 1);
  1263. expect(chatbox.get('first_unread_id')).toBe(msgid);
  1264. await u.waitUntil(() => chatbox.sendMarker.calls.count() === 1);
  1265. expect(sent_stanzas[0].nodeTree.querySelector('received')).toBeDefined();
  1266. done();
  1267. }));
  1268. });
  1269. describe("A RosterView's Unread Message Count", function () {
  1270. it("is updated when message is received and chatbox is scrolled up",
  1271. mock.initConverse(
  1272. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1273. async function (done, _converse) {
  1274. await mock.waitForRoster(_converse, 'current', 1);
  1275. let msg, indicator_el;
  1276. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1277. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 500);
  1278. await mock.openChatBoxFor(_converse, sender_jid);
  1279. const chatbox = _converse.chatboxes.get(sender_jid);
  1280. chatbox.save('scrolled', true);
  1281. msg = mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1282. await _converse.handleMessageStanza(msg);
  1283. await u.waitUntil(() => chatbox.messages.length);
  1284. const selector = 'a.open-chat:contains("' + chatbox.get('nickname') + '") .msgs-indicator';
  1285. indicator_el = sizzle(selector, _converse.rosterview.el).pop();
  1286. expect(indicator_el.textContent).toBe('1');
  1287. msg = mock.createChatMessage(_converse, sender_jid, 'This message will be unread too');
  1288. await _converse.handleMessageStanza(msg);
  1289. await u.waitUntil(() => chatbox.messages.length > 1);
  1290. indicator_el = sizzle(selector, _converse.rosterview.el).pop();
  1291. expect(indicator_el.textContent).toBe('2');
  1292. done();
  1293. }));
  1294. it("is updated when message is received and chatbox is minimized",
  1295. mock.initConverse(
  1296. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1297. async function (done, _converse) {
  1298. await mock.waitForRoster(_converse, 'current', 1);
  1299. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1300. let indicator_el, msg;
  1301. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 500);
  1302. await mock.openChatBoxFor(_converse, sender_jid);
  1303. const chatbox = _converse.chatboxes.get(sender_jid);
  1304. var chatboxview = _converse.chatboxviews.get(sender_jid);
  1305. chatboxview.minimize();
  1306. msg = mock.createChatMessage(_converse, sender_jid, 'This message will be unread');
  1307. await _converse.handleMessageStanza(msg);
  1308. await u.waitUntil(() => chatbox.messages.length);
  1309. const selector = 'a.open-chat:contains("' + chatbox.get('nickname') + '") .msgs-indicator';
  1310. indicator_el = sizzle(selector, _converse.rosterview.el).pop();
  1311. expect(indicator_el.textContent).toBe('1');
  1312. msg = mock.createChatMessage(_converse, sender_jid, 'This message will be unread too');
  1313. await _converse.handleMessageStanza(msg);
  1314. await u.waitUntil(() => chatbox.messages.length === 2);
  1315. indicator_el = sizzle(selector, _converse.rosterview.el).pop();
  1316. expect(indicator_el.textContent).toBe('2');
  1317. done();
  1318. }));
  1319. it("is cleared when chatbox is maximzied after receiving messages in minimized mode",
  1320. mock.initConverse(
  1321. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1322. async function (done, _converse) {
  1323. await mock.waitForRoster(_converse, 'current', 1);
  1324. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1325. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, 'This message will be received as unread, but eventually will be read');
  1326. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 500);
  1327. await mock.openChatBoxFor(_converse, sender_jid);
  1328. const chatbox = _converse.chatboxes.get(sender_jid);
  1329. const view = _converse.chatboxviews.get(sender_jid);
  1330. const selector = 'a.open-chat:contains("' + chatbox.get('nickname') + '") .msgs-indicator';
  1331. const select_msgs_indicator = () => sizzle(selector, _converse.rosterview.el).pop();
  1332. view.minimize();
  1333. _converse.handleMessageStanza(msgFactory());
  1334. await u.waitUntil(() => chatbox.messages.length);
  1335. expect(select_msgs_indicator().textContent).toBe('1');
  1336. _converse.handleMessageStanza(msgFactory());
  1337. await u.waitUntil(() => chatbox.messages.length > 1);
  1338. expect(select_msgs_indicator().textContent).toBe('2');
  1339. view.model.maximize();
  1340. u.waitUntil(() => typeof select_msgs_indicator() === 'undefined');
  1341. done();
  1342. }));
  1343. it("is cleared when unread messages are viewed which were received in scrolled-up chatbox",
  1344. mock.initConverse(
  1345. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1346. async function (done, _converse) {
  1347. await mock.openControlBox(_converse);
  1348. await mock.waitForRoster(_converse, 'current', 1);
  1349. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1350. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 500);
  1351. await mock.openChatBoxFor(_converse, sender_jid);
  1352. const chatbox = _converse.chatboxes.get(sender_jid);
  1353. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, 'This message will be received as unread, but eventually will be read');
  1354. const selector = `a.open-chat:contains("${chatbox.get('nickname')}") .msgs-indicator`;
  1355. const select_msgs_indicator = () => sizzle(selector, _converse.rosterview.el).pop();
  1356. chatbox.save('scrolled', true);
  1357. _converse.handleMessageStanza(msgFactory());
  1358. const view = _converse.chatboxviews.get(sender_jid);
  1359. await u.waitUntil(() => view.model.messages.length);
  1360. expect(select_msgs_indicator().textContent).toBe('1');
  1361. view.viewUnreadMessages();
  1362. _converse.rosterview.render();
  1363. expect(select_msgs_indicator()).toBeUndefined();
  1364. done();
  1365. }));
  1366. it("is not cleared after user clicks on roster view when chatbox is already opened and scrolled up",
  1367. mock.initConverse(
  1368. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1369. async function (done, _converse) {
  1370. await mock.waitForRoster(_converse, 'current', 1);
  1371. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1372. await u.waitUntil(() => _converse.rosterview.el.querySelectorAll('.roster-group').length, 500);
  1373. await mock.openChatBoxFor(_converse, sender_jid);
  1374. const chatbox = _converse.chatboxes.get(sender_jid);
  1375. const view = _converse.chatboxviews.get(sender_jid);
  1376. const msg = 'This message will be received as unread, but eventually will be read';
  1377. const msgFactory = () => mock.createChatMessage(_converse, sender_jid, msg);
  1378. const selector = 'a.open-chat:contains("' + chatbox.get('nickname') + '") .msgs-indicator';
  1379. const select_msgs_indicator = () => sizzle(selector, _converse.rosterview.el).pop();
  1380. chatbox.save('scrolled', true);
  1381. _converse.handleMessageStanza(msgFactory());
  1382. await u.waitUntil(() => view.model.messages.length);
  1383. expect(select_msgs_indicator().textContent).toBe('1');
  1384. await mock.openChatBoxFor(_converse, sender_jid);
  1385. expect(select_msgs_indicator().textContent).toBe('1');
  1386. done();
  1387. }));
  1388. });
  1389. describe("A Minimized ChatBoxView's Unread Message Count", function () {
  1390. it("is displayed when scrolled up chatbox is minimized after receiving unread messages",
  1391. mock.initConverse(
  1392. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1393. async function (done, _converse) {
  1394. await mock.waitForRoster(_converse, 'current', 1);
  1395. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1396. await mock.openChatBoxFor(_converse, sender_jid);
  1397. const msgFactory = function () {
  1398. return mock.createChatMessage(_converse, sender_jid, 'This message will be received as unread, but eventually will be read');
  1399. };
  1400. const selectUnreadMsgCount = function () {
  1401. const minimizedChatBoxView = _converse.minimized_chats.get(sender_jid);
  1402. return minimizedChatBoxView.el.querySelector('.message-count');
  1403. };
  1404. const chatbox = _converse.chatboxes.get(sender_jid);
  1405. chatbox.save('scrolled', true);
  1406. _converse.handleMessageStanza(msgFactory());
  1407. await u.waitUntil(() => chatbox.messages.length);
  1408. const chatboxview = _converse.chatboxviews.get(sender_jid);
  1409. chatboxview.minimize();
  1410. const unread_count = selectUnreadMsgCount();
  1411. expect(u.isVisible(unread_count)).toBeTruthy();
  1412. expect(unread_count.innerHTML).toBe('1');
  1413. done();
  1414. }));
  1415. it("is incremented when message is received and windows is not focused",
  1416. mock.initConverse(
  1417. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1418. async function (done, _converse) {
  1419. await mock.waitForRoster(_converse, 'current', 1);
  1420. const sender_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1421. const view = await mock.openChatBoxFor(_converse, sender_jid)
  1422. const msgFactory = function () {
  1423. return mock.createChatMessage(_converse, sender_jid,
  1424. 'This message will be received as unread, but eventually will be read');
  1425. };
  1426. const selectUnreadMsgCount = function () {
  1427. const minimizedChatBoxView = _converse.minimized_chats.get(sender_jid);
  1428. return minimizedChatBoxView.el.querySelector('.message-count');
  1429. };
  1430. view.minimize();
  1431. _converse.handleMessageStanza(msgFactory());
  1432. await u.waitUntil(() => view.model.messages.length);
  1433. const unread_count = selectUnreadMsgCount();
  1434. expect(u.isVisible(unread_count)).toBeTruthy();
  1435. expect(unread_count.innerHTML).toBe('1');
  1436. done();
  1437. }));
  1438. it("will render Openstreetmap-URL from geo-URI",
  1439. mock.initConverse(
  1440. ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  1441. async function (done, _converse) {
  1442. await mock.waitForRoster(_converse, 'current', 1);
  1443. const message = "geo:37.786971,-122.399677";
  1444. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  1445. await mock.openChatBoxFor(_converse, contact_jid);
  1446. const view = _converse.chatboxviews.get(contact_jid);
  1447. spyOn(view.model, 'sendMessage').and.callThrough();
  1448. mock.sendMessage(view, message);
  1449. await u.waitUntil(() => view.el.querySelectorAll('.chat-content .chat-msg').length, 1000);
  1450. expect(view.model.sendMessage).toHaveBeenCalled();
  1451. const msg = sizzle('.chat-content .chat-msg:last .chat-msg__text', view.el).pop();
  1452. await u.waitUntil(() => msg.innerHTML.replace(/\<!----\>/g, '') ===
  1453. '<a target="_blank" rel="noopener" href="https://www.openstreetmap.org/?mlat=37.786971&amp;'+
  1454. 'mlon=-122.399677#map=18/37.786971/-122.399677">https://www.openstreetmap.org/?mlat=37.786971&amp;mlon=-122.399677#map=18/37.786971/-122.399677</a>');
  1455. done();
  1456. }));
  1457. });
  1458. });