Initial commit.

4 files changed, 260 insertions, 0 deletions

diff --git a/src/livestreamer/plugins/__init__.py b/src/livestreamer/plugins/__init__.py
new file mode 100644
index 0000000..3999574
--- /dev/null
+++ b/src/livestreamer/plugins/__init__.py
@@ -0,0 +1,31 @@
+#!/usr/bin/env python3
+
+import pkgutil
+import imp
+
+plugins_loaded = {}
+
+class Plugin(object):
+    def can_handle_url(self, url):
+        raise NotImplementedError
+
+    def get_streams(self, channel):
+        raise NotImplementedError
+
+    def stream_cmdline(self, stream, filename):
+        raise NotImplementedError
+
+
+def load_plugins(plugins):
+    for loader, name, ispkg in pkgutil.iter_modules(plugins.__path__):
+        file, pathname, desc = imp.find_module(name, plugins.__path__)
+        imp.load_module(name, file, pathname, desc)
+    return plugins_loaded
+
+
+def get_plugins():
+    return plugins_loaded
+
+def register_plugin(name, klass):
+    obj = klass()
+    plugins_loaded[name] = obj
diff --git a/src/livestreamer/plugins/justintv.py b/src/livestreamer/plugins/justintv.py
new file mode 100644
index 0000000..6607ae4
--- /dev/null
+++ b/src/livestreamer/plugins/justintv.py
@@ -0,0 +1,80 @@
+#!/usr/bin/env python3
+
+from livestreamer.plugins import Plugin, register_plugin
+from livestreamer.utils import CommandLine
+
+import urllib.request, urllib.error, urllib.parse
+import xml.dom.minidom, re
+
+class JustinTV(object):
+    StreamInfoURL = "http://usher.justin.tv/find/%s.xml?type=any"
+    SWFURL = "http://www.justin.tv/widgets/live_embed_player.swf"
+
+    def can_handle_url(self, url):
+        return ("justin.tv" in url) or ("twitch.tv" in url)
+
+    def get_channel_name(self, url):
+        fd = urllib.request.urlopen(url)
+        data = fd.read()
+        fd.close()
+
+        match = re.search(b"live_facebook_embed_player\.swf\?channel=(\w+)", data)
+        if match:
+            return str(match.group(1), "ascii")
+
+
+    def get_streams(self, url):
+        def get_node_text(element):
+            res = []
+            for node in element.childNodes:
+                if node.nodeType == node.TEXT_NODE:
+                    res.append(node.data)
+            return "".join(res)
+
+        def clean_tag(tag):
+            if tag[0] == "_":
+                return tag[1:]
+            else:
+                return tag
+
+        channelname = self.get_channel_name(url)
+
+        if not channelname:
+            return False
+
+        fd = urllib.request.urlopen(self.StreamInfoURL % channelname)
+        data = fd.read()
+        fd.close()
+
+        # fix invalid xml
+        data = re.sub(b"<(\d+)", b"<_\g<1>", data)
+        data = re.sub(b"</(\d+)", b"</_\g<1>", data)
+
+        streams = {}
+        dom = xml.dom.minidom.parseString(data)
+        nodes = dom.getElementsByTagName("nodes")[0]
+
+        for node in nodes.childNodes:
+            stream = {}
+            for child in node.childNodes:
+                stream[child.tagName] = get_node_text(child)
+
+            sname = clean_tag(node.tagName)
+            streams[sname] = stream
+
+        return streams
+
+    def stream_cmdline(self, stream, filename):
+        cmd = CommandLine("rtmpdump")
+        cmd.arg("rtmp", ("{0}/{1}").format(stream["connect"], stream["play"]))
+        cmd.arg("swfUrl", self.SWFURL)
+        cmd.arg("live", True)
+        cmd.arg("flv", filename)
+
+        if "token" in stream:
+            cmd.arg("jtv", stream["token"])
+
+        return cmd.format()
+
+
+register_plugin("justintv", JustinTV)
diff --git a/src/livestreamer/plugins/ownedtv.py b/src/livestreamer/plugins/ownedtv.py
new file mode 100644
index 0000000..1bf05db
--- /dev/null
+++ b/src/livestreamer/plugins/ownedtv.py
@@ -0,0 +1,80 @@
+#!/usr/bin/env python3
+
+from livestreamer.plugins import Plugin, register_plugin
+from livestreamer.utils import CommandLine
+
+import urllib.request, urllib.error, urllib.parse
+import xml.dom.minidom, re
+
+class RelativeRedirectHandler(urllib.request.HTTPRedirectHandler):
+    def http_error_302(self, req, fp, code, msg, headers):
+        if "location" in headers and headers["location"][0] == "/":
+            absurl = ("{scheme}://{host}{path}").format(
+                      scheme=req.get_type(), host=req.get_host(),
+                      path=headers["location"])
+            del headers["location"]
+            headers["location"] = absurl
+
+        return urllib.request.HTTPRedirectHandler.http_error_301(
+               self, req, fp, code, msg, headers)
+
+urlopener = urllib.request.build_opener(RelativeRedirectHandler)
+
+
+class OwnedTV(Plugin):
+    ConfigURL = "http://www.own3d.tv/livecfg/{0}"
+    RTMPURL = "rtmp://owned.fc.llnwd.net:1935/owned/"
+
+    def can_handle_url(self, url):
+        return "own3d.tv" in url
+
+    def get_channel_id(self, url):
+        fd = urlopener.open(url)
+        data = fd.read()
+        fd.close()
+
+        match = re.search(b"own3d.tv\/livestreamfb\/(\d+)", data)
+        if match:
+            return int(match.group(1))
+
+    def get_streams(self, url):
+        channelid = self.get_channel_id(url)
+
+        if not channelid:
+            return False
+
+        fd = urllib.request.urlopen(self.ConfigURL.format(channelid))
+        data = fd.read()
+        fd.close()
+
+        streams = {}
+        dom = xml.dom.minidom.parseString(data)
+        channels = dom.getElementsByTagName("channels")[0]
+        clip = channels.getElementsByTagName("clip")[0]
+
+        streams = {}
+        for item in clip.getElementsByTagName("item"):
+            base = item.getAttribute("base")
+            if base == "${cdn2}":
+                for streamel in item.getElementsByTagName("stream"):
+                    name = streamel.getAttribute("label").lower()
+                    playpath = streamel.getAttribute("name")
+
+                    streams[name] = {
+                        "name": name,
+                        "playpath": playpath
+                    }
+
+        return streams
+
+
+    def stream_cmdline(self, stream, filename):
+        cmd = CommandLine("rtmpdump")
+        cmd.arg("rtmp", ("{0}/{1}").format(self.RTMPURL, stream["playpath"]))
+        cmd.arg("live", True)
+        cmd.arg("flv", filename)
+
+        return cmd.format()
+
+
+register_plugin("own3dtv", OwnedTV)
diff --git a/src/livestreamer/plugins/ustreamtv.py b/src/livestreamer/plugins/ustreamtv.py
new file mode 100644
index 0000000..a33b1d4
--- /dev/null
+++ b/src/livestreamer/plugins/ustreamtv.py
@@ -0,0 +1,69 @@
+#!/usr/bin/env python3
+
+from livestreamer.plugins import Plugin, register_plugin
+from livestreamer.utils import CommandLine
+
+import urllib.request, urllib.error, urllib.parse
+import xml.dom.minidom, re
+
+
+class UStreamTV(Plugin):
+    AMFURL = "http://cgw.ustream.tv/Viewer/getStream/1/{0}.amf"
+    SWFURL = "http://cdn1.ustream.tv/swf/4/viewer.rsl.210.swf"
+
+    def can_handle_url(self, url):
+        return "ustream.tv" in url
+
+    def get_channel_id(self, url):
+        fd = urllib.request.urlopen(url)
+        data = fd.read()
+        fd.close()
+
+        match = re.search(b"channelId=(\d+)", data)
+        if match:
+            return int(match.group(1))
+
+    def get_streams(self, url):
+        def get_amf_value(data, key):
+            pattern = ("{0}\W\W\W(.+?)\x00").format(key)
+            match = re.search(bytes(pattern, "ascii"), data)
+            if match:
+                return str(match.group(1), "ascii")
+
+        channelid = self.get_channel_id(url)
+
+        if not channelid:
+            return False
+
+        fd = urllib.request.urlopen(self.AMFURL.format(channelid))
+        data = fd.read()
+        fd.close()
+
+        stream = {}
+
+        playpath = get_amf_value(data, "streamName")
+        cdnurl = get_amf_value(data, "cdnUrl")
+        fmsurl = get_amf_value(data, "fmsUrl")
+
+        if not playpath:
+            return False
+
+        stream["playpath"] = playpath
+        stream["rtmp"] = cdnurl or fmsurl
+        stream["url"] = url
+
+        return {"live": stream}
+
+
+    def stream_cmdline(self, stream, filename):
+        cmd = CommandLine("rtmpdump")
+        cmd.arg("rtmp", ("{0}/{1}").format(stream["rtmp"], stream["playpath"]))
+        cmd.arg("swfUrl", self.SWFURL)
+        cmd.arg("pageUrl", stream["url"])
+        cmd.arg("live", True)
+        cmd.arg("flv", filename)
+
+        return cmd.format()
+
+
+register_plugin("ustreamtv", UStreamTV)