http-file-upload.js 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667
  1. (function (root, factory) {
  2. define([
  3. "jasmine",
  4. "mock",
  5. "test-utils"], factory);
  6. } (this, function (jasmine, mock, test_utils) {
  7. "use strict";
  8. const Strophe = converse.env.Strophe;
  9. const $iq = converse.env.$iq;
  10. const _ = converse.env._;
  11. const sizzle = converse.env.sizzle;
  12. const u = converse.env.utils;
  13. describe("XEP-0363: HTTP File Upload", function () {
  14. describe("Discovering support", function () {
  15. it("is done automatically", mock.initConverse(async (done, _converse) => {
  16. const IQ_stanzas = _converse.connection.IQ_stanzas;
  17. const IQ_ids = _converse.connection.IQ_ids;
  18. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], []);
  19. await u.waitUntil(() => _.filter(
  20. IQ_stanzas,
  21. iq => iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]')).length
  22. );
  23. /* <iq type='result'
  24. * from='plays.shakespeare.lit'
  25. * to='romeo@montague.net/orchard'
  26. * id='info1'>
  27. * <query xmlns='http://jabber.org/protocol/disco#info'>
  28. * <identity
  29. * category='server'
  30. * type='im'/>
  31. * <feature var='http://jabber.org/protocol/disco#info'/>
  32. * <feature var='http://jabber.org/protocol/disco#items'/>
  33. * </query>
  34. * </iq>
  35. */
  36. let stanza = _.find(IQ_stanzas, function (iq) {
  37. return iq.querySelector(
  38. 'iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  39. });
  40. const info_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  41. stanza = $iq({
  42. 'type': 'result',
  43. 'from': 'montague.lit',
  44. 'to': 'romeo@montague.lit/orchard',
  45. 'id': info_IQ_id
  46. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
  47. .c('identity', {
  48. 'category': 'server',
  49. 'type': 'im'}).up()
  50. .c('feature', {
  51. 'var': 'http://jabber.org/protocol/disco#info'}).up()
  52. .c('feature', {
  53. 'var': 'http://jabber.org/protocol/disco#items'});
  54. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  55. let entities = await _converse.api.disco.entities.get();
  56. expect(entities.length).toBe(2);
  57. expect(_.includes(entities.pluck('jid'), 'montague.lit')).toBe(true);
  58. expect(_.includes(entities.pluck('jid'), 'romeo@montague.lit')).toBe(true);
  59. expect(entities.get(_converse.domain).features.length).toBe(2);
  60. expect(entities.get(_converse.domain).identities.length).toBe(1);
  61. // Converse.js sees that the entity has a disco#items feature,
  62. // so it will make a query for it.
  63. await u.waitUntil(() => _.filter(
  64. IQ_stanzas,
  65. iq => iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#items"]')
  66. ).length
  67. );
  68. /* <iq from='montague.tld'
  69. * id='step_01'
  70. * to='romeo@montague.tld/garden'
  71. * type='result'>
  72. * <query xmlns='http://jabber.org/protocol/disco#items'>
  73. * <item jid='upload.montague.tld' name='HTTP File Upload' />
  74. * <item jid='conference.montague.tld' name='Chatroom Service' />
  75. * </query>
  76. * </iq>
  77. */
  78. stanza = _.find(IQ_stanzas, function (iq) {
  79. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#items"]');
  80. });
  81. const items_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  82. stanza = $iq({
  83. 'type': 'result',
  84. 'from': 'montague.lit',
  85. 'to': 'romeo@montague.lit/orchard',
  86. 'id': items_IQ_id
  87. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#items'})
  88. .c('item', {
  89. 'jid': 'upload.montague.lit',
  90. 'name': 'HTTP File Upload'});
  91. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  92. _converse.api.disco.entities.get().then(function (entities) {
  93. expect(entities.length).toBe(2);
  94. expect(entities.get('montague.lit').items.length).toBe(1);
  95. return u.waitUntil(function () {
  96. // Converse.js sees that the entity has a disco#info feature,
  97. // so it will make a query for it.
  98. return _.filter(IQ_stanzas, function (iq) {
  99. return iq.querySelector('iq[to="upload.montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  100. }).length > 0;
  101. }, 300);
  102. });
  103. stanza = await u.waitUntil(() =>
  104. _.filter(
  105. IQ_stanzas,
  106. iq => iq.querySelector('iq[to="upload.montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]')
  107. ).pop()
  108. );
  109. const IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  110. expect(Strophe.serialize(stanza)).toBe(
  111. `<iq from="romeo@montague.lit/orchard" id="`+IQ_id+`" to="upload.montague.lit" type="get" xmlns="jabber:client">`+
  112. `<query xmlns="http://jabber.org/protocol/disco#info"/>`+
  113. `</iq>`);
  114. // Upload service responds and reports a maximum file size of 5MiB
  115. /* <iq from='upload.montague.tld'
  116. * id='step_02'
  117. * to='romeo@montague.tld/garden'
  118. * type='result'>
  119. * <query xmlns='http://jabber.org/protocol/disco#info'>
  120. * <identity category='store'
  121. * type='file'
  122. * name='HTTP File Upload' />
  123. * <feature var='urn:xmpp:http:upload:0' />
  124. * <x type='result' xmlns='jabber:x:data'>
  125. * <field var='FORM_TYPE' type='hidden'>
  126. * <value>urn:xmpp:http:upload:0</value>
  127. * </field>
  128. * <field var='max-file-size'>
  129. * <value>5242880</value>
  130. * </field>
  131. * </x>
  132. * </query>
  133. * </iq>
  134. */
  135. stanza = $iq({'type': 'result', 'to': 'romeo@montague.lit/orchard', 'id': IQ_id, 'from': 'upload.montague.lit'})
  136. .c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
  137. .c('identity', {'category':'store', 'type':'file', 'name':'HTTP File Upload'}).up()
  138. .c('feature', {'var':'urn:xmpp:http:upload:0'}).up()
  139. .c('x', {'type':'result', 'xmlns':'jabber:x:data'})
  140. .c('field', {'var':'FORM_TYPE', 'type':'hidden'})
  141. .c('value').t('urn:xmpp:http:upload:0').up().up()
  142. .c('field', {'var':'max-file-size'})
  143. .c('value').t('5242880');
  144. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  145. entities = await _converse.api.disco.entities.get();
  146. expect(entities.get('montague.lit').items.get('upload.montague.lit').identities.where({'category': 'store'}).length).toBe(1);
  147. const supported = await _converse.api.disco.supports(Strophe.NS.HTTPUPLOAD, _converse.domain);
  148. expect(supported).toBe(true);
  149. const features = await _converse.api.disco.features.get(Strophe.NS.HTTPUPLOAD, _converse.domain);
  150. expect(features.length).toBe(1);
  151. expect(features[0].get('jid')).toBe('upload.montague.lit');
  152. expect(features[0].dataforms.where({'FORM_TYPE': {value: "urn:xmpp:http:upload:0", type: "hidden"}}).length).toBe(1);
  153. done();
  154. }));
  155. });
  156. describe("When not supported", function () {
  157. describe("A file upload toolbar button", function () {
  158. it("does not appear in private chats",
  159. mock.initConverse(
  160. null, ['emojisInitialized'], {},
  161. async function (done, _converse) {
  162. await test_utils.waitForRoster(_converse, 'current', 3);
  163. test_utils.openControlBox();
  164. const contact_jid = mock.cur_names[0].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  165. await test_utils.openChatBoxFor(_converse, contact_jid);
  166. await test_utils.waitUntilDiscoConfirmed(
  167. _converse, _converse.domain,
  168. [{'category': 'server', 'type':'IM'}],
  169. ['http://jabber.org/protocol/disco#items'], [], 'info');
  170. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], [], 'items');
  171. const view = _converse.chatboxviews.get(contact_jid);
  172. expect(view.el.querySelector('.chat-toolbar .upload-file')).toBe(null);
  173. done();
  174. }));
  175. it("does not appear in MUC chats", mock.initConverse(
  176. null, ['rosterGroupsFetched'], {},
  177. async (done, _converse) => {
  178. await test_utils.openAndEnterChatRoom(_converse, 'lounge@montague.lit', 'romeo');
  179. test_utils.waitUntilDiscoConfirmed(
  180. _converse, _converse.domain,
  181. [{'category': 'server', 'type':'IM'}],
  182. ['http://jabber.org/protocol/disco#items'], [], 'info');
  183. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.lit'], 'items');
  184. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.lit', [], [Strophe.NS.HTTPUPLOAD], []);
  185. const view = _converse.chatboxviews.get('lounge@montague.lit');
  186. expect(view.el.querySelector('.chat-toolbar .upload-file')).toBe(null);
  187. done();
  188. }));
  189. });
  190. });
  191. describe("When supported", function () {
  192. describe("A file upload toolbar button", function () {
  193. it("appears in private chats", mock.initConverse(async (done, _converse) => {
  194. await test_utils.waitUntilDiscoConfirmed(
  195. _converse, _converse.domain,
  196. [{'category': 'server', 'type':'IM'}],
  197. ['http://jabber.org/protocol/disco#items'], [], 'info');
  198. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.lit'], 'items')
  199. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.lit', [], [Strophe.NS.HTTPUPLOAD], []);
  200. test_utils.createContacts(_converse, 'current', 3);
  201. _converse.api.trigger('rosterContactsFetched');
  202. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  203. await test_utils.openChatBoxFor(_converse, contact_jid);
  204. const view = _converse.chatboxviews.get(contact_jid);
  205. u.waitUntil(() => view.el.querySelector('.upload-file'));
  206. expect(view.el.querySelector('.chat-toolbar .upload-file')).not.toBe(null);
  207. done();
  208. }));
  209. it("appears in MUC chats", mock.initConverse(
  210. null, ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  211. async (done, _converse) => {
  212. await test_utils.waitUntilDiscoConfirmed(
  213. _converse, _converse.domain,
  214. [{'category': 'server', 'type':'IM'}],
  215. ['http://jabber.org/protocol/disco#items'], [], 'info');
  216. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.lit'], 'items');
  217. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.lit', [], [Strophe.NS.HTTPUPLOAD], []);
  218. await test_utils.openAndEnterChatRoom(_converse, 'lounge@montague.lit', 'romeo');
  219. await u.waitUntil(() => _converse.chatboxviews.get('lounge@montague.lit').el.querySelector('.upload-file'));
  220. const view = _converse.chatboxviews.get('lounge@montague.lit');
  221. expect(view.el.querySelector('.chat-toolbar .upload-file')).not.toBe(null);
  222. done();
  223. }));
  224. describe("when clicked and a file chosen", function () {
  225. it("is uploaded and sent out", mock.initConverse(async (done, _converse) => {
  226. const base_url = 'https://conversejs.org';
  227. await test_utils.waitUntilDiscoConfirmed(
  228. _converse, _converse.domain,
  229. [{'category': 'server', 'type':'IM'}],
  230. ['http://jabber.org/protocol/disco#items'], [], 'info');
  231. const send_backup = XMLHttpRequest.prototype.send;
  232. const IQ_stanzas = _converse.connection.IQ_stanzas;
  233. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
  234. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
  235. test_utils.createContacts(_converse, 'current');
  236. _converse.api.trigger('rosterContactsFetched');
  237. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  238. await test_utils.openChatBoxFor(_converse, contact_jid);
  239. const view = _converse.chatboxviews.get(contact_jid);
  240. const file = {
  241. 'type': 'image/jpeg',
  242. 'size': '23456' ,
  243. 'lastModifiedDate': "",
  244. 'name': "my-juliet.jpg"
  245. };
  246. view.model.sendFiles([file]);
  247. await new Promise((resolve, reject) => view.once('messageInserted', resolve));
  248. await u.waitUntil(() => _.filter(IQ_stanzas, iq => iq.querySelector('iq[to="upload.montague.tld"] request')).length);
  249. const iq = IQ_stanzas.pop();
  250. expect(Strophe.serialize(iq)).toBe(
  251. `<iq from="romeo@montague.lit/orchard" `+
  252. `id="${iq.getAttribute("id")}" `+
  253. `to="upload.montague.tld" `+
  254. `type="get" `+
  255. `xmlns="jabber:client">`+
  256. `<request `+
  257. `content-type="image/jpeg" `+
  258. `filename="my-juliet.jpg" `+
  259. `size="23456" `+
  260. `xmlns="urn:xmpp:http:upload:0"/>`+
  261. `</iq>`);
  262. const message = base_url+"/logo/conversejs-filled.svg";
  263. const stanza = u.toStanza(`
  264. <iq from="upload.montague.tld"
  265. id="${iq.getAttribute("id")}"
  266. to="romeo@montague.lit/orchard"
  267. type="result">
  268. <slot xmlns="urn:xmpp:http:upload:0">
  269. <put url="https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg">
  270. <header name="Authorization">Basic Base64String==</header>
  271. <header name="Cookie">foo=bar; user=romeo</header>
  272. </put>
  273. <get url="${message}" />
  274. </slot>
  275. </iq>`);
  276. spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
  277. const message = view.model.messages.at(0);
  278. expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
  279. message.set('progress', 0.5);
  280. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
  281. .then(() => {
  282. message.set('progress', 1);
  283. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
  284. }).then(() => {
  285. message.save({
  286. 'upload': _converse.SUCCESS,
  287. 'oob_url': message.get('get'),
  288. 'message': message.get('get')
  289. });
  290. return new Promise((resolve, reject) => view.model.messages.once('rendered', resolve));
  291. });
  292. });
  293. let sent_stanza;
  294. spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
  295. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  296. await u.waitUntil(() => sent_stanza, 1000);
  297. expect(sent_stanza.toLocaleString()).toBe(
  298. `<message from="romeo@montague.lit/orchard" `+
  299. `id="${sent_stanza.nodeTree.getAttribute("id")}" `+
  300. `to="lady.montague@montague.lit" `+
  301. `type="chat" `+
  302. `xmlns="jabber:client">`+
  303. `<body>${message}</body>`+
  304. `<active xmlns="http://jabber.org/protocol/chatstates"/>`+
  305. `<request xmlns="urn:xmpp:receipts"/>`+
  306. `<x xmlns="jabber:x:oob">`+
  307. `<url>${message}</url>`+
  308. `</x>`+
  309. `<origin-id id="${sent_stanza.nodeTree.querySelector('origin-id').getAttribute("id")}" xmlns="urn:xmpp:sid:0"/>`+
  310. `</message>`);
  311. await u.waitUntil(() => view.el.querySelector('.chat-image'), 1000);
  312. // Check that the image renders
  313. expect(view.el.querySelector('.chat-msg .chat-msg__media').innerHTML.trim()).toEqual(
  314. `<!-- src/templates/image.html -->\n`+
  315. `<a href="${base_url}/logo/conversejs-filled.svg" target="_blank" rel="noopener">`+
  316. `<img class="chat-image img-thumbnail" src="${base_url}/logo/conversejs-filled.svg">`+
  317. `</a>`);
  318. XMLHttpRequest.prototype.send = send_backup;
  319. done();
  320. }));
  321. it("is uploaded and sent out from a groupchat", mock.initConverse(async (done, _converse) => {
  322. const base_url = 'https://conversejs.org';
  323. await test_utils.waitUntilDiscoConfirmed(
  324. _converse, _converse.domain,
  325. [{'category': 'server', 'type':'IM'}],
  326. ['http://jabber.org/protocol/disco#items'], [], 'info');
  327. const send_backup = XMLHttpRequest.prototype.send;
  328. const IQ_stanzas = _converse.connection.IQ_stanzas;
  329. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
  330. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
  331. await test_utils.openAndEnterChatRoom(_converse, 'lounge@montague.lit', 'romeo');
  332. // Wait until MAM query has been sent out
  333. const sent_stanzas = _converse.connection.sent_stanzas;
  334. await u.waitUntil(() => sent_stanzas.filter(s => sizzle(`[xmlns="${Strophe.NS.MAM}"]`, s).length).pop());
  335. const view = _converse.chatboxviews.get('lounge@montague.lit');
  336. const file = {
  337. 'type': 'image/jpeg',
  338. 'size': '23456' ,
  339. 'lastModifiedDate': "",
  340. 'name': "my-juliet.jpg"
  341. };
  342. view.model.sendFiles([file]);
  343. await new Promise((resolve, reject) => view.once('messageInserted', resolve));
  344. await u.waitUntil(() => _.filter(IQ_stanzas, iq => iq.querySelector('iq[to="upload.montague.tld"] request')).length);
  345. const iq = IQ_stanzas.pop();
  346. expect(Strophe.serialize(iq)).toBe(
  347. `<iq from="romeo@montague.lit/orchard" `+
  348. `id="${iq.getAttribute("id")}" `+
  349. `to="upload.montague.tld" `+
  350. `type="get" `+
  351. `xmlns="jabber:client">`+
  352. `<request `+
  353. `content-type="image/jpeg" `+
  354. `filename="my-juliet.jpg" `+
  355. `size="23456" `+
  356. `xmlns="urn:xmpp:http:upload:0"/>`+
  357. `</iq>`);
  358. const message = base_url+"/logo/conversejs-filled.svg";
  359. const stanza = u.toStanza(`
  360. <iq from='upload.montague.tld'
  361. id="${iq.getAttribute('id')}"
  362. to='romeo@montague.lit/orchard'
  363. type='result'>
  364. <slot xmlns='urn:xmpp:http:upload:0'>
  365. <put url='https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg'>
  366. <header name='Authorization'>Basic Base64String==</header>
  367. <header name='Cookie'>foo=bar; user=romeo</header>
  368. </put>
  369. <get url="${message}" />
  370. </slot>
  371. </iq>`);
  372. spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
  373. const message = view.model.messages.at(0);
  374. expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
  375. message.set('progress', 0.5);
  376. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
  377. .then(() => {
  378. message.set('progress', 1);
  379. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
  380. }).then(() => {
  381. message.save({
  382. 'upload': _converse.SUCCESS,
  383. 'oob_url': message.get('get'),
  384. 'message': message.get('get')
  385. });
  386. return new Promise((resolve, reject) => view.model.messages.once('rendered', resolve));
  387. });
  388. });
  389. let sent_stanza;
  390. spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
  391. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  392. await u.waitUntil(() => sent_stanza, 1000);
  393. expect(sent_stanza.toLocaleString()).toBe(
  394. `<message `+
  395. `from="romeo@montague.lit/orchard" `+
  396. `id="${sent_stanza.nodeTree.getAttribute("id")}" `+
  397. `to="lounge@montague.lit" `+
  398. `type="groupchat" `+
  399. `xmlns="jabber:client">`+
  400. `<body>${message}</body>`+
  401. `<active xmlns="http://jabber.org/protocol/chatstates"/>`+
  402. `<x xmlns="jabber:x:oob">`+
  403. `<url>${message}</url>`+
  404. `</x>`+
  405. `<origin-id id="${sent_stanza.nodeTree.querySelector('origin-id').getAttribute("id")}" xmlns="urn:xmpp:sid:0"/>`+
  406. `</message>`);
  407. await u.waitUntil(() => view.el.querySelector('.chat-image'), 1000);
  408. // Check that the image renders
  409. expect(view.el.querySelector('.chat-msg .chat-msg__media').innerHTML.trim()).toEqual(
  410. `<!-- src/templates/image.html -->\n`+
  411. `<a href="${base_url}/logo/conversejs-filled.svg" target="_blank" rel="noopener">`+
  412. `<img class="chat-image img-thumbnail" src="${base_url}/logo/conversejs-filled.svg">`+
  413. `</a>`);
  414. XMLHttpRequest.prototype.send = send_backup;
  415. done();
  416. }));
  417. it("shows an error message if the file is too large",
  418. mock.initConverse(
  419. null, ['emojisInitialized'], {},
  420. async function (done, _converse) {
  421. const IQ_stanzas = _converse.connection.IQ_stanzas;
  422. const IQ_ids = _converse.connection.IQ_ids;
  423. const send_backup = XMLHttpRequest.prototype.send;
  424. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], []);
  425. await u.waitUntil(() => _.filter(
  426. IQ_stanzas,
  427. iq => iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]')).length
  428. );
  429. let stanza = _.find(IQ_stanzas, function (iq) {
  430. return iq.querySelector(
  431. 'iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  432. });
  433. const info_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  434. stanza = $iq({
  435. 'type': 'result',
  436. 'from': 'montague.lit',
  437. 'to': 'romeo@montague.lit/orchard',
  438. 'id': info_IQ_id
  439. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
  440. .c('identity', {
  441. 'category': 'server',
  442. 'type': 'im'}).up()
  443. .c('feature', {
  444. 'var': 'http://jabber.org/protocol/disco#info'}).up()
  445. .c('feature', {
  446. 'var': 'http://jabber.org/protocol/disco#items'});
  447. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  448. let entities = await _converse.api.disco.entities.get();
  449. expect(entities.length).toBe(2);
  450. expect(_.includes(entities.pluck('jid'), 'montague.lit')).toBe(true);
  451. expect(_.includes(entities.pluck('jid'), 'romeo@montague.lit')).toBe(true);
  452. expect(entities.get(_converse.domain).features.length).toBe(2);
  453. expect(entities.get(_converse.domain).identities.length).toBe(1);
  454. await u.waitUntil(function () {
  455. // Converse.js sees that the entity has a disco#items feature,
  456. // so it will make a query for it.
  457. return _.filter(IQ_stanzas, function (iq) {
  458. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#items"]');
  459. }).length > 0;
  460. }, 300);
  461. stanza = _.find(IQ_stanzas, function (iq) {
  462. return iq.querySelector('iq[to="montague.lit"] query[xmlns="http://jabber.org/protocol/disco#items"]');
  463. });
  464. var items_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  465. stanza = $iq({
  466. 'type': 'result',
  467. 'from': 'montague.lit',
  468. 'to': 'romeo@montague.lit/orchard',
  469. 'id': items_IQ_id
  470. }).c('query', {'xmlns': 'http://jabber.org/protocol/disco#items'})
  471. .c('item', {
  472. 'jid': 'upload.montague.lit',
  473. 'name': 'HTTP File Upload'});
  474. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  475. entities = await _converse.api.disco.entities.get()
  476. expect(entities.length).toBe(2);
  477. expect(entities.get('montague.lit').items.length).toBe(1);
  478. await u.waitUntil(function () {
  479. // Converse.js sees that the entity has a disco#info feature,
  480. // so it will make a query for it.
  481. return _.filter(IQ_stanzas, function (iq) {
  482. return iq.querySelector('iq[to="upload.montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]');
  483. }).length > 0;
  484. }, 300);
  485. stanza = _.find(IQ_stanzas, iq => iq.querySelector('iq[to="upload.montague.lit"] query[xmlns="http://jabber.org/protocol/disco#info"]'));
  486. const IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
  487. expect(Strophe.serialize(stanza)).toBe(
  488. `<iq from="romeo@montague.lit/orchard" id="${IQ_id}" to="upload.montague.lit" type="get" xmlns="jabber:client">`+
  489. `<query xmlns="http://jabber.org/protocol/disco#info"/>`+
  490. `</iq>`);
  491. // Upload service responds and reports a maximum file size of 5MiB
  492. stanza = $iq({'type': 'result', 'to': 'romeo@montague.lit/orchard', 'id': IQ_id, 'from': 'upload.montague.lit'})
  493. .c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
  494. .c('identity', {'category':'store', 'type':'file', 'name':'HTTP File Upload'}).up()
  495. .c('feature', {'var':'urn:xmpp:http:upload:0'}).up()
  496. .c('x', {'type':'result', 'xmlns':'jabber:x:data'})
  497. .c('field', {'var':'FORM_TYPE', 'type':'hidden'})
  498. .c('value').t('urn:xmpp:http:upload:0').up().up()
  499. .c('field', {'var':'max-file-size'})
  500. .c('value').t('5242880');
  501. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  502. entities = await _converse.api.disco.entities.get();
  503. expect(entities.get('montague.lit').items.get('upload.montague.lit').identities.where({'category': 'store'}).length).toBe(1);
  504. await _converse.api.disco.supports(Strophe.NS.HTTPUPLOAD, _converse.domain);
  505. test_utils.createContacts(_converse, 'current');
  506. _converse.api.trigger('rosterContactsFetched');
  507. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  508. await test_utils.openChatBoxFor(_converse, contact_jid);
  509. const view = _converse.chatboxviews.get(contact_jid);
  510. var file = {
  511. 'type': 'image/jpeg',
  512. 'size': '5242881',
  513. 'lastModifiedDate': "",
  514. 'name': "my-juliet.jpg"
  515. };
  516. view.model.sendFiles([file]);
  517. await u.waitUntil(() => view.el.querySelectorAll('.message').length)
  518. const messages = view.el.querySelectorAll('.message.chat-error');
  519. expect(messages.length).toBe(1);
  520. expect(messages[0].textContent.trim()).toBe(
  521. 'The size of your file, my-juliet.jpg, exceeds the maximum allowed by your server, which is 5 MB.');
  522. done();
  523. }));
  524. });
  525. });
  526. describe("While a file is being uploaded", function () {
  527. it("shows a progress bar", mock.initConverse(
  528. null, ['rosterGroupsFetched', 'chatBoxesFetched'], {},
  529. async function (done, _converse) {
  530. await test_utils.waitUntilDiscoConfirmed(
  531. _converse, _converse.domain,
  532. [{'category': 'server', 'type':'IM'}],
  533. ['http://jabber.org/protocol/disco#items'], [], 'info');
  534. const send_backup = XMLHttpRequest.prototype.send;
  535. const IQ_stanzas = _converse.connection.IQ_stanzas;
  536. await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
  537. await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
  538. test_utils.createContacts(_converse, 'current');
  539. _converse.api.trigger('rosterContactsFetched');
  540. const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@montague.lit';
  541. await test_utils.openChatBoxFor(_converse, contact_jid);
  542. const view = _converse.chatboxviews.get(contact_jid);
  543. const file = {
  544. 'type': 'image/jpeg',
  545. 'size': '23456' ,
  546. 'lastModifiedDate': "",
  547. 'name': "my-juliet.jpg"
  548. };
  549. view.model.sendFiles([file]);
  550. await new Promise((resolve, reject) => view.once('messageInserted', resolve));
  551. await u.waitUntil(() => _.filter(IQ_stanzas, iq => iq.querySelector('iq[to="upload.montague.tld"] request')).length)
  552. const iq = IQ_stanzas.pop();
  553. expect(Strophe.serialize(iq)).toBe(
  554. `<iq from="romeo@montague.lit/orchard" `+
  555. `id="${iq.getAttribute("id")}" `+
  556. `to="upload.montague.tld" `+
  557. `type="get" `+
  558. `xmlns="jabber:client">`+
  559. `<request `+
  560. `content-type="image/jpeg" `+
  561. `filename="my-juliet.jpg" `+
  562. `size="23456" `+
  563. `xmlns="urn:xmpp:http:upload:0"/>`+
  564. `</iq>`);
  565. const base_url = 'https://conversejs.org';
  566. const message = base_url+"/logo/conversejs-filled.svg";
  567. const stanza = u.toStanza(`
  568. <iq from="upload.montague.tld"
  569. id="${iq.getAttribute("id")}"
  570. to="romeo@montague.lit/orchard"
  571. type="result">
  572. <slot xmlns="urn:xmpp:http:upload:0">
  573. <put url="https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg">
  574. <header name="Authorization">Basic Base64String==</header>
  575. <header name="Cookie">foo=bar; user=romeo</header>
  576. </put>
  577. <get url="${message}" />
  578. </slot>
  579. </iq>`);
  580. spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
  581. const message = view.model.messages.at(0);
  582. expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
  583. message.set('progress', 0.5);
  584. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
  585. .then(() => {
  586. message.set('progress', 1);
  587. u.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
  588. }).then(() => {
  589. expect(view.el.querySelector('.chat-content .chat-msg__text').textContent).toBe('Uploading file: my-juliet.jpg, 22.91 KB');
  590. done();
  591. });
  592. });
  593. let sent_stanza;
  594. spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
  595. _converse.connection._dataRecv(test_utils.createRequest(stanza));
  596. }));
  597. });
  598. });
  599. });
  600. }));