michael@0: // -*- Mode: js2; tab-width: 2; indent-tabs-mode: nil; js2-basic-offset: 2; js2-skip-preprocessor-directives: t; -*-
michael@0: /* This Source Code Form is subject to the terms of the Mozilla Public
michael@0:  * License, v. 2.0. If a copy of the MPL was not distributed with this file,
michael@0:  * You can obtain one at http://mozilla.org/MPL/2.0/. */
michael@0: 
michael@0: Components.utils.import("resource://gre/modules/OrderedBroadcast.jsm");
michael@0: Components.utils.import("resource://gre/modules/Promise.jsm");
michael@0: 
michael@0: let _observerId = 0;
michael@0: 
michael@0: function makeObserver() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let ret = {
michael@0:     id: _observerId++,
michael@0:     count: 0,
michael@0:     promise: deferred.promise,
michael@0:     callback: function(data, token, action) {
michael@0:       ret.count += 1;
michael@0:       deferred.resolve({ data: data,
michael@0:                          token: token,
michael@0:                          action: action });
michael@0:     },
michael@0:   };
michael@0: 
michael@0:   return ret;
michael@0: };
michael@0: 
michael@0: add_task(function test_send() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let observer = makeObserver();
michael@0: 
michael@0:   let token = { a: "bcde", b: 1234 };
michael@0:   sendOrderedBroadcast("org.mozilla.gecko.test.receiver",
michael@0:                        token, observer.callback);
michael@0: 
michael@0:   let value = yield observer.promise;
michael@0: 
michael@0:   do_check_eq(observer.count, 1);
michael@0: 
michael@0:   // We get back the correct action and token.
michael@0:   do_check_neq(value, null);
michael@0:   do_check_matches(value.token, token);
michael@0:   do_check_eq(value.action, "org.mozilla.gecko.test.receiver");
michael@0: 
michael@0:   // Data is provided by testOrderedBroadcast.java.in.
michael@0:   do_check_neq(value.data, null);
michael@0:   do_check_eq(value.data.c, "efg");
michael@0:   do_check_eq(value.data.d, 456);
michael@0: 
michael@0:   // And the provided token is returned to us (as a string) by
michael@0:   // testOrderedBroadcast.java.in.
michael@0:   do_check_neq(value.data.token, null);
michael@0:   do_check_eq(typeof(value.data.token), "string");
michael@0:   do_check_matches(JSON.parse(value.data.token), token);
michael@0: });
michael@0: 
michael@0: add_task(function test_null_token() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let observer = makeObserver();
michael@0: 
michael@0:   sendOrderedBroadcast("org.mozilla.gecko.test.receiver",
michael@0:                        null, observer.callback);
michael@0: 
michael@0:   let value = yield observer.promise;
michael@0: 
michael@0:   do_check_eq(observer.count, 1);
michael@0: 
michael@0:   // We get back the correct action and token.
michael@0:   do_check_neq(value, null);
michael@0:   do_check_eq(value.token, null);
michael@0:   do_check_eq(value.action, "org.mozilla.gecko.test.receiver");
michael@0: 
michael@0:   // Data is provided by testOrderedBroadcast.java.in.
michael@0:   do_check_neq(value.data, null);
michael@0:   do_check_eq(value.data.c, "efg");
michael@0:   do_check_eq(value.data.d, 456);
michael@0: });
michael@0: 
michael@0: add_task(function test_string_token() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let observer = makeObserver();
michael@0: 
michael@0:   let token = "string_token";
michael@0:   let permission = null; // means any receiver can listen for our intent
michael@0:   sendOrderedBroadcast("org.mozilla.gecko.test.receiver",
michael@0:                        token, observer.callback, permission);
michael@0: 
michael@0:   let value = yield observer.promise;
michael@0: 
michael@0:   do_check_eq(observer.count, 1);
michael@0: 
michael@0:   // We get back the correct action and token.
michael@0:   do_check_neq(value, null);
michael@0:   do_check_eq(value.token, token);
michael@0:   do_check_eq(typeof(value.token), "string");
michael@0:   do_check_eq(value.action, "org.mozilla.gecko.test.receiver");
michael@0: 
michael@0:   // Data is provided by testOrderedBroadcast.java.in.
michael@0:   do_check_neq(value.data, null);
michael@0:   do_check_eq(value.data.c, "efg");
michael@0:   do_check_eq(value.data.d, 456);
michael@0:   do_check_eq(value.data.token, token);
michael@0: });
michael@0: 
michael@0: add_task(function test_permission() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let observer = makeObserver();
michael@0: 
michael@0:   sendOrderedBroadcast("org.mozilla.gecko.test.receiver",
michael@0:                        null, observer.callback,
michael@0:                        "org.mozilla.gecko.fake.permission");
michael@0: 
michael@0:   let value = yield observer.promise;
michael@0: 
michael@0:   do_check_eq(observer.count, 1);
michael@0: 
michael@0:   // We get back the correct action and token.
michael@0:   do_check_neq(value, null);
michael@0:   do_check_eq(value.token, null);
michael@0:   do_check_eq(value.action, "org.mozilla.gecko.test.receiver");
michael@0: 
michael@0:   // Data would be provided by testOrderedBroadcast.java.in, except
michael@0:   // the no package has the permission, so no responder exists.
michael@0:   do_check_eq(value.data, null);
michael@0: });
michael@0: 
michael@0: add_task(function test_send_no_receiver() {
michael@0:   let deferred = Promise.defer();
michael@0: 
michael@0:   let observer = makeObserver();
michael@0: 
michael@0:   sendOrderedBroadcast("org.mozilla.gecko.test.no.receiver",
michael@0:                        { a: "bcd", b: 123 }, observer.callback);
michael@0: 
michael@0:   let value = yield observer.promise;
michael@0: 
michael@0:   do_check_eq(observer.count, 1);
michael@0: 
michael@0:   // We get back the correct action and token, but the default is to
michael@0:   // return no data.
michael@0:   do_check_neq(value, null);
michael@0:   do_check_neq(value.token, null);
michael@0:   do_check_eq(value.token.a, "bcd");
michael@0:   do_check_eq(value.token.b, 123);
michael@0:   do_check_eq(value.action, "org.mozilla.gecko.test.no.receiver");
michael@0:   do_check_eq(value.data, null);
michael@0: });
michael@0: 
michael@0: run_next_test();