chrome/browser/net/websocket_browsertest.cc

   1 // Copyright (c) 2012 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 <string>
   6
   7 #include "base/strings/string_util.h"
   8 #include "base/strings/utf_string_conversions.h"
   9 #include "chrome/browser/chrome_notification_types.h"
  10 #include "chrome/browser/ui/browser.h"
  11 #include "chrome/browser/ui/login/login_prompt.h"
  12 #include "chrome/browser/ui/login/login_prompt_test_utils.h"
  13 #include "chrome/browser/ui/tabs/tab_strip_model.h"
  14 #include "chrome/test/base/in_process_browser_test.h"
  15 #include "chrome/test/base/ui_test_utils.h"
  16 #include "content/public/browser/navigation_controller.h"
  17 #include "content/public/browser/notification_details.h"
  18 #include "content/public/browser/notification_registrar.h"
  19 #include "content/public/browser/notification_source.h"
  20 #include "content/public/browser/web_contents.h"
  21 #include "content/public/test/browser_test_utils.h"
  22 #include "net/base/test_data_directory.h"
  23 #include "net/test/spawned_test_server/spawned_test_server.h"
  24 #include "url/gurl.h"
  25
  26 namespace {
  27
  28 class WebSocketBrowserTest : public InProcessBrowserTest {
  29  public:
  30   WebSocketBrowserTest()
  31       : ws_server_(net::SpawnedTestServer::TYPE_WS,
  32                    net::SpawnedTestServer::kLocalhost,
  33                    net::GetWebSocketTestDataDirectory()),
  34         wss_server_(net::SpawnedTestServer::TYPE_WSS,
  35                     SSLOptions(SSLOptions::CERT_OK),
  36                     net::GetWebSocketTestDataDirectory()) {}
  37
  38  protected:
  39   void NavigateToHTTP(const std::string& path) {
  40     // Visit a HTTP page for testing.
  41     GURL::Replacements replacements;
  42     replacements.SetSchemeStr("http");
  43     ui_test_utils::NavigateToURL(
  44         browser(), ws_server_.GetURL(path).ReplaceComponents(replacements));
  45   }
  46
  47   void NavigateToHTTPS(const std::string& path) {
  48     // Visit a HTTPS page for testing.
  49     GURL::Replacements replacements;
  50     replacements.SetSchemeStr("https");
  51     ui_test_utils::NavigateToURL(
  52         browser(), wss_server_.GetURL(path).ReplaceComponents(replacements));
  53   }
  54
  55   // Prepare the title watcher.
  56   void SetUpOnMainThread() override {
  57     watcher_.reset(new content::TitleWatcher(
  58         browser()->tab_strip_model()->GetActiveWebContents(),
  59         base::ASCIIToUTF16("PASS")));
  60     watcher_->AlsoWaitForTitle(base::ASCIIToUTF16("FAIL"));
  61   }
  62
  63   void TearDownOnMainThread() override { watcher_.reset(); }
  64
  65   std::string WaitAndGetTitle() {
  66     return base::UTF16ToUTF8(watcher_->WaitAndGetTitle());
  67   }
  68
  69   net::SpawnedTestServer ws_server_;
  70   net::SpawnedTestServer wss_server_;
  71
  72  private:
  73   typedef net::SpawnedTestServer::SSLOptions SSLOptions;
  74   scoped_ptr<content::TitleWatcher> watcher_;
  75
  76   DISALLOW_COPY_AND_ASSIGN(WebSocketBrowserTest);
  77 };
  78
  79 // Framework for tests using the connect_to.html page served by a separate HTTP
  80 // server.
  81 class WebSocketBrowserConnectToTest : public WebSocketBrowserTest {
  82  protected:
  83   WebSocketBrowserConnectToTest()
  84       : http_server_(net::SpawnedTestServer::TYPE_HTTP,
  85                      net::SpawnedTestServer::kLocalhost,
  86                      net::GetWebSocketTestDataDirectory()) {}
  87
  88   // The title watcher and HTTP server are set up automatically by the test
  89   // framework. Each test case still needs to configure and start the
  90   // WebSocket server(s) it needs.
  91   void SetUpOnMainThread() override {
  92     WebSocketBrowserTest::SetUpOnMainThread();
  93     ASSERT_TRUE(http_server_.StartInBackground());
  94   }
  95
  96   // Supply a ws: or wss: URL to connect to.
  97   void ConnectTo(GURL url) {
  98     ASSERT_TRUE(http_server_.BlockUntilStarted());
  99     std::string query("url=" + url.spec());
 100     GURL::Replacements replacements;
 101     replacements.SetQueryStr(query);
 102     ui_test_utils::NavigateToURL(browser(),
 103                                  http_server_.GetURL("files/connect_to.html")
 104                                      .ReplaceComponents(replacements));
 105   }
 106
 107  private:
 108   net::SpawnedTestServer http_server_;
 109 };
 110
 111 // Automatically fill in any login prompts that appear with the supplied
 112 // credentials.
 113 class AutoLogin : public content::NotificationObserver {
 114  public:
 115   AutoLogin(const std::string& username,
 116             const std::string& password,
 117             content::NavigationController* navigation_controller)
 118       : username_(base::UTF8ToUTF16(username)),
 119         password_(base::UTF8ToUTF16(password)),
 120         logged_in_(false) {
 121     registrar_.Add(
 122         this,
 123         chrome::NOTIFICATION_AUTH_NEEDED,
 124         content::Source<content::NavigationController>(navigation_controller));
 125   }
 126
 127   // NotificationObserver implementation
 128   void Observe(int type,
 129                const content::NotificationSource& source,
 130                const content::NotificationDetails& details) override {
 131     DCHECK_EQ(chrome::NOTIFICATION_AUTH_NEEDED, type);
 132     scoped_refptr<LoginHandler> login_handler =
 133         content::Details<LoginNotificationDetails>(details)->handler();
 134     login_handler->SetAuth(username_, password_);
 135     logged_in_ = true;
 136   }
 137
 138   bool logged_in() const { return logged_in_; }
 139
 140  private:
 141   const base::string16 username_;
 142   const base::string16 password_;
 143   bool logged_in_;
 144
 145   content::NotificationRegistrar registrar_;
 146
 147   DISALLOW_COPY_AND_ASSIGN(AutoLogin);
 148 };
 149
 150 // Test that the browser can handle a WebSocket frame split into multiple TCP
 151 // segments.
 152 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, WebSocketSplitSegments) {
 153   // Launch a WebSocket server.
 154   ASSERT_TRUE(ws_server_.Start());
 155
 156   NavigateToHTTP("split_packet_check.html");
 157
 158   EXPECT_EQ("PASS", WaitAndGetTitle());
 159 }
 160
 161 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, SecureWebSocketSplitRecords) {
 162   // Launch a secure WebSocket server.
 163   ASSERT_TRUE(wss_server_.Start());
 164
 165   NavigateToHTTPS("split_packet_check.html");
 166
 167   EXPECT_EQ("PASS", WaitAndGetTitle());
 168 }
 169
 170 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, SendCloseFrameWhenTabIsClosed) {
 171   // Launch a WebSocket server.
 172   ASSERT_TRUE(ws_server_.Start());
 173
 174   {
 175     // Create a new tab, establish a WebSocket connection and close the tab.
 176     content::WebContents* tab =
 177         browser()->tab_strip_model()->GetActiveWebContents();
 178     content::WebContents* new_tab = content::WebContents::Create(
 179         content::WebContents::CreateParams(tab->GetBrowserContext()));
 180     browser()->tab_strip_model()->AppendWebContents(new_tab, true);
 181     ASSERT_EQ(new_tab, browser()->tab_strip_model()->GetWebContentsAt(1));
 182
 183     content::TitleWatcher connected_title_watcher(
 184         new_tab, base::ASCIIToUTF16("CONNECTED"));
 185     connected_title_watcher.AlsoWaitForTitle(base::ASCIIToUTF16("CLOSED"));
 186     NavigateToHTTP("counted_connection.html");
 187     const base::string16 result = connected_title_watcher.WaitAndGetTitle();
 188     EXPECT_TRUE(base::EqualsASCII(result, "CONNECTED"));
 189
 190     content::WebContentsDestroyedWatcher destroyed_watcher(new_tab);
 191     browser()->tab_strip_model()->CloseWebContentsAt(1, 0);
 192     destroyed_watcher.Wait();
 193   }
 194
 195   NavigateToHTTP("count_connection.html");
 196   EXPECT_EQ("PASS", WaitAndGetTitle());
 197 }
 198
 199 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, WebSocketBasicAuthInHTTPURL) {
 200   // Launch a basic-auth-protected WebSocket server.
 201   ws_server_.set_websocket_basic_auth(true);
 202   ASSERT_TRUE(ws_server_.Start());
 203
 204   // Open connect_check.html via HTTP with credentials in the URL.
 205   GURL::Replacements replacements;
 206   replacements.SetSchemeStr("http");
 207   ui_test_utils::NavigateToURL(
 208       browser(),
 209       ws_server_.GetURLWithUserAndPassword("connect_check.html", "test", "test")
 210           .ReplaceComponents(replacements));
 211
 212   EXPECT_EQ("PASS", WaitAndGetTitle());
 213 }
 214
 215 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, WebSocketBasicAuthInHTTPSURL) {
 216   // Launch a basic-auth-protected secure WebSocket server.
 217   wss_server_.set_websocket_basic_auth(true);
 218   ASSERT_TRUE(wss_server_.Start());
 219
 220   // Open connect_check.html via HTTPS with credentials in the URL.
 221   GURL::Replacements replacements;
 222   replacements.SetSchemeStr("https");
 223   ui_test_utils::NavigateToURL(
 224       browser(),
 225       wss_server_.GetURLWithUserAndPassword(
 226                       "connect_check.html", "test", "test")
 227           .ReplaceComponents(replacements));
 228
 229   EXPECT_EQ("PASS", WaitAndGetTitle());
 230 }
 231
 232 // This test verifies that login details entered by the user into the login
 233 // prompt to authenticate the main page are re-used for WebSockets from the same
 234 // origin.
 235 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest,
 236                        ReuseMainPageBasicAuthCredentialsForWebSocket) {
 237   // Launch a basic-auth-protected WebSocket server.
 238   ws_server_.set_websocket_basic_auth(true);
 239   ASSERT_TRUE(ws_server_.Start());
 240
 241   content::NavigationController* navigation_controller =
 242       &browser()->tab_strip_model()->GetActiveWebContents()->GetController();
 243   AutoLogin auto_login("test", "test", navigation_controller);
 244
 245   WindowedAuthNeededObserver auth_needed_waiter(navigation_controller);
 246   NavigateToHTTP("connect_check.html");
 247   auth_needed_waiter.Wait();
 248
 249   EXPECT_TRUE(auto_login.logged_in());
 250   EXPECT_EQ("PASS", WaitAndGetTitle());
 251 }
 252
 253 IN_PROC_BROWSER_TEST_F(WebSocketBrowserConnectToTest,
 254                        WebSocketBasicAuthInWSURL) {
 255   // Launch a basic-auth-protected WebSocket server.
 256   ws_server_.set_websocket_basic_auth(true);
 257   ASSERT_TRUE(ws_server_.Start());
 258
 259   ConnectTo(ws_server_.GetURLWithUserAndPassword(
 260       "echo-with-no-extension", "test", "test"));
 261
 262   EXPECT_EQ("PASS", WaitAndGetTitle());
 263 }
 264
 265 IN_PROC_BROWSER_TEST_F(WebSocketBrowserConnectToTest,
 266                        WebSocketBasicAuthInWSURLBadCreds) {
 267   // Launch a basic-auth-protected WebSocket server.
 268   ws_server_.set_websocket_basic_auth(true);
 269   ASSERT_TRUE(ws_server_.Start());
 270
 271   ConnectTo(ws_server_.GetURLWithUserAndPassword(
 272       "echo-with-no-extension", "wrong-user", "wrong-password"));
 273
 274   EXPECT_EQ("FAIL", WaitAndGetTitle());
 275 }
 276
 277 IN_PROC_BROWSER_TEST_F(WebSocketBrowserConnectToTest,
 278                        WebSocketBasicAuthNoCreds) {
 279   // Launch a basic-auth-protected WebSocket server.
 280   ws_server_.set_websocket_basic_auth(true);
 281   ASSERT_TRUE(ws_server_.Start());
 282
 283   ConnectTo(ws_server_.GetURL("echo-with-no-extension"));
 284
 285   EXPECT_EQ("FAIL", WaitAndGetTitle());
 286 }
 287
 288 // HTTPS connection limits should not be applied to wss:. This is only tested
 289 // for secure connections here because the unencrypted case is tested in the
 290 // Blink layout tests, and browser tests are expensive to run.
 291 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, SSLConnectionLimit) {
 292   ASSERT_TRUE(wss_server_.Start());
 293
 294   NavigateToHTTPS("multiple-connections.html");
 295
 296   EXPECT_EQ("PASS", WaitAndGetTitle());
 297 }
 298
 299 // Regression test for crbug.com/903553005
 300 IN_PROC_BROWSER_TEST_F(WebSocketBrowserTest, WebSocketAppliesHSTS) {
 301   net::SpawnedTestServer https_server(
 302       net::SpawnedTestServer::TYPE_HTTPS,
 303       net::SpawnedTestServer::SSLOptions(
 304           net::SpawnedTestServer::SSLOptions::CERT_COMMON_NAME_IS_DOMAIN),
 305       base::FilePath(FILE_PATH_LITERAL("chrome/test/data")));
 306   net::SpawnedTestServer wss_server(
 307       net::SpawnedTestServer::TYPE_WSS,
 308       net::SpawnedTestServer::SSLOptions(
 309           net::SpawnedTestServer::SSLOptions::CERT_COMMON_NAME_IS_DOMAIN),
 310       net::GetWebSocketTestDataDirectory());
 311   // This test sets HSTS on localhost. To avoid being redirected to https, start
 312   // the http server on 127.0.0.1 instead.
 313   net::SpawnedTestServer http_server(
 314       net::SpawnedTestServer::TYPE_HTTP, net::SpawnedTestServer::kLocalhost,
 315       base::FilePath(FILE_PATH_LITERAL("chrome/test/data")));
 316   ASSERT_TRUE(https_server.StartInBackground());
 317   ASSERT_TRUE(http_server.StartInBackground());
 318   ASSERT_TRUE(wss_server.StartInBackground());
 319   ASSERT_TRUE(https_server.BlockUntilStarted());
 320
 321   // Set HSTS on localhost.
 322   content::TitleWatcher title_watcher(
 323       browser()->tab_strip_model()->GetActiveWebContents(),
 324       base::ASCIIToUTF16("SET"));
 325   ui_test_utils::NavigateToURL(
 326       browser(), https_server.GetURL("files/websocket/set-hsts.html"));
 327   const base::string16 result = title_watcher.WaitAndGetTitle();
 328   EXPECT_TRUE(base::EqualsASCII(result, "SET"));
 329
 330   // Verify that it applies to WebSockets.
 331   ASSERT_TRUE(wss_server.BlockUntilStarted());
 332   GURL wss_url = wss_server.GetURL("echo-with-no-extension");
 333   std::string scheme("ws");
 334   GURL::Replacements scheme_replacement;
 335   scheme_replacement.SetSchemeStr(scheme);
 336   GURL ws_url = wss_url.ReplaceComponents(scheme_replacement);
 337
 338   // An https: URL won't work here here because the mixed content policy
 339   // disallows connections to unencrypted WebSockets from encrypted pages.
 340   ASSERT_TRUE(http_server.BlockUntilStarted());
 341   GURL http_url =
 342       http_server.GetURL("files/websocket/check-hsts.html#" + ws_url.spec());
 343
 344   ui_test_utils::NavigateToURL(browser(), http_url);
 345
 346   EXPECT_EQ("PASS", WaitAndGetTitle());
 347 }
 348
 349 }  // namespace