]> code.delx.au - webdl/blobdiff - iview.py
hls: allow last segment to be missing
[webdl] / iview.py
index 22897bb82d90dff344b6c9c52ad2e29d57b4e502..cfe5ec4a9ceab6e08eeac0a8e915e560155db4c6 100644 (file)
--- a/iview.py
+++ b/iview.py
-#!/usr/bin/env python
-# vim:ts=4:sts=4:sw=4:noet
-
-from common import grab_xml, grab_json, download_rtmp, Node
-from datetime import datetime
-
-BASE_URL = "http://www.abc.net.au/iview/"
-CONFIG_URL = BASE_URL + "xml/config.xml"
-HASH_URL = BASE_URL + "images/iview.jpg"
-NS = {
-       "auth": "http://www.abc.net.au/iView/Services/iViewHandshaker",
-}
-
-class IviewNode(Node):
-       def __init__(self, title, parent, vpath):
-               Node.__init__(self, title, parent)
-               self.vpath = vpath
-               self.can_download = True
-
-       def download(self):
-               auth_doc = grab_xml(PARAMS["auth"], 0)
-               vbase = auth_doc.xpath("//auth:server/text()", namespaces=NS)[0]
-               token = auth_doc.xpath("//auth:token/text()", namespaces=NS)[0]
-               vbase += "?auth=" + token
-               vpath, ext = self.vpath.rsplit(".", 1)
-               vpath = ext + ":" + vpath
-               filename = self.title + "." + ext
-               return download_rtmp(filename, vbase, vpath, HASH_URL)
-
-
-class IviewSeries(Node):
-       def __init__(self, series_title, series_id, parent):
-               Node.__init__(self, series_title, parent)
-               self.series_title = series_title
-               self.series_id = series_id
-
-       def fill_children(self):
-               series_doc = grab_json(PARAMS["api"] + "series=" + self.series_id, 3600)[0]
-               for episode in series_doc["f"]:
-                       vpath = episode["n"]
-                       episode_title = episode["b"].strip()
-                       if not episode_title.startswith(self.series_title):
-                               episode_title = self.series_title + " " + episode_title
-                       IviewNode(episode_title, self, vpath)
+from common import grab_json, grab_xml, Node, download_hls
+import urlparse
 
