http-file-upload.js 37 KB

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