| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 |
| OLD | NEW |