Left: | ||
Right: |
OLD | NEW |
---|---|
1 /* | 1 /* |
2 * This file is part of Adblock Plus <https://adblockplus.org/>, | 2 * This file is part of Adblock Plus <https://adblockplus.org/>, |
3 * Copyright (C) 2006-2016 Eyeo GmbH | 3 * Copyright (C) 2006-2016 Eyeo GmbH |
4 * | 4 * |
5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
8 * | 8 * |
9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
12 * GNU General Public License for more details. | 12 * GNU General Public License for more details. |
13 * | 13 * |
14 * You should have received a copy of the GNU General Public License | 14 * You should have received a copy of the GNU General Public License |
15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
16 */ | 16 */ |
17 | 17 |
18 (function(global) | 18 (function(global) |
19 { | 19 { |
20 const Ci = Components.interfaces; | |
21 | |
22 if (!global.ext) | 20 if (!global.ext) |
23 global.ext = {}; | 21 global.ext = {}; |
24 | 22 |
25 var holder = { | 23 function wrapFrames(frames) |
26 get Page() | 24 { |
27 { | 25 if (!frames.length) |
28 delete this.Page; | 26 return null; |
29 this.Page = (typeof require == "function" ? | |
30 require("ext_background").Page : | |
31 function() {}); | |
32 return this.Page; | |
33 } | |
34 }; | |
35 | 27 |
36 var getSender = global.ext._getSender = function(origin) | 28 // We have frames as an array, non-Firefox code expects url and parent |
29 // properties however. | |
30 Object.defineProperty(frames, "url", { | |
31 enumerable: true, | |
32 get: () => new URL(frames[0].location) | |
33 }); | |
34 | |
35 Object.defineProperty(frames, "parent", { | |
36 enumerable: true, | |
37 get: () => wrapFrames(frames.slice(1)) | |
38 }); | |
39 | |
40 return frames; | |
41 } | |
42 | |
43 var EventTarget = global.ext._EventTarget = function(port, windowID) | |
Thomas Greiner
2016/04/18 13:22:50
Detail: It looks a bit contradictory to export som
Wladimir Palant
2016/04/18 15:28:56
It's used internally by the ext layer, not meant f
| |
37 { | 44 { |
38 if (origin instanceof Ci.nsIDOMXULElement) | 45 this._port = port; |
39 return origin.messageManager; | 46 this._windowID = windowID; |
40 else if (origin instanceof Ci.nsIMessageSender) | |
41 return origin; | |
42 else | |
43 return null; | |
44 }; | |
45 | |
46 var MessageProxy = global.ext._MessageProxy = function(messageManager, message Target) | |
47 { | |
48 this._messageManager = messageManager; | |
49 this._messageTarget = messageTarget; | |
50 this._callbacks = new Map(); | |
51 this._responseCallbackCounter = 0; | |
52 | |
53 this._handleRequest = this._handleRequest.bind(this); | |
54 this._handleResponse = this._handleResponse.bind(this); | |
55 this._messageManager.addMessageListener("AdblockPlus:Message", this._handleR equest); | |
56 this._messageManager.addMessageListener("AdblockPlus:Response", this._handle Response); | |
57 }; | |
58 MessageProxy.prototype = { | |
59 _disconnect: function() | |
60 { | |
61 this._messageManager.removeMessageListener("AdblockPlus:Message", this._ha ndleRequest); | |
62 this._messageManager.removeMessageListener("AdblockPlus:Response", this._h andleResponse); | |
63 }, | |
64 | |
65 _sendResponse: function(sender, callbackId, message) | |
66 { | |
67 var response = { | |
68 callbackId: callbackId | |
69 }; | |
70 if (typeof response != "undefined") | |
71 response.payload = message; | |
72 sender.sendAsyncMessage("AdblockPlus:Response", response); | |
73 }, | |
74 | |
75 _handleRequest: function(message) | |
76 { | |
77 var sender = getSender(message.target); | |
78 var request = message.data; | |
79 | |
80 var sent = false; | |
81 var sendResponse; | |
82 if (sender && "callbackId" in request) | |
83 { | |
84 sendResponse = function(message) | |
85 { | |
86 this._sendResponse(sender, request.callbackId, message); | |
87 sent = true; | |
88 }.bind(this); | |
89 } | |
90 else | |
91 sendResponse = function() {}; | |
92 | |
93 var results = this._messageTarget._dispatch(request.payload, { | |
94 page: new holder.Page(sender) | |
95 }, sendResponse); | |
96 if (!sent && results.indexOf(true) == -1) | |
97 sendResponse(undefined); | |
98 }, | |
99 | |
100 _handleResponse: function(message) | |
101 { | |
102 var response = message.data; | |
103 var callback = this._callbacks.get(response.callbackId); | |
104 if (callback) | |
105 { | |
106 this._callbacks.delete(response.callbackId); | |
107 if ("payload" in response) | |
108 callback(response.payload); | |
109 } | |
110 }, | |
111 | |
112 sendMessage: function(message, responseCallback) | |
113 { | |
114 if (!(this._messageManager instanceof Ci.nsIMessageSender)) | |
115 throw new Error("Not implemented"); | |
116 | |
117 var request = { | |
118 payload: message | |
119 }; | |
120 if (responseCallback) | |
121 { | |
122 request.callbackId = ++this._responseCallbackCounter; | |
123 this._callbacks.set(request.callbackId, responseCallback); | |
124 } | |
125 | |
126 this._messageManager.sendAsyncMessage("AdblockPlus:Message", request); | |
127 } | |
128 }; | |
129 | |
130 var EventTarget = global.ext._EventTarget = function() | |
131 { | |
132 this._listeners = []; | |
133 }; | 47 }; |
134 EventTarget.prototype = { | 48 EventTarget.prototype = { |
135 addListener: function(listener) | 49 addListener: function(listener) |
136 { | 50 { |
137 if (this._listeners.indexOf(listener) == -1) | 51 var wrapper = (message, sender) => |
Thomas Greiner
2016/04/18 13:22:50
Detail: I noticed that throughout this review you
Wladimir Palant
2016/04/18 15:28:56
The first-run page loads the files via usual <scri
Thomas Greiner
2016/04/18 17:47:14
Doesn't the same then also apply to `const`? (see
Wladimir Palant
2016/04/19 11:57:28
It doesn't, Firefox has been supporting const in "
| |
138 this._listeners.push(listener); | 52 { |
53 if (this._windowID && this._windowID != message.targetID) | |
54 return undefined; | |
55 | |
56 return new Promise((resolve, reject) => | |
57 { | |
58 var sender = {}; | |
59 if (message.senderID) | |
60 { | |
61 const Page = require("ext_background").Page; | |
Thomas Greiner
2016/04/18 13:22:50
Detail: I'm wondering why `Page` is in "ext_backgr
Wladimir Palant
2016/04/18 15:28:56
It's not shared functionality - pages only exist f
Thomas Greiner
2016/04/18 17:47:14
Ok, since this part of the code is only executed i
| |
62 sender.page = new Page(message.senderID); | |
63 } | |
64 if (message.frames) | |
65 sender.frame = wrapFrames(message.frames); | |
66 if (!listener(message.payload, sender, resolve)) | |
67 resolve(undefined); | |
68 }); | |
69 }; | |
70 listener._ext_wrapper = wrapper; | |
Thomas Greiner
2016/04/18 13:22:50
Detail: This property name is not in accordance to
Wladimir Palant
2016/04/18 15:28:56
Done.
| |
71 this._port.on("ext_message", wrapper); | |
139 }, | 72 }, |
73 | |
140 removeListener: function(listener) | 74 removeListener: function(listener) |
141 { | 75 { |
142 var idx = this._listeners.indexOf(listener); | 76 if (listener._ext_wrapper) |
143 if (idx != -1) | 77 this._port.off("ext_message", listener._ext_wrapper); |
144 this._listeners.splice(idx, 1); | |
145 }, | |
146 _dispatch: function() | |
147 { | |
148 var results = []; | |
149 | |
150 for (var i = 0; i < this._listeners.length; i++) | |
151 results.push(this._listeners[i].apply(null, arguments)); | |
152 | |
153 return results; | |
154 } | 78 } |
155 }; | 79 }; |
156 | 80 |
157 if (typeof exports == "object") | 81 if (typeof exports == "object") |
158 exports = global.ext; | 82 exports = global.ext; |
159 })(this); | 83 })(this); |
OLD | NEW |