services/sync/tps/extensions/mozmill/resource/driver/msgbroker.js

branch
TOR_BUG_3246
changeset 5
4ab42b5ab56c
equal deleted inserted replaced
-1:000000000000 0:37541ae79c64
1 /* This Source Code Form is subject to the terms of the Mozilla Public
2 * License, v. 2.0. If a copy of the MPL was not distributed with this
3 * file, you can obtain one at http://mozilla.org/MPL/2.0/. */
4
5 var EXPORTED_SYMBOLS = ['addListener', 'addObject',
6 'removeListener',
7 'sendMessage', 'log', 'pass', 'fail'];
8
9 var listeners = {};
10
11 // add a listener for a specific message type
12 function addListener(msgType, listener) {
13 if (listeners[msgType] === undefined) {
14 listeners[msgType] = [];
15 }
16
17 listeners[msgType].push(listener);
18 }
19
20 // add each method in an object as a message listener
21 function addObject(object) {
22 for (var msgType in object) {
23 addListener(msgType, object[msgType]);
24 }
25 }
26
27 // remove a listener for all message types
28 function removeListener(listener) {
29 for (var msgType in listeners) {
30 for (let i = 0; i < listeners.length; ++i) {
31 if (listeners[msgType][i] == listener) {
32 listeners[msgType].splice(i, 1); // remove listener from array
33 }
34 }
35 }
36 }
37
38 function sendMessage(msgType, obj) {
39 if (listeners[msgType] === undefined) {
40 return;
41 }
42
43 for (let i = 0; i < listeners[msgType].length; ++i) {
44 listeners[msgType][i](obj);
45 }
46 }
47
48 function log(obj) {
49 sendMessage('log', obj);
50 }
51
52 function pass(obj) {
53 sendMessage('pass', obj);
54 }
55
56 function fail(obj) {
57 sendMessage('fail', obj);
58 }

mercurial