|
|
@ -57,8 +57,6 @@ from get_providers import get_providers, get_providers_auth, list_throttled_prov
|
|
|
|
from get_series import *
|
|
|
|
from get_series import *
|
|
|
|
from get_episodes import *
|
|
|
|
from get_episodes import *
|
|
|
|
|
|
|
|
|
|
|
|
# if not args.no_update:
|
|
|
|
|
|
|
|
# from check_update import check_updates
|
|
|
|
|
|
|
|
from list_subtitles import store_subtitles, store_subtitles_movie, series_scan_subtitles, movies_scan_subtitles, \
|
|
|
|
from list_subtitles import store_subtitles, store_subtitles_movie, series_scan_subtitles, movies_scan_subtitles, \
|
|
|
|
list_missing_subtitles, list_missing_subtitles_movies
|
|
|
|
list_missing_subtitles, list_missing_subtitles_movies
|
|
|
|
from get_subtitle import download_subtitle, series_download_subtitles, movies_download_subtitles, \
|
|
|
|
from get_subtitle import download_subtitle, series_download_subtitles, movies_download_subtitles, \
|
|
|
@ -2009,27 +2007,6 @@ def notifications():
|
|
|
|
def running_tasks_list():
|
|
|
|
def running_tasks_list():
|
|
|
|
return dict(tasks=running_tasks)
|
|
|
|
return dict(tasks=running_tasks)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@route(base_url + 'websocket_updater')
|
|
|
|
|
|
|
|
@custom_auth_basic(check_credentials)
|
|
|
|
|
|
|
|
def handle_websocket():
|
|
|
|
|
|
|
|
wsock = request.environ.get('wsgi.websocket')
|
|
|
|
|
|
|
|
if not wsock:
|
|
|
|
|
|
|
|
abort(400, 'Expected WebSocket request.')
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
queueconfig.q4ws_updater.clear()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
while True:
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
|
|
|
if queueconfig.q4ws_updater:
|
|
|
|
|
|
|
|
wsock.send(queueconfig.q4ws_updater.popleft())
|
|
|
|
|
|
|
|
gevent.sleep(0.1)
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
|
|
|
gevent.sleep(0.5)
|
|
|
|
|
|
|
|
except WebSocketError:
|
|
|
|
|
|
|
|
break
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# Mute DeprecationWarning
|
|
|
|
# Mute DeprecationWarning
|
|
|
|
warnings.simplefilter("ignore", DeprecationWarning)
|
|
|
|
warnings.simplefilter("ignore", DeprecationWarning)
|
|
|
|
server = WSGIServer((str(settings.general.ip), (int(args.port) if args.port else int(settings.general.port))), app, handler_class=WebSocketHandler)
|
|
|
|
server = WSGIServer((str(settings.general.ip), (int(args.port) if args.port else int(settings.general.port))), app, handler_class=WebSocketHandler)
|
|
|
|