2526d80464
Also add a new API method `api.disco.features.get` for the use-case where you still want the feature object to be returned.
658 lines
38 KiB
JavaScript
658 lines
38 KiB
JavaScript
(function (root, factory) {
|
|
define([
|
|
"jasmine",
|
|
"mock",
|
|
"test-utils"], factory);
|
|
} (this, function (jasmine, mock, test_utils) {
|
|
"use strict";
|
|
const Strophe = converse.env.Strophe;
|
|
const $iq = converse.env.$iq;
|
|
const _ = converse.env._;
|
|
const u = converse.env.utils;
|
|
const f = converse.env.f;
|
|
|
|
describe("XEP-0363: HTTP File Upload", function () {
|
|
|
|
describe("Discovering support", function () {
|
|
|
|
it("is done automatically", mock.initConverse(async (done, _converse) => {
|
|
const IQ_stanzas = _converse.connection.IQ_stanzas;
|
|
const IQ_ids = _converse.connection.IQ_ids;
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], []);
|
|
await test_utils.waitUntil(() => _.filter(
|
|
IQ_stanzas,
|
|
iq => iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]')).length
|
|
);
|
|
|
|
/* <iq type='result'
|
|
* from='plays.shakespeare.lit'
|
|
* to='romeo@montague.net/orchard'
|
|
* id='info1'>
|
|
* <query xmlns='http://jabber.org/protocol/disco#info'>
|
|
* <identity
|
|
* category='server'
|
|
* type='im'/>
|
|
* <feature var='http://jabber.org/protocol/disco#info'/>
|
|
* <feature var='http://jabber.org/protocol/disco#items'/>
|
|
* </query>
|
|
* </iq>
|
|
*/
|
|
let stanza = _.find(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector(
|
|
'iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]');
|
|
});
|
|
const info_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
stanza = $iq({
|
|
'type': 'result',
|
|
'from': 'localhost',
|
|
'to': 'dummy@localhost/resource',
|
|
'id': info_IQ_id
|
|
}).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
|
|
.c('identity', {
|
|
'category': 'server',
|
|
'type': 'im'}).up()
|
|
.c('feature', {
|
|
'var': 'http://jabber.org/protocol/disco#info'}).up()
|
|
.c('feature', {
|
|
'var': 'http://jabber.org/protocol/disco#items'});
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
let entities = await _converse.api.disco.entities.get();
|
|
expect(entities.length).toBe(2);
|
|
expect(_.includes(entities.pluck('jid'), 'localhost')).toBe(true);
|
|
expect(_.includes(entities.pluck('jid'), 'dummy@localhost')).toBe(true);
|
|
|
|
expect(entities.get(_converse.domain).features.length).toBe(2);
|
|
expect(entities.get(_converse.domain).identities.length).toBe(1);
|
|
|
|
// Converse.js sees that the entity has a disco#items feature,
|
|
// so it will make a query for it.
|
|
await test_utils.waitUntil(() => _.filter(
|
|
IQ_stanzas,
|
|
iq => iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#items"]')
|
|
).length
|
|
);
|
|
/* <iq from='montague.tld'
|
|
* id='step_01'
|
|
* to='romeo@montague.tld/garden'
|
|
* type='result'>
|
|
* <query xmlns='http://jabber.org/protocol/disco#items'>
|
|
* <item jid='upload.montague.tld' name='HTTP File Upload' />
|
|
* <item jid='conference.montague.tld' name='Chatroom Service' />
|
|
* </query>
|
|
* </iq>
|
|
*/
|
|
stanza = _.find(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#items"]');
|
|
});
|
|
const items_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
stanza = $iq({
|
|
'type': 'result',
|
|
'from': 'localhost',
|
|
'to': 'dummy@localhost/resource',
|
|
'id': items_IQ_id
|
|
}).c('query', {'xmlns': 'http://jabber.org/protocol/disco#items'})
|
|
.c('item', {
|
|
'jid': 'upload.localhost',
|
|
'name': 'HTTP File Upload'});
|
|
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
_converse.api.disco.entities.get().then(function (entities) {
|
|
expect(entities.length).toBe(2);
|
|
expect(entities.get('localhost').items.length).toBe(1);
|
|
return test_utils.waitUntil(function () {
|
|
// Converse.js sees that the entity has a disco#info feature,
|
|
// so it will make a query for it.
|
|
return _.filter(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="upload.localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]');
|
|
}).length > 0;
|
|
}, 300);
|
|
});
|
|
|
|
stanza = await test_utils.waitUntil(() =>
|
|
_.filter(
|
|
IQ_stanzas,
|
|
iq => iq.nodeTree.querySelector('iq[to="upload.localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]')
|
|
).pop()
|
|
);
|
|
const IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
|
|
expect(stanza.toLocaleString()).toBe(
|
|
`<iq from="dummy@localhost/resource" id="`+IQ_id+`" to="upload.localhost" type="get" xmlns="jabber:client">`+
|
|
`<query xmlns="http://jabber.org/protocol/disco#info"/>`+
|
|
`</iq>`);
|
|
|
|
// Upload service responds and reports a maximum file size of 5MiB
|
|
/* <iq from='upload.montague.tld'
|
|
* id='step_02'
|
|
* to='romeo@montague.tld/garden'
|
|
* type='result'>
|
|
* <query xmlns='http://jabber.org/protocol/disco#info'>
|
|
* <identity category='store'
|
|
* type='file'
|
|
* name='HTTP File Upload' />
|
|
* <feature var='urn:xmpp:http:upload:0' />
|
|
* <x type='result' xmlns='jabber:x:data'>
|
|
* <field var='FORM_TYPE' type='hidden'>
|
|
* <value>urn:xmpp:http:upload:0</value>
|
|
* </field>
|
|
* <field var='max-file-size'>
|
|
* <value>5242880</value>
|
|
* </field>
|
|
* </x>
|
|
* </query>
|
|
* </iq>
|
|
*/
|
|
stanza = $iq({'type': 'result', 'to': 'dummy@localhost/resource', 'id': IQ_id, 'from': 'upload.localhost'})
|
|
.c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
|
|
.c('identity', {'category':'store', 'type':'file', 'name':'HTTP File Upload'}).up()
|
|
.c('feature', {'var':'urn:xmpp:http:upload:0'}).up()
|
|
.c('x', {'type':'result', 'xmlns':'jabber:x:data'})
|
|
.c('field', {'var':'FORM_TYPE', 'type':'hidden'})
|
|
.c('value').t('urn:xmpp:http:upload:0').up().up()
|
|
.c('field', {'var':'max-file-size'})
|
|
.c('value').t('5242880');
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
entities = await _converse.api.disco.entities.get();
|
|
expect(entities.get('localhost').items.get('upload.localhost').identities.where({'category': 'store'}).length).toBe(1);
|
|
const supported = await _converse.api.disco.supports(Strophe.NS.HTTPUPLOAD, _converse.domain);
|
|
expect(supported).toBe(true);
|
|
const features = await _converse.api.disco.features.get(Strophe.NS.HTTPUPLOAD, _converse.domain);
|
|
expect(features.length).toBe(1);
|
|
expect(features[0].get('jid')).toBe('upload.localhost');
|
|
expect(features[0].dataforms.where({'FORM_TYPE': {value: "urn:xmpp:http:upload:0", type: "hidden"}}).length).toBe(1);
|
|
done();
|
|
}));
|
|
});
|
|
|
|
describe("When not supported", function () {
|
|
describe("A file upload toolbar button", function () {
|
|
|
|
it("does not appear in private chats", mock.initConverse(async (done, _converse) => {
|
|
var contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@localhost';
|
|
test_utils.createContacts(_converse, 'current');
|
|
test_utils.openChatBoxFor(_converse, contact_jid);
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], [], 'items');
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
expect(view.el.querySelector('.chat-toolbar .upload-file')).toBe(null);
|
|
done();
|
|
}));
|
|
|
|
it("does not appear in MUC chats", mock.initConverse(
|
|
null, ['rosterGroupsFetched'], {},
|
|
async (done, _converse) => {
|
|
|
|
await test_utils.openAndEnterChatRoom(_converse, 'lounge', 'localhost', 'dummy');
|
|
test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.localhost'], 'items');
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.localhost', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
const view = _converse.chatboxviews.get('lounge@localhost');
|
|
expect(view.el.querySelector('.chat-toolbar .upload-file')).toBe(null);
|
|
done();
|
|
}));
|
|
|
|
});
|
|
});
|
|
|
|
describe("When supported", function () {
|
|
|
|
describe("A file upload toolbar button", function () {
|
|
|
|
it("appears in private chats", mock.initConverse(async (done, _converse) => {
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.localhost'], 'items')
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.localhost', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
test_utils.createContacts(_converse, 'current', 3);
|
|
_converse.api.trigger('rosterContactsFetched');
|
|
const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@localhost';
|
|
await test_utils.openChatBoxFor(_converse, contact_jid);
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
test_utils.waitUntil(() => view.el.querySelector('.upload-file'));
|
|
expect(view.el.querySelector('.chat-toolbar .upload-file')).not.toBe(null);
|
|
done();
|
|
}));
|
|
|
|
it("appears in MUC chats", mock.initConverse(
|
|
null, ['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async (done, _converse) => {
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.localhost'], 'items');
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.localhost', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
await test_utils.openAndEnterChatRoom(_converse, 'lounge', 'localhost', 'dummy');
|
|
await test_utils.waitUntil(() => _converse.chatboxviews.get('lounge@localhost').el.querySelector('.upload-file'));
|
|
const view = _converse.chatboxviews.get('lounge@localhost');
|
|
expect(view.el.querySelector('.chat-toolbar .upload-file')).not.toBe(null);
|
|
done();
|
|
}));
|
|
|
|
describe("when clicked and a file chosen", function () {
|
|
|
|
it("is uploaded and sent out", mock.initConverse(async (done, _converse) => {
|
|
const base_url = 'https://conversejs.org';
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
const send_backup = XMLHttpRequest.prototype.send;
|
|
const IQ_stanzas = _converse.connection.IQ_stanzas;
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
test_utils.createContacts(_converse, 'current');
|
|
_converse.api.trigger('rosterContactsFetched');
|
|
const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@localhost';
|
|
await test_utils.openChatBoxFor(_converse, contact_jid);
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
const file = {
|
|
'type': 'image/jpeg',
|
|
'size': '23456' ,
|
|
'lastModifiedDate': "",
|
|
'name': "my-juliet.jpg"
|
|
};
|
|
view.model.sendFiles([file]);
|
|
await new Promise((resolve, reject) => view.once('messageInserted', resolve));
|
|
|
|
await test_utils.waitUntil(() => _.filter(IQ_stanzas, iq => iq.nodeTree.querySelector('iq[to="upload.montague.tld"] request')).length);
|
|
const iq = IQ_stanzas.pop();
|
|
expect(iq.toLocaleString()).toBe(
|
|
`<iq from="dummy@localhost/resource" `+
|
|
`id="${iq.nodeTree.getAttribute("id")}" `+
|
|
`to="upload.montague.tld" `+
|
|
`type="get" `+
|
|
`xmlns="jabber:client">`+
|
|
`<request `+
|
|
`content-type="image/jpeg" `+
|
|
`filename="my-juliet.jpg" `+
|
|
`size="23456" `+
|
|
`xmlns="urn:xmpp:http:upload:0"/>`+
|
|
`</iq>`);
|
|
|
|
const message = base_url+"/logo/conversejs-filled.svg";
|
|
|
|
const stanza = u.toStanza(`
|
|
<iq from="upload.montague.tld"
|
|
id="${iq.nodeTree.getAttribute("id")}"
|
|
to="dummy@localhost/resource"
|
|
type="result">
|
|
<slot xmlns="urn:xmpp:http:upload:0">
|
|
<put url="https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg">
|
|
<header name="Authorization">Basic Base64String==</header>
|
|
<header name="Cookie">foo=bar; user=romeo</header>
|
|
</put>
|
|
<get url="${message}" />
|
|
</slot>
|
|
</iq>`);
|
|
|
|
spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
|
|
const message = view.model.messages.at(0);
|
|
expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
|
|
message.set('progress', 0.5);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
|
|
.then(() => {
|
|
message.set('progress', 1);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
|
|
}).then(() => {
|
|
message.save({
|
|
'upload': _converse.SUCCESS,
|
|
'oob_url': message.get('get'),
|
|
'message': message.get('get')
|
|
});
|
|
return new Promise((resolve, reject) => view.model.messages.once('rendered', resolve));
|
|
});
|
|
});
|
|
let sent_stanza;
|
|
spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
await test_utils.waitUntil(() => sent_stanza, 1000);
|
|
expect(sent_stanza.toLocaleString()).toBe(
|
|
`<message from="dummy@localhost/resource" `+
|
|
`id="${sent_stanza.nodeTree.getAttribute("id")}" `+
|
|
`to="irini.vlastuin@localhost" `+
|
|
`type="chat" `+
|
|
`xmlns="jabber:client">`+
|
|
`<body>${message}</body>`+
|
|
`<active xmlns="http://jabber.org/protocol/chatstates"/>`+
|
|
`<request xmlns="urn:xmpp:receipts"/>`+
|
|
`<x xmlns="jabber:x:oob">`+
|
|
`<url>${message}</url>`+
|
|
`</x>`+
|
|
`<origin-id id="${sent_stanza.nodeTree.querySelector('origin-id').getAttribute("id")}" xmlns="urn:xmpp:sid:0"/>`+
|
|
`</message>`);
|
|
await test_utils.waitUntil(() => view.el.querySelector('.chat-image'), 1000);
|
|
// Check that the image renders
|
|
expect(view.el.querySelector('.chat-msg .chat-msg__media').innerHTML.trim()).toEqual(
|
|
`<!-- src/templates/image.html -->\n`+
|
|
`<a href="${base_url}/logo/conversejs-filled.svg" target="_blank" rel="noopener">`+
|
|
`<img class="chat-image img-thumbnail" src="${base_url}/logo/conversejs-filled.svg">`+
|
|
`</a>`);
|
|
XMLHttpRequest.prototype.send = send_backup;
|
|
done();
|
|
}));
|
|
|
|
it("is uploaded and sent out from a groupchat", mock.initConverse(async (done, _converse) => {
|
|
|
|
const base_url = 'https://conversejs.org';
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
const send_backup = XMLHttpRequest.prototype.send;
|
|
const IQ_stanzas = _converse.connection.IQ_stanzas;
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
await test_utils.openAndEnterChatRoom(_converse, 'lounge', 'localhost', 'dummy');
|
|
const view = _converse.chatboxviews.get('lounge@localhost');
|
|
const file = {
|
|
'type': 'image/jpeg',
|
|
'size': '23456' ,
|
|
'lastModifiedDate': "",
|
|
'name': "my-juliet.jpg"
|
|
};
|
|
view.model.sendFiles([file]);
|
|
await new Promise((resolve, reject) => view.once('messageInserted', resolve));
|
|
|
|
await test_utils.waitUntil(() => _.filter(IQ_stanzas, iq => iq.nodeTree.querySelector('iq[to="upload.montague.tld"] request')).length);
|
|
const iq = IQ_stanzas.pop();
|
|
expect(iq.toLocaleString()).toBe(
|
|
`<iq from="dummy@localhost/resource" `+
|
|
`id="${iq.nodeTree.getAttribute("id")}" `+
|
|
`to="upload.montague.tld" `+
|
|
`type="get" `+
|
|
`xmlns="jabber:client">`+
|
|
`<request `+
|
|
`content-type="image/jpeg" `+
|
|
`filename="my-juliet.jpg" `+
|
|
`size="23456" `+
|
|
`xmlns="urn:xmpp:http:upload:0"/>`+
|
|
`</iq>`);
|
|
|
|
const message = base_url+"/logo/conversejs-filled.svg";
|
|
const stanza = u.toStanza(`
|
|
<iq from='upload.montague.tld'
|
|
id="${iq.nodeTree.getAttribute('id')}"
|
|
to='dummy@localhost/resource'
|
|
type='result'>
|
|
<slot xmlns='urn:xmpp:http:upload:0'>
|
|
<put url='https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg'>
|
|
<header name='Authorization'>Basic Base64String==</header>
|
|
<header name='Cookie'>foo=bar; user=romeo</header>
|
|
</put>
|
|
<get url="${message}" />
|
|
</slot>
|
|
</iq>`);
|
|
|
|
spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
|
|
const message = view.model.messages.at(0);
|
|
expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
|
|
message.set('progress', 0.5);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
|
|
.then(() => {
|
|
message.set('progress', 1);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
|
|
}).then(() => {
|
|
message.save({
|
|
'upload': _converse.SUCCESS,
|
|
'oob_url': message.get('get'),
|
|
'message': message.get('get')
|
|
});
|
|
return new Promise((resolve, reject) => view.model.messages.once('rendered', resolve));
|
|
});
|
|
});
|
|
let sent_stanza;
|
|
spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
await test_utils.waitUntil(() => sent_stanza, 1000);
|
|
expect(sent_stanza.toLocaleString()).toBe(
|
|
`<message `+
|
|
`from="dummy@localhost/resource" `+
|
|
`id="${sent_stanza.nodeTree.getAttribute("id")}" `+
|
|
`to="lounge@localhost" `+
|
|
`type="groupchat" `+
|
|
`xmlns="jabber:client">`+
|
|
`<body>${message}</body>`+
|
|
`<active xmlns="http://jabber.org/protocol/chatstates"/>`+
|
|
`<x xmlns="jabber:x:oob">`+
|
|
`<url>${message}</url>`+
|
|
`</x>`+
|
|
`<origin-id id="${sent_stanza.nodeTree.querySelector('origin-id').getAttribute("id")}" xmlns="urn:xmpp:sid:0"/>`+
|
|
`</message>`);
|
|
await test_utils.waitUntil(() => view.el.querySelector('.chat-image'), 1000);
|
|
// Check that the image renders
|
|
expect(view.el.querySelector('.chat-msg .chat-msg__media').innerHTML.trim()).toEqual(
|
|
`<!-- src/templates/image.html -->\n`+
|
|
`<a href="${base_url}/logo/conversejs-filled.svg" target="_blank" rel="noopener">`+
|
|
`<img class="chat-image img-thumbnail" src="${base_url}/logo/conversejs-filled.svg">`+
|
|
`</a>`);
|
|
XMLHttpRequest.prototype.send = send_backup;
|
|
done();
|
|
}));
|
|
|
|
it("shows an error message if the file is too large", mock.initConverse(async (done, _converse) => {
|
|
const IQ_stanzas = _converse.connection.IQ_stanzas;
|
|
const IQ_ids = _converse.connection.IQ_ids;
|
|
const send_backup = XMLHttpRequest.prototype.send;
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.bare_jid, [], []);
|
|
await test_utils.waitUntil(() => _.filter(
|
|
IQ_stanzas,
|
|
iq => iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]')).length
|
|
);
|
|
|
|
var stanza = _.find(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector(
|
|
'iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]');
|
|
});
|
|
var info_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
|
|
stanza = $iq({
|
|
'type': 'result',
|
|
'from': 'localhost',
|
|
'to': 'dummy@localhost/resource',
|
|
'id': info_IQ_id
|
|
}).c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
|
|
.c('identity', {
|
|
'category': 'server',
|
|
'type': 'im'}).up()
|
|
.c('feature', {
|
|
'var': 'http://jabber.org/protocol/disco#info'}).up()
|
|
.c('feature', {
|
|
'var': 'http://jabber.org/protocol/disco#items'});
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
let entities = await _converse.api.disco.entities.get();
|
|
|
|
expect(entities.length).toBe(2);
|
|
expect(_.includes(entities.pluck('jid'), 'localhost')).toBe(true);
|
|
expect(_.includes(entities.pluck('jid'), 'dummy@localhost')).toBe(true);
|
|
|
|
expect(entities.get(_converse.domain).features.length).toBe(2);
|
|
expect(entities.get(_converse.domain).identities.length).toBe(1);
|
|
|
|
await test_utils.waitUntil(function () {
|
|
// Converse.js sees that the entity has a disco#items feature,
|
|
// so it will make a query for it.
|
|
return _.filter(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#items"]');
|
|
}).length > 0;
|
|
}, 300);
|
|
|
|
stanza = _.find(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="localhost"] query[xmlns="http://jabber.org/protocol/disco#items"]');
|
|
});
|
|
var items_IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
stanza = $iq({
|
|
'type': 'result',
|
|
'from': 'localhost',
|
|
'to': 'dummy@localhost/resource',
|
|
'id': items_IQ_id
|
|
}).c('query', {'xmlns': 'http://jabber.org/protocol/disco#items'})
|
|
.c('item', {
|
|
'jid': 'upload.localhost',
|
|
'name': 'HTTP File Upload'});
|
|
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
|
|
entities = await _converse.api.disco.entities.get()
|
|
|
|
expect(entities.length).toBe(2);
|
|
expect(entities.get('localhost').items.length).toBe(1);
|
|
await test_utils.waitUntil(function () {
|
|
// Converse.js sees that the entity has a disco#info feature,
|
|
// so it will make a query for it.
|
|
return _.filter(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="upload.localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]');
|
|
}).length > 0;
|
|
}, 300);
|
|
|
|
stanza = _.find(IQ_stanzas, function (iq) {
|
|
return iq.nodeTree.querySelector('iq[to="upload.localhost"] query[xmlns="http://jabber.org/protocol/disco#info"]');
|
|
});
|
|
var IQ_id = IQ_ids[IQ_stanzas.indexOf(stanza)];
|
|
expect(stanza.toLocaleString()).toBe(
|
|
`<iq from="dummy@localhost/resource" id="${IQ_id}" to="upload.localhost" type="get" xmlns="jabber:client">`+
|
|
`<query xmlns="http://jabber.org/protocol/disco#info"/>`+
|
|
`</iq>`);
|
|
|
|
// Upload service responds and reports a maximum file size of 5MiB
|
|
stanza = $iq({'type': 'result', 'to': 'dummy@localhost/resource', 'id': IQ_id, 'from': 'upload.localhost'})
|
|
.c('query', {'xmlns': 'http://jabber.org/protocol/disco#info'})
|
|
.c('identity', {'category':'store', 'type':'file', 'name':'HTTP File Upload'}).up()
|
|
.c('feature', {'var':'urn:xmpp:http:upload:0'}).up()
|
|
.c('x', {'type':'result', 'xmlns':'jabber:x:data'})
|
|
.c('field', {'var':'FORM_TYPE', 'type':'hidden'})
|
|
.c('value').t('urn:xmpp:http:upload:0').up().up()
|
|
.c('field', {'var':'max-file-size'})
|
|
.c('value').t('5242880');
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
entities = await _converse.api.disco.entities.get();
|
|
expect(entities.get('localhost').items.get('upload.localhost').identities.where({'category': 'store'}).length).toBe(1);
|
|
await _converse.api.disco.supports(Strophe.NS.HTTPUPLOAD, _converse.domain);
|
|
test_utils.createContacts(_converse, 'current');
|
|
_converse.api.trigger('rosterContactsFetched');
|
|
|
|
const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@localhost';
|
|
await test_utils.openChatBoxFor(_converse, contact_jid);
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
var file = {
|
|
'type': 'image/jpeg',
|
|
'size': '5242881',
|
|
'lastModifiedDate': "",
|
|
'name': "my-juliet.jpg"
|
|
};
|
|
view.model.sendFiles([file]);
|
|
await test_utils.waitUntil(() => view.el.querySelectorAll('.message').length)
|
|
const messages = view.el.querySelectorAll('.message.chat-error');
|
|
expect(messages.length).toBe(1);
|
|
expect(messages[0].textContent).toBe(
|
|
'The size of your file, my-juliet.jpg, exceeds the maximum allowed by your server, which is 5 MB.');
|
|
done();
|
|
}));
|
|
});
|
|
});
|
|
|
|
describe("While a file is being uploaded", function () {
|
|
|
|
it("shows a progress bar", mock.initConverse(
|
|
null, ['rosterGroupsFetched', 'chatBoxesFetched'], {},
|
|
async function (done, _converse) {
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(
|
|
_converse, _converse.domain,
|
|
[{'category': 'server', 'type':'IM'}],
|
|
['http://jabber.org/protocol/disco#items'], [], 'info');
|
|
|
|
const send_backup = XMLHttpRequest.prototype.send;
|
|
const IQ_stanzas = _converse.connection.IQ_stanzas;
|
|
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, _converse.domain, [], [], ['upload.montague.tld'], 'items');
|
|
await test_utils.waitUntilDiscoConfirmed(_converse, 'upload.montague.tld', [], [Strophe.NS.HTTPUPLOAD], []);
|
|
test_utils.createContacts(_converse, 'current');
|
|
_converse.api.trigger('rosterContactsFetched');
|
|
const contact_jid = mock.cur_names[2].replace(/ /g,'.').toLowerCase() + '@localhost';
|
|
await test_utils.openChatBoxFor(_converse, contact_jid);
|
|
const view = _converse.chatboxviews.get(contact_jid);
|
|
const file = {
|
|
'type': 'image/jpeg',
|
|
'size': '23456' ,
|
|
'lastModifiedDate': "",
|
|
'name': "my-juliet.jpg"
|
|
};
|
|
view.model.sendFiles([file]);
|
|
await new Promise((resolve, reject) => view.once('messageInserted', resolve));
|
|
await test_utils.waitUntil(() => _.filter(IQ_stanzas, (iq) => iq.nodeTree.querySelector('iq[to="upload.montague.tld"] request')).length)
|
|
const iq = IQ_stanzas.pop();
|
|
expect(iq.toLocaleString()).toBe(
|
|
`<iq from="dummy@localhost/resource" `+
|
|
`id="${iq.nodeTree.getAttribute("id")}" `+
|
|
`to="upload.montague.tld" `+
|
|
`type="get" `+
|
|
`xmlns="jabber:client">`+
|
|
`<request `+
|
|
`content-type="image/jpeg" `+
|
|
`filename="my-juliet.jpg" `+
|
|
`size="23456" `+
|
|
`xmlns="urn:xmpp:http:upload:0"/>`+
|
|
`</iq>`);
|
|
|
|
const base_url = 'https://conversejs.org';
|
|
const message = base_url+"/logo/conversejs-filled.svg";
|
|
const stanza = u.toStanza(`
|
|
<iq from="upload.montague.tld"
|
|
id="${iq.nodeTree.getAttribute("id")}"
|
|
to="dummy@localhost/resource"
|
|
type="result">
|
|
<slot xmlns="urn:xmpp:http:upload:0">
|
|
<put url="https://upload.montague.tld/4a771ac1-f0b2-4a4a-9700-f2a26fa2bb67/my-juliet.jpg">
|
|
<header name="Authorization">Basic Base64String==</header>
|
|
<header name="Cookie">foo=bar; user=romeo</header>
|
|
</put>
|
|
<get url="${message}" />
|
|
</slot>
|
|
</iq>`);
|
|
spyOn(XMLHttpRequest.prototype, 'send').and.callFake(function () {
|
|
const message = view.model.messages.at(0);
|
|
expect(view.el.querySelector('.chat-content progress').getAttribute('value')).toBe('0');
|
|
message.set('progress', 0.5);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '0.5')
|
|
.then(() => {
|
|
message.set('progress', 1);
|
|
test_utils.waitUntil(() => view.el.querySelector('.chat-content progress').getAttribute('value') === '1')
|
|
}).then(() => {
|
|
expect(view.el.querySelector('.chat-content .chat-msg__text').textContent).toBe('Uploading file: my-juliet.jpg, 22.91 KB');
|
|
done();
|
|
});
|
|
});
|
|
let sent_stanza;
|
|
spyOn(_converse.connection, 'send').and.callFake(stanza => (sent_stanza = stanza));
|
|
_converse.connection._dataRecv(test_utils.createRequest(stanza));
|
|
}));
|
|
});
|
|
});
|
|
});
|
|
}));
|