+API_URL = "http://iview.abc.net.au/api"
+AUTH_URL = "http://iview.abc.net.au/auth"
+
+def format_episode_title(series, ep):
+    if ep:
+        return series + " " + ep
+    else:
+        return series
+
+class IviewEpisodeNode(Node):
+    def __init__(self, title, parent, video_key):
+        Node.__init__(self, title, parent)
+        self.video_key = video_key
+        self.filename = title + ".mp4"
+        self.can_download = True
+
+    def find_hls_url(self, playlist):
+        for video in playlist:
+            if video["type"] == "program":
+                return video["hls-high"]
+        raise Exception("Missing hls-high program stream for " + self.video_key)
+
+    def get_auth_details(self):
+        auth_doc = grab_xml(AUTH_URL, 0)
+        NS = {
+            "auth": "http://www.abc.net.au/iView/Services/iViewHandshaker",
+        }
+        token = auth_doc.xpath("//auth:tokenhd/text()", namespaces=NS)[0]
+        token_url = auth_doc.xpath("//auth:server/text()", namespaces=NS)[0]
+        token_hostname = urlparse.urlparse(token_url).netloc
+        return token, token_hostname
+
+    def hack_url_auth_token(self, video_url, token, token_hostname):
+        parsed_url = urlparse.urlparse(video_url)
+        hacked_url = parsed_url._replace(netloc=token_hostname, query="hdnea=" + token)
+        video_url = urlparse.urlunparse(hacked_url)
+        return video_url
+
+    def download(self):
+        info = grab_json(API_URL + "/programs/" + self.video_key, 3600)
+        video_url = self.find_hls_url(info["playlist"])
+        token, token_hostname= self.get_auth_details()
+        hack_url = lambda url: self.hack_url_auth_token(url, token, token_hostname)
+        download_hls(self.filename, video_url, hack_url)
+
+
+class IviewIndexNode(Node):
+    def __init__(self, title, parent, url):
+        Node.__init__(self, title, parent)
+        self.url = url
+        self.series_map = {}
+
+    def add_episode(self, ep_info):
+        video_key = ep_info["episodeHouseNumber"]
+        series_title = ep_info["seriesTitle"]
+        title = ep_info.get("title", None)
+        episode_title = format_episode_title(series_title, title)
+
+        series_node = self.series_map.get(series_title, None)
+        if not series_node:
+            series_node = Node(series_title, self)
+            self.series_map[series_title] = series_node
+
+        IviewEpisodeNode(episode_title, series_node, video_key)
+
+    def fill_children(self):
+        info = grab_json(self.url, 3600)
+        for index_list in info["index"]:
+            for ep_info in index_list["episodes"]:
+                self.add_episode(ep_info)
+
+class IviewFlatNode(Node):
+    def __init__(self, title, parent, url):
+        Node.__init__(self, title, parent)
+        self.url = url
+
+    def add_episode(self, ep_info):
+        video_key = ep_info["episodeHouseNumber"]
+        series_title = ep_info["seriesTitle"]
+        title = ep_info.get("title", None)
+        episode_title = format_episode_title(series_title, title)
+
+        IviewEpisodeNode(episode_title, self, video_key)
+
+    def fill_children(self):
+        info = grab_json(self.url, 3600)
+        for ep_info in info:
+            self.add_episode(ep_info)
+
+
+class IviewRootNode(Node):
+    def load_categories(self):
+        by_category_node = Node("By Category", self)
+        def category(name, slug):
+            IviewIndexNode(name, by_category_node, API_URL + "/category/" + slug)
+
+        category("Arts & Culture", "arts")
+        category("Comedy", "comedy")
+        category("Documentary", "docs")
+        category("Drama", "drama")
+        category("Education", "education")
+        category("Lifestyle", "lifestyle")
+        category("News & Current Affairs", "news")
+        category("Panel & Discussion", "panel")
+        category("Sport", "sport")
+
+    def load_channels(self):
+        by_channel_node = Node("By Channel", self)
+        def channel(name, slug):
+            IviewIndexNode(name, by_channel_node, API_URL + "/channel/" + slug)
+
+        channel("ABC1", "abc1")
+        channel("ABC2", "abc2")
+        channel("ABC3", "abc3")
+        channel("ABC4Kids", "abc4kids")
+        channel("iView Exclusives", "iview")
+
+    def load_featured(self):
+        IviewFlatNode("Featured", self, API_URL + "/featured")
+
+    def fill_children(self):
+        self.load_categories()
+        self.load_channels()
+        self.load_featured()
 
 
 def fill_nodes(root_node):
-       root_node = Node("ABC iView", root_node)
-
-       config_doc = grab_xml(CONFIG_URL, 24*3600)
-       global PARAMS
-       PARAMS = dict((p.attrib["name"], p.attrib["value"]) for p in config_doc.xpath("/config/param"))
-
-       categories_doc = grab_xml(BASE_URL + PARAMS["categories"], 24*3600)
-       categories_map = {}
-       for category in categories_doc.xpath("//category[@genre='true']"):
-               cid = category.attrib["id"]
-               category_name = category.xpath("name/text()")[0]
-               category_node = Node(category_name, root_node)
-               categories_map[cid] = category_node
-
-       # Create a duplicate of each series within each category that it appears
-       series_list_doc = grab_json(PARAMS["api"] + "seriesIndex", 3600)
-       for series in series_list_doc:
-               categories = series["e"].split()
-               sid = series["a"]
-
-               series_title = series["b"].replace("&", "&")
-               for cid in categories:
-                       category_node = categories_map.get(cid, None)
-                       if category_node:
-                               IviewSeries(series_title, sid, category_node)
+    IviewRootNode("ABC iView", root_node)