src/chrome/browser/speech/tts_message_filter.cc

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