mirror of
https://github.com/spaam/svtplay-dl.git
synced 2024-11-24 04:05:39 +01:00
69 lines
2.2 KiB
Python
69 lines
2.2 KiB
Python
# ex:ts=4:sw=4:sts=4:et
|
|
# -*- tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*-
|
|
import json
|
|
import re
|
|
from urllib.parse import urlparse
|
|
|
|
from svtplay_dl.error import ServiceError
|
|
from svtplay_dl.fetcher.hls import hlsparse
|
|
from svtplay_dl.service import Service
|
|
|
|
|
|
class Npo(Service):
|
|
supported_domains = ["npo.nl", "ntr.nl", "omroepwnl.nl", "zapp.nl", "npo3.nl"]
|
|
|
|
def get(self):
|
|
# Get video id
|
|
parse = urlparse(self.url)
|
|
video_id = parse.path.split("/")[-1]
|
|
|
|
if "__" in video_id:
|
|
video_id = video_id.split("__")[-1]
|
|
|
|
if not video_id:
|
|
yield ServiceError("Can't find video info")
|
|
return
|
|
|
|
# Get prid
|
|
prid_src = self.http.request("get", f"http://e.omroep.nl/metadata/{video_id}")
|
|
prid_raw = prid_src.text.split("(", 1)[-1].split(")", 1)[0]
|
|
|
|
try:
|
|
janson = json.loads(prid_raw)
|
|
prid = janson["prid"]
|
|
|
|
if "titel" in janson:
|
|
self.output["title"] = janson["titel"]
|
|
except json.decoder.JSONDecodeError:
|
|
yield ServiceError(f"Can't decode prid request: {prid_raw}")
|
|
return
|
|
|
|
# Get token
|
|
token_src = self.http.request("get", f"http://ida.omroep.nl/app.php/auth/{prid}")
|
|
|
|
try:
|
|
janson = json.loads(token_src.text)
|
|
token = janson["token"]
|
|
|
|
except json.decoder.JSONDecodeError:
|
|
yield ServiceError(f"Can't decode token request: {token_src.text}")
|
|
return
|
|
|
|
# Get super api
|
|
api_url = self.http.request("get", f"http://ida.omroep.nl/app.php/{prid}?token={token}")
|
|
|
|
try:
|
|
janson = json.loads(api_url.text)
|
|
|
|
except json.decoder.JSONDecodeError:
|
|
yield ServiceError(f"Can't decode api request: {api_url.text}")
|
|
return
|
|
|
|
# Get sub api and streams
|
|
for item in janson["items"][0]:
|
|
if item["format"] == "hls":
|
|
api = self.http.request("get", item["url"]).text
|
|
raw_url = re.search(r'"url":"(.+?)"', api).group(1)
|
|
url = json.loads(f'"{raw_url}"')
|
|
yield from hlsparse(self.config, self.http.request("get", url), url, output=self.output)
|