mirror of
https://github.com/nova-r/fediplug.git
synced 2025-03-13 09:08:53 +01:00
7eb9fb6673
This only works if YoutubeDL sends out a downloading status progress whenever it starts to download a new file. This is not guaranteed, however in practice it seems to be the case (and seems to be a reasonable assumption).
81 lines
2.2 KiB
Python
81 lines
2.2 KiB
Python
'''The play queue.'''
|
|
|
|
import shlex
|
|
from subprocess import run
|
|
from threading import Thread, Lock
|
|
|
|
from youtube_dl import YoutubeDL
|
|
|
|
import fediplay.env as env
|
|
|
|
class Queue(object):
|
|
'''The play queue.'''
|
|
|
|
# pylint: disable=too-few-public-methods
|
|
|
|
def __init__(self):
|
|
self.lock = Lock()
|
|
self.playing = False
|
|
self.queue = []
|
|
|
|
def add(self, url):
|
|
'''Fetches the url and adds the resulting audio to the play queue.'''
|
|
|
|
filenames = Getter().get(url)
|
|
|
|
with self.lock:
|
|
self.queue.extend(filenames)
|
|
if not self.playing:
|
|
self._play(self.queue.pop(0), self._play_finished)
|
|
|
|
def _play(self, filename, cb_complete):
|
|
self.playing = True
|
|
|
|
def _run_thread(filename, cb_complete):
|
|
print('==> Playing', filename)
|
|
play_command = build_play_command(filename)
|
|
print('[executing]', play_command)
|
|
run(play_command, shell=True)
|
|
print('==> Playback complete')
|
|
cb_complete()
|
|
|
|
thread = Thread(target=_run_thread, args=(filename, cb_complete))
|
|
thread.start()
|
|
|
|
def _play_finished(self):
|
|
with self.lock:
|
|
self.playing = False
|
|
if self.queue:
|
|
self._play(self.queue.pop(0), self._play_finished)
|
|
|
|
class Getter(object):
|
|
'''Fetches music from a url.'''
|
|
|
|
# pylint: disable=too-few-public-methods
|
|
|
|
def __init__(self):
|
|
self.filenames = []
|
|
|
|
def _progress_hook(self, progress):
|
|
if progress['status'] == 'downloading' and progress['filename'] not in self.filenames:
|
|
self.filenames.append(progress['filename'])
|
|
|
|
def get(self, url):
|
|
'''Fetches music from the given url.'''
|
|
|
|
options = {
|
|
'format': 'mp3/mp4',
|
|
'nocheckcertificate': env.no_check_certificate(),
|
|
'progress_hooks': [self._progress_hook]
|
|
}
|
|
with YoutubeDL(options) as downloader:
|
|
downloader.download([url])
|
|
|
|
return self.filenames
|
|
|
|
def build_play_command(filename):
|
|
'''Builds a play command for the given filename.'''
|
|
|
|
escaped_filename = shlex.quote(filename)
|
|
template = env.play_command()
|
|
return template.format(filename=escaped_filename)
|