| Index: ext/common.js | 
| =================================================================== | 
| new file mode 100644 | 
| --- /dev/null | 
| +++ b/ext/common.js | 
| @@ -0,0 +1,164 @@ | 
| +/* | 
| + * This file is part of Adblock Plus <http://adblockplus.org/>, | 
| + * Copyright (C) 2006-2014 Eyeo GmbH | 
| + * | 
| + * Adblock Plus is free software: you can redistribute it and/or modify | 
| + * it under the terms of the GNU General Public License version 3 as | 
| + * published by the Free Software Foundation. | 
| + * | 
| + * Adblock Plus is distributed in the hope that it will be useful, | 
| + * but WITHOUT ANY WARRANTY; without even the implied warranty of | 
| + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | 
| + * GNU General Public License for more details. | 
| + * | 
| + * You should have received a copy of the GNU General Public License | 
| + * along with Adblock Plus.  If not, see <http://www.gnu.org/licenses/>. | 
| + */ | 
| + | 
| +(function(global) | 
| +{ | 
| +  const Ci = Components.interfaces; | 
| + | 
| +  var holder = { | 
| +    get Page() | 
| +    { | 
| +      delete this.Page; | 
| +      this.Page = (typeof require == "function" ? | 
| +          require("ext_background").Page : | 
| +          function() {}); | 
| +      return this.Page; | 
| +    } | 
| +  }; | 
| + | 
| +  function getSender(origin) | 
| +  { | 
| +    if (origin instanceof Ci.nsIDOMXULElement) | 
| +      return origin.messageManager; | 
| +    else if (origin instanceof Ci.nsIMessageSender) | 
| +      return origin; | 
| +    else | 
| +      return null; | 
| +  } | 
| + | 
| +  function MessageProxy(messageManager, messageTarget) | 
| +  { | 
| +    this._messageManager = messageManager; | 
| +    this._messageTarget = messageTarget; | 
| +    this._callbacks = new Map(); | 
| +    this._responseCallbackCounter = 0; | 
| + | 
| +    this._handleRequest = this._handleRequest.bind(this); | 
| +    this._handleResponse = this._handleResponse.bind(this); | 
| +    this._messageManager.addMessageListener("AdblockPlus:Message", this._handleRequest); | 
| +    this._messageManager.addMessageListener("AdblockPlus:Response", this._handleResponse); | 
| +  } | 
| +  MessageProxy.prototype = { | 
| +    _disconnect: function() | 
| +    { | 
| +      this._messageManager.removeMessageListener("AdblockPlus:Message", this._handleRequest); | 
| +      this._messageManager.removeMessageListener("AdblockPlus:Response", this._handleResponse); | 
| +    }, | 
| + | 
| +    _sendResponse: function(sender, callbackId, response) | 
| +    { | 
| +      this._responseSent = true; | 
| + | 
| +      if (sender instanceof Ci.nsIMessageSender) | 
| +      { | 
| +        sender.sendAsyncMessage("AdblockPlus:Response", { | 
| +          callbackId: callbackId, | 
| +          responseSent: typeof response != "undefined", | 
| +          payload: response | 
| +        }); | 
| +      } | 
| +    }, | 
| + | 
| +    _handleRequest: function(message) | 
| +    { | 
| +      var sender = getSender(message.target); | 
| +      var request = message.data; | 
| +      var sendResponse; | 
| +      if (sender && "callbackId" in request) | 
| +        sendResponse = this._sendResponse.bind(this, sender, request.callbackId); | 
| +      else | 
| +        sendResponse = function() {}; | 
| + | 
| +      this._responseSent = false; | 
| +      var result = this._messageTarget._dispatch(request.payload, { | 
| +        page: new holder.Page(sender) | 
| +      }, sendResponse); | 
| +      if (!result && !this._responseSent) | 
| +        sendResponse(undefined); | 
| +    }, | 
| + | 
| +    _handleResponse: function(message) | 
| +    { | 
| +      var response = message.data; | 
| +      var callback = this._callbacks.get(response.callbackId); | 
| +      if (callback) | 
| +      { | 
| +        this._callbacks.delete(response.callbackId); | 
| +        if (response.responseSent) | 
| +          callback(response.payload); | 
| +      } | 
| +    }, | 
| + | 
| +    sendMessage: function(message, responseCallback) | 
| +    { | 
| +      if (!(this._messageManager instanceof Ci.nsIMessageSender)) | 
| +        throw new Error("Not implemented"); | 
| + | 
| +      var request = { | 
| +        payload: message | 
| +      }; | 
| +      if (responseCallback) | 
| +      { | 
| +        request.callbackId = ++this._responseCallbackCounter; | 
| +        this._callbacks.set(request.callbackId, responseCallback); | 
| +      } | 
| + | 
| +      this._messageManager.sendAsyncMessage("AdblockPlus:Message", request); | 
| +    } | 
| +  }; | 
| + | 
| +  function EventTarget() | 
| +  { | 
| +    this._listeners = []; | 
| +  }; | 
| +  EventTarget.prototype = { | 
| +    addListener: function(listener) | 
| +    { | 
| +      if (this._listeners.indexOf(listener) == -1) | 
| +        this._listeners.push(listener); | 
| +    }, | 
| +    removeListener: function(listener) | 
| +    { | 
| +      var idx = this._listeners.indexOf(listener); | 
| +      if (idx != -1) | 
| +        this._listeners.splice(idx, 1); | 
| +    }, | 
| +    _dispatch: function() | 
| +    { | 
| +      var result = null; | 
| + | 
| +      for (var i = 0; i < this._listeners.length; i++) | 
| +        result = this._listeners[i].apply(null, arguments); | 
| + | 
| +      return result; | 
| +    } | 
| +  }; | 
| + | 
| +  if (typeof exports == "object") | 
| +  { | 
| +    exports.MessageProxy = MessageProxy; | 
| +    exports.EventTarget = EventTarget; | 
| +    exports.getSender = getSender; | 
| +  } | 
| +  else | 
| +  { | 
| +    if (!global.ext) | 
| +      global.ext = {}; | 
| +    global.ext._MessageProxy = MessageProxy; | 
| +    global.ext._EventTarget = EventTarget; | 
| +  } | 
| +})(this); | 
|  |