http-file-upload.js 37 KB

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