http-file-upload.js 35 KB

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