http-file-upload.js 40 KB

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