-def fill_nodes(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)
- now = datetime.now()
- for series in series_list_doc:
- categories = series["e"].split()
- sid = series["a"]
- max_age = None
- for episode in series["f"]:
- air_date = datetime.strptime(episode["f"], "%Y-%m-%d %H:%M:%S")
- diff = now - air_date
- diff = 24*3600*diff.days + diff.seconds
- if max_age is None or diff < max_age:
- max_age = diff
-
- if max_age is None:
- continue
-
- series_title = series["b"].replace("&", "&")
- series_nodes = []
- for cid in categories:
- category_node = categories_map.get(cid, None)
- if category_node:
- series_nodes.append(Node(series_title, category_node))
- if not series_nodes:
- continue
-
- series_doc = grab_json(PARAMS["api"] + "series=" + sid, max_age)[0]
- for episode in series_doc["f"]:
- vpath = episode["n"]
- episode_title = episode["b"].strip()
- if series_title != episode_title:
- episode_title = series_title + " " + episode_title
- for series_node in series_nodes:
- IviewNode(episode_title, series_node, vpath)
+BASE_URL = "https://iview.abc.net.au"
+API_URL = "https://iview.abc.net.au/api"
+
+def format_episode_title(series, ep):
+ if ep:
+ return series + " " + ep
+ else:
+ return series
+
+def add_episode(parent, 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, parent, video_key)
+
+class IviewEpisodeNode(Node):
+ def __init__(self, title, parent, video_key):
+ Node.__init__(self, title, parent)
+ self.video_key = video_key
+ self.filename = title + ".ts"
+ self.can_download = True
+
+ def find_hls_url(self, playlist):
+ for video in playlist:
+ if video["type"] in ["program", "livestream"]:
+ streams = video["streams"]["hls"]
+ for quality in ["720", "sd", "sd-low"]:
+ if quality in streams:
+ return streams[quality]
+ raise Exception("Missing program stream for " + self.video_key + " -- " + self.title)
+
+ def get_auth_token(self):
+ path = "/auth/hls/sign?ts=%s&hn=%s&d=android-tablet" % (int(time.time()), self.video_key)
+ sig = hmac.new(b'android.content.res.Resources', path.encode("utf-8"), hashlib.sha256).hexdigest()
+ auth_url = BASE_URL + path + "&sig=" + sig
+ with requests_cache.disabled():
+ auth_token = grab_text(auth_url)
+ return auth_token
+
+ def download(self):
+ info = grab_json(API_URL + "/programs/" + self.video_key)
+ if "playlist" not in info:
+ return False
+ video_url = self.find_hls_url(info["playlist"])
+ auth_token = self.get_auth_token()
+ video_url = append_to_qs(video_url, {"hdnea": auth_token})
+ return download_hls(self.filename, video_url)
+
+
+class IviewIndexNode(Node):
+ def __init__(self, title, parent, url):
+ Node.__init__(self, title, parent)
+ self.url = url
+ self.unique_series = set()
+
+ def fill_children(self):
+ info = grab_json(self.url)
+ for key in ["carousels", "collections", "index"]:
+ for collection_list in info.get(key, None):
+ if isinstance(collection_list, dict):
+ for ep_info in collection_list.get("episodes", []):
+ self.add_series(ep_info)
+
+ def add_series(self, ep_info):
+ title = ep_info["seriesTitle"]
+ if title in self.unique_series:
+ return
+ self.unique_series.add(title)
+ url = API_URL + "/" + ep_info["href"]
+ IviewSeriesNode(title, self, url)
+
+class IviewSeriesNode(Node):
+ def __init__(self, title, parent, url):
+ Node.__init__(self, title, parent)
+ self.url = url
+
+ def fill_children(self):
+ ep_info = grab_json(self.url)
+ series_slug = ep_info["href"].split("/")[1]
+ series_url = API_URL + "/series/" + series_slug + "/" + ep_info["seriesHouseNumber"]
+ info = grab_json(series_url)
+ for ep_info in info.get("episodes", []):
+ add_episode(self, ep_info)
+
+class IviewFlatNode(Node):
+ def __init__(self, title, parent, url):
+ Node.__init__(self, title, parent)
+ self.url = url
+
+ def fill_children(self):
+ info = grab_json(self.url)
+ for ep_info in info:
+ add_episode(self, ep_info)