Index: content/browser/media/webrtc_identity_store_unittest.cc |
diff --git a/content/browser/media/webrtc_identity_store_unittest.cc b/content/browser/media/webrtc_identity_store_unittest.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..edbcb6844d13d39048b718ee40779dae6c1f7a89 |
--- /dev/null |
+++ b/content/browser/media/webrtc_identity_store_unittest.cc |
@@ -0,0 +1,108 @@ |
+// Copyright (c) 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/memory/scoped_ptr.h" |
+#include "base/message_loop.h" |
+#include "base/run_loop.h" |
+#include "base/synchronization/waitable_event.h" |
+#include "base/threading/sequenced_worker_pool.h" |
+#include "content/browser/media/webrtc_identity_store.h" |
+#include "content/browser/renderer_host/media/webrtc_identity_service_host.h" |
+#include "content/common/media/webrtc_identity_messages.h" |
+#include "content/public/test/test_browser_thread_bundle.h" |
+#include "content/public/test/test_utils.h" |
+#include "googleurl/src/gurl.h" |
+#include "net/base/net_errors.h" |
+#include "testing/gtest/include/gtest/gtest.h" |
+ |
+namespace content { |
+ |
+class WebRTCIdentityStoreTest : public testing::Test { |
Ryan Sleevi
2013/06/27 18:05:24
Place these tests in an unnamed namespace.
jiayl
2013/06/27 18:29:36
Class WebRTCIdentityStoreTest needs to be forward
|
+ public: |
+ WebRTCIdentityStoreTest() |
+ : browser_thread_bundle_(TestBrowserThreadBundle::IO_MAINLOOP), |
+ sequenced_worker_pool_( |
+ new base::SequencedWorkerPool(3, "ServerBoundCertServiceTest")) { |
+ webrtc_identity_store_.reset( |
+ new WebRTCIdentityStore(sequenced_worker_pool_)); |
+ } |
+ |
+ virtual ~WebRTCIdentityStoreTest() { sequenced_worker_pool_->Shutdown(); } |
+ |
+ virtual void SignalWaitableEvent(const base::Closure& quit_task) { |
+ quit_task.Run(); |
+ } |
Ryan Sleevi
2013/06/27 18:05:24
Unneeded
jiayl
2013/06/27 18:29:36
Done.
|
+ |
+ protected: |
+ TestBrowserThreadBundle browser_thread_bundle_; |
+ scoped_refptr<base::SequencedWorkerPool> sequenced_worker_pool_; |
+ scoped_ptr<WebRTCIdentityStore> webrtc_identity_store_; |
+}; |
+ |
+void OnRequestCompleted(bool* completed, |
+ int error, |
+ const std::string& certificate, |
+ const std::string& private_key) { |
+ ASSERT_EQ(net::OK, error); |
+ ASSERT_NE("", certificate); |
+ ASSERT_NE("", private_key); |
+ *completed = true; |
+} |
+ |
+TEST_F(WebRTCIdentityStoreTest, RequestIdentity) { |
+ scoped_ptr<bool> completed(new bool(false)); |
+ base::Closure cancel_callback; |
+ webrtc_identity_store_->RequestIdentity( |
+ GURL("http://google.com"), |
+ "a", |
+ "b", |
+ base::Bind(&OnRequestCompleted, base::Unretained(completed.get())), |
+ &cancel_callback); |
+ sequenced_worker_pool_->FlushForTesting(); |
+ base::RunLoop().RunUntilIdle(); |
+ EXPECT_EQ(true, *completed); |
+} |
+ |
+TEST_F(WebRTCIdentityStoreTest, CancelRequest) { |
+ scoped_ptr<bool> completed(new bool(false)); |
+ base::Closure cancel_callback; |
+ bool success = webrtc_identity_store_->RequestIdentity( |
+ GURL("http://google.com"), |
+ "a", |
+ "b", |
+ base::Bind(&OnRequestCompleted, base::Unretained(completed.get())), |
+ &cancel_callback); |
+ EXPECT_TRUE(success); |
+ cancel_callback.Run(); |
+ sequenced_worker_pool_->FlushForTesting(); |
+ base::RunLoop().RunUntilIdle(); |
+ EXPECT_EQ(false, *completed); |
+} |
+ |
+TEST_F(WebRTCIdentityStoreTest, MultipleRequests) { |
+ scoped_ptr<bool> completed_1(new bool(false)); |
+ scoped_ptr<bool> completed_2(new bool(false)); |
+ base::Closure cancel_callback; |
+ webrtc_identity_store_->RequestIdentity( |
+ GURL("http://foo.com"), |
+ "a", |
+ "b", |
+ base::Bind(&OnRequestCompleted, base::Unretained(completed_1.get())), |
+ &cancel_callback); |
+ |
+ webrtc_identity_store_->RequestIdentity( |
+ GURL("http://bar.com"), |
+ "a", |
+ "b", |
+ base::Bind(&OnRequestCompleted, base::Unretained(completed_2.get())), |
+ &cancel_callback); |
+ |
+ sequenced_worker_pool_->FlushForTesting(); |
+ base::RunLoop().RunUntilIdle(); |
+ EXPECT_EQ(true, *completed_1); |
+ EXPECT_EQ(true, *completed_2); |
+} |
+ |
+} // namespace content |