2014-10-27 23:29:04 +01:00
|
|
|
# -*- coding: utf-8 -*-
|
|
|
|
import sys
|
|
|
|
import url_shortener
|
|
|
|
import audio_services
|
|
|
|
import os
|
|
|
|
import logging as original_logger
|
|
|
|
log = original_logger.getLogger("sound")
|
|
|
|
import paths
|
2017-07-19 15:25:09 +02:00
|
|
|
import sound_lib
|
2014-10-27 23:29:04 +01:00
|
|
|
import subprocess
|
|
|
|
import platform
|
2014-11-13 03:41:29 +01:00
|
|
|
import output
|
2018-02-17 00:58:57 +01:00
|
|
|
import youtube_utils
|
2014-10-27 23:29:04 +01:00
|
|
|
system = platform.system()
|
|
|
|
from mysc.repeating_timer import RepeatingTimer
|
2015-05-14 16:01:37 +02:00
|
|
|
from mysc.thread_utils import call_threaded
|
2015-04-20 01:10:34 +02:00
|
|
|
import application
|
2016-01-30 17:14:41 +01:00
|
|
|
import tempfile
|
|
|
|
import glob
|
2015-01-20 22:40:33 +01:00
|
|
|
URLPlayer = None
|
2014-10-27 23:29:04 +01:00
|
|
|
|
|
|
|
def setup():
|
2015-01-20 22:40:33 +01:00
|
|
|
global URLPlayer
|
2014-11-13 03:41:29 +01:00
|
|
|
if not URLPlayer:
|
2015-01-19 00:19:39 +01:00
|
|
|
log.debug("creating stream URL player...")
|
2014-11-13 03:41:29 +01:00
|
|
|
URLPlayer = URLStream()
|
2014-10-27 23:29:04 +01:00
|
|
|
|
|
|
|
def recode_audio(filename, quality=4.5):
|
|
|
|
global system
|
|
|
|
if system == "Windows": subprocess.call(r'"%s" -q %r "%s"' % (paths.app_path('oggenc2.exe'), quality, filename))
|
|
|
|
|
|
|
|
def recording(filename):
|
|
|
|
# try:
|
2017-07-19 15:25:09 +02:00
|
|
|
val = sound_lib.recording.WaveRecording(filename=filename)
|
2014-10-27 23:29:04 +01:00
|
|
|
# except sound_lib.main.BassError:
|
|
|
|
# sound_lib.input.Input()
|
|
|
|
# val = sound_lib.recording.WaveRecording(filename=filename)
|
|
|
|
return val
|
|
|
|
|
|
|
|
class soundSystem(object):
|
|
|
|
|
|
|
|
def check_soundpack(self):
|
|
|
|
""" Checks if the folder where live the current soundpack exists."""
|
|
|
|
self.soundpack_OK = False
|
2015-01-20 22:40:33 +01:00
|
|
|
if os.path.exists(paths.sound_path(self.config["current_soundpack"])):
|
|
|
|
self.path = paths.sound_path(self.config["current_soundpack"])
|
2014-10-27 23:29:04 +01:00
|
|
|
self.soundpack_OK = True
|
|
|
|
elif os.path.exists(paths.sound_path("default")):
|
2015-01-19 00:19:39 +01:00
|
|
|
log.error("The soundpack does not exist, using default...")
|
2014-10-27 23:29:04 +01:00
|
|
|
self.path = paths.sound_path("default")
|
|
|
|
self.soundpack_OK = True
|
|
|
|
else:
|
2015-04-20 01:10:34 +02:00
|
|
|
log.error("The current soundpack could not be found and the default soundpack has been deleted, " + application.name + " will not play sounds.")
|
2014-10-27 23:29:04 +01:00
|
|
|
self.soundpack_OK = False
|
|
|
|
|
2015-01-20 22:40:33 +01:00
|
|
|
def __init__(self, soundConfig):
|
2014-10-27 23:29:04 +01:00
|
|
|
""" Sound Player."""
|
2015-01-20 22:40:33 +01:00
|
|
|
self.config = soundConfig
|
2014-10-27 23:29:04 +01:00
|
|
|
# Set the output and input default devices.
|
2017-07-19 15:23:34 +02:00
|
|
|
try:
|
2017-07-19 15:25:09 +02:00
|
|
|
self.output = sound_lib.output.Output()
|
|
|
|
self.input = sound_lib.input.Input()
|
|
|
|
except:
|
2017-07-19 15:23:34 +02:00
|
|
|
pass
|
2017-07-19 15:25:09 +02:00
|
|
|
# Try to use the selected device from the configuration. It can fail if the machine does not has a mic.
|
2017-07-19 15:23:34 +02:00
|
|
|
try:
|
|
|
|
log.debug("Setting input and output devices...")
|
|
|
|
self.output.set_device(self.output.find_device_by_name(self.config["output_device"]))
|
|
|
|
self.input.set_device(self.input.find_device_by_name(self.config["input_device"]))
|
|
|
|
except:
|
2017-07-19 15:25:09 +02:00
|
|
|
log.error("Error in input or output devices, using defaults...")
|
2017-07-19 15:23:34 +02:00
|
|
|
self.config["output_device"] = "Default"
|
|
|
|
self.config["input_device"] = "Default"
|
|
|
|
|
2014-10-27 23:29:04 +01:00
|
|
|
self.files = []
|
|
|
|
self.cleaner = RepeatingTimer(60, self.clear_list)
|
|
|
|
self.cleaner.start()
|
|
|
|
self.check_soundpack()
|
|
|
|
|
|
|
|
def clear_list(self):
|
2014-11-13 03:41:29 +01:00
|
|
|
if len(self.files) == 0: return
|
|
|
|
try:
|
|
|
|
for i in range(0, len(self.files)):
|
|
|
|
if self.files[i].is_playing == False:
|
|
|
|
self.files[i].free()
|
|
|
|
self.files.pop(i)
|
|
|
|
except IndexError:
|
|
|
|
pass
|
2014-10-27 23:29:04 +01:00
|
|
|
|
|
|
|
def play(self, sound, argument=False):
|
|
|
|
if self.soundpack_OK == False: return
|
2015-03-12 00:17:29 +01:00
|
|
|
if self.config["session_mute"] == True: return
|
2017-07-19 15:25:09 +02:00
|
|
|
sound_object = sound_lib.stream.FileStream(file="%s/%s" % (self.path, sound))
|
2015-01-20 22:40:33 +01:00
|
|
|
sound_object.volume = float(self.config["volume"])
|
2014-10-27 23:29:04 +01:00
|
|
|
self.files.append(sound_object)
|
|
|
|
sound_object.play()
|
|
|
|
|
2014-11-13 03:41:29 +01:00
|
|
|
class URLStream(object):
|
2017-09-18 06:28:31 +02:00
|
|
|
def __init__(self, url=None):
|
2015-05-13 16:39:21 +02:00
|
|
|
self.url = url
|
2014-10-27 23:29:04 +01:00
|
|
|
self.prepared = False
|
2015-03-11 13:11:42 +01:00
|
|
|
log.debug("URL Player initialized")
|
2018-02-17 00:58:57 +01:00
|
|
|
self.mode = "generic"
|
2014-10-27 23:29:04 +01:00
|
|
|
|
2014-11-13 03:41:29 +01:00
|
|
|
def prepare(self, url):
|
2015-03-11 13:11:42 +01:00
|
|
|
log.debug("Preparing URL: %s" % (url,))
|
2014-10-27 23:29:04 +01:00
|
|
|
self.prepared = False
|
2014-11-13 03:41:29 +01:00
|
|
|
self.url = url_shortener.unshorten(url)
|
2017-12-10 17:22:12 +01:00
|
|
|
if self.url == None:
|
|
|
|
self.url = url
|
2015-03-11 13:11:42 +01:00
|
|
|
log.debug("Expanded URL: %s" % (self.url,))
|
2014-11-13 03:41:29 +01:00
|
|
|
if self.url != None:
|
|
|
|
transformer = audio_services.find_url_transformer(self.url)
|
2018-02-17 00:58:57 +01:00
|
|
|
transformed_url = transformer(self.url)
|
|
|
|
if transformed_url == "youtube-url":
|
|
|
|
self.url = youtube_utils.get_video_url(url)
|
|
|
|
self.mode = "youtube"
|
|
|
|
else:
|
|
|
|
self.url = transformed_url
|
|
|
|
self.mode = "generic"
|
2017-12-10 17:22:12 +01:00
|
|
|
log.debug("Transformed URL: %s. Prepared" % (self.url,))
|
2017-09-22 17:38:03 +02:00
|
|
|
self.prepared = True
|
2014-10-27 23:29:04 +01:00
|
|
|
|
2016-08-11 04:59:19 +02:00
|
|
|
def seek(self,step):
|
2018-02-17 00:58:57 +01:00
|
|
|
if self.mode == "youtube":
|
|
|
|
return
|
2016-08-11 04:59:19 +02:00
|
|
|
pos=self.stream.get_position()
|
|
|
|
pos=self.stream.bytes_to_seconds(pos)
|
|
|
|
pos+=step
|
|
|
|
pos=self.stream.seconds_to_bytes(pos)
|
|
|
|
if pos<0:
|
|
|
|
pos=0
|
|
|
|
self.stream.set_position(pos)
|
|
|
|
|
|
|
|
def playpause(self):
|
2018-02-17 00:58:57 +01:00
|
|
|
if self.mode == "youtube":
|
|
|
|
if youtube_utils.player != None:
|
|
|
|
youtube_utils.player.kill()
|
|
|
|
self.mode = "generic"
|
|
|
|
youtube_utils.player = None
|
2016-08-11 04:59:19 +02:00
|
|
|
if self.stream.is_playing==True:
|
|
|
|
self.stream.pause()
|
|
|
|
else:
|
|
|
|
self.stream.play()
|
|
|
|
|
2015-05-13 23:29:58 +02:00
|
|
|
def play(self, url=None, volume=1.0, stream=None,announce=True):
|
2015-07-04 00:23:25 +02:00
|
|
|
if announce:
|
|
|
|
output.speak(_(u"Playing..."))
|
|
|
|
log.debug("Attempting to play an URL...")
|
|
|
|
if url != None:
|
|
|
|
self.prepare(url)
|
|
|
|
elif stream != None:
|
|
|
|
self.stream=stream
|
|
|
|
if self.prepared == True:
|
2018-02-17 00:58:57 +01:00
|
|
|
if self.mode == "youtube":
|
|
|
|
youtube_utils.play_video(self.url)
|
|
|
|
else:
|
|
|
|
self.stream = sound_lib.stream.URLStream(url=self.url)
|
|
|
|
if hasattr(self,'stream'):
|
|
|
|
self.stream.volume = float(volume)
|
|
|
|
self.stream.play()
|
|
|
|
log.debug("played")
|
|
|
|
self.prepared=False
|
2015-05-14 16:01:37 +02:00
|
|
|
|
2015-05-14 03:34:26 +02:00
|
|
|
def stop_audio(self,delete=False):
|
2018-02-17 00:58:57 +01:00
|
|
|
if self.mode == "youtube":
|
|
|
|
youtube_utils.stop()
|
|
|
|
self.prepared = False
|
2015-06-01 18:18:39 +02:00
|
|
|
output.speak(_(u"Stopped."), True)
|
2015-05-14 03:34:26 +02:00
|
|
|
return True
|
|
|
|
else:
|
2018-02-17 00:58:57 +01:00
|
|
|
if hasattr(self, "stream"):
|
|
|
|
output.speak(_(u"Stopped."), True)
|
|
|
|
try:
|
|
|
|
self.stream.stop()
|
|
|
|
log.debug("Stopped audio stream.")
|
|
|
|
except:
|
|
|
|
log.exception("Exception while stopping stream.")
|
|
|
|
if delete:
|
|
|
|
del self.stream
|
|
|
|
log.debug("Deleted audio stream.")
|
|
|
|
self.prepared=False
|
|
|
|
return True
|
|
|
|
else:
|
|
|
|
return False
|
2015-07-04 00:23:25 +02:00
|
|
|
|
2014-10-27 23:29:04 +01:00
|
|
|
@staticmethod
|
|
|
|
def delete_old_tempfiles():
|
|
|
|
for f in glob(os.path.join(tempfile.gettempdir(), 'tmp*.wav')):
|
|
|
|
try:
|
|
|
|
os.remove(f)
|
|
|
|
except:
|
|
|
|
pass
|
|
|
|
|