OLD | NEW |
1 // This file is generated | 1 // This file is generated |
2 | 2 |
3 // Copyright (c) 2016 The Chromium Authors. All rights reserved. | 3 // Copyright (c) 2016 The Chromium Authors. All rights reserved. |
4 // Use of this source code is governed by a BSD-style license that can be | 4 // Use of this source code is governed by a BSD-style license that can be |
5 // found in the LICENSE file. | 5 // found in the LICENSE file. |
6 | 6 |
7 #include "platform/inspector_protocol/{{class_name}}.h" | 7 #include "platform/inspector_protocol/{{class_name}}.h" |
8 | 8 |
9 #include "platform/inspector_protocol/Collections.h" | 9 #include "platform/inspector_protocol/Collections.h" |
10 #include "platform/inspector_protocol/FrontendChannel.h" | 10 #include "platform/inspector_protocol/FrontendChannel.h" |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
63 m_weakPtrs.clear(); | 63 m_weakPtrs.clear(); |
64 } | 64 } |
65 | 65 |
66 PassOwnPtr<DispatcherImplWeakPtr> weakPtr() | 66 PassOwnPtr<DispatcherImplWeakPtr> weakPtr() |
67 { | 67 { |
68 OwnPtr<DispatcherImplWeakPtr> weak = adoptPtr(new DispatcherImplWeakPtr(
this)); | 68 OwnPtr<DispatcherImplWeakPtr> weak = adoptPtr(new DispatcherImplWeakPtr(
this)); |
69 m_weakPtrs.add(weak.get()); | 69 m_weakPtrs.add(weak.get()); |
70 return weak.release(); | 70 return weak.release(); |
71 } | 71 } |
72 | 72 |
73 virtual void dispatch(int sessionId, const String& message); | 73 virtual void dispatch(int sessionId, const String16& message); |
74 virtual void reportProtocolError(int sessionId, int callId, CommonErrorCode,
const String& errorMessage, ErrorSupport* errors) const; | 74 virtual void reportProtocolError(int sessionId, int callId, CommonErrorCode,
const String16& errorMessage, ErrorSupport* errors) const; |
75 using Dispatcher::reportProtocolError; | 75 using Dispatcher::reportProtocolError; |
76 | 76 |
77 void sendResponse(int sessionId, int callId, const ErrorString& invocationEr
ror, ErrorSupport* errors, PassOwnPtr<protocol::DictionaryValue> result); | 77 void sendResponse(int sessionId, int callId, const ErrorString& invocationEr
ror, ErrorSupport* errors, PassOwnPtr<protocol::DictionaryValue> result); |
78 | 78 |
79 {% for domain in api.domains %} | 79 {% for domain in api.domains %} |
80 virtual void registerAgent({{domain.domain}}CommandHandler* agent) { ASSERT(
!m_{{domain.domain | lower}}Agent); m_{{domain.domain | lower}}Agent = agent; } | 80 virtual void registerAgent({{domain.domain}}CommandHandler* agent) { ASSERT(
!m_{{domain.domain | lower}}Agent); m_{{domain.domain | lower}}Agent = agent; } |
81 {% endfor %} | 81 {% endfor %} |
82 | 82 |
83 private: | 83 private: |
84 friend class CallbackBase; | 84 friend class CallbackBase; |
85 friend class DispatcherImplWeakPtr; | 85 friend class DispatcherImplWeakPtr; |
86 using CallHandler = void (DispatcherImpl::*)(int sessionId, int callId, Pass
OwnPtr<DictionaryValue> messageObject, ErrorSupport* errors); | 86 using CallHandler = void (DispatcherImpl::*)(int sessionId, int callId, Pass
OwnPtr<DictionaryValue> messageObject, ErrorSupport* errors); |
87 using DispatchMap = protocol::HashMap<String, CallHandler>; | 87 using DispatchMap = protocol::HashMap<String16, CallHandler>; |
88 | 88 |
89 {% for domain in api.domains %} | 89 {% for domain in api.domains %} |
90 {% for command in domain.commands %} | 90 {% for command in domain.commands %} |
91 {% if "redirect" in command %}{% continue %}{% endif %} | 91 {% if "redirect" in command %}{% continue %}{% endif %} |
92 {% if "handlers" in command and not ("renderer" in command["handlers"]) %}{%
continue %}{% endif %} | 92 {% if "handlers" in command and not ("renderer" in command["handlers"]) %}{%
continue %}{% endif %} |
93 void {{domain.domain}}_{{command.name}}(int sessionId, int callId, PassOwnPt
r<DictionaryValue> requestMessageObject, ErrorSupport*); | 93 void {{domain.domain}}_{{command.name}}(int sessionId, int callId, PassOwnPt
r<DictionaryValue> requestMessageObject, ErrorSupport*); |
94 {% endfor %} | 94 {% endfor %} |
95 {% endfor %} | 95 {% endfor %} |
96 | 96 |
97 FrontendChannel* m_frontendChannel; | 97 FrontendChannel* m_frontendChannel; |
98 | 98 |
99 {% for domain in api.domains %} | 99 {% for domain in api.domains %} |
100 {{domain.domain}}CommandHandler* m_{{domain.domain | lower}}Agent; | 100 {{domain.domain}}CommandHandler* m_{{domain.domain | lower}}Agent; |
101 {% endfor %} | 101 {% endfor %} |
102 | 102 |
103 void sendResponse(int sessionId, int callId, ErrorString invocationError, Pa
ssOwnPtr<protocol::DictionaryValue> result) | 103 void sendResponse(int sessionId, int callId, ErrorString invocationError, Pa
ssOwnPtr<protocol::DictionaryValue> result) |
104 { | 104 { |
105 sendResponse(sessionId, callId, invocationError, nullptr, result); | 105 sendResponse(sessionId, callId, invocationError, nullptr, result); |
106 } | 106 } |
107 | 107 |
108 void sendResponse(int sessionId, int callId, ErrorString invocationError) | 108 void sendResponse(int sessionId, int callId, ErrorString invocationError) |
109 { | 109 { |
110 sendResponse(sessionId, callId, invocationError, nullptr, DictionaryValu
e::create()); | 110 sendResponse(sessionId, callId, invocationError, nullptr, DictionaryValu
e::create()); |
111 } | 111 } |
112 | 112 |
113 static const char InvalidParamsFormatString[]; | 113 static const char kInvalidRequest[]; |
114 | 114 |
115 DispatchMap m_dispatchMap; | 115 DispatchMap m_dispatchMap; |
116 protocol::Vector<int> m_commonErrors; | 116 protocol::Vector<int> m_commonErrors; |
117 protocol::HashSet<DispatcherImplWeakPtr*> m_weakPtrs; | 117 protocol::HashSet<DispatcherImplWeakPtr*> m_weakPtrs; |
118 }; | 118 }; |
119 | 119 |
120 DispatcherImplWeakPtr::~DispatcherImplWeakPtr() | 120 DispatcherImplWeakPtr::~DispatcherImplWeakPtr() |
121 { | 121 { |
122 if (m_dispatcher) | 122 if (m_dispatcher) |
123 m_dispatcher->m_weakPtrs.remove(this); | 123 m_dispatcher->m_weakPtrs.remove(this); |
124 } | 124 } |
125 | 125 |
126 const char DispatcherImpl::InvalidParamsFormatString[] = "Some arguments of meth
od '%s' can't be processed"; | 126 const char DispatcherImpl::kInvalidRequest[] = "Invalid request"; |
| 127 |
127 {% for domain in api.domains %} | 128 {% for domain in api.domains %} |
128 {% for command in domain.commands %} | 129 {% for command in domain.commands %} |
129 {% if "redirect" in command %}{% continue %}{% endif %} | 130 {% if "redirect" in command %}{% continue %}{% endif %} |
130 {% if "handlers" in command and not ("renderer" in command["handlers"]) %}{%
continue %}{% endif %} | 131 {% if "handlers" in command and not ("renderer" in command["handlers"]) %}{%
continue %}{% endif %} |
131 | 132 |
132 {% if "async" in command %} | 133 {% if "async" in command %} |
133 Dispatcher::{{domain.domain}}CommandHandler::{{command.name | to_title_case}}Cal
lback::{{command.name | to_title_case}}Callback(PassOwnPtr<DispatcherImplWeakPtr
> backendImpl, int sessionId, int id) : CallbackBase(backendImpl, sessionId, id)
{ } | 134 Dispatcher::{{domain.domain}}CommandHandler::{{command.name | to_title_case}}Cal
lback::{{command.name | to_title_case}}Callback(PassOwnPtr<DispatcherImplWeakPtr
> backendImpl, int sessionId, int id) : CallbackBase(backendImpl, sessionId, id)
{ } |
134 | 135 |
135 void Dispatcher::{{domain.domain}}CommandHandler::{{command.name | to_title_case
}}Callback::sendSuccess( | 136 void Dispatcher::{{domain.domain}}CommandHandler::{{command.name | to_title_case
}}Callback::sendSuccess( |
136 {%- for parameter in command.returns -%} | 137 {%- for parameter in command.returns -%} |
(...skipping 17 matching lines...) Expand all Loading... |
154 sendIfActive(resultObject.release(), ErrorString()); | 155 sendIfActive(resultObject.release(), ErrorString()); |
155 } | 156 } |
156 {% endif %} | 157 {% endif %} |
157 | 158 |
158 void DispatcherImpl::{{domain.domain}}_{{command.name}}(int sessionId, int callI
d, PassOwnPtr<DictionaryValue> requestMessageObject, ErrorSupport* errors) | 159 void DispatcherImpl::{{domain.domain}}_{{command.name}}(int sessionId, int callI
d, PassOwnPtr<DictionaryValue> requestMessageObject, ErrorSupport* errors) |
159 { | 160 { |
160 if (!m_{{domain.domain | lower}}Agent) | 161 if (!m_{{domain.domain | lower}}Agent) |
161 errors->addError("{{domain.domain}} handler is not available."); | 162 errors->addError("{{domain.domain}} handler is not available."); |
162 | 163 |
163 if (errors->hasErrors()) { | 164 if (errors->hasErrors()) { |
164 reportProtocolError(sessionId, callId, InvalidParams, String::format(Inv
alidParamsFormatString, "{{domain.domain}}.{{command.name}}"), errors); | 165 reportProtocolError(sessionId, callId, InvalidParams, kInvalidRequest, e
rrors); |
165 return; | 166 return; |
166 } | 167 } |
167 {% if "parameters" in command %} | 168 {% if "parameters" in command %} |
168 | 169 |
169 // Prepare input parameters. | 170 // Prepare input parameters. |
170 protocol::DictionaryValue* object = DictionaryValue::cast(requestMessageObje
ct->get("params")); | 171 protocol::DictionaryValue* object = DictionaryValue::cast(requestMessageObje
ct->get("params")); |
171 errors->push(); | 172 errors->push(); |
172 {% for property in command.parameters %} | 173 {% for property in command.parameters %} |
173 protocol::Value* {{property.name}}Value = object ? object->get("{{property.n
ame}}") : nullptr; | 174 protocol::Value* {{property.name}}Value = object ? object->get("{{property.n
ame}}") : nullptr; |
174 {% if property.optional %} | 175 {% if property.optional %} |
175 Maybe<{{resolve_type(property).raw_type}}> in_{{property.name}}; | 176 Maybe<{{resolve_type(property).raw_type}}> in_{{property.name}}; |
176 if ({{property.name}}Value) { | 177 if ({{property.name}}Value) { |
177 errors->setName("{{property.name}}"); | 178 errors->setName("{{property.name}}"); |
178 in_{{property.name}} = FromValue<{{resolve_type(property).raw_type}}>::p
arse({{property.name}}Value, errors); | 179 in_{{property.name}} = FromValue<{{resolve_type(property).raw_type}}>::p
arse({{property.name}}Value, errors); |
179 } | 180 } |
180 {% else %} | 181 {% else %} |
181 errors->setName("{{property.name}}"); | 182 errors->setName("{{property.name}}"); |
182 {{resolve_type(property).type}} in_{{property.name}} = FromValue<{{resolve_t
ype(property).raw_type}}>::parse({{property.name}}Value, errors); | 183 {{resolve_type(property).type}} in_{{property.name}} = FromValue<{{resolve_t
ype(property).raw_type}}>::parse({{property.name}}Value, errors); |
183 {% endif %} | 184 {% endif %} |
184 {% endfor %} | 185 {% endfor %} |
185 errors->pop(); | 186 errors->pop(); |
186 if (errors->hasErrors()) { | 187 if (errors->hasErrors()) { |
187 reportProtocolError(sessionId, callId, InvalidParams, String::format(Inv
alidParamsFormatString, "{{domain.domain}}.{{command.name}}"), errors); | 188 reportProtocolError(sessionId, callId, InvalidParams, kInvalidRequest, e
rrors); |
188 return; | 189 return; |
189 } | 190 } |
190 {% endif %} | 191 {% endif %} |
191 | 192 |
192 {% if "async" in command %} | 193 {% if "async" in command %} |
193 OwnPtr<{{domain.domain}}CommandHandler::{{command.name | to_title_case}}Call
back> callback = adoptPtr(new {{domain.domain}}CommandHandler::{{command.name |
to_title_case}}Callback(weakPtr(), sessionId, callId)); | 194 OwnPtr<{{domain.domain}}CommandHandler::{{command.name | to_title_case}}Call
back> callback = adoptPtr(new {{domain.domain}}CommandHandler::{{command.name |
to_title_case}}Callback(weakPtr(), sessionId, callId)); |
194 {% elif "returns" in command %} | 195 {% elif "returns" in command %} |
195 // Declare output parameters. | 196 // Declare output parameters. |
196 OwnPtr<protocol::DictionaryValue> result = DictionaryValue::create(); | 197 OwnPtr<protocol::DictionaryValue> result = DictionaryValue::create(); |
197 {% for property in command.returns %} | 198 {% for property in command.returns %} |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
239 {% endif %} | 240 {% endif %} |
240 } | 241 } |
241 {% endfor %} | 242 {% endfor %} |
242 {% endfor %} | 243 {% endfor %} |
243 | 244 |
244 PassOwnPtr<Dispatcher> Dispatcher::create(FrontendChannel* frontendChannel) | 245 PassOwnPtr<Dispatcher> Dispatcher::create(FrontendChannel* frontendChannel) |
245 { | 246 { |
246 return adoptPtr(new DispatcherImpl(frontendChannel)); | 247 return adoptPtr(new DispatcherImpl(frontendChannel)); |
247 } | 248 } |
248 | 249 |
249 void DispatcherImpl::dispatch(int sessionId, const String& message) | 250 void DispatcherImpl::dispatch(int sessionId, const String16& message) |
250 { | 251 { |
251 int callId = 0; | 252 int callId = 0; |
252 OwnPtr<protocol::Value> parsedMessage = parseJSON(message); | 253 OwnPtr<protocol::Value> parsedMessage = parseJSON(message); |
253 ASSERT(parsedMessage); | 254 ASSERT(parsedMessage); |
254 OwnPtr<protocol::DictionaryValue> messageObject = DictionaryValue::cast(pars
edMessage.release()); | 255 OwnPtr<protocol::DictionaryValue> messageObject = DictionaryValue::cast(pars
edMessage.release()); |
255 ASSERT(messageObject); | 256 ASSERT(messageObject); |
256 | 257 |
257 protocol::Value* callIdValue = messageObject->get("id"); | 258 protocol::Value* callIdValue = messageObject->get("id"); |
258 bool success = callIdValue->asNumber(&callId); | 259 bool success = callIdValue->asNumber(&callId); |
259 ASSERT_UNUSED(success, success); | 260 ASSERT_UNUSED(success, success); |
260 | 261 |
261 protocol::Value* methodValue = messageObject->get("method"); | 262 protocol::Value* methodValue = messageObject->get("method"); |
262 String method; | 263 String16 method; |
263 success = methodValue && methodValue->asString(&method); | 264 success = methodValue && methodValue->asString(&method); |
264 ASSERT_UNUSED(success, success); | 265 ASSERT_UNUSED(success, success); |
265 | 266 |
266 protocol::HashMap<String, CallHandler>::iterator it = m_dispatchMap.find(met
hod); | 267 protocol::HashMap<String16, CallHandler>::iterator it = m_dispatchMap.find(m
ethod); |
267 if (it == m_dispatchMap.end()) { | 268 if (it == m_dispatchMap.end()) { |
268 reportProtocolError(sessionId, callId, MethodNotFound, "'" + method + "'
wasn't found"); | 269 reportProtocolError(sessionId, callId, MethodNotFound, "'" + method + "'
wasn't found"); |
269 return; | 270 return; |
270 } | 271 } |
271 | 272 |
272 protocol::ErrorSupport errors; | 273 protocol::ErrorSupport errors; |
273 ((*this).*(*it->second))(sessionId, callId, messageObject.release(), &errors
); | 274 ((*this).*(*it->second))(sessionId, callId, messageObject.release(), &errors
); |
274 } | 275 } |
275 | 276 |
276 void DispatcherImpl::sendResponse(int sessionId, int callId, const ErrorString&
invocationError, ErrorSupport* errors, PassOwnPtr<protocol::DictionaryValue> res
ult) | 277 void DispatcherImpl::sendResponse(int sessionId, int callId, const ErrorString&
invocationError, ErrorSupport* errors, PassOwnPtr<protocol::DictionaryValue> res
ult) |
277 { | 278 { |
278 if (invocationError.length() || (errors && errors->hasErrors())) { | 279 if (invocationError.length() || (errors && errors->hasErrors())) { |
279 reportProtocolError(sessionId, callId, ServerError, invocationError, err
ors); | 280 reportProtocolError(sessionId, callId, ServerError, invocationError, err
ors); |
280 return; | 281 return; |
281 } | 282 } |
282 | 283 |
283 OwnPtr<protocol::DictionaryValue> responseMessage = DictionaryValue::create(
); | 284 OwnPtr<protocol::DictionaryValue> responseMessage = DictionaryValue::create(
); |
284 responseMessage->setNumber("id", callId); | 285 responseMessage->setNumber("id", callId); |
285 responseMessage->setObject("result", result); | 286 responseMessage->setObject("result", result); |
286 if (m_frontendChannel) | 287 if (m_frontendChannel) |
287 m_frontendChannel->sendProtocolResponse(sessionId, callId, responseMessa
ge.release()); | 288 m_frontendChannel->sendProtocolResponse(sessionId, callId, responseMessa
ge.release()); |
288 } | 289 } |
289 | 290 |
290 void Dispatcher::reportProtocolError(int sessionId, int callId, CommonErrorCode
code, const String& errorMessage) const | 291 void Dispatcher::reportProtocolError(int sessionId, int callId, CommonErrorCode
code, const String16& errorMessage) const |
291 { | 292 { |
292 ErrorSupport errors; | 293 ErrorSupport errors; |
293 reportProtocolError(sessionId, callId, code, errorMessage, &errors); | 294 reportProtocolError(sessionId, callId, code, errorMessage, &errors); |
294 } | 295 } |
295 | 296 |
296 void DispatcherImpl::reportProtocolError(int sessionId, int callId, CommonErrorC
ode code, const String& errorMessage, ErrorSupport* errors) const | 297 void DispatcherImpl::reportProtocolError(int sessionId, int callId, CommonErrorC
ode code, const String16& errorMessage, ErrorSupport* errors) const |
297 { | 298 { |
298 ASSERT(code >=0); | 299 ASSERT(code >=0); |
299 ASSERT((unsigned)code < m_commonErrors.size()); | 300 ASSERT((unsigned)code < m_commonErrors.size()); |
300 ASSERT(m_commonErrors[code]); | 301 ASSERT(m_commonErrors[code]); |
301 OwnPtr<protocol::DictionaryValue> error = DictionaryValue::create(); | 302 OwnPtr<protocol::DictionaryValue> error = DictionaryValue::create(); |
302 error->setNumber("code", m_commonErrors[code]); | 303 error->setNumber("code", m_commonErrors[code]); |
303 error->setString("message", errorMessage); | 304 error->setString("message", errorMessage); |
304 ASSERT(error); | 305 ASSERT(error); |
305 if (errors && errors->hasErrors()) | 306 if (errors && errors->hasErrors()) |
306 error->setString("data", errors->errors()); | 307 error->setString("data", errors->errors()); |
307 OwnPtr<protocol::DictionaryValue> message = DictionaryValue::create(); | 308 OwnPtr<protocol::DictionaryValue> message = DictionaryValue::create(); |
308 message->setObject("error", error.release()); | 309 message->setObject("error", error.release()); |
309 message->setNumber("id", callId); | 310 message->setNumber("id", callId); |
310 if (m_frontendChannel) | 311 if (m_frontendChannel) |
311 m_frontendChannel->sendProtocolResponse(sessionId, callId, message.relea
se()); | 312 m_frontendChannel->sendProtocolResponse(sessionId, callId, message.relea
se()); |
312 } | 313 } |
313 | 314 |
314 bool Dispatcher::getCommandName(const String& message, String* result) | 315 bool Dispatcher::getCommandName(const String16& message, String16* result) |
315 { | 316 { |
316 OwnPtr<protocol::Value> value = parseJSON(message); | 317 OwnPtr<protocol::Value> value = parseJSON(message); |
317 if (!value) | 318 if (!value) |
318 return false; | 319 return false; |
319 | 320 |
320 protocol::DictionaryValue* object = DictionaryValue::cast(value.get()); | 321 protocol::DictionaryValue* object = DictionaryValue::cast(value.get()); |
321 if (!object) | 322 if (!object) |
322 return false; | 323 return false; |
323 | 324 |
324 if (!object->getString("method", result)) | 325 if (!object->getString("method", result)) |
(...skipping 21 matching lines...) Expand all Loading... |
346 void Dispatcher::CallbackBase::sendIfActive(PassOwnPtr<protocol::DictionaryValue
> partialMessage, const ErrorString& invocationError) | 347 void Dispatcher::CallbackBase::sendIfActive(PassOwnPtr<protocol::DictionaryValue
> partialMessage, const ErrorString& invocationError) |
347 { | 348 { |
348 if (!m_backendImpl->get()) | 349 if (!m_backendImpl->get()) |
349 return; | 350 return; |
350 m_backendImpl->get()->sendResponse(m_sessionId, m_id, invocationError, nullp
tr, partialMessage); | 351 m_backendImpl->get()->sendResponse(m_sessionId, m_id, invocationError, nullp
tr, partialMessage); |
351 m_backendImpl = nullptr; | 352 m_backendImpl = nullptr; |
352 } | 353 } |
353 | 354 |
354 } // namespace protocol | 355 } // namespace protocol |
355 } // namespace blink | 356 } // namespace blink |
OLD | NEW |