Source code
Revision control
Copy as Markdown
Other Tools
/* Any copyright is dedicated to the Public Domain.
"use strict";
function run_test() {
initTestDevToolsServer();
add_test_bulk_actor();
add_task(async function () {
await test_string_error(socket_transport);
await test_string_error(local_transport);
DevToolsServer.destroy();
});
run_next_test();
}
/** * Sample Bulk Actor ***/
const protocol = require("resource://devtools/shared/protocol.js");
const { Arg, RetVal } = protocol;
const { Actor } = require("resource://devtools/shared/protocol/Actor.js");
const testBulkSpec = protocol.generateActorSpec({
typeName: "testBulk",
methods: {
jsonReply: {
request: protocol.BULK_REQUEST,
response: { allDone: RetVal("number") },
},
bulkReply: {
request: { foo: Arg(0, "number") },
response: protocol.BULK_RESPONSE,
},
},
});
class TestBulkActor extends Actor {
constructor(conn) {
super(conn, testBulkSpec);
}
jsonReply({ length }) {
Assert.equal(length, really_long().length);
return {
allDone: true,
};
}
async bulkReply({ foo }) {
Assert.equal(foo, 42, "received the bulk reply request");
throw new Error("actor exception");
}
}
class TestBulkFront extends protocol.FrontClassWithSpec(testBulkSpec) {
formAttributeName = "testBulk";
form(form) {
this.actor = form.actor;
}
}
protocol.registerFront(TestBulkFront);
function add_test_bulk_actor() {
ActorRegistry.addGlobalActor(
{
constructorName: "TestBulkActor",
constructorFun: TestBulkActor,
},
"testBulk"
);
}
/** * Tests ***/
var test_string_error = async function (transportFactory) {
const transport = await transportFactory();
const client = new DevToolsClient(transport);
await client.connect();
await client.mainRoot.rootForm;
const front = await client.mainRoot.getFront("testBulk");
try {
await front.bulkReply({ foo: 42 });
Assert.ok(false, "bulkReply should have thrown");
} catch (e) {
Assert.stringContains(e.message, "actor exception");
}
const reallyLong = really_long();
const input = Cc["@mozilla.org/io/string-input-stream;1"].createInstance(
Ci.nsIStringInputStream
);
input.setByteStringData(reallyLong);
const { promise, resolve } = Promise.withResolvers();
function bulkSendReadyCallback({ writer, done }) {
try {
// Send bulk data to server
writer.copyFrom(input, () => {
input.close();
done();
});
do_throw(new Error("Copying should fail, the stream is not async."));
} catch (e) {
Assert.ok(true);
resolve();
}
}
await front.jsonReply({ length: reallyLong.length }, bulkSendReadyCallback);
await promise;
client.close();
transport.close();
};