extensions/browser/api/cast_channel/cast_socket_unittest.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "extensions/browser/api/cast_channel/cast_socket.h"
   6
   7 #include <vector>
   8
   9 #include "base/memory/weak_ptr.h"
  10 #include "base/message_loop/message_loop.h"
  11 #include "base/run_loop.h"
  12 #include "base/strings/string_number_conversions.h"
  13 #include "base/sys_byteorder.h"
  14 #include "base/test/simple_test_tick_clock.h"
  15 #include "base/timer/mock_timer.h"
  16 #include "extensions/browser/api/cast_channel/cast_auth_util.h"
  17 #include "extensions/browser/api/cast_channel/cast_framer.h"
  18 #include "extensions/browser/api/cast_channel/cast_message_util.h"
  19 #include "extensions/browser/api/cast_channel/cast_test_util.h"
  20 #include "extensions/browser/api/cast_channel/cast_transport.h"
  21 #include "extensions/browser/api/cast_channel/logger.h"
  22 #include "extensions/common/api/cast_channel/cast_channel.pb.h"
  23 #include "net/base/address_list.h"
  24 #include "net/base/net_errors.h"
  25 #include "net/base/net_util.h"
  26 #include "net/log/test_net_log.h"
  27 #include "net/socket/socket_test_util.h"
  28 #include "net/socket/ssl_client_socket.h"
  29 #include "net/socket/tcp_client_socket.h"
  30 #include "net/ssl/ssl_info.h"
  31 #include "testing/gmock/include/gmock/gmock.h"
  32 #include "testing/gtest/include/gtest/gtest.h"
  33
  34 const int64 kDistantTimeoutMillis = 100000;  // 100 seconds (never hit).
  35
  36 using ::testing::_;
  37 using ::testing::A;
  38 using ::testing::DoAll;
  39 using ::testing::Invoke;
  40 using ::testing::InvokeArgument;
  41 using ::testing::NotNull;
  42 using ::testing::Return;
  43 using ::testing::SaveArg;
  44
  45 namespace extensions {
  46 namespace core_api {
  47 namespace cast_channel {
  48 const char kAuthNamespace[] = "urn:x-cast:com.google.cast.tp.deviceauth";
  49
  50 // Returns an auth challenge message inline.
  51 CastMessage CreateAuthChallenge() {
  52   CastMessage output;
  53   CreateAuthChallengeMessage(&output);
  54   return output;
  55 }
  56
  57 // Returns an auth challenge response message inline.
  58 CastMessage CreateAuthReply() {
  59   CastMessage output;
  60   output.set_protocol_version(CastMessage::CASTV2_1_0);
  61   output.set_source_id("sender-0");
  62   output.set_destination_id("receiver-0");
  63   output.set_payload_type(CastMessage::BINARY);
  64   output.set_payload_binary("abcd");
  65   output.set_namespace_(kAuthNamespace);
  66   return output;
  67 }
  68
  69 CastMessage CreateTestMessage() {
  70   CastMessage test_message;
  71   test_message.set_protocol_version(CastMessage::CASTV2_1_0);
  72   test_message.set_namespace_("ns");
  73   test_message.set_source_id("source");
  74   test_message.set_destination_id("dest");
  75   test_message.set_payload_type(CastMessage::STRING);
  76   test_message.set_payload_utf8("payload");
  77   return test_message;
  78 }
  79
  80 class MockTCPSocket : public net::TCPClientSocket {
  81  public:
  82   explicit MockTCPSocket(const net::MockConnect& connect_data)
  83       : TCPClientSocket(net::AddressList(), nullptr, net::NetLog::Source()),
  84         connect_data_(connect_data),
  85         do_nothing_(false) {}
  86
  87   explicit MockTCPSocket(bool do_nothing)
  88       : TCPClientSocket(net::AddressList(), nullptr, net::NetLog::Source()) {
  89     CHECK(do_nothing);
  90     do_nothing_ = do_nothing;
  91   }
  92
  93   virtual int Connect(const net::CompletionCallback& callback) {
  94     if (do_nothing_) {
  95       // Stall the I/O event loop.
  96       return net::ERR_IO_PENDING;
  97     }
  98
  99     if (connect_data_.mode == net::ASYNC) {
 100       CHECK_NE(connect_data_.result, net::ERR_IO_PENDING);
 101       base::MessageLoop::current()->PostTask(
 102           FROM_HERE,
 103           base::Bind(callback, connect_data_.result));
 104       return net::ERR_IO_PENDING;
 105     } else {
 106       return connect_data_.result;
 107     }
 108   }
 109
 110   virtual bool SetKeepAlive(bool enable, int delay) {
 111     // Always return true in tests
 112     return true;
 113   }
 114
 115   virtual bool SetNoDelay(bool no_delay) {
 116     // Always return true in tests
 117     return true;
 118   }
 119
 120   MOCK_METHOD3(Read,
 121                int(net::IOBuffer*, int, const net::CompletionCallback&));
 122   MOCK_METHOD3(Write,
 123                int(net::IOBuffer*, int, const net::CompletionCallback&));
 124
 125   virtual void Disconnect() {
 126     // Do nothing in tests
 127   }
 128
 129  private:
 130   net::MockConnect connect_data_;
 131   bool do_nothing_;
 132
 133   DISALLOW_COPY_AND_ASSIGN(MockTCPSocket);
 134 };
 135
 136 class MockDelegate : public CastTransport::Delegate {
 137  public:
 138   MockDelegate() {}
 139   virtual ~MockDelegate() {}
 140   MOCK_METHOD1(OnError, void(ChannelError error_state));
 141   MOCK_METHOD1(OnMessage, void(const CastMessage& message));
 142   MOCK_METHOD0(Start, void());
 143
 144  private:
 145   DISALLOW_COPY_AND_ASSIGN(MockDelegate);
 146 };
 147
 148 class CompleteHandler {
 149  public:
 150   CompleteHandler() {}
 151   MOCK_METHOD1(OnCloseComplete, void(int result));
 152   MOCK_METHOD1(OnConnectComplete, void(ChannelError error_state));
 153   MOCK_METHOD1(OnWriteComplete, void(int result));
 154   MOCK_METHOD1(OnReadComplete, void(int result));
 155
 156  private:
 157   DISALLOW_COPY_AND_ASSIGN(CompleteHandler);
 158 };
 159
 160 class TestCastSocket : public CastSocketImpl {
 161  public:
 162   static scoped_ptr<TestCastSocket> Create(
 163       Logger* logger,
 164       uint64 device_capabilities = cast_channel::CastDeviceCapability::NONE) {
 165     return scoped_ptr<TestCastSocket>(
 166         new TestCastSocket(CreateIPEndPointForTest(), CHANNEL_AUTH_TYPE_SSL,
 167                            kDistantTimeoutMillis, logger, device_capabilities));
 168   }
 169
 170   static scoped_ptr<TestCastSocket> CreateSecure(
 171       Logger* logger,
 172       uint64 device_capabilities = cast_channel::CastDeviceCapability::NONE) {
 173     return scoped_ptr<TestCastSocket>(new TestCastSocket(
 174         CreateIPEndPointForTest(), CHANNEL_AUTH_TYPE_SSL_VERIFIED,
 175         kDistantTimeoutMillis, logger, device_capabilities));
 176   }
 177
 178   explicit TestCastSocket(const net::IPEndPoint& ip_endpoint,
 179                           ChannelAuthType channel_auth,
 180                           int64 timeout_ms,
 181                           Logger* logger,
 182                           uint64 device_capabilities)
 183       : CastSocketImpl("some_extension_id",
 184                        ip_endpoint,
 185                        channel_auth,
 186                        &capturing_net_log_,
 187                        base::TimeDelta::FromMilliseconds(timeout_ms),
 188                        false,
 189                        logger,
 190                        device_capabilities),
 191         ip_(ip_endpoint),
 192         connect_index_(0),
 193         extract_cert_result_(true),
 194         verify_challenge_result_(true),
 195         verify_challenge_disallow_(false),
 196         tcp_unresponsive_(false),
 197         mock_timer_(new base::MockTimer(false, false)),
 198         mock_transport_(nullptr) {}
 199
 200   ~TestCastSocket() override {}
 201
 202   void SetupMockTransport() {
 203     mock_transport_ = new MockCastTransport;
 204     SetTransportForTesting(make_scoped_ptr(mock_transport_));
 205   }
 206
 207   // Socket connection helpers.
 208   void SetupTcp1Connect(net::IoMode mode, int result) {
 209     tcp_connect_data_[0].reset(new net::MockConnect(mode, result));
 210   }
 211   void SetupTcp2Connect(net::IoMode mode, int result) {
 212     tcp_connect_data_[1].reset(new net::MockConnect(mode, result));
 213   }
 214   void SetupSsl1Connect(net::IoMode mode, int result) {
 215     ssl_connect_data_[0].reset(new net::MockConnect(mode, result));
 216   }
 217   void SetupSsl2Connect(net::IoMode mode, int result) {
 218     ssl_connect_data_[1].reset(new net::MockConnect(mode, result));
 219   }
 220
 221   // Socket I/O helpers.
 222   void AddWriteResult(const net::MockWrite& write) {
 223     writes_.push_back(write);
 224   }
 225   void AddWriteResult(net::IoMode mode, int result) {
 226     AddWriteResult(net::MockWrite(mode, result));
 227   }
 228   void AddWriteResultForData(net::IoMode mode, const std::string& msg) {
 229     AddWriteResult(mode, msg.size());
 230   }
 231   void AddReadResult(const net::MockRead& read) {
 232     reads_.push_back(read);
 233   }
 234   void AddReadResult(net::IoMode mode, int result) {
 235     AddReadResult(net::MockRead(mode, result));
 236   }
 237   void AddReadResultForData(net::IoMode mode, const std::string& data) {
 238     AddReadResult(net::MockRead(mode, data.c_str(), data.size()));
 239   }
 240
 241   // Helpers for modifying other connection-related behaviors.
 242   void SetupTcp1ConnectUnresponsive() { tcp_unresponsive_ = true; }
 243
 244   void SetExtractCertResult(bool value) {
 245     extract_cert_result_ = value;
 246   }
 247
 248   void SetVerifyChallengeResult(bool value) {
 249     verify_challenge_result_ = value;
 250   }
 251
 252   void TriggerTimeout() {
 253     mock_timer_->Fire();
 254   }
 255
 256   bool TestVerifyChannelPolicyNone() {
 257     AuthResult authResult;
 258     return VerifyChannelPolicy(authResult);
 259   }
 260
 261   bool TestVerifyChannelPolicyAudioOnly() {
 262     AuthResult authResult;
 263     authResult.channel_policies |= AuthResult::POLICY_AUDIO_ONLY;
 264     return VerifyChannelPolicy(authResult);
 265   }
 266
 267   void DisallowVerifyChallengeResult() { verify_challenge_disallow_ = true; }
 268
 269   MockCastTransport* GetMockTransport() {
 270     CHECK(mock_transport_);
 271     return mock_transport_;
 272   }
 273
 274  private:
 275   scoped_ptr<net::TCPClientSocket> CreateTcpSocket() override {
 276     if (tcp_unresponsive_) {
 277       return scoped_ptr<net::TCPClientSocket>(new MockTCPSocket(true));
 278     } else {
 279       net::MockConnect* connect_data = tcp_connect_data_[connect_index_].get();
 280       connect_data->peer_addr = ip_;
 281       return scoped_ptr<net::TCPClientSocket>(new MockTCPSocket(*connect_data));
 282     }
 283   }
 284
 285   scoped_ptr<net::SSLClientSocket> CreateSslSocket(
 286       scoped_ptr<net::StreamSocket> socket) override {
 287     net::MockConnect* connect_data = ssl_connect_data_[connect_index_].get();
 288     connect_data->peer_addr = ip_;
 289     ++connect_index_;
 290
 291     ssl_data_.reset(new net::StaticSocketDataProvider(
 292         reads_.data(), reads_.size(), writes_.data(), writes_.size()));
 293     ssl_data_->set_connect_data(*connect_data);
 294     // NOTE: net::MockTCPClientSocket inherits from net::SSLClientSocket !!
 295     return scoped_ptr<net::SSLClientSocket>(
 296         new net::MockTCPClientSocket(
 297             net::AddressList(), &capturing_net_log_, ssl_data_.get()));
 298   }
 299
 300   bool ExtractPeerCert(std::string* cert) override {
 301     if (extract_cert_result_)
 302       cert->assign("dummy_test_cert");
 303     return extract_cert_result_;
 304   }
 305
 306   bool VerifyChallengeReply() override {
 307     EXPECT_FALSE(verify_challenge_disallow_);
 308     return verify_challenge_result_;
 309   }
 310
 311   base::Timer* GetTimer() override { return mock_timer_.get(); }
 312
 313   net::TestNetLog capturing_net_log_;
 314   net::IPEndPoint ip_;
 315   // Simulated connect data
 316   scoped_ptr<net::MockConnect> tcp_connect_data_[2];
 317   scoped_ptr<net::MockConnect> ssl_connect_data_[2];
 318   // Simulated read / write data
 319   std::vector<net::MockWrite> writes_;
 320   std::vector<net::MockRead> reads_;
 321   scoped_ptr<net::SocketDataProvider> ssl_data_;
 322   // Number of times Connect method is called
 323   size_t connect_index_;
 324   // Simulated result of peer cert extraction.
 325   bool extract_cert_result_;
 326   // Simulated result of verifying challenge reply.
 327   bool verify_challenge_result_;
 328   bool verify_challenge_disallow_;
 329   // If true, makes TCP connection process stall. For timeout testing.
 330   bool tcp_unresponsive_;
 331   scoped_ptr<base::MockTimer> mock_timer_;
 332   MockCastTransport* mock_transport_;
 333
 334   DISALLOW_COPY_AND_ASSIGN(TestCastSocket);
 335 };
 336
 337 class CastSocketTest : public testing::Test {
 338  public:
 339   CastSocketTest()
 340       : logger_(new Logger(
 341             scoped_ptr<base::TickClock>(new base::SimpleTestTickClock),
 342             base::TimeTicks())),
 343         delegate_(new MockDelegate) {}
 344   ~CastSocketTest() override {}
 345
 346   void SetUp() override { EXPECT_CALL(*delegate_, OnMessage(_)).Times(0); }
 347
 348   void TearDown() override {
 349     if (socket_.get()) {
 350       EXPECT_CALL(handler_, OnCloseComplete(net::OK));
 351       socket_->Close(base::Bind(&CompleteHandler::OnCloseComplete,
 352                                 base::Unretained(&handler_)));
 353     }
 354   }
 355
 356   void CreateCastSocket() { socket_ = TestCastSocket::Create(logger_); }
 357
 358   void CreateCastSocketSecure() {
 359     socket_ = TestCastSocket::CreateSecure(logger_);
 360   }
 361
 362   void HandleAuthHandshake() {
 363     socket_->SetupMockTransport();
 364     CastMessage challenge_proto = CreateAuthChallenge();
 365     EXPECT_CALL(*socket_->GetMockTransport(),
 366                 SendMessage(EqualsProto(challenge_proto), _))
 367         .WillOnce(RunCompletionCallback<1>(net::OK));
 368     EXPECT_CALL(*socket_->GetMockTransport(), Start());
 369     EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 370     socket_->Connect(delegate_.Pass(),
 371                      base::Bind(&CompleteHandler::OnConnectComplete,
 372                                 base::Unretained(&handler_)));
 373     RunPendingTasks();
 374     socket_->GetMockTransport()->current_delegate()->OnMessage(
 375         CreateAuthReply());
 376     RunPendingTasks();
 377   }
 378
 379  protected:
 380   // Runs all pending tasks in the message loop.
 381   void RunPendingTasks() {
 382     base::RunLoop run_loop;
 383     run_loop.RunUntilIdle();
 384   }
 385
 386   base::MessageLoop message_loop_;
 387   Logger* logger_;
 388   scoped_ptr<TestCastSocket> socket_;
 389   CompleteHandler handler_;
 390   scoped_ptr<MockDelegate> delegate_;
 391
 392  private:
 393   DISALLOW_COPY_AND_ASSIGN(CastSocketTest);
 394 };
 395
 396 // Tests connecting and closing the socket.
 397 TEST_F(CastSocketTest, TestConnectAndClose) {
 398   CreateCastSocket();
 399   socket_->SetupMockTransport();
 400   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 401   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK);
 402
 403   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 404   socket_->Connect(delegate_.Pass(),
 405                    base::Bind(&CompleteHandler::OnConnectComplete,
 406                               base::Unretained(&handler_)));
 407   RunPendingTasks();
 408
 409   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 410   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 411
 412   EXPECT_CALL(handler_, OnCloseComplete(net::OK));
 413   socket_->Close(base::Bind(&CompleteHandler::OnCloseComplete,
 414                             base::Unretained(&handler_)));
 415   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 416   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 417 }
 418
 419 // Tests that the following connection flow works:
 420 // - TCP connection succeeds (async)
 421 // - SSL connection succeeds (async)
 422 TEST_F(CastSocketTest, TestConnect) {
 423   CreateCastSocket();
 424   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 425   socket_->SetupSsl1Connect(net::ASYNC, net::OK);
 426   socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING);
 427
 428   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 429   socket_->Connect(delegate_.Pass(),
 430                    base::Bind(&CompleteHandler::OnConnectComplete,
 431                               base::Unretained(&handler_)));
 432   RunPendingTasks();
 433
 434   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 435   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 436 }
 437
 438 // Tests that the following connection flow works:
 439 // - TCP connection fails (async)
 440 TEST_F(CastSocketTest, TestConnectFails) {
 441   CreateCastSocket();
 442   socket_->SetupTcp1Connect(net::ASYNC, net::ERR_FAILED);
 443
 444   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_ERROR));
 445   socket_->Connect(delegate_.Pass(),
 446                    base::Bind(&CompleteHandler::OnConnectComplete,
 447                               base::Unretained(&handler_)));
 448   RunPendingTasks();
 449
 450   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 451   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state());
 452   EXPECT_EQ(proto::TCP_SOCKET_CONNECT_COMPLETE,
 453             logger_->GetLastErrors(socket_->id()).event_type);
 454   EXPECT_EQ(net::ERR_FAILED,
 455             logger_->GetLastErrors(socket_->id()).net_return_value);
 456 }
 457
 458 // Test that the following connection flow works:
 459 // - TCP connection succeeds (async)
 460 // - SSL connection fails with cert error (async)
 461 // - Cert is extracted successfully
 462 // - Second TCP connection succeeds (async)
 463 // - Second SSL connection succeeds (async)
 464 TEST_F(CastSocketTest, TestConnectTwoStep) {
 465   CreateCastSocket();
 466   socket_->SetupMockTransport();
 467   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 468   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 469   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 470   socket_->SetupSsl2Connect(net::ASYNC, net::OK);
 471
 472   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 473   socket_->Connect(delegate_.Pass(),
 474                    base::Bind(&CompleteHandler::OnConnectComplete,
 475                               base::Unretained(&handler_)));
 476   RunPendingTasks();
 477   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 478   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 479 }
 480
 481 // Test that the following connection flow works:
 482 // - TCP connection succeeds (async)
 483 // - SSL connection fails with cert error (async)
 484 // - Cert is extracted successfully
 485 // - Second TCP connection succeeds (async)
 486 // - Second SSL connection fails (async)
 487 // - The flow should NOT be tried again
 488 TEST_F(CastSocketTest, TestConnectMaxTwoAttempts) {
 489   CreateCastSocket();
 490   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 491   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 492   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 493   socket_->SetupSsl2Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 494
 495   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 496   socket_->Connect(delegate_.Pass(),
 497                    base::Bind(&CompleteHandler::OnConnectComplete,
 498                               base::Unretained(&handler_)));
 499   RunPendingTasks();
 500
 501   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 502   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 503             socket_->error_state());
 504 }
 505
 506 // Tests that the following connection flow works:
 507 // - TCP connection succeeds (async)
 508 // - SSL connection fails with cert error (async)
 509 // - Cert is extracted successfully
 510 // - Second TCP connection succeeds (async)
 511 // - Second SSL connection succeeds (async)
 512 // - Challenge request is sent (async)
 513 // - Challenge response is received (async)
 514 // - Credentials are verified successfuly
 515 TEST_F(CastSocketTest, TestConnectFullSecureFlowAsync) {
 516   CreateCastSocketSecure();
 517   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 518   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 519   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 520   socket_->SetupSsl2Connect(net::ASYNC, net::OK);
 521
 522   HandleAuthHandshake();
 523
 524   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 525   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 526 }
 527
 528 // Tests that the following connection flow works:
 529 // - TCP connection succeeds (sync)
 530 // - SSL connection fails with cert error (sync)
 531 // - Cert is extracted successfully
 532 // - Second TCP connection succeeds (sync)
 533 // - Second SSL connection succeeds (sync)
 534 // - Challenge request is sent (sync)
 535 // - Challenge response is received (sync)
 536 // - Credentials are verified successfuly
 537 TEST_F(CastSocketTest, TestConnectFullSecureFlowSync) {
 538   CreateCastSocketSecure();
 539   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 540   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CERT_AUTHORITY_INVALID);
 541   socket_->SetupTcp2Connect(net::SYNCHRONOUS, net::OK);
 542   socket_->SetupSsl2Connect(net::SYNCHRONOUS, net::OK);
 543
 544   HandleAuthHandshake();
 545
 546   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 547   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 548 }
 549
 550 // Test that an AuthMessage with a mangled namespace triggers cancelation
 551 // of the connection event loop.
 552 TEST_F(CastSocketTest, TestConnectAuthMessageCorrupted) {
 553   CreateCastSocketSecure();
 554   socket_->SetupMockTransport();
 555
 556   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 557   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 558   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 559   socket_->SetupSsl2Connect(net::ASYNC, net::OK);
 560
 561   CastMessage challenge_proto = CreateAuthChallenge();
 562   EXPECT_CALL(*socket_->GetMockTransport(),
 563               SendMessage(EqualsProto(challenge_proto), _))
 564       .WillOnce(RunCompletionCallback<1>(net::OK));
 565   EXPECT_CALL(*socket_->GetMockTransport(), Start());
 566   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_TRANSPORT_ERROR));
 567   socket_->Connect(delegate_.Pass(),
 568                    base::Bind(&CompleteHandler::OnConnectComplete,
 569                               base::Unretained(&handler_)));
 570   RunPendingTasks();
 571   CastMessage mangled_auth_reply = CreateAuthReply();
 572   mangled_auth_reply.set_namespace_("BOGUS_NAMESPACE");
 573
 574   socket_->GetMockTransport()->current_delegate()->OnMessage(
 575       mangled_auth_reply);
 576   RunPendingTasks();
 577
 578   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 579   EXPECT_EQ(cast_channel::CHANNEL_ERROR_TRANSPORT_ERROR,
 580             socket_->error_state());
 581 }
 582
 583 // Test connection error - TCP connect fails (async)
 584 TEST_F(CastSocketTest, TestConnectTcpConnectErrorAsync) {
 585   CreateCastSocketSecure();
 586
 587   socket_->SetupTcp1Connect(net::ASYNC, net::ERR_FAILED);
 588
 589   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_ERROR));
 590   socket_->Connect(delegate_.Pass(),
 591                    base::Bind(&CompleteHandler::OnConnectComplete,
 592                               base::Unretained(&handler_)));
 593   RunPendingTasks();
 594
 595   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 596   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state());
 597 }
 598
 599 // Test connection error - TCP connect fails (sync)
 600 TEST_F(CastSocketTest, TestConnectTcpConnectErrorSync) {
 601   CreateCastSocketSecure();
 602
 603   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::ERR_FAILED);
 604
 605   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_ERROR));
 606   socket_->Connect(delegate_.Pass(),
 607                    base::Bind(&CompleteHandler::OnConnectComplete,
 608                               base::Unretained(&handler_)));
 609   RunPendingTasks();
 610
 611   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 612   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_ERROR, socket_->error_state());
 613 }
 614
 615 // Test connection error - timeout
 616 TEST_F(CastSocketTest, TestConnectTcpTimeoutError) {
 617   CreateCastSocketSecure();
 618   socket_->SetupTcp1ConnectUnresponsive();
 619   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_TIMEOUT));
 620   EXPECT_CALL(*delegate_, OnError(CHANNEL_ERROR_CONNECT_TIMEOUT));
 621   socket_->Connect(delegate_.Pass(),
 622                    base::Bind(&CompleteHandler::OnConnectComplete,
 623                               base::Unretained(&handler_)));
 624   RunPendingTasks();
 625
 626   EXPECT_EQ(cast_channel::READY_STATE_CONNECTING, socket_->ready_state());
 627   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 628   socket_->TriggerTimeout();
 629   RunPendingTasks();
 630
 631   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 632   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_TIMEOUT,
 633             socket_->error_state());
 634 }
 635
 636 // Test connection error - TCP socket returns timeout
 637 TEST_F(CastSocketTest, TestConnectTcpSocketTimeoutError) {
 638   CreateCastSocketSecure();
 639   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::ERR_CONNECTION_TIMED_OUT);
 640   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_TIMEOUT));
 641   EXPECT_CALL(*delegate_, OnError(CHANNEL_ERROR_CONNECT_TIMEOUT));
 642   socket_->Connect(delegate_.Pass(),
 643                    base::Bind(&CompleteHandler::OnConnectComplete,
 644                               base::Unretained(&handler_)));
 645   RunPendingTasks();
 646
 647   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 648   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_TIMEOUT,
 649             socket_->error_state());
 650   EXPECT_EQ(net::ERR_CONNECTION_TIMED_OUT,
 651             logger_->GetLastErrors(socket_->id()).net_return_value);
 652 }
 653
 654 // Test connection error - SSL connect fails (async)
 655 TEST_F(CastSocketTest, TestConnectSslConnectErrorAsync) {
 656   CreateCastSocketSecure();
 657
 658   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 659   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_FAILED);
 660
 661   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 662   socket_->Connect(delegate_.Pass(),
 663                    base::Bind(&CompleteHandler::OnConnectComplete,
 664                               base::Unretained(&handler_)));
 665   RunPendingTasks();
 666
 667   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 668   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 669             socket_->error_state());
 670 }
 671
 672 // Test connection error - SSL connect fails (sync)
 673 TEST_F(CastSocketTest, TestConnectSslConnectErrorSync) {
 674   CreateCastSocketSecure();
 675
 676   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 677   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_FAILED);
 678
 679   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 680   socket_->Connect(delegate_.Pass(),
 681                    base::Bind(&CompleteHandler::OnConnectComplete,
 682                               base::Unretained(&handler_)));
 683   RunPendingTasks();
 684
 685   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 686   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 687             socket_->error_state());
 688   EXPECT_EQ(net::ERR_FAILED,
 689             logger_->GetLastErrors(socket_->id()).net_return_value);
 690 }
 691
 692 // Test connection error - SSL connect times out (sync)
 693 TEST_F(CastSocketTest, TestConnectSslConnectTimeoutSync) {
 694   CreateCastSocketSecure();
 695
 696   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 697   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CONNECTION_TIMED_OUT);
 698
 699   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_TIMEOUT));
 700   socket_->Connect(delegate_.Pass(),
 701                    base::Bind(&CompleteHandler::OnConnectComplete,
 702                               base::Unretained(&handler_)));
 703   RunPendingTasks();
 704
 705   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 706   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_TIMEOUT,
 707             socket_->error_state());
 708   EXPECT_EQ(net::ERR_CONNECTION_TIMED_OUT,
 709             logger_->GetLastErrors(socket_->id()).net_return_value);
 710 }
 711
 712 // Test connection error - SSL connect times out (async)
 713 TEST_F(CastSocketTest, TestConnectSslConnectTimeoutAsync) {
 714   CreateCastSocketSecure();
 715
 716   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 717   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CONNECTION_TIMED_OUT);
 718
 719   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_CONNECT_TIMEOUT));
 720   socket_->Connect(delegate_.Pass(),
 721                    base::Bind(&CompleteHandler::OnConnectComplete,
 722                               base::Unretained(&handler_)));
 723   RunPendingTasks();
 724
 725   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 726   EXPECT_EQ(cast_channel::CHANNEL_ERROR_CONNECT_TIMEOUT,
 727             socket_->error_state());
 728 }
 729
 730 // Test connection error - cert extraction error (async)
 731 TEST_F(CastSocketTest, TestConnectCertExtractionErrorAsync) {
 732   CreateCastSocket();
 733   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 734   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 735   // Set cert extraction to fail
 736   socket_->SetExtractCertResult(false);
 737
 738   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 739   socket_->Connect(delegate_.Pass(),
 740                    base::Bind(&CompleteHandler::OnConnectComplete,
 741                               base::Unretained(&handler_)));
 742   RunPendingTasks();
 743
 744   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 745   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 746             socket_->error_state());
 747 }
 748
 749 // Test connection error - cert extraction error (sync)
 750 TEST_F(CastSocketTest, TestConnectCertExtractionErrorSync) {
 751   CreateCastSocket();
 752   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 753   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CERT_AUTHORITY_INVALID);
 754   // Set cert extraction to fail
 755   socket_->SetExtractCertResult(false);
 756
 757   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 758   socket_->Connect(delegate_.Pass(),
 759                    base::Bind(&CompleteHandler::OnConnectComplete,
 760                               base::Unretained(&handler_)));
 761   RunPendingTasks();
 762
 763   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 764   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 765             socket_->error_state());
 766 }
 767
 768 // Test connection error - challenge send fails
 769 TEST_F(CastSocketTest, TestConnectChallengeSendError) {
 770   CreateCastSocketSecure();
 771   socket_->SetupMockTransport();
 772
 773   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 774   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK);
 775   EXPECT_CALL(*socket_->GetMockTransport(),
 776               SendMessage(EqualsProto(CreateAuthChallenge()), _))
 777       .WillOnce(RunCompletionCallback<1>(net::ERR_CONNECTION_RESET));
 778
 779   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_SOCKET_ERROR));
 780   socket_->Connect(delegate_.Pass(),
 781                    base::Bind(&CompleteHandler::OnConnectComplete,
 782                               base::Unretained(&handler_)));
 783   RunPendingTasks();
 784
 785   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 786   EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state());
 787 }
 788
 789 // Test connection error - challenge reply receive fails
 790 TEST_F(CastSocketTest, TestConnectChallengeReplyReceiveError) {
 791   CreateCastSocketSecure();
 792   socket_->SetupMockTransport();
 793
 794   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 795   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::OK);
 796   EXPECT_CALL(*socket_->GetMockTransport(),
 797               SendMessage(EqualsProto(CreateAuthChallenge()), _))
 798       .WillOnce(RunCompletionCallback<1>(net::OK));
 799   socket_->AddReadResult(net::SYNCHRONOUS, net::ERR_FAILED);
 800   EXPECT_CALL(*delegate_, OnError(CHANNEL_ERROR_SOCKET_ERROR));
 801   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_SOCKET_ERROR));
 802   EXPECT_CALL(*socket_->GetMockTransport(), Start());
 803   socket_->Connect(delegate_.Pass(),
 804                    base::Bind(&CompleteHandler::OnConnectComplete,
 805                               base::Unretained(&handler_)));
 806   socket_->GetMockTransport()->current_delegate()->OnError(
 807       CHANNEL_ERROR_SOCKET_ERROR);
 808   RunPendingTasks();
 809
 810   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 811   EXPECT_EQ(cast_channel::CHANNEL_ERROR_SOCKET_ERROR, socket_->error_state());
 812 }
 813
 814 TEST_F(CastSocketTest, TestConnectChallengeVerificationFails) {
 815   CreateCastSocketSecure();
 816   socket_->SetupMockTransport();
 817   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 818   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 819   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 820   socket_->SetupSsl2Connect(net::ASYNC, net::OK);
 821   socket_->SetVerifyChallengeResult(false);
 822
 823   EXPECT_CALL(*delegate_, OnError(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 824   CastMessage challenge_proto = CreateAuthChallenge();
 825   EXPECT_CALL(*socket_->GetMockTransport(),
 826               SendMessage(EqualsProto(challenge_proto), _))
 827       .WillOnce(RunCompletionCallback<1>(net::OK));
 828   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_AUTHENTICATION_ERROR));
 829   EXPECT_CALL(*socket_->GetMockTransport(), Start());
 830   socket_->Connect(delegate_.Pass(),
 831                    base::Bind(&CompleteHandler::OnConnectComplete,
 832                               base::Unretained(&handler_)));
 833   RunPendingTasks();
 834   socket_->GetMockTransport()->current_delegate()->OnMessage(CreateAuthReply());
 835   RunPendingTasks();
 836
 837   EXPECT_EQ(cast_channel::READY_STATE_CLOSED, socket_->ready_state());
 838   EXPECT_EQ(cast_channel::CHANNEL_ERROR_AUTHENTICATION_ERROR,
 839             socket_->error_state());
 840 }
 841
 842 // Sends message data through an actual non-mocked CastTransport object,
 843 // testing the two components in integration.
 844 TEST_F(CastSocketTest, TestConnectEndToEndWithRealTransportAsync) {
 845   CreateCastSocketSecure();
 846   socket_->SetupTcp1Connect(net::ASYNC, net::OK);
 847   socket_->SetupSsl1Connect(net::ASYNC, net::ERR_CERT_AUTHORITY_INVALID);
 848   socket_->SetupTcp2Connect(net::ASYNC, net::OK);
 849   socket_->SetupSsl2Connect(net::ASYNC, net::OK);
 850
 851   // Set low-level auth challenge expectations.
 852   CastMessage challenge = CreateAuthChallenge();
 853   std::string challenge_str;
 854   EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str));
 855   socket_->AddWriteResultForData(net::ASYNC, challenge_str);
 856
 857   // Set low-level auth reply expectations.
 858   CastMessage reply = CreateAuthReply();
 859   std::string reply_str;
 860   EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str));
 861   socket_->AddReadResultForData(net::ASYNC, reply_str);
 862   socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING);
 863
 864   CastMessage test_message = CreateTestMessage();
 865   std::string test_message_str;
 866   EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str));
 867   socket_->AddWriteResultForData(net::ASYNC, test_message_str);
 868
 869   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 870   socket_->Connect(delegate_.Pass(),
 871                    base::Bind(&CompleteHandler::OnConnectComplete,
 872                               base::Unretained(&handler_)));
 873   RunPendingTasks();
 874   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 875   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 876
 877   // Send the test message through a real transport object.
 878   EXPECT_CALL(handler_, OnWriteComplete(net::OK));
 879   socket_->transport()->SendMessage(
 880       test_message, base::Bind(&CompleteHandler::OnWriteComplete,
 881                                base::Unretained(&handler_)));
 882   RunPendingTasks();
 883
 884   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 885   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 886 }
 887
 888 // Same as TestConnectEndToEndWithRealTransportAsync, except synchronous.
 889 TEST_F(CastSocketTest, TestConnectEndToEndWithRealTransportSync) {
 890   CreateCastSocketSecure();
 891   socket_->SetupTcp1Connect(net::SYNCHRONOUS, net::OK);
 892   socket_->SetupSsl1Connect(net::SYNCHRONOUS, net::ERR_CERT_AUTHORITY_INVALID);
 893   socket_->SetupTcp2Connect(net::SYNCHRONOUS, net::OK);
 894   socket_->SetupSsl2Connect(net::SYNCHRONOUS, net::OK);
 895
 896   // Set low-level auth challenge expectations.
 897   CastMessage challenge = CreateAuthChallenge();
 898   std::string challenge_str;
 899   EXPECT_TRUE(MessageFramer::Serialize(challenge, &challenge_str));
 900   socket_->AddWriteResultForData(net::SYNCHRONOUS, challenge_str);
 901
 902   // Set low-level auth reply expectations.
 903   CastMessage reply = CreateAuthReply();
 904   std::string reply_str;
 905   EXPECT_TRUE(MessageFramer::Serialize(reply, &reply_str));
 906   socket_->AddReadResultForData(net::SYNCHRONOUS, reply_str);
 907   socket_->AddReadResult(net::ASYNC, net::ERR_IO_PENDING);
 908
 909   CastMessage test_message = CreateTestMessage();
 910   std::string test_message_str;
 911   EXPECT_TRUE(MessageFramer::Serialize(test_message, &test_message_str));
 912   socket_->AddWriteResultForData(net::SYNCHRONOUS, test_message_str);
 913
 914   EXPECT_CALL(handler_, OnConnectComplete(CHANNEL_ERROR_NONE));
 915   socket_->Connect(delegate_.Pass(),
 916                    base::Bind(&CompleteHandler::OnConnectComplete,
 917                               base::Unretained(&handler_)));
 918   RunPendingTasks();
 919   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 920   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 921
 922   // Send the test message through a real transport object.
 923   EXPECT_CALL(handler_, OnWriteComplete(net::OK));
 924   socket_->transport()->SendMessage(
 925       test_message, base::Bind(&CompleteHandler::OnWriteComplete,
 926                                base::Unretained(&handler_)));
 927   RunPendingTasks();
 928
 929   EXPECT_EQ(cast_channel::READY_STATE_OPEN, socket_->ready_state());
 930   EXPECT_EQ(cast_channel::CHANNEL_ERROR_NONE, socket_->error_state());
 931 }
 932
 933 // Tests channel policy verification for device with no capabilities.
 934 TEST_F(CastSocketTest, TestChannelPolicyVerificationCapabilitiesNone) {
 935   socket_ =
 936       TestCastSocket::Create(logger_, cast_channel::CastDeviceCapability::NONE);
 937   EXPECT_TRUE(socket_->TestVerifyChannelPolicyNone());
 938   EXPECT_TRUE(socket_->TestVerifyChannelPolicyAudioOnly());
 939 }
 940
 941 // Tests channel policy verification for device with video out capability.
 942 TEST_F(CastSocketTest, TestChannelPolicyVerificationCapabilitiesVideoOut) {
 943   socket_ = TestCastSocket::Create(
 944       logger_, cast_channel::CastDeviceCapability::VIDEO_OUT);
 945   EXPECT_TRUE(socket_->TestVerifyChannelPolicyNone());
 946   EXPECT_FALSE(socket_->TestVerifyChannelPolicyAudioOnly());
 947 }
 948 }  // namespace cast_channel
 949 }  // namespace core_api
 950 }  // namespace extensions