minor cleanup for PR review

pull/2621/head
Kris Gesling 2020-06-29 14:30:39 +09:30
parent c4478e82ad
commit e39fe64ba4
1 changed files with 15 additions and 14 deletions

View File

@ -304,36 +304,37 @@ class AudioService:
Args:
message: message bus message, not used but required
"""
def __restore_volume():
def restore_volume():
LOG.debug('restoring volume')
self.current.restore_volume()
def wait_for_speak(bus, timeout=8):
def wait_for_speak(timeout=8):
"""Wait for a speak Message on the bus.
Arguments:
bus (Mycroft MessageBus): Bus instance to listen on
timeout (int): how long to wait, defaults to 8 sec
"""
self.speak_msg_detected = False
speak_msg_detected = False
def detected_speak(message=None):
self.speak_msg_detected = True
nonlocal speak_msg_detected
speak_msg_detected = True
self.bus.on('speak', detected_speak)
time.sleep(timeout)
self.bus.remove('speak', detected_speak)
return self.speak_msg_detected
return speak_msg_detected
if self.current is None:
if self.current:
self.bus.on('recognizer_loop:speech.recognition.unknown',
restore_volume)
speak_msg_detected = wait_for_speak(self.bus)
if not speak_msg_detected:
restore_volume()
self.bus.remove('recognizer_loop:speech.recognition.unknown',
restore_volume)
else:
LOG.debug("No audio service to restore volume of")
return None
self.bus.on('recognizer_loop:speech.recognition.unknown',
__restore_volume)
speak_msg_detected = wait_for_speak(self.bus)
if not speak_msg_detected:
__restore_volume()
self.bus.remove('recognizer_loop:speech.recognition.unknown',
__restore_volume)
def play(self, tracks, prefered_service, repeat=False):
"""