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 |