1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000 1.2 +++ b/services/sync/tps/extensions/mozmill/resource/driver/msgbroker.js Wed Dec 31 06:09:35 2014 +0100 1.3 @@ -0,0 +1,58 @@ 1.4 +/* This Source Code Form is subject to the terms of the Mozilla Public 1.5 + * License, v. 2.0. If a copy of the MPL was not distributed with this 1.6 + * file, you can obtain one at http://mozilla.org/MPL/2.0/. */ 1.7 + 1.8 +var EXPORTED_SYMBOLS = ['addListener', 'addObject', 1.9 + 'removeListener', 1.10 + 'sendMessage', 'log', 'pass', 'fail']; 1.11 + 1.12 +var listeners = {}; 1.13 + 1.14 +// add a listener for a specific message type 1.15 +function addListener(msgType, listener) { 1.16 + if (listeners[msgType] === undefined) { 1.17 + listeners[msgType] = []; 1.18 + } 1.19 + 1.20 + listeners[msgType].push(listener); 1.21 +} 1.22 + 1.23 +// add each method in an object as a message listener 1.24 +function addObject(object) { 1.25 + for (var msgType in object) { 1.26 + addListener(msgType, object[msgType]); 1.27 + } 1.28 +} 1.29 + 1.30 +// remove a listener for all message types 1.31 +function removeListener(listener) { 1.32 + for (var msgType in listeners) { 1.33 + for (let i = 0; i < listeners.length; ++i) { 1.34 + if (listeners[msgType][i] == listener) { 1.35 + listeners[msgType].splice(i, 1); // remove listener from array 1.36 + } 1.37 + } 1.38 + } 1.39 +} 1.40 + 1.41 +function sendMessage(msgType, obj) { 1.42 + if (listeners[msgType] === undefined) { 1.43 + return; 1.44 + } 1.45 + 1.46 + for (let i = 0; i < listeners[msgType].length; ++i) { 1.47 + listeners[msgType][i](obj); 1.48 + } 1.49 +} 1.50 + 1.51 +function log(obj) { 1.52 + sendMessage('log', obj); 1.53 +} 1.54 + 1.55 +function pass(obj) { 1.56 + sendMessage('pass', obj); 1.57 +} 1.58 + 1.59 +function fail(obj) { 1.60 + sendMessage('fail', obj); 1.61 +}