sugarlabs/sugar-toolkit-gtk3
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

sugar3.speech - expose player pipeline

Browse Source 
Expose the GstSpeechPlayer pipeline so that the activities may add their
own handlers.

A quick way to get the rest of the gst-plugins-espeak signals available.
This commit is contained in:
James Cameron 2019-07-24 16:57:09 +10:00
parent 9a6c9ce69c
commit 23e664df05
1 changed files with 33 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
src/sugar3/speech.py
View File

@ -205,16 +205,16 @@ class SpeechManager(GObject.GObject):
def __init__(self, **kwargs): def __init__(self, **kwargs):
GObject.GObject.__init__(self, **kwargs) GObject.GObject.__init__(self, **kwargs)
self._player = None self.player = None
if not self.enabled(): if not self.enabled():
return return
self._player = _GstSpeechPlayer() self.player = _GstSpeechPlayer()
self._player.connect('play', self._update_state, 'play') self.player.connect('play', self._update_state, 'play')
self._player.connect('stop', self._update_state, 'stop') self.player.connect('stop', self._update_state, 'stop')
self._player.connect('pause', self._update_state, 'pause') self.player.connect('pause', self._update_state, 'pause')
self._player.connect('mark', self._mark_cb) self.player.connect('mark', self._mark_cb)
self._default_voice_name = self._player.get_default_voice() self._default_voice_name = self.player.get_default_voice()
self._pitch = DEFAULT_PITCH self._pitch = DEFAULT_PITCH
self._rate = DEFAULT_RATE self._rate = DEFAULT_RATE
self._is_playing = False self._is_playing = False
@ -271,7 +271,7 @@ class SpeechManager(GObject.GObject):
if lang_code is None: if lang_code is None:
voice_name = self._default_voice_name voice_name = self._default_voice_name
else: else:
voice_name = self._player.get_all_voices()[lang_code] voice_name = self.player.get_all_voices()[lang_code]
if text: if text:
logging.error( logging.error(
'PLAYING %r lang %r pitch %r rate %r', 'PLAYING %r lang %r pitch %r rate %r',
@ -279,20 +279,20 @@ class SpeechManager(GObject.GObject):
voice_name, voice_name,
pitch, pitch,
rate) rate)
self._player.speak(pitch, rate, voice_name, text) self.player.speak(pitch, rate, voice_name, text)
def say_selected_text(self): def say_selected_text(self):
clipboard = Gtk.Clipboard.get(Gdk.SELECTION_PRIMARY) clipboard = Gtk.Clipboard.get(Gdk.SELECTION_PRIMARY)
clipboard.request_text(self.__primary_selection_cb, None) clipboard.request_text(self.__primary_selection_cb, None)
def pause(self): def pause(self):
self._player.pause_sound_device() self.player.pause_sound_device()
def restart(self): def restart(self):
self._player.restart_sound_device() self.player.restart_sound_device()
def stop(self): def stop(self):
self._player.stop_sound_device() self.player.stop_sound_device()
def __primary_selection_cb(self, clipboard, text, user_data): def __primary_selection_cb(self, clipboard, text, user_data):
self.say_text(text) self.say_text(text)
@ -315,23 +315,23 @@ class SpeechManager(GObject.GObject):
self._pitch, self._rate) self._pitch, self._rate)
def get_all_voices(self): def get_all_voices(self):
if self._player: if self.player:
return self._player.get_all_voices() return self.player.get_all_voices()
return None return None
def get_all_traslated_voices(self): def get_all_traslated_voices(self):
""" deprecated after 0.112, due to method name spelling error """ """ deprecated after 0.112, due to method name spelling error """
if self._player: if self.player:
return self._player.get_all_translated_voices() return self.player.get_all_translated_voices()
return None return None
def get_all_translated_voices(self): def get_all_translated_voices(self):
if self._player: if self.player:
return self._player.get_all_translated_voices() return self.player.get_all_translated_voices()
return None return None
class _GstSpeechPlayer(GObject.GObject): class GstSpeechPlayer(GObject.GObject):
__gsignals__ = { __gsignals__ = {
'play': (GObject.SignalFlags.RUN_FIRST, None, []), 'play': (GObject.SignalFlags.RUN_FIRST, None, []),
@ -342,50 +342,50 @@ class _GstSpeechPlayer(GObject.GObject):
def __init__(self): def __init__(self):
GObject.GObject.__init__(self) GObject.GObject.__init__(self)
self._pipeline = None self.pipeline = None
self._all_voices = None self._all_voices = None
self._all_translated_voices = None self._all_translated_voices = None
def restart_sound_device(self): def restart_sound_device(self):
if self._pipeline is None: if self.pipeline is None:
logging.debug('Trying to restart not initialized sound device') logging.debug('Trying to restart not initialized sound device')
return return
power.get_power_manager().inhibit_suspend() power.get_power_manager().inhibit_suspend()
self._pipeline.set_state(Gst.State.PLAYING) self.pipeline.set_state(Gst.State.PLAYING)
self.emit('play') self.emit('play')
def pause_sound_device(self): def pause_sound_device(self):
if self._pipeline is None: if self.pipeline is None:
return return
self._pipeline.set_state(Gst.State.PAUSED) self.pipeline.set_state(Gst.State.PAUSED)
power.get_power_manager().restore_suspend() power.get_power_manager().restore_suspend()
self.emit('pause') self.emit('pause')
def stop_sound_device(self): def stop_sound_device(self):
if self._pipeline is None: if self.pipeline is None:
return return
self._pipeline.set_state(Gst.State.NULL) self.pipeline.set_state(Gst.State.NULL)
power.get_power_manager().restore_suspend() power.get_power_manager().restore_suspend()
self.emit('stop') self.emit('stop')
def make_pipeline(self, command): def make_pipeline(self, command):
if self._pipeline is not None: if self.pipeline is not None:
self.stop_sound_device() self.stop_sound_device()
del self._pipeline del self.pipeline
self._pipeline = Gst.parse_launch(command) self.pipeline = Gst.parse_launch(command)
bus = self._pipeline.get_bus() bus = self.pipeline.get_bus()
bus.add_signal_watch() bus.add_signal_watch()
bus.connect('message', self.__pipe_message_cb) bus.connect('message', self.__pipe_message_cb)
def __pipe_message_cb(self, bus, message): def __pipe_message_cb(self, bus, message):
if message.type in (Gst.MessageType.EOS, Gst.MessageType.ERROR): if message.type in (Gst.MessageType.EOS, Gst.MessageType.ERROR):
self._pipeline.set_state(Gst.State.NULL) self.pipeline.set_state(Gst.State.NULL)
self._pipeline = None self.pipeline = None
power.get_power_manager().restore_suspend() power.get_power_manager().restore_suspend()
self.emit('stop') self.emit('stop')
elif message.type is Gst.MessageType.ELEMENT and \ elif message.type is Gst.MessageType.ELEMENT and \
@ -399,7 +399,7 @@ class _GstSpeechPlayer(GObject.GObject):
return return
self.make_pipeline('espeak name=espeak ! autoaudiosink') self.make_pipeline('espeak name=espeak ! autoaudiosink')
src = self._pipeline.get_by_name('espeak') src = self.pipeline.get_by_name('espeak')
src.props.text = text src.props.text = text
src.props.pitch = pitch src.props.pitch = pitch