98 lines
2.7 KiB
JavaScript
98 lines
2.7 KiB
JavaScript
/* Any copyright is dedicated to the Public Domain.
|
|
https://creativecommons.org/publicdomain/zero/1.0/ */
|
|
|
|
"use strict";
|
|
|
|
function make_channel(url) {
|
|
return NetUtil.newChannel({ uri: url, loadUsingSystemPrincipal: true });
|
|
}
|
|
|
|
var multipartBody =
|
|
"--boundary\r\n\r\nSome text\r\n--boundary\r\nContent-Type: text/x-test\r\n\r\n<?xml version='1.1'?>\r\n<root/>\r\n--boundary\r\n\r\n<?xml version='1.0'?><root/>\r\n--boundary--";
|
|
|
|
var testData = [
|
|
{ data: "Some text", type: "text/plain" },
|
|
{ data: "<?xml version='1.1'?>\r\n<root/>", type: "text/x-test" },
|
|
{ data: "<?xml version='1.0'?><root/>", type: "text/xml" },
|
|
];
|
|
|
|
function responseHandler(request, index, buffer) {
|
|
Assert.equal(buffer, testData[index].data);
|
|
Assert.equal(
|
|
request.QueryInterface(Ci.nsIChannel).contentType,
|
|
testData[index].type
|
|
);
|
|
}
|
|
|
|
add_task(async function test_inputstream() {
|
|
let uri = "http://localhost";
|
|
let httpChan = make_channel(uri);
|
|
|
|
let inputStream = Cc["@mozilla.org/io/string-input-stream;1"].createInstance(
|
|
Ci.nsIStringInputStream
|
|
);
|
|
|
|
inputStream.setUTF8Data(multipartBody);
|
|
|
|
let channel = Cc["@mozilla.org/network/input-stream-channel;1"]
|
|
.createInstance(Ci.nsIInputStreamChannel)
|
|
.QueryInterface(Ci.nsIChannel);
|
|
|
|
channel.setURI(httpChan.URI);
|
|
channel.loadInfo = httpChan.loadInfo;
|
|
channel.contentStream = inputStream;
|
|
channel.contentType = `multipart/mixed; boundary="boundary"`;
|
|
|
|
await new Promise(resolve => {
|
|
let streamConv = Cc["@mozilla.org/streamConverters;1"].getService(
|
|
Ci.nsIStreamConverterService
|
|
);
|
|
let multipartListener = {
|
|
_buffer: "",
|
|
_index: 0,
|
|
|
|
QueryInterface: ChromeUtils.generateQI([
|
|
"nsIStreamListener",
|
|
"nsIRequestObserver",
|
|
]),
|
|
|
|
onStartRequest() {},
|
|
onDataAvailable(request, stream, offset, count) {
|
|
try {
|
|
this._buffer = this._buffer.concat(read_stream(stream, count));
|
|
dump("BUFFEEE: " + this._buffer + "\n\n");
|
|
} catch (ex) {
|
|
do_throw("Error in onDataAvailable: " + ex);
|
|
}
|
|
},
|
|
|
|
onStopRequest(request) {
|
|
try {
|
|
responseHandler(request, this._index, this._buffer);
|
|
} catch (ex) {
|
|
do_throw("Error in closure function: " + ex);
|
|
}
|
|
|
|
this._index++;
|
|
this._buffer = "";
|
|
|
|
let isLastPart = request.QueryInterface(
|
|
Ci.nsIMultiPartChannel
|
|
).isLastPart;
|
|
Assert.equal(isLastPart, this._index == testData.length);
|
|
|
|
if (isLastPart) {
|
|
resolve();
|
|
}
|
|
},
|
|
};
|
|
let conv = streamConv.asyncConvertData(
|
|
"multipart/mixed",
|
|
"*/*",
|
|
multipartListener,
|
|
null
|
|
);
|
|
|
|
channel.asyncOpen(conv);
|
|
});
|
|
});
|