OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "chrome/renderer/extensions/event_bindings.h" | 5 #include "chrome/renderer/extensions/event_bindings.h" |
6 | 6 |
7 #include <vector> | 7 #include <vector> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 | 63 |
64 // A map of extension IDs to filtered listener counts for that extension. | 64 // A map of extension IDs to filtered listener counts for that extension. |
65 base::LazyInstance<std::map<std::string, FilteredEventListenerCounts> > | 65 base::LazyInstance<std::map<std::string, FilteredEventListenerCounts> > |
66 g_filtered_listener_counts = LAZY_INSTANCE_INITIALIZER; | 66 g_filtered_listener_counts = LAZY_INSTANCE_INITIALIZER; |
67 | 67 |
68 base::LazyInstance<EventFilter> g_event_filter = LAZY_INSTANCE_INITIALIZER; | 68 base::LazyInstance<EventFilter> g_event_filter = LAZY_INSTANCE_INITIALIZER; |
69 | 69 |
70 // TODO(koz): Merge this into EventBindings. | 70 // TODO(koz): Merge this into EventBindings. |
71 class ExtensionImpl : public ChromeV8Extension { | 71 class ExtensionImpl : public ChromeV8Extension { |
72 public: | 72 public: |
73 explicit ExtensionImpl(Dispatcher* dispatcher, | 73 explicit ExtensionImpl(Dispatcher* dispatcher, ChromeV8Context* context) |
74 v8::Handle<v8::Context> v8_context) | 74 : ChromeV8Extension(dispatcher, context) { |
75 : ChromeV8Extension(dispatcher, v8_context) { | |
76 RouteFunction("AttachEvent", | 75 RouteFunction("AttachEvent", |
77 base::Bind(&ExtensionImpl::AttachEvent, base::Unretained(this))); | 76 base::Bind(&ExtensionImpl::AttachEvent, base::Unretained(this))); |
78 RouteFunction("DetachEvent", | 77 RouteFunction("DetachEvent", |
79 base::Bind(&ExtensionImpl::DetachEvent, base::Unretained(this))); | 78 base::Bind(&ExtensionImpl::DetachEvent, base::Unretained(this))); |
80 RouteFunction("AttachFilteredEvent", | 79 RouteFunction("AttachFilteredEvent", |
81 base::Bind(&ExtensionImpl::AttachFilteredEvent, | 80 base::Bind(&ExtensionImpl::AttachFilteredEvent, |
82 base::Unretained(this))); | 81 base::Unretained(this))); |
83 RouteFunction("DetachFilteredEvent", | 82 RouteFunction("DetachFilteredEvent", |
84 base::Bind(&ExtensionImpl::DetachFilteredEvent, | 83 base::Bind(&ExtensionImpl::DetachFilteredEvent, |
85 base::Unretained(this))); | 84 base::Unretained(this))); |
86 RouteFunction("MatchAgainstEventFilter", | 85 RouteFunction("MatchAgainstEventFilter", |
87 base::Bind(&ExtensionImpl::MatchAgainstEventFilter, | 86 base::Bind(&ExtensionImpl::MatchAgainstEventFilter, |
88 base::Unretained(this))); | 87 base::Unretained(this))); |
89 } | 88 } |
90 | 89 |
91 virtual ~ExtensionImpl() {} | 90 virtual ~ExtensionImpl() {} |
92 | 91 |
93 // Attach an event name to an object. | 92 // Attach an event name to an object. |
94 v8::Handle<v8::Value> AttachEvent(const v8::Arguments& args) { | 93 v8::Handle<v8::Value> AttachEvent(const v8::Arguments& args) { |
95 DCHECK(args.Length() == 1); | 94 DCHECK(args.Length() == 1); |
96 // TODO(erikkay) should enforce that event name is a string in the bindings | 95 // TODO(erikkay) should enforce that event name is a string in the bindings |
97 DCHECK(args[0]->IsString() || args[0]->IsUndefined()); | 96 DCHECK(args[0]->IsString() || args[0]->IsUndefined()); |
98 | 97 |
99 if (args[0]->IsString()) { | 98 if (args[0]->IsString()) { |
100 std::string event_name = *v8::String::AsciiValue(args[0]->ToString()); | 99 std::string event_name = *v8::String::AsciiValue(args[0]->ToString()); |
101 const ChromeV8ContextSet& context_set = dispatcher_->v8_context_set(); | 100 CHECK(context()); |
102 ChromeV8Context* context = context_set.GetByV8Context(v8_context()); | |
103 CHECK(context); | |
104 | 101 |
105 if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context)) | 102 if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context())) |
106 return v8::Undefined(); | 103 return v8::Undefined(); |
107 | 104 |
108 std::string extension_id = context->GetExtensionID(); | 105 std::string extension_id = context()->GetExtensionID(); |
109 EventListenerCounts& listener_counts = | 106 EventListenerCounts& listener_counts = |
110 g_listener_counts.Get()[extension_id]; | 107 g_listener_counts.Get()[extension_id]; |
111 if (++listener_counts[event_name] == 1) { | 108 if (++listener_counts[event_name] == 1) { |
112 content::RenderThread::Get()->Send( | 109 content::RenderThread::Get()->Send( |
113 new ExtensionHostMsg_AddListener(extension_id, event_name)); | 110 new ExtensionHostMsg_AddListener(extension_id, event_name)); |
114 } | 111 } |
115 | 112 |
116 // This is called the first time the page has added a listener. Since | 113 // This is called the first time the page has added a listener. Since |
117 // the background page is the only lazy page, we know this is the first | 114 // the background page is the only lazy page, we know this is the first |
118 // time this listener has been registered. | 115 // time this listener has been registered. |
119 if (IsLazyBackgroundPage(GetRenderView(), context->extension())) { | 116 if (IsLazyBackgroundPage(GetRenderView(), context()->extension())) { |
120 content::RenderThread::Get()->Send( | 117 content::RenderThread::Get()->Send( |
121 new ExtensionHostMsg_AddLazyListener(extension_id, event_name)); | 118 new ExtensionHostMsg_AddLazyListener(extension_id, event_name)); |
122 } | 119 } |
123 } | 120 } |
124 return v8::Undefined(); | 121 return v8::Undefined(); |
125 } | 122 } |
126 | 123 |
127 v8::Handle<v8::Value> DetachEvent(const v8::Arguments& args) { | 124 v8::Handle<v8::Value> DetachEvent(const v8::Arguments& args) { |
128 DCHECK(args.Length() == 2); | 125 DCHECK(args.Length() == 2); |
129 // TODO(erikkay) should enforce that event name is a string in the bindings | 126 // TODO(erikkay) should enforce that event name is a string in the bindings |
130 DCHECK(args[0]->IsString() || args[0]->IsUndefined()); | 127 DCHECK(args[0]->IsString() || args[0]->IsUndefined()); |
131 | 128 |
132 if (args[0]->IsString() && args[1]->IsBoolean()) { | 129 if (args[0]->IsString() && args[1]->IsBoolean()) { |
133 std::string event_name = *v8::String::AsciiValue(args[0]->ToString()); | 130 std::string event_name = *v8::String::AsciiValue(args[0]->ToString()); |
134 bool is_manual = args[1]->BooleanValue(); | 131 bool is_manual = args[1]->BooleanValue(); |
135 | 132 |
136 const ChromeV8ContextSet& context_set = dispatcher_->v8_context_set(); | 133 if (!context()) |
137 ChromeV8Context* context = context_set.GetByV8Context(v8_context()); | |
138 if (!context) | |
139 return v8::Undefined(); | 134 return v8::Undefined(); |
140 | 135 |
141 std::string extension_id = context->GetExtensionID(); | 136 std::string extension_id = context()->GetExtensionID(); |
142 EventListenerCounts& listener_counts = | 137 EventListenerCounts& listener_counts = |
143 g_listener_counts.Get()[extension_id]; | 138 g_listener_counts.Get()[extension_id]; |
144 | 139 |
145 if (--listener_counts[event_name] == 0) { | 140 if (--listener_counts[event_name] == 0) { |
146 content::RenderThread::Get()->Send( | 141 content::RenderThread::Get()->Send( |
147 new ExtensionHostMsg_RemoveListener(extension_id, event_name)); | 142 new ExtensionHostMsg_RemoveListener(extension_id, event_name)); |
148 } | 143 } |
149 | 144 |
150 // DetachEvent is called when the last listener for the context is | 145 // DetachEvent is called when the last listener for the context is |
151 // removed. If the context is the background page, and it removes the | 146 // removed. If the context is the background page, and it removes the |
152 // last listener manually, then we assume that it is no longer interested | 147 // last listener manually, then we assume that it is no longer interested |
153 // in being awakened for this event. | 148 // in being awakened for this event. |
154 if (is_manual && IsLazyBackgroundPage(GetRenderView(), | 149 if (is_manual && IsLazyBackgroundPage(GetRenderView(), |
155 context->extension())) { | 150 context()->extension())) { |
156 content::RenderThread::Get()->Send( | 151 content::RenderThread::Get()->Send( |
157 new ExtensionHostMsg_RemoveLazyListener(extension_id, event_name)); | 152 new ExtensionHostMsg_RemoveLazyListener(extension_id, event_name)); |
158 } | 153 } |
159 } | 154 } |
160 return v8::Undefined(); | 155 return v8::Undefined(); |
161 } | 156 } |
162 | 157 |
163 // MatcherID AttachFilteredEvent(string event_name, object filter) | 158 // MatcherID AttachFilteredEvent(string event_name, object filter) |
164 // event_name - Name of the event to attach. | 159 // event_name - Name of the event to attach. |
165 // filter - Which instances of the named event are we interested in. | 160 // filter - Which instances of the named event are we interested in. |
166 // returns the id assigned to the listener, which will be returned from calls | 161 // returns the id assigned to the listener, which will be returned from calls |
167 // to MatchAgainstEventFilter where this listener matches. | 162 // to MatchAgainstEventFilter where this listener matches. |
168 v8::Handle<v8::Value> AttachFilteredEvent(const v8::Arguments& args) { | 163 v8::Handle<v8::Value> AttachFilteredEvent(const v8::Arguments& args) { |
169 DCHECK_EQ(2, args.Length()); | 164 DCHECK_EQ(2, args.Length()); |
170 DCHECK(args[0]->IsString()); | 165 DCHECK(args[0]->IsString()); |
171 DCHECK(args[1]->IsObject()); | 166 DCHECK(args[1]->IsObject()); |
172 | 167 |
173 const ChromeV8ContextSet& context_set = dispatcher_->v8_context_set(); | 168 DCHECK(context()); |
174 ChromeV8Context* context = context_set.GetByV8Context(v8_context()); | 169 if (!context()) |
175 DCHECK(context); | |
176 if (!context) | |
177 return v8::Integer::New(-1); | 170 return v8::Integer::New(-1); |
178 | 171 |
179 std::string event_name = *v8::String::AsciiValue(args[0]); | 172 std::string event_name = *v8::String::AsciiValue(args[0]); |
180 // This method throws an exception if it returns false. | 173 // This method throws an exception if it returns false. |
181 if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context)) | 174 if (!dispatcher_->CheckContextAccessToExtensionAPI(event_name, context())) |
182 return v8::Undefined(); | 175 return v8::Undefined(); |
183 | 176 |
184 std::string extension_id = context->GetExtensionID(); | 177 std::string extension_id = context()->GetExtensionID(); |
185 if (extension_id.empty()) | 178 if (extension_id.empty()) |
186 return v8::Integer::New(-1); | 179 return v8::Integer::New(-1); |
187 | 180 |
188 scoped_ptr<base::DictionaryValue> filter; | 181 scoped_ptr<base::DictionaryValue> filter; |
189 scoped_ptr<content::V8ValueConverter> converter( | 182 scoped_ptr<content::V8ValueConverter> converter( |
190 content::V8ValueConverter::create()); | 183 content::V8ValueConverter::create()); |
191 | 184 |
192 base::DictionaryValue* filter_dict = NULL; | 185 base::DictionaryValue* filter_dict = NULL; |
193 base::Value* filter_value = | 186 base::Value* filter_value = |
194 converter->FromV8Value(args[1]->ToObject(), context->v8_context()); | 187 converter->FromV8Value(args[1]->ToObject(), context()->v8_context()); |
195 if (!filter_value) | 188 if (!filter_value) |
196 return v8::Integer::New(-1); | 189 return v8::Integer::New(-1); |
197 if (!filter_value->GetAsDictionary(&filter_dict)) { | 190 if (!filter_value->GetAsDictionary(&filter_dict)) { |
198 delete filter_value; | 191 delete filter_value; |
199 return v8::Integer::New(-1); | 192 return v8::Integer::New(-1); |
200 } | 193 } |
201 | 194 |
202 filter.reset(filter_dict); | 195 filter.reset(filter_dict); |
203 EventFilter& event_filter = g_event_filter.Get(); | 196 EventFilter& event_filter = g_event_filter.Get(); |
204 int id = event_filter.AddEventMatcher(event_name, ParseEventMatcher( | 197 int id = event_filter.AddEventMatcher(event_name, ParseEventMatcher( |
205 filter.get())); | 198 filter.get())); |
206 | 199 |
207 // Only send IPCs the first time a filter gets added. | 200 // Only send IPCs the first time a filter gets added. |
208 if (AddFilter(event_name, extension_id, filter.get())) { | 201 if (AddFilter(event_name, extension_id, filter.get())) { |
209 bool lazy = IsLazyBackgroundPage(GetRenderView(), context->extension()); | 202 bool lazy = IsLazyBackgroundPage(GetRenderView(), context()->extension()); |
210 content::RenderThread::Get()->Send( | 203 content::RenderThread::Get()->Send( |
211 new ExtensionHostMsg_AddFilteredListener(extension_id, event_name, | 204 new ExtensionHostMsg_AddFilteredListener(extension_id, event_name, |
212 *filter, lazy)); | 205 *filter, lazy)); |
213 } | 206 } |
214 | 207 |
215 return v8::Integer::New(id); | 208 return v8::Integer::New(id); |
216 } | 209 } |
217 | 210 |
218 // Add a filter to |event_name| in |extension_id|, returning true if it | 211 // Add a filter to |event_name| in |extension_id|, returning true if it |
219 // was the first filter for that event in that extension. | 212 // was the first filter for that event in that extension. |
(...skipping 25 matching lines...) Expand all Loading... |
245 | 238 |
246 // void DetachFilteredEvent(int id, bool manual) | 239 // void DetachFilteredEvent(int id, bool manual) |
247 // id - Id of the event to detach. | 240 // id - Id of the event to detach. |
248 // manual - false if this is part of the extension unload process where all | 241 // manual - false if this is part of the extension unload process where all |
249 // listeners are automatically detached. | 242 // listeners are automatically detached. |
250 v8::Handle<v8::Value> DetachFilteredEvent(const v8::Arguments& args) { | 243 v8::Handle<v8::Value> DetachFilteredEvent(const v8::Arguments& args) { |
251 DCHECK_EQ(2, args.Length()); | 244 DCHECK_EQ(2, args.Length()); |
252 DCHECK(args[0]->IsInt32()); | 245 DCHECK(args[0]->IsInt32()); |
253 DCHECK(args[1]->IsBoolean()); | 246 DCHECK(args[1]->IsBoolean()); |
254 bool is_manual = args[1]->BooleanValue(); | 247 bool is_manual = args[1]->BooleanValue(); |
255 const ChromeV8ContextSet& context_set = dispatcher_->v8_context_set(); | 248 if (!context()) |
256 ChromeV8Context* context = context_set.GetByV8Context(v8_context()); | |
257 if (!context) | |
258 return v8::Undefined(); | 249 return v8::Undefined(); |
259 | 250 |
260 std::string extension_id = context->GetExtensionID(); | 251 std::string extension_id = context()->GetExtensionID(); |
261 if (extension_id.empty()) | 252 if (extension_id.empty()) |
262 return v8::Undefined(); | 253 return v8::Undefined(); |
263 | 254 |
264 int matcher_id = args[0]->Int32Value(); | 255 int matcher_id = args[0]->Int32Value(); |
265 EventFilter& event_filter = g_event_filter.Get(); | 256 EventFilter& event_filter = g_event_filter.Get(); |
266 EventMatcher* event_matcher = | 257 EventMatcher* event_matcher = |
267 event_filter.GetEventMatcher(matcher_id); | 258 event_filter.GetEventMatcher(matcher_id); |
268 | 259 |
269 const std::string& event_name = event_filter.GetEventName(matcher_id); | 260 const std::string& event_name = event_filter.GetEventName(matcher_id); |
270 | 261 |
271 // Only send IPCs the last time a filter gets removed. | 262 // Only send IPCs the last time a filter gets removed. |
272 if (RemoveFilter(event_name, extension_id, event_matcher->value())) { | 263 if (RemoveFilter(event_name, extension_id, event_matcher->value())) { |
273 bool lazy = is_manual && IsLazyBackgroundPage(GetRenderView(), | 264 bool lazy = is_manual && IsLazyBackgroundPage(GetRenderView(), |
274 context->extension()); | 265 context()->extension()); |
275 content::RenderThread::Get()->Send( | 266 content::RenderThread::Get()->Send( |
276 new ExtensionHostMsg_RemoveFilteredListener(extension_id, event_name, | 267 new ExtensionHostMsg_RemoveFilteredListener(extension_id, event_name, |
277 *event_matcher->value(), | 268 *event_matcher->value(), |
278 lazy)); | 269 lazy)); |
279 } | 270 } |
280 | 271 |
281 event_filter.RemoveEventMatcher(matcher_id); | 272 event_filter.RemoveEventMatcher(matcher_id); |
282 | 273 |
283 return v8::Undefined(); | 274 return v8::Undefined(); |
284 } | 275 } |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
324 base::DictionaryValue* filter_dict) { | 315 base::DictionaryValue* filter_dict) { |
325 return scoped_ptr<EventMatcher>(new EventMatcher( | 316 return scoped_ptr<EventMatcher>(new EventMatcher( |
326 scoped_ptr<base::DictionaryValue>(filter_dict->DeepCopy()))); | 317 scoped_ptr<base::DictionaryValue>(filter_dict->DeepCopy()))); |
327 } | 318 } |
328 }; | 319 }; |
329 | 320 |
330 } // namespace | 321 } // namespace |
331 | 322 |
332 // static | 323 // static |
333 ChromeV8Extension* EventBindings::Create(Dispatcher* dispatcher, | 324 ChromeV8Extension* EventBindings::Create(Dispatcher* dispatcher, |
334 v8::Handle<v8::Context> context) { | 325 ChromeV8Context* context) { |
335 return new ExtensionImpl(dispatcher, context); | 326 return new ExtensionImpl(dispatcher, context); |
336 } | 327 } |
337 | 328 |
338 } // namespace extensions | 329 } // namespace extensions |
OLD | NEW |