mirror of
https://github.com/spaam/svtplay-dl.git
synced 2024-11-28 06:04:17 +01:00
196 lines
6.6 KiB
Python
196 lines
6.6 KiB
Python
import os
|
|
import sys
|
|
import copy
|
|
|
|
|
|
from svtplay_dl.log import log
|
|
from svtplay_dl.service import service_handler, Generic
|
|
from svtplay_dl.service.services import sites, Raw
|
|
from svtplay_dl.fetcher import VideoRetriever
|
|
from svtplay_dl.subtitle import subtitle
|
|
from svtplay_dl.utils.output import filename, formatname
|
|
from svtplay_dl.postprocess import postprocess
|
|
from svtplay_dl.utils.stream import select_quality, list_quality
|
|
from svtplay_dl.utils.text import exclude
|
|
from svtplay_dl.error import UIException
|
|
|
|
|
|
def get_multiple_media(urls, options):
|
|
if options.output and os.path.isfile(options.output):
|
|
log.error("Output must be a directory if used with multiple URLs")
|
|
sys.exit(2)
|
|
elif options.output and not os.path.exists(options.output):
|
|
try:
|
|
os.makedirs(options.output)
|
|
except OSError as e:
|
|
log.error("%s: %s", e.strerror, e.filename)
|
|
return
|
|
|
|
for url in urls:
|
|
get_media(url, copy.copy(options))
|
|
|
|
|
|
def get_media(url, options, version="Unknown"):
|
|
if "http" not in url[:4]:
|
|
url = "http://%s" % url
|
|
|
|
if options.get("silent_semi"):
|
|
options.set("silent", True)
|
|
if options.get("verbose"):
|
|
log.debug("version: {0}".format(version))
|
|
|
|
stream = service_handler(sites, options, url)
|
|
if not stream:
|
|
generic = Generic(options, url)
|
|
url, stream = generic.get(sites)
|
|
if not stream:
|
|
if url.find(".f4m") > 0 or url.find(".m3u8") > 0:
|
|
stream = Raw(options, url)
|
|
if not stream:
|
|
log.error("That site is not supported. Make a ticket or send a message")
|
|
sys.exit(2)
|
|
|
|
if options.get("all_episodes"):
|
|
get_all_episodes(stream, copy.copy(options), url)
|
|
else:
|
|
get_one_media(stream, copy.copy(options))
|
|
|
|
|
|
def get_all_episodes(stream, options, url):
|
|
if options.output and os.path.isfile(options.output):
|
|
log.error("Output must be a directory if used with --all-episodes")
|
|
sys.exit(2)
|
|
elif options.output and not os.path.exists(options.output):
|
|
try:
|
|
os.makedirs(options.output)
|
|
except OSError as e:
|
|
log.error("%s: %s", e.strerror, e.filename)
|
|
return
|
|
|
|
episodes = stream.find_all_episodes(options)
|
|
if episodes is None:
|
|
return
|
|
for idx, o in enumerate(episodes):
|
|
if o == url:
|
|
substream = stream
|
|
else:
|
|
substream = service_handler(sites, copy.copy(options), o)
|
|
|
|
log.info("Episode %d of %d", idx + 1, len(episodes))
|
|
log.info("Url: %s", o)
|
|
|
|
# get_one_media overwrites options.output...
|
|
get_one_media(substream, copy.copy(options))
|
|
|
|
|
|
def get_one_media(stream, config):
|
|
# Make an automagic filename
|
|
if not filename(stream):
|
|
return
|
|
|
|
if config.get("merge_subtitle"):
|
|
from svtplay_dl.utils.proc import which
|
|
if not which('ffmpeg'):
|
|
log.error("--merge-subtitle needs ffmpeg. Please install ffmpeg.")
|
|
log.info("https://ffmpeg.org/download.html")
|
|
sys.exit(2)
|
|
|
|
videos = []
|
|
subs = []
|
|
subfixes = []
|
|
error = []
|
|
streams = stream.get()
|
|
try:
|
|
for i in streams:
|
|
if not exclude(config, formatname(i.output, config)):
|
|
if isinstance(i, VideoRetriever):
|
|
if config.get("preferred"):
|
|
if config.get("preferred").lower() == i.name():
|
|
videos.append(i)
|
|
else:
|
|
videos.append(i)
|
|
if isinstance(i, subtitle):
|
|
subs.append(i)
|
|
if isinstance(i, Exception):
|
|
error.append(i)
|
|
except Exception as e:
|
|
if config.get("verbose"):
|
|
raise
|
|
else:
|
|
log.error("svtplay-dl crashed")
|
|
log.error("Run again and add --verbose as an argument, to get more information")
|
|
log.error("If the error persists, you can report it at https://github.com/spaam/svtplay-dl/issues")
|
|
log.error("Include the URL used, the stack trace and the output of svtplay-dl --version in the issue")
|
|
sys.exit(3)
|
|
|
|
if config.get("require_subtitle") and not subs:
|
|
log.info("No subtitles available")
|
|
return
|
|
|
|
if config.get("subtitle") and config.get("get_url"):
|
|
if subs:
|
|
if config.get("get_all_subtitles"):
|
|
for sub in subs:
|
|
print(sub.url)
|
|
else:
|
|
print(subs[0].url)
|
|
if config.force_subtitle:
|
|
return
|
|
|
|
def options_subs_dl(subfixes):
|
|
if subs:
|
|
if config.get("get_all_subtitles"):
|
|
for sub in subs:
|
|
sub.download()
|
|
if config.get("merge_subtitle"):
|
|
if sub.subfix:
|
|
subfixes += [sub.subfix]
|
|
else:
|
|
config.set("get_all_subtitles", False)
|
|
else:
|
|
subs[0].download()
|
|
elif config.get("merge_subtitle"):
|
|
config.set("merge_subtitle", False)
|
|
|
|
if config.get("subtitle") and not config.get("get_url"):
|
|
options_subs_dl(subfixes)
|
|
if config.get("force_subtitle"):
|
|
return
|
|
|
|
if config.get("merge_subtitle") and not config.get("subtitle"):
|
|
options_subs_dl(subfixes)
|
|
|
|
if not videos:
|
|
log.error("No videos found.")
|
|
for exc in error:
|
|
log.error(str(exc))
|
|
else:
|
|
if config.get("list_quality"):
|
|
list_quality(videos)
|
|
return
|
|
try:
|
|
stream = select_quality(config, videos)
|
|
if config.get("get_url"):
|
|
print(stream.url)
|
|
return
|
|
log.info("Selected to download %s, bitrate: %s",
|
|
stream.name(), stream.bitrate)
|
|
stream.download()
|
|
except UIException as e:
|
|
if config.get("verbose"):
|
|
raise e
|
|
log.error(e)
|
|
sys.exit(2)
|
|
|
|
if config.get("thumbnail") and hasattr(stream, "get_thumbnail"):
|
|
stream.get_thumbnail(config)
|
|
post = postprocess(stream, config, subfixes)
|
|
if stream.name() == "dash" and post.detect:
|
|
post.merge()
|
|
if stream.name() == "dash" and not post.detect and stream.finished:
|
|
log.warning("Cant find ffmpeg/avconv. audio and video is in seperate files. if you dont want this use -P hls or hds")
|
|
if config.get("remux"):
|
|
post.remux()
|
|
if config.get("silent_semi") and stream.finished:
|
|
log.log(25, "Download of %s was completed" % stream.options.output)
|