summaryrefslogtreecommitdiffstats
path: root/devtools/server/tests/unit/test_protocol_longstring.js
diff options
context:
space:
mode:
authorMatt A. Tobin <mattatobin@localhost.localdomain>2018-02-02 04:16:08 -0500
committerMatt A. Tobin <mattatobin@localhost.localdomain>2018-02-02 04:16:08 -0500
commit5f8de423f190bbb79a62f804151bc24824fa32d8 (patch)
tree10027f336435511475e392454359edea8e25895d /devtools/server/tests/unit/test_protocol_longstring.js
parent49ee0794b5d912db1f95dce6eb52d781dc210db5 (diff)
downloadUXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar
UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.gz
UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.lz
UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.tar.xz
UXP-5f8de423f190bbb79a62f804151bc24824fa32d8.zip
Add m-esr52 at 52.6.0
Diffstat (limited to 'devtools/server/tests/unit/test_protocol_longstring.js')
-rw-r--r--devtools/server/tests/unit/test_protocol_longstring.js218
1 files changed, 218 insertions, 0 deletions
diff --git a/devtools/server/tests/unit/test_protocol_longstring.js b/devtools/server/tests/unit/test_protocol_longstring.js
new file mode 100644
index 000000000..c37f4251e
--- /dev/null
+++ b/devtools/server/tests/unit/test_protocol_longstring.js
@@ -0,0 +1,218 @@
+/* Any copyright is dedicated to the Public Domain.
+ http://creativecommons.org/publicdomain/zero/1.0/ */
+
+/**
+ * Test simple requests using the protocol helpers.
+ */
+var protocol = require("devtools/shared/protocol");
+var {RetVal, Arg, Option} = protocol;
+var events = require("sdk/event/core");
+var {LongStringActor} = require("devtools/server/actors/string");
+
+// The test implicitly relies on this.
+require("devtools/shared/fronts/string");
+
+function simpleHello() {
+ return {
+ from: "root",
+ applicationType: "xpcshell-tests",
+ traits: [],
+ };
+}
+
+DebuggerServer.LONG_STRING_LENGTH = DebuggerServer.LONG_STRING_INITIAL_LENGTH = DebuggerServer.LONG_STRING_READ_LENGTH = 5;
+
+var SHORT_STR = "abc";
+var LONG_STR = "abcdefghijklmnop";
+
+var rootActor = null;
+
+const rootSpec = protocol.generateActorSpec({
+ typeName: "root",
+
+ events: {
+ "string-event": {
+ str: Arg(0, "longstring")
+ }
+ },
+
+ methods: {
+ shortString: {
+ response: { value: RetVal("longstring") },
+ },
+ longString: {
+ response: { value: RetVal("longstring") },
+ },
+ emitShortString: {
+ oneway: true,
+ },
+ emitLongString: {
+ oneway: true,
+ }
+ }
+});
+
+var RootActor = protocol.ActorClassWithSpec(rootSpec, {
+ initialize: function (conn) {
+ rootActor = this;
+ protocol.Actor.prototype.initialize.call(this, conn);
+ // Root actor owns itself.
+ this.manage(this);
+ this.actorID = "root";
+ },
+
+ sayHello: simpleHello,
+
+ shortString: function () {
+ return new LongStringActor(this.conn, SHORT_STR);
+ },
+
+ longString: function () {
+ return new LongStringActor(this.conn, LONG_STR);
+ },
+
+ emitShortString: function () {
+ events.emit(this, "string-event", new LongStringActor(this.conn, SHORT_STR));
+ },
+
+ emitLongString: function () {
+ events.emit(this, "string-event", new LongStringActor(this.conn, LONG_STR));
+ },
+});
+
+var RootFront = protocol.FrontClassWithSpec(rootSpec, {
+ initialize: function (client) {
+ this.actorID = "root";
+ protocol.Front.prototype.initialize.call(this, client);
+ // Root owns itself.
+ this.manage(this);
+ }
+});
+
+function run_test()
+{
+ DebuggerServer.createRootActor = (conn => {
+ return RootActor(conn);
+ });
+
+ DebuggerServer.init();
+ let trace = connectPipeTracing();
+ let client = new DebuggerClient(trace);
+ let rootClient;
+
+ let strfront = null;
+
+ let expectRootChildren = function (size) {
+ do_check_eq(rootActor.__poolMap.size, size + 1);
+ do_check_eq(rootClient.__poolMap.size, size + 1);
+ };
+
+
+ client.connect().then(([applicationType, traits]) => {
+ rootClient = RootFront(client);
+
+ // Root actor has no children yet.
+ expectRootChildren(0);
+
+ trace.expectReceive({"from":"<actorid>", "applicationType":"xpcshell-tests", "traits":[]});
+ do_check_eq(applicationType, "xpcshell-tests");
+ rootClient.shortString().then(ret => {
+ trace.expectSend({"type":"shortString", "to":"<actorid>"});
+ trace.expectReceive({"value":"abc", "from":"<actorid>"});
+
+ // Should only own the one reference (itself) at this point.
+ expectRootChildren(0);
+ strfront = ret;
+ }).then(() => {
+ return strfront.string();
+ }).then(ret => {
+ do_check_eq(ret, SHORT_STR);
+ }).then(() => {
+ return rootClient.longString();
+ }).then(ret => {
+ trace.expectSend({"type":"longString", "to":"<actorid>"});
+ trace.expectReceive({"value":{"type":"longString", "actor":"<actorid>", "length":16, "initial":"abcde"}, "from":"<actorid>"});
+
+ strfront = ret;
+ // Should own a reference to itself and an extra string now.
+ expectRootChildren(1);
+ }).then(() => {
+ return strfront.string();
+ }).then(ret => {
+ trace.expectSend({"type":"substring", "start":5, "end":10, "to":"<actorid>"});
+ trace.expectReceive({"substring":"fghij", "from":"<actorid>"});
+ trace.expectSend({"type":"substring", "start":10, "end":15, "to":"<actorid>"});
+ trace.expectReceive({"substring":"klmno", "from":"<actorid>"});
+ trace.expectSend({"type":"substring", "start":15, "end":20, "to":"<actorid>"});
+ trace.expectReceive({"substring":"p", "from":"<actorid>"});
+
+ do_check_eq(ret, LONG_STR);
+ }).then(() => {
+ return strfront.release();
+ }).then(() => {
+ trace.expectSend({"type":"release", "to":"<actorid>"});
+ trace.expectReceive({"from":"<actorid>"});
+
+ // That reference should be removed now.
+ expectRootChildren(0);
+ }).then(() => {
+ let deferred = promise.defer();
+ rootClient.once("string-event", (str) => {
+ trace.expectSend({"type":"emitShortString", "to":"<actorid>"});
+ trace.expectReceive({"type":"string-event", "str":"abc", "from":"<actorid>"});
+
+ do_check_true(!!str);
+ strfront = str;
+ // Shouldn't generate any new references
+ expectRootChildren(0);
+ // will generate no packets.
+ strfront.string().then((value) => { deferred.resolve(value); });
+ });
+ rootClient.emitShortString();
+ return deferred.promise;
+ }).then(value => {
+ do_check_eq(value, SHORT_STR);
+ }).then(() => {
+ // Will generate no packets
+ return strfront.release();
+ }).then(() => {
+ let deferred = promise.defer();
+ rootClient.once("string-event", (str) => {
+ trace.expectSend({"type":"emitLongString", "to":"<actorid>"});
+ trace.expectReceive({"type":"string-event", "str":{"type":"longString", "actor":"<actorid>", "length":16, "initial":"abcde"}, "from":"<actorid>"});
+
+ do_check_true(!!str);
+ // Should generate one new reference
+ expectRootChildren(1);
+ strfront = str;
+ strfront.string().then((value) => {
+ trace.expectSend({"type":"substring", "start":5, "end":10, "to":"<actorid>"});
+ trace.expectReceive({"substring":"fghij", "from":"<actorid>"});
+ trace.expectSend({"type":"substring", "start":10, "end":15, "to":"<actorid>"});
+ trace.expectReceive({"substring":"klmno", "from":"<actorid>"});
+ trace.expectSend({"type":"substring", "start":15, "end":20, "to":"<actorid>"});
+ trace.expectReceive({"substring":"p", "from":"<actorid>"});
+
+ deferred.resolve(value);
+ });
+ });
+ rootClient.emitLongString();
+ return deferred.promise;
+ }).then(value => {
+ do_check_eq(value, LONG_STR);
+ }).then(() => {
+ return strfront.release();
+ }).then(() => {
+ trace.expectSend({"type":"release", "to":"<actorid>"});
+ trace.expectReceive({"from":"<actorid>"});
+ expectRootChildren(0);
+ }).then(() => {
+ client.close().then(() => {
+ do_test_finished();
+ });
+ }).then(null, err => {
+ do_report_unexpected_exception(err, "Failure executing test");
+ });
+ });
+ do_test_pending();
+}