| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 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 #ifndef CHROME_BROWSER_EXTENSIONS_SPEECH_INPUT_EXTENSION_SPEECH_INPUT_MANAGER_H_ | |
| 6 #define CHROME_BROWSER_EXTENSIONS_SPEECH_INPUT_EXTENSION_SPEECH_INPUT_MANAGER_H_ | |
| 7 #pragma once | |
| 8 | |
| 9 #include "base/memory/ref_counted.h" | |
| 10 #include "base/synchronization/lock.h" | |
| 11 #include "content/browser/speech/speech_recognizer.h" | |
| 12 #include "content/common/speech_input_result.h" | |
| 13 #include "content/public/browser/notification_observer.h" | |
| 14 #include "content/public/browser/notification_registrar.h" | |
| 15 #include <string> | |
| 16 | |
| 17 class Extension; | |
| 18 class Profile; | |
| 19 | |
| 20 namespace net { | |
| 21 class URLRequestContextGetter; | |
| 22 } | |
| 23 | |
| 24 // Used for API tests. | |
| 25 class ExtensionSpeechInterface { | |
| 26 public: | |
| 27 ExtensionSpeechInterface(); | |
| 28 virtual ~ExtensionSpeechInterface(); | |
| 29 | |
| 30 // Called from the IO thread. | |
| 31 virtual void StartRecording( | |
| 32 speech_input::SpeechRecognizerDelegate* delegate, | |
| 33 net::URLRequestContextGetter* context_getter, | |
| 34 int caller_id, | |
| 35 const std::string& language, | |
| 36 const std::string& grammar, | |
| 37 bool filter_profanities) = 0; | |
| 38 | |
| 39 virtual void StopRecording(bool recognition_failed) = 0; | |
| 40 virtual bool HasAudioInputDevices() = 0; | |
| 41 | |
| 42 // Called from the UI thread. | |
| 43 virtual bool HasValidRecognizer() = 0; | |
| 44 | |
| 45 // Called from both IO and UI threads. | |
| 46 virtual bool IsRecordingInProcess() = 0; | |
| 47 | |
| 48 protected: | |
| 49 scoped_refptr<speech_input::SpeechRecognizer> recognizer_; | |
| 50 }; | |
| 51 | |
| 52 // Manages the speech input requests and responses from the extensions | |
| 53 // associated to the given profile. | |
| 54 class ExtensionSpeechInputManager | |
| 55 : public base::RefCountedThreadSafe<ExtensionSpeechInputManager>, | |
| 56 public speech_input::SpeechRecognizerDelegate, | |
| 57 public content::NotificationObserver, | |
| 58 private ExtensionSpeechInterface { | |
| 59 public: | |
| 60 enum State { | |
| 61 kIdle = 0, | |
| 62 kStarting, | |
| 63 kRecording, | |
| 64 kStopping, | |
| 65 kShutdown // Internal sink state when the profile is destroyed on shutdown. | |
| 66 }; | |
| 67 | |
| 68 // Structure containing the details of the speech input failed notification. | |
| 69 struct ExtensionError { | |
| 70 std::string extension_id_; | |
| 71 std::string error_; | |
| 72 | |
| 73 ExtensionError(const std::string& extension_id, const std::string& error) | |
| 74 : extension_id_(extension_id), error_(error) {} | |
| 75 }; | |
| 76 | |
| 77 // Should not be used directly. Managed by a ProfileKeyedServiceFactory. | |
| 78 explicit ExtensionSpeechInputManager(Profile* profile); | |
| 79 | |
| 80 // Returns the corresponding manager for the given profile, creating | |
| 81 // a new one if required. | |
| 82 static ExtensionSpeechInputManager* GetForProfile(Profile* profile); | |
| 83 | |
| 84 // Initialize the ProfileKeyedServiceFactory. | |
| 85 static void InitializeFactory(); | |
| 86 | |
| 87 // Request to start speech recognition for the provided extension. | |
| 88 bool Start(const std::string& extension_id, | |
| 89 const std::string& language, | |
| 90 const std::string& grammar, | |
| 91 bool filter_profanities, | |
| 92 std::string* error); | |
| 93 | |
| 94 // Request to stop an ongoing speech recognition. | |
| 95 bool Stop(const std::string& extension_id, std::string* error); | |
| 96 | |
| 97 // Retrieve the actual state of the API manager. | |
| 98 State state() const { return state_; } | |
| 99 | |
| 100 // Check if recording is currently ongoing in Chrome. | |
| 101 bool IsRecording(); | |
| 102 | |
| 103 // Called by internal ProfileKeyedService class. | |
| 104 void ShutdownOnUIThread(); | |
| 105 | |
| 106 // Methods from content::NotificationObserver. | |
| 107 virtual void Observe(int type, | |
| 108 const content::NotificationSource& source, | |
| 109 const content::NotificationDetails& details) OVERRIDE; | |
| 110 | |
| 111 // Methods from SpeechRecognizerDelegate. | |
| 112 virtual void SetRecognitionResult( | |
| 113 int caller_id, | |
| 114 const speech_input::SpeechInputResult& result) OVERRIDE; | |
| 115 | |
| 116 virtual void DidStartReceivingAudio(int caller_id) OVERRIDE; | |
| 117 virtual void DidCompleteRecording(int caller_id) OVERRIDE; | |
| 118 virtual void DidCompleteRecognition(int caller_id) OVERRIDE; | |
| 119 virtual void DidStartReceivingSpeech(int caller_id) OVERRIDE; | |
| 120 virtual void DidStopReceivingSpeech(int caller_id) OVERRIDE; | |
| 121 virtual void OnRecognizerError(int caller_id, | |
| 122 speech_input::SpeechInputError error) | |
| 123 OVERRIDE; | |
| 124 virtual void DidCompleteEnvironmentEstimation(int caller_id) OVERRIDE; | |
| 125 virtual void SetInputVolume(int caller_id, float volume, | |
| 126 float noise_volume) OVERRIDE {} | |
| 127 | |
| 128 // Methods for API testing. | |
| 129 void SetExtensionSpeechInterface(ExtensionSpeechInterface* interface); | |
| 130 ExtensionSpeechInterface* GetExtensionSpeechInterface(); | |
| 131 | |
| 132 private: | |
| 133 // ExtensionSpeechInterface methods: | |
| 134 virtual bool IsRecordingInProcess() OVERRIDE; | |
| 135 virtual bool HasAudioInputDevices() OVERRIDE; | |
| 136 virtual bool HasValidRecognizer() OVERRIDE; | |
| 137 | |
| 138 virtual void StartRecording( | |
| 139 speech_input::SpeechRecognizerDelegate* delegate, | |
| 140 net::URLRequestContextGetter* context_getter, | |
| 141 int caller_id, | |
| 142 const std::string& language, | |
| 143 const std::string& grammar, | |
| 144 bool filter_profanities) OVERRIDE; | |
| 145 | |
| 146 virtual void StopRecording(bool recognition_failed) OVERRIDE; | |
| 147 | |
| 148 // Internal methods. | |
| 149 void StartOnIOThread( | |
| 150 net::URLRequestContextGetter* context_getter, | |
| 151 const std::string& language, | |
| 152 const std::string& grammar, | |
| 153 bool filter_profanities); | |
| 154 void ForceStopOnIOThread(); | |
| 155 | |
| 156 void SetRecognitionResultOnUIThread( | |
| 157 const speech_input::SpeechInputResult& result, | |
| 158 const std::string& extension_id); | |
| 159 void DidStartReceivingAudioOnUIThread(); | |
| 160 void StopSucceededOnUIThread(); | |
| 161 | |
| 162 void DispatchError(const std::string& error, bool dispatch_event); | |
| 163 void DispatchEventToExtension(const std::string& extension_id, | |
| 164 const std::string& event, | |
| 165 const std::string& json_args); | |
| 166 void ExtensionUnloaded(const std::string& extension_id); | |
| 167 | |
| 168 void ResetToIdleState(); | |
| 169 | |
| 170 virtual ~ExtensionSpeechInputManager(); | |
| 171 | |
| 172 friend class base::RefCountedThreadSafe<ExtensionSpeechInputManager>; | |
| 173 class Factory; | |
| 174 | |
| 175 // Lock used to allow exclusive access to the state variable and methods that | |
| 176 // either read or write on it. This is required since the speech code | |
| 177 // operates in the IO thread while the extension code uses the UI thread. | |
| 178 base::Lock state_lock_; | |
| 179 | |
| 180 // Used in the UI thread but also its raw value as notification | |
| 181 // source in the IO thread, guarded by the state lock and value. | |
| 182 Profile* profile_; | |
| 183 | |
| 184 // Used in both threads, guarded by the state lock. | |
| 185 State state_; | |
| 186 std::string extension_id_in_use_; | |
| 187 | |
| 188 // Used in the UI thread. | |
| 189 content::NotificationRegistrar registrar_; | |
| 190 ExtensionSpeechInterface* speech_interface_; | |
| 191 }; | |
| 192 | |
| 193 #endif // CHROME_BROWSER_EXTENSIONS_SPEECH_INPUT_EXTENSION_SPEECH_INPUT_MANAGER
_H_ | |
| OLD | NEW |