1
0
mirror of https://github.com/spaam/svtplay-dl.git synced 2024-11-27 21:54:17 +01:00

Add service Barnkanalen

Heavily based on svtplay
This commit is contained in:
Nick Leppänen Larsson 2018-01-08 20:38:20 +01:00 committed by Johan Andersson
parent 02ae9767b4
commit bfa6e6e296
2 changed files with 237 additions and 0 deletions

View File

@ -49,6 +49,7 @@ from svtplay_dl.service.solidtango import Solidtango
from svtplay_dl.service.sportlib import Sportlib
from svtplay_dl.service.sr import Sr
from svtplay_dl.service.svt import Svt
from svtplay_dl.service.barnkanalen import Barnkanalen
from svtplay_dl.service.svtplay import Svtplay
from svtplay_dl.service.tv4play import Tv4play
from svtplay_dl.service.urplay import Urplay
@ -65,6 +66,7 @@ sites = [
Aftonbladet,
Aftonbladettv,
Bambuser,
Barnkanalen,
Bigbrother,
Cmore,
Dbtv,

View File

@ -0,0 +1,235 @@
# ex:ts=4:sw=4:sts=4:et
# -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*-
from __future__ import absolute_import
import re
import os
import xml.etree.ElementTree as ET
import copy
import json
import hashlib
from svtplay_dl.log import log
from svtplay_dl.service import Service, OpenGraphThumbMixin
from svtplay_dl.utils import filenamify, is_py2
from svtplay_dl.utils.urllib import urlparse, urljoin, parse_qs
from svtplay_dl.fetcher.hds import hdsparse
from svtplay_dl.fetcher.hls import hlsparse
from svtplay_dl.fetcher.dash import dashparse
from svtplay_dl.subtitle import subtitle
from svtplay_dl.error import ServiceError
class Barnkanalen(Service, OpenGraphThumbMixin):
supported_domains = ['svt.se']
supported_path = "/barnkanalen"
@classmethod
def handles(cls, url):
urlp = urlparse(url)
correctpath = urlp.path.startswith(cls.supported_path)
if urlp.netloc in cls.supported_domains and correctpath:
return True
# For every listed domain, try with www. subdomain as well.
if urlp.netloc in ['www.'+x for x in cls.supported_domains] and correctpath:
return True
return False
def get(self):
parse = urlparse(self.url)
query = parse_qs(parse.query)
self.access = None
if "accessService" in query:
self.access = query["accessService"]
match = re.search("__barnplay'] = ({.*});", self.get_urldata())
if not match:
yield ServiceError("Can't find video info.")
return
janson = json.loads(match.group(1))["context"]["dispatcher"]["stores"]["ApplicationStateStore"]["data"]
janson["video"] = janson["categoryStateCache"]["karaktarer"]["episodeModel"]
if "title" not in janson["video"]:
yield ServiceError("Can't find any video on that page.")
return
if "live" in janson["video"]:
self.options.live = janson["video"]["live"]
if self.options.output_auto:
self.options.service = "svtplay"
self.options.output = self.outputfilename(janson["video"], self.options.output)
if self.exclude():
yield ServiceError("Excluding video.")
return
if "programVersionId" in janson["video"]:
vid = janson["video"]["programVersionId"]
else:
vid = janson["video"]["id"]
res = self.http.get("http://api.svt.se/videoplayer-api/video/{0}".format(vid))
try:
janson = res.json()
except json.decoder.JSONDecodeError:
yield ServiceError("Can't decode api request: {0}".format(res.request.url))
return
videos = self._get_video(janson)
for i in videos:
yield i
def _get_video(self, janson):
if "subtitleReferences" in janson:
for i in janson["subtitleReferences"]:
if i["format"] == "websrt" and "url" in i:
yield subtitle(copy.copy(self.options), "wrst", i["url"])
if "videoReferences" in janson:
if len(janson["videoReferences"]) == 0:
yield ServiceError("Media doesn't have any associated videos.")
return
for i in janson["videoReferences"]:
streams = None
alt_streams = None
alt = None
query = parse_qs(urlparse(i["url"]).query)
if "alt" in query and len(query["alt"]) > 0:
alt = self.http.get(query["alt"][0])
if i["format"] == "hls":
streams = hlsparse(self.options, self.http.request("get", i["url"]), i["url"])
if alt:
alt_streams = hlsparse(self.options, self.http.request("get", alt.request.url), alt.request.url)
elif i["format"] == "hds":
match = re.search(r"\/se\/secure\/", i["url"])
if not match:
streams = hdsparse(self.options, self.http.request("get", i["url"], params={"hdcore": "3.7.0"}), i["url"])
if alt:
alt_streams = hdsparse(self.options, self.http.request("get", alt.request.url, params={"hdcore": "3.7.0"}), alt.request.url)
elif i["format"] == "dash264" or i["format"] == "dashhbbtv":
streams = dashparse(self.options, self.http.request("get", i["url"]), i["url"])
if alt:
alt_streams = dashparse(self.options, self.http.request("get", alt.request.url), alt.request.url)
if streams:
for n in list(streams.keys()):
yield streams[n]
if alt_streams:
for n in list(alt_streams.keys()):
yield alt_streams[n]
def _genre(self, jansson):
videos = []
parse = urlparse(self._url)
dataj = jansson["clusterPage"]
tab = re.search("tab=(.+)", parse.query)
if tab:
tab = tab.group(1)
for i in dataj["tabs"]:
if i["slug"] == tab:
videos = self.videos_to_list(i["content"], videos)
else:
videos = self.videos_to_list(dataj["clips"], videos)
return videos
def find_all_episodes(self, options):
parse = urlparse(self._url)
videos = []
tab = None
match = re.search("__barnplay'] = ({.*});", self.get_urldata())
if not match:
log.error("Couldn't retrieve episode list.")
return
else:
dataj = json.loads(match.group(1))
if re.search("/genre", parse.path):
videos = self._genre(dataj)
else:
if parse.query:
match = re.search("tab=(.+)", parse.query)
if match:
tab = match.group(1)
dataj = dataj["context"]["dispatcher"]["stores"]["EpisodesStore"]
showId = dataj["data"].keys()[0]
items = dataj["data"][showId]["episodes"]
for i in items:
program = i
videos = self.videos_to_list(program, videos)
episodes = [urljoin("http://www.svt.se", x) for x in videos]
if options.all_last > 0:
return sorted(episodes)[-options.all_last:]
return sorted(episodes)
def videos_to_list(self, lvideos, videos):
url = self.url + "/" + str(lvideos["id"])
parse = urlparse(url)
if parse.path not in videos:
filename = self.outputfilename(lvideos, self.options.output)
if not self.exclude2(filename):
videos.append(parse.path)
return videos
def outputfilename(self, data, filename):
if filename:
directory = os.path.dirname(filename)
else:
directory = ""
name = None
if data["title"]:
name = filenamify(data["title"])
other = filenamify(data["title"])
if "programVersionId" in data:
vid = str(data["programVersionId"])
else:
vid = str(data["id"])
if is_py2:
id = hashlib.sha256(vid).hexdigest()[:7]
else:
id = hashlib.sha256(vid.encode("utf-8")).hexdigest()[:7]
if name == other:
other = None
elif name is None:
name = other
other = None
season = self.seasoninfo(data)
title = name
if season:
title += ".{}".format(season)
if other:
title += ".{}".format(other)
if "accessService" in data:
if data["accessService"] == "audioDescription":
title += "-syntolkat"
if data["accessService"] == "signInterpretation":
title += "-teckentolkat"
title += "-{}-barnkanalen".format(id)
title = filenamify(title)
if len(directory):
output = os.path.join(directory, title)
else:
output = title
return output
def seasoninfo(self, data):
if "season" in data and data["season"]:
season = "{:02d}".format(data["season"])
episode = "{:02d}".format(data["episodeNumber"])
if int(season) == 0 and int(episode) == 0:
return None
return "S{}E{}".format(season, episode)
else:
return None