Verify certificate of Privet v3 device

chrome/browser/local_discovery/privet_http_unittest.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/bind.h"
 #include "base/json/json_reader.h"
 #include "base/json/json_writer.h"
 #include "base/location.h"
 #include "base/message_loop/message_loop.h"
+#include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/thread_task_runner_handle.h"
 #include "chrome/browser/local_discovery/privet_http_impl.h"
+#include "content/public/browser/browser_thread.h"
+#include "content/public/test/test_browser_thread_bundle.h"
 #include "net/base/host_port_pair.h"
 #include "net/base/net_errors.h"
+#include "net/test/embedded_test_server/embedded_test_server.h"
 #include "net/url_request/test_url_fetcher_factory.h"
+#include "net/url_request/url_fetcher.h"
 #include "net/url_request/url_request_test_util.h"
 #include "printing/pwg_raster_settings.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 #if defined(ENABLE_PRINT_PREVIEW)
 #include "chrome/browser/local_discovery/pwg_raster_converter.h"
 #endif  // ENABLE_PRINT_PREVIEW
 
-using testing::StrictMock;
-using testing::NiceMock;
-
 namespace local_discovery {
 
 namespace {
 
+using testing::StrictMock;
+using testing::NiceMock;
+
+using content::BrowserThread;
+using net::EmbeddedTestServer;
+
+const base::FilePath::CharType kTestDataRoot[] =
+    FILE_PATH_LITERAL("chrome/test/data");
+
 const char kSampleInfoResponse[] = "{"
     "       \"version\": \"1.0\","
     "       \"name\": \"Common printer\","
     "       \"description\": \"Printer connected through Chrome connector\","
     "       \"url\": \"https://www.google.com/cloudprint\","
     "       \"type\": ["
     "               \"printer\""
     "       ],"
     "       \"id\": \"\","
     "       \"device_state\": \"idle\","
@@ skipping 1028 matching lines @@
       kSampleErrorResponsePrinterBusy));
 
   RunFor(base::TimeDelta::FromSeconds(3));
 
   EXPECT_TRUE(SuccessfulResponseToURL(
       GURL("http://10.0.0.8:6006/privet/printer/createjob"),
       kSampleCreatejobResponse));
 }
 #endif  // ENABLE_PRINT_PREVIEW
 
+class PrivetHttpWithServerTest : public ::testing::Test,
+                                 public PrivetURLFetcher::Delegate {
+ protected:
+  PrivetHttpWithServerTest()
+      : thread_bundle_(content::TestBrowserThreadBundle::REAL_IO_THREAD) {}
+  void OnError(PrivetURLFetcher* fetcher,
+               PrivetURLFetcher::ErrorType error) override {
+    done_ = true;
+    success_ = false;
+    error_ = error;
+
+    base::MessageLoop::current()->PostTask(FROM_HERE, quit_);
+  }
+
+  void OnParsedJson(PrivetURLFetcher* fetcher,
+                    const base::DictionaryValue& value,
+                    bool has_error) override {
+    NOTREACHED();
+    base::MessageLoop::current()->PostTask(FROM_HERE, quit_);
+  }
+
+  bool OnRawData(PrivetURLFetcher* fetcher,
+                 bool response_is_file,
+                 const std::string& data_string,
+                 const base::FilePath& data_file) override {
+    done_ = true;
+    success_ = true;
+
+    base::MessageLoop::current()->PostTask(FROM_HERE, quit_);
+    return true;
+  }
+
+  void CreateServer(EmbeddedTestServer::Type type) {
+    server_.reset(new EmbeddedTestServer(type));
+    ASSERT_TRUE(server_->InitializeAndWaitUntilReady());
+
+    base::FilePath test_data_dir;
+    ASSERT_TRUE(PathService::Get(base::DIR_SOURCE_ROOT, &test_data_dir));
+    server_->ServeFilesFromDirectory(test_data_dir.AppendASCII(kTestDataRoot));
+  }
+
+  void CreateClient() {
+    client_.reset(new PrivetHTTPClientImpl(
+        "test", server_->host_port_pair(),
+        BrowserThread::GetMessageLoopProxyForThread(BrowserThread::IO)));
+  }
+
+  void Run() {
+    success_ = false;
+    done_ = false;
+
+    base::RunLoop run_loop;
+    quit_ = run_loop.QuitClosure();
+
+    auto fetcher = client_->CreateURLFetcher(server_->GetURL("/simple.html"),
+                                             net::URLFetcher::GET, this);
+
+    fetcher->SetMaxRetries(1);
+    fetcher->V3Mode();
+    fetcher->Start();
+
+    run_loop.Run();
+
+    EXPECT_TRUE(done_);
+  }
+
+  bool success_ = false;
+  bool done_ = false;
+  PrivetURLFetcher::ErrorType error_ = PrivetURLFetcher::ErrorType();
+  content::TestBrowserThreadBundle thread_bundle_;
+
+  scoped_ptr<EmbeddedTestServer> server_;
+  scoped_ptr<PrivetHTTPClientImpl> client_;
+
+  base::Closure quit_;
+};
+
+TEST_F(PrivetHttpWithServerTest, HttpServer) {
+  CreateServer(EmbeddedTestServer::TYPE_HTTP);
+
+  CreateClient();
+  Run();
+  EXPECT_TRUE(success_);
+
+  CreateClient();
+  net::SHA256HashValue fingerprint = {};
+  client_->SwitchToHttps(server_->host_port_pair().port(), fingerprint);
+
+  Run();
+  EXPECT_FALSE(success_);
+  EXPECT_EQ(PrivetURLFetcher::UNKNOWN_ERROR, error_);

[Vitaly Buka (NO REVIEWS), 2015/10/29 05:27:46]

here request fails, as expected, but takes too long with EmbeddedTestServer.
about 30sec on linux

[Vitaly Buka (NO REVIEWS), 2015/10/29 06:24:35]

New bug for that:
https://code.google.com/p/chromium/issues/detail?id=548971

+}
+
+TEST_F(PrivetHttpWithServerTest, HttpsServer) {
+  CreateServer(EmbeddedTestServer::TYPE_HTTPS);
+
+  CreateClient();
+  Run();
+#ifdef OS_MACOSX
+  // Seems like an issue of the test server, it's in HTTPS mode and still
+  // accepts HTTP requests.
+  // TODO(vitalybuka): Remove #ifdef when test server is fixed. crbug.com/548888
+  EXPECT_TRUE(success_);
+#else
+  EXPECT_FALSE(success_);
+  EXPECT_EQ(PrivetURLFetcher::UNKNOWN_ERROR, error_);
+#endif  // OS_MACOSX
+
+  CreateClient();
+  net::SHA256HashValue fingerprint =
+      net::X509Certificate::CalculateFingerprint256(
+          server_->GetCertificate()->os_cert_handle());
+  client_->SwitchToHttps(server_->host_port_pair().port(), fingerprint);
+
+  Run();
+  EXPECT_TRUE(success_);
+
+  CreateClient();
+  fingerprint = {};
+  client_->SwitchToHttps(server_->host_port_pair().port(), fingerprint);
+
+  Run();
+  EXPECT_FALSE(success_);
+  EXPECT_EQ(PrivetURLFetcher::REQUEST_CANCELED, error_);
+}
+
 }  // namespace
 
 }  // namespace local_discovery