Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1013)

Side by Side Diff: chrome/browser/extensions/api/cast_channel/cast_channel_api.cc

Issue 256333002: Revert of Implement argument validation for chrome.cast.channel.{open,send} (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 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/browser/extensions/api/cast_channel/cast_channel_api.h" 5 #include "chrome/browser/extensions/api/cast_channel/cast_channel_api.h"
6 6
7 #include <limits> 7 #include <limits>
8 8
9 #include "base/json/json_writer.h" 9 #include "base/json/json_writer.h"
10 #include "base/memory/scoped_ptr.h" 10 #include "base/memory/scoped_ptr.h"
(...skipping 262 matching lines...) Expand 10 before | Expand all | Expand 10 after
273 EXTENSION_FUNCTION_VALIDATE(params_.get()); 273 EXTENSION_FUNCTION_VALIDATE(params_.get());
274 // The connect_info parameter may be a string URL like cast:// or casts:// or 274 // The connect_info parameter may be a string URL like cast:// or casts:// or
275 // a ConnectInfo object. 275 // a ConnectInfo object.
276 std::string cast_url; 276 std::string cast_url;
277 switch (params_->connect_info->GetType()) { 277 switch (params_->connect_info->GetType()) {
278 case base::Value::TYPE_STRING: 278 case base::Value::TYPE_STRING:
279 CHECK(params_->connect_info->GetAsString(&cast_url)); 279 CHECK(params_->connect_info->GetAsString(&cast_url));
280 connect_info_.reset(new ConnectInfo); 280 connect_info_.reset(new ConnectInfo);
281 if (!ParseChannelUrl(GURL(cast_url), connect_info_.get())) { 281 if (!ParseChannelUrl(GURL(cast_url), connect_info_.get())) {
282 connect_info_.reset(); 282 connect_info_.reset();
283 SetError("Invalid Cast URL " + cast_url);
284 return false;
285 } 283 }
286 break; 284 break;
287 case base::Value::TYPE_DICTIONARY: 285 case base::Value::TYPE_DICTIONARY:
288 connect_info_ = ConnectInfo::FromValue(*(params_->connect_info)); 286 connect_info_ = ConnectInfo::FromValue(*(params_->connect_info));
289 break; 287 break;
290 default: 288 default:
291 break; 289 break;
292 } 290 }
293 if (!connect_info_.get()) { 291 if (connect_info_.get()) {
294 SetError("Invalid connect_info"); 292 channel_auth_ = connect_info_->auth;
295 return false; 293 ip_endpoint_.reset(ParseConnectInfo(*connect_info_));
294 return ip_endpoint_.get() != NULL;
296 } 295 }
297 channel_auth_ = connect_info_->auth; 296 return false;
298 ip_endpoint_.reset(ParseConnectInfo(*connect_info_));
299 if (!ip_endpoint_.get()) {
300 SetError("Invalid connect_info");
301 return false;
302 }
303 return true;
304 } 297 }
305 298
306 void CastChannelOpenFunction::AsyncWorkStart() { 299 void CastChannelOpenFunction::AsyncWorkStart() {
307 DCHECK(api_); 300 DCHECK(api_);
308 DCHECK(ip_endpoint_.get()); 301 DCHECK(ip_endpoint_.get());
309 scoped_ptr<CastSocket> socket = api_->CreateCastSocket( 302 scoped_ptr<CastSocket> socket = api_->CreateCastSocket(
310 extension_->id(), *ip_endpoint_, channel_auth_); 303 extension_->id(), *ip_endpoint_, channel_auth_);
311 new_channel_id_ = AddSocket(socket.release()); 304 new_channel_id_ = AddSocket(socket.release());
312 GetSocket(new_channel_id_)->Connect( 305 GetSocket(new_channel_id_)->Connect(
313 base::Bind(&CastChannelOpenFunction::OnOpen, this)); 306 base::Bind(&CastChannelOpenFunction::OnOpen, this));
314 } 307 }
315 308
316 void CastChannelOpenFunction::OnOpen(int result) { 309 void CastChannelOpenFunction::OnOpen(int result) {
317 DCHECK_CURRENTLY_ON(BrowserThread::IO); 310 DCHECK_CURRENTLY_ON(BrowserThread::IO);
318 SetResultFromSocket(new_channel_id_); 311 SetResultFromSocket(new_channel_id_);
319 AsyncWorkCompleted(); 312 AsyncWorkCompleted();
320 } 313 }
321 314
322 CastChannelSendFunction::CastChannelSendFunction() { } 315 CastChannelSendFunction::CastChannelSendFunction() { }
323 316
324 CastChannelSendFunction::~CastChannelSendFunction() { } 317 CastChannelSendFunction::~CastChannelSendFunction() { }
325 318
326 bool CastChannelSendFunction::Prepare() { 319 bool CastChannelSendFunction::Prepare() {
327 params_ = Send::Params::Create(*args_); 320 params_ = Send::Params::Create(*args_);
328 EXTENSION_FUNCTION_VALIDATE(params_.get()); 321 EXTENSION_FUNCTION_VALIDATE(params_.get());
329 if (params_->message.namespace_.empty()) {
330 SetError("message_info.namespace_ is required");
331 return false;
332 }
333 if (params_->message.source_id.empty()) {
334 SetError("message_info.source_id is required");
335 return false;
336 }
337 if (params_->message.destination_id.empty()) {
338 SetError("message_info.destination_id is required");
339 return false;
340 }
341 switch (params_->message.data->GetType()) {
342 case base::Value::TYPE_STRING:
343 case base::Value::TYPE_BINARY:
344 break;
345 default:
346 SetError("Invalid type of message_info.data");
347 return false;
348 }
349 return true; 322 return true;
350 } 323 }
351 324
352 void CastChannelSendFunction::AsyncWorkStart() { 325 void CastChannelSendFunction::AsyncWorkStart() {
353 CastSocket* socket = GetSocketOrCompleteWithError( 326 CastSocket* socket = GetSocketOrCompleteWithError(
354 params_->channel.channel_id); 327 params_->channel.channel_id);
355 if (socket) 328 if (socket)
356 socket->SendMessage(params_->message, 329 socket->SendMessage(params_->message,
357 base::Bind(&CastChannelSendFunction::OnSend, this)); 330 base::Bind(&CastChannelSendFunction::OnSend, this));
358 } 331 }
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after
391 SetResultFromError(cast_channel::CHANNEL_ERROR_SOCKET_ERROR); 364 SetResultFromError(cast_channel::CHANNEL_ERROR_SOCKET_ERROR);
392 } else { 365 } else {
393 int channel_id = params_->channel.channel_id; 366 int channel_id = params_->channel.channel_id;
394 SetResultFromSocket(channel_id); 367 SetResultFromSocket(channel_id);
395 RemoveSocket(channel_id); 368 RemoveSocket(channel_id);
396 } 369 }
397 AsyncWorkCompleted(); 370 AsyncWorkCompleted();
398 } 371 }
399 372
400 } // namespace extensions 373 } // namespace extensions
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698