content/browser: Move speech code into content namespace.

content/browser/speech/google_streaming_remote_engine_unittest.cc

 // Copyright (c) 2012 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 <queue>
 
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/utf_string_conversions.h"
 #include "content/browser/speech/audio_buffer.h"
 #include "content/browser/speech/google_streaming_remote_engine.h"
 #include "content/browser/speech/proto/google_streaming_api.pb.h"
 #include "content/public/common/speech_recognition_error.h"
 #include "content/public/common/speech_recognition_result.h"
 #include "net/url_request/test_url_fetcher_factory.h"
 #include "net/url_request/url_request_context_getter.h"
 #include "net/url_request/url_request_status.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
-using content::SpeechRecognitionHypothesis;
-using content::SpeechRecognitionResult;
 using net::URLRequestStatus;
 using net::TestURLFetcher;
 using net::TestURLFetcherFactory;
 
-namespace speech {
+namespace content {
 
 // Note: the terms upstream and downstream are from the point-of-view of the
 // client (engine_under_test_).
 
-class GoogleStreamingRemoteEngineTest
-    : public SpeechRecognitionEngineDelegate,
-      public testing::Test {
+class GoogleStreamingRemoteEngineTest : public SpeechRecognitionEngineDelegate,
+                                        public testing::Test {
  public:
   GoogleStreamingRemoteEngineTest()
       : last_number_of_upstream_chunks_seen_(0U),
-        error_(content::SPEECH_RECOGNITION_ERROR_NONE) { }
+        error_(SPEECH_RECOGNITION_ERROR_NONE) { }
 
   // Creates a speech recognition request and invokes its URL fetcher delegate
   // with the given test data.
   void CreateAndTestRequest(bool success, const std::string& http_response);
 
   // SpeechRecognitionRequestDelegate methods.
   virtual void OnSpeechRecognitionEngineResult(
       const SpeechRecognitionResult& result) OVERRIDE {
     results_.push(result);
   }
   virtual void OnSpeechRecognitionEngineError(
-      const content::SpeechRecognitionError& error) OVERRIDE {
+      const SpeechRecognitionError& error) OVERRIDE {
     error_ = error.code;
   }
 
   // testing::Test methods.
   virtual void SetUp() OVERRIDE;
   virtual void TearDown() OVERRIDE;
 
  protected:
   enum DownstreamError {
     DOWNSTREAM_ERROR_NONE,
@@ skipping 17 matching lines @@
       const proto::SpeechRecognitionEvent& result);
   void ProvideMockResultDownstream(const SpeechRecognitionResult& result);
   void ExpectResultReceived(const SpeechRecognitionResult& result);
   void CloseMockDownstream(DownstreamError error);
 
   scoped_ptr<GoogleStreamingRemoteEngine> engine_under_test_;
   TestURLFetcherFactory url_fetcher_factory_;
   size_t last_number_of_upstream_chunks_seen_;
   MessageLoop message_loop_;
   std::string response_buffer_;
-  content::SpeechRecognitionErrorCode error_;
+  SpeechRecognitionErrorCode error_;
   std::queue<SpeechRecognitionResult> results_;
 };
 
 TEST_F(GoogleStreamingRemoteEngineTest, SingleDefinitiveResult) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   // Inject some dummy audio chunks and check a corresponding chunked upload
   // is performed every time on the server.
@@ skipping 17 matching lines @@
       SpeechRecognitionHypothesis(UTF8ToUTF16("hypothesis 2"), 0.2F));
 
   ProvideMockResultDownstream(result);
   ExpectResultReceived(result);
   ASSERT_TRUE(engine_under_test_->IsRecognitionPending());
 
   // Ensure everything is closed cleanly after the downstream is closed.
   CloseMockDownstream(DOWNSTREAM_ERROR_NONE);
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NONE, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NONE, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 TEST_F(GoogleStreamingRemoteEngineTest, SeveralStreamingResults) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   for (int i = 0; i < 4; ++i) {
     InjectDummyAudioChunk();
@@ skipping 21 matching lines @@
   result.hypotheses.push_back(
       SpeechRecognitionHypothesis(UTF8ToUTF16("The final result"), 1.0F));
   ProvideMockResultDownstream(result);
   ExpectResultReceived(result);
   ASSERT_TRUE(engine_under_test_->IsRecognitionPending());
 
   // Ensure everything is closed cleanly after the downstream is closed.
   CloseMockDownstream(DOWNSTREAM_ERROR_NONE);
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NONE, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NONE, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 TEST_F(GoogleStreamingRemoteEngineTest, NoFinalResultAfterAudioChunksEnded) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   // Simulate one pushed audio chunk.
   InjectDummyAudioChunk();
@@ skipping 14 matching lines @@
   CloseMockDownstream(DOWNSTREAM_ERROR_NONE);
 
   // Expect an empty result, aimed at notifying recognition ended with no
   // actual results nor errors.
   SpeechRecognitionResult empty_result;
   ExpectResultReceived(empty_result);
 
   // Ensure everything is closed cleanly after the downstream is closed.
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NONE, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NONE, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 TEST_F(GoogleStreamingRemoteEngineTest, NoMatchError) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   for (int i = 0; i < 3; ++i)
     InjectDummyAudioChunk();
@@ skipping 26 matching lines @@
 
   InjectDummyAudioChunk();
   ASSERT_EQ(1U, UpstreamChunksUploadedFromLastCall());
 
   // Close the downstream with a HTTP 500 error.
   CloseMockDownstream(DOWNSTREAM_ERROR_HTTP500);
 
   // Expect a SPEECH_RECOGNITION_ERROR_NETWORK error to be raised.
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NETWORK, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NETWORK, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 TEST_F(GoogleStreamingRemoteEngineTest, NetworkError) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   InjectDummyAudioChunk();
   ASSERT_EQ(1U, UpstreamChunksUploadedFromLastCall());
 
   // Close the downstream fetcher simulating a network failure.
   CloseMockDownstream(DOWNSTREAM_ERROR_NETWORK);
 
   // Expect a SPEECH_RECOGNITION_ERROR_NETWORK error to be raised.
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NETWORK, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NETWORK, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 TEST_F(GoogleStreamingRemoteEngineTest, Stability) {
   StartMockRecognition();
   ASSERT_TRUE(GetUpstreamFetcher());
   ASSERT_EQ(0U, UpstreamChunksUploadedFromLastCall());
 
   // Upload a dummy audio chunk.
   InjectDummyAudioChunk();
@@ skipping 24 matching lines @@
   ASSERT_TRUE(engine_under_test_->IsRecognitionPending());
 
   // Shut down.
   CloseMockDownstream(DOWNSTREAM_ERROR_NONE);
   ASSERT_FALSE(engine_under_test_->IsRecognitionPending());
   EndMockRecognition();
 
   // Since there was no final result, we get an empty "no match" result.
   SpeechRecognitionResult empty_result;
   ExpectResultReceived(empty_result);
-  ASSERT_EQ(content::SPEECH_RECOGNITION_ERROR_NONE, error_);
+  ASSERT_EQ(SPEECH_RECOGNITION_ERROR_NONE, error_);
   ASSERT_EQ(0U, results_.size());
 }
 
 void GoogleStreamingRemoteEngineTest::SetUp() {
   engine_under_test_.reset(
       new  GoogleStreamingRemoteEngine(NULL /*URLRequestContextGetter*/));
   engine_under_test_->set_delegate(this);
 }
 
 void GoogleStreamingRemoteEngineTest::TearDown() {
@@ skipping 153 matching lines @@
 
 std::string GoogleStreamingRemoteEngineTest::ToBigEndian32(uint32 value) {
   char raw_data[4];
   raw_data[0] = static_cast<uint8>((value >> 24) & 0xFF);
   raw_data[1] = static_cast<uint8>((value >> 16) & 0xFF);
   raw_data[2] = static_cast<uint8>((value >> 8) & 0xFF);
   raw_data[3] = static_cast<uint8>(value & 0xFF);
   return std::string(raw_data, sizeof(raw_data));
 }
 
-}  // namespace speech
+}  // namespace content