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