tts_message_filter.cc revision 5d1f7b1de12d16ceb2c938c56701a3e8bfa558f7
1// Copyright (c) 2013 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 "chrome/browser/speech/tts_message_filter.h" 6 7#include "base/bind.h" 8#include "base/logging.h" 9#include "chrome/browser/profiles/profile.h" 10#include "chrome/browser/speech/tts_controller.h" 11#include "chrome/browser/speech/tts_message_filter.h" 12#include "content/public/browser/browser_context.h" 13#include "content/public/browser/render_process_host.h" 14 15using content::BrowserThread; 16 17TtsMessageFilter::TtsMessageFilter(int render_process_id, Profile* profile) 18 : BrowserMessageFilter(TtsMsgStart), 19 render_process_id_(render_process_id), 20 profile_(profile) { 21 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 22 TtsController::GetInstance()->AddVoicesChangedDelegate(this); 23} 24 25void TtsMessageFilter::OverrideThreadForMessage( 26 const IPC::Message& message, BrowserThread::ID* thread) { 27 switch (message.type()) { 28 case TtsHostMsg_InitializeVoiceList::ID: 29 case TtsHostMsg_Speak::ID: 30 case TtsHostMsg_Pause::ID: 31 case TtsHostMsg_Resume::ID: 32 case TtsHostMsg_Cancel::ID: 33 *thread = BrowserThread::UI; 34 break; 35 } 36} 37 38bool TtsMessageFilter::OnMessageReceived(const IPC::Message& message, 39 bool* message_was_ok) { 40 bool handled = true; 41 IPC_BEGIN_MESSAGE_MAP_EX(TtsMessageFilter, message, *message_was_ok) 42 IPC_MESSAGE_HANDLER(TtsHostMsg_InitializeVoiceList, OnInitializeVoiceList) 43 IPC_MESSAGE_HANDLER(TtsHostMsg_Speak, OnSpeak) 44 IPC_MESSAGE_HANDLER(TtsHostMsg_Pause, OnPause) 45 IPC_MESSAGE_HANDLER(TtsHostMsg_Resume, OnResume) 46 IPC_MESSAGE_HANDLER(TtsHostMsg_Cancel, OnCancel) 47 IPC_MESSAGE_UNHANDLED(handled = false) 48 IPC_END_MESSAGE_MAP() 49 return handled; 50} 51 52void TtsMessageFilter::OnChannelClosing() { 53 BrowserThread::PostTask( 54 BrowserThread::UI, FROM_HERE, 55 base::Bind(&TtsMessageFilter::OnChannelClosingInUIThread, this)); 56} 57 58void TtsMessageFilter::OnInitializeVoiceList() { 59 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 60 TtsController* tts_controller = TtsController::GetInstance(); 61 std::vector<VoiceData> voices; 62 tts_controller->GetVoices(profile_, &voices); 63 64 std::vector<TtsVoice> out_voices; 65 out_voices.resize(voices.size()); 66 for (size_t i = 0; i < voices.size(); ++i) { 67 TtsVoice& out_voice = out_voices[i]; 68 out_voice.voice_uri = voices[i].name; 69 out_voice.name = voices[i].name; 70 out_voice.lang = voices[i].lang; 71 out_voice.local_service = !voices[i].remote; 72 out_voice.is_default = (i == 0); 73 } 74 Send(new TtsMsg_SetVoiceList(out_voices)); 75} 76 77void TtsMessageFilter::OnSpeak(const TtsUtteranceRequest& request) { 78 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 79 scoped_ptr<Utterance> utterance(new Utterance(profile_)); 80 utterance->set_src_id(request.id); 81 utterance->set_text(request.text); 82 utterance->set_lang(request.lang); 83 utterance->set_voice_name(request.voice); 84 utterance->set_can_enqueue(true); 85 86 UtteranceContinuousParameters params; 87 params.rate = request.rate; 88 params.pitch = request.pitch; 89 params.volume = request.volume; 90 utterance->set_continuous_parameters(params); 91 92 utterance->set_event_delegate(this->AsWeakPtr()); 93 94 TtsController::GetInstance()->SpeakOrEnqueue(utterance.release()); 95} 96 97void TtsMessageFilter::OnPause() { 98 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 99 TtsController::GetInstance()->Pause(); 100} 101 102void TtsMessageFilter::OnResume() { 103 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 104 TtsController::GetInstance()->Resume(); 105} 106 107void TtsMessageFilter::OnCancel() { 108 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 109 TtsController::GetInstance()->Stop(); 110} 111 112void TtsMessageFilter::OnTtsEvent(Utterance* utterance, 113 TtsEventType event_type, 114 int char_index, 115 const std::string& error_message) { 116 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 117 switch (event_type) { 118 case TTS_EVENT_START: 119 Send(new TtsMsg_DidStartSpeaking(utterance->src_id())); 120 break; 121 case TTS_EVENT_END: 122 Send(new TtsMsg_DidFinishSpeaking(utterance->src_id())); 123 break; 124 case TTS_EVENT_WORD: 125 Send(new TtsMsg_WordBoundary(utterance->src_id(), char_index)); 126 break; 127 case TTS_EVENT_SENTENCE: 128 Send(new TtsMsg_SentenceBoundary(utterance->src_id(), char_index)); 129 break; 130 case TTS_EVENT_MARKER: 131 Send(new TtsMsg_MarkerEvent(utterance->src_id(), char_index)); 132 break; 133 case TTS_EVENT_INTERRUPTED: 134 Send(new TtsMsg_WasInterrupted(utterance->src_id())); 135 break; 136 case TTS_EVENT_CANCELLED: 137 Send(new TtsMsg_WasCancelled(utterance->src_id())); 138 break; 139 case TTS_EVENT_ERROR: 140 Send(new TtsMsg_SpeakingErrorOccurred( 141 utterance->src_id(), error_message)); 142 break; 143 case TTS_EVENT_PAUSE: 144 Send(new TtsMsg_DidPauseSpeaking(utterance->src_id())); 145 break; 146 case TTS_EVENT_RESUME: 147 Send(new TtsMsg_DidResumeSpeaking(utterance->src_id())); 148 break; 149 } 150} 151 152void TtsMessageFilter::OnVoicesChanged() { 153 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 154 OnInitializeVoiceList(); 155} 156 157void TtsMessageFilter::OnChannelClosingInUIThread() { 158 CHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 159 TtsController::GetInstance()->RemoveVoicesChangedDelegate(this); 160} 161 162TtsMessageFilter::~TtsMessageFilter() { 163} 164