XBMC Tuxbox Enigma Stream Client (Enigma / Enigma2 Based Dreambox & Dbox2)

Code:
import xbmc, xbmcplugin, xbmcgui, urllib, urllib2, sys, xml.dom.minidom



def getText(nodelist):

    rc = []

    for node in nodelist:

        if node.nodeType == node.TEXT_NODE:

            rc.append(node.data)

    return ''.join(rc)



class Dreambox(object):

    __settings__ = sys.modules[ "__main__" ].__settings__

    __language__ = sys.modules[ "__main__" ].__language__

    __plugin__ = sys.modules[ "__main__" ].__plugin__



    def __init__(self, handle):

        self.handle = handle

        self.ipaddress = self.__settings__.getSetting("ipaddress")

        self.username = self.__settings__.getSetting("username")

        self.password = self.__settings__.getSetting("password")

        

        password_mgr = urllib2.HTTPPasswordMgrWithDefaultRealm()

        dreambox_url = "http://" + self.ipaddress

        password_mgr.add_password(None, dreambox_url, self.username, self.password)

        handler = urllib2.HTTPBasicAuthHandler(password_mgr)

        opener = urllib2.build_opener(handler)

        urllib2.install_opener(opener)



    def rootmenu(self):

        menu = [

            { "name":self.__language__( 1 ), "mode": "tv" },

            { "name":self.__language__( 2 ), "mode": "radio" },

            { "name":self.__language__( 3 ), "mode": "movies" },

        ]



        for item in menu:

            li = xbmcgui.ListItem(item["name"])

            url = sys.argv[0] + '?' + urllib.urlencode({"mode":item["mode"]})

            xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(menu) )



        xbmcplugin.endOfDirectory(handle=self.handle, succeeded=True)



    def readradioservicelist(self):

        # Get Bouquet list

        data = urllib2.urlopen("http://" + self.ipaddress + "/web/getservices?" + urllib.urlencode({"sRef": '1:7:2:0:0:0:0:0:0:0:(type == 2)FROM BOUQUET "bouquets.radio" ORDER BY bouquet'}))

        e2servicelist = xml.dom.minidom.parse(data)

        data.close()



        servicelist = e2servicelist.getElementsByTagName("e2service")

        for service in servicelist:

            data = {}

            for element in service.childNodes:

                data[element.localName] = getText(element.childNodes)



            cmd = {}

            cmd["mode"] ="readservice"

            cmd["e2servicename"] = data["e2servicename"].encode("utf-8")

            cmd["e2servicereference"] = data["e2servicereference"].encode("utf-8")



            li = xbmcgui.ListItem(data["e2servicename"])

            url = sys.argv[0] + '?' + urllib.urlencode(cmd)

            xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(servicelist))



        # Get provider list

        data = {

            "mode":"readservice",

            "e2servicename":"Provider",

            "e2servicereference":"1:7:2:0:0:0:0:0:0:0:(type == 2) FROM PROVIDERS ORDER BY name"

        }

        li = xbmcgui.ListItem(data["e2servicename"])

        url = sys.argv[0] + '?' + urllib.urlencode(data)

        xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(servicelist))



        xbmcplugin.endOfDirectory(handle=self.handle, succeeded=True)



    def readtvservicelist(self):

        # Get Bouquet list

        data = urllib2.urlopen("http://" + self.ipaddress + "/web/getservices?" + urllib.urlencode({"sRef": '1:7:1:0:0:0:0:0:0:0:(type == 1) || (type == 17) || (type == 195) || (type == 25)FROM BOUQUET "bouquets.tv" ORDER BY bouquet'}))

        e2servicelist = xml.dom.minidom.parse(data)

        data.close()



        servicelist = e2servicelist.getElementsByTagName("e2service")

        for service in servicelist:

            data = {}

            for element in service.childNodes:

                data[element.localName] = getText(element.childNodes)



            cmd = {}

            cmd["mode"] ="readservice"

            cmd["e2servicename"] = data["e2servicename"].encode("utf-8")

            cmd["e2servicereference"] = data["e2servicereference"].encode("utf-8")



            li = xbmcgui.ListItem(data["e2servicename"])

            url = sys.argv[0] + '?' + urllib.urlencode(cmd)

            xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(servicelist))



        # Get provider list

        data = {

            "mode":"readservice",

            "e2servicename":"Provider",

            "e2servicereference":"1:7:1:0:0:0:0:0:0:0:(type == 1) || (type == 17) || (type == 195) || (type == 25) FROM PROVIDERS ORDER BY name"

        }

        li = xbmcgui.ListItem(data["e2servicename"])

        url = sys.argv[0] + '?' + urllib.urlencode(data)

        xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(servicelist))



        # Get satellite list

        data = {

            "mode":"readservice",

            "e2servicename":"Satellite",

            "e2servicereference":"1:7:1:0:0:0:0:0:0:0:(type == 1) || (type == 17) || (type == 195) || (type == 25) FROM SATELLITES ORDER BY name"

        }

        li = xbmcgui.ListItem(data["e2servicename"])

        url = sys.argv[0] + '?' + urllib.urlencode(data)

        xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=True, totalItems=len(servicelist))



        xbmcplugin.endOfDirectory(handle=self.handle, succeeded=True)



    def readservice(self, data):

        servicereference = data["e2servicereference"][0].decode("utf-8")

        data = urllib2.urlopen("http://" + self.ipaddress + "/web/getservices?" + urllib.urlencode({"sRef": servicereference.encode("utf-8")}))

        e2servicelist = xml.dom.minidom.parse(data)

        data.close()

        currentEvent1 = "http://" + self.ipaddress + "/web/epgnow?" + urllib.urlencode({"bRef": servicereference})

        dataEpg = urllib2.urlopen("http://" + self.ipaddress + "/web/epgnow?" + urllib.urlencode({"bRef": servicereference.encode("utf-8")}))

        e2epglist = xml.dom.minidom.parse(dataEpg)

        dataEpg.close()

        servicelist = e2servicelist.getElementsByTagName("e2service")

        epglist = e2epglist.getElementsByTagName("e2event")

        epgArray = {}

        theTitle = ""

        theName = ""

        for epg in epglist:

            tempData = {}

            for element in epg.childNodes:

                tempData[element.localName] = getText(element.childNodes)

                if element.localName == "e2eventtitle" :

                    theTitle = getText(element.childNodes)

                if element.localName == "e2eventservicename" :

                    theName = getText(element.childNodes)

                if theName and theTitle:

                    epgArray[theName] = theTitle

                    theName=""

                    theTitle=""

            

            



            

    

        for service in servicelist:

            data = {}

            for element in service.childNodes:

                data[element.localName] = getText(element.childNodes)

            servicereference = data["e2servicereference"].split(":")

            attr = int(servicereference[1])

            mode = int(servicereference[2])

            cmd = {}

            if attr & 4:

                cmd["mode"] ="readservice"

                isFolder = True

                currentEvent = ""

            else:

                cmd["mode"] ="stream"

                isFolder = False

                

                currentEvent = " (" + epgArray[data["e2servicename"]]  + ")"

                

            cmd["e2servicename"] = data["e2servicename"].encode("utf-8")

            cmd["e2servicereference"] = data["e2servicereference"].encode("utf-8")

            extraInfo = " (" + epgArray[data["e2servicename"]]  + ")"

            li = xbmcgui.ListItem(data["e2servicename"] + extraInfo)

            mediatype = ""

            if mode == 1:

                mediatype = "video"

            elif mode == 2:

                mediatype = "music"

            if mediatype:

                li.setInfo(mediatype, {'Title': data["e2servicename"] })

            url = sys.argv[0] + '?' + urllib.urlencode(cmd)

            xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=isFolder, totalItems=len(servicelist))

        xbmcplugin.endOfDirectory(handle=self.handle, succeeded=True)



    def readmovies(self):

        data = urllib2.urlopen("http://" + self.ipaddress + "/web/movielist")

        e2movielist = xml.dom.minidom.parse(data)

        data.close()



        movieList = e2movielist.getElementsByTagName("e2movie")

        for movie in movieList:

            data = {}

            for element in movie.childNodes:

                data[element.localName] = getText(element.childNodes)



            li = xbmcgui.ListItem(data["e2title"], data["e2description"])

            labels = {

                "size":int(data["e2filesize"]), 

                "plot":data["e2description"], 

                "title":data["e2title"]

            }

            li.setInfo("video", labels)

            url = sys.argv[0] + '?' + urllib.urlencode({"mode":"ts", "e2servicename":data["e2title"].encode("utf-8"), "e2filename":data["e2filename"].encode("utf-8"), "e2servicereference":data["e2servicereference"].encode("utf-8")})

            xbmcplugin.addDirectoryItem(handle=self.handle, url=url, listitem=li, isFolder=False, totalItems=len(movieList))

        xbmcplugin.endOfDirectory(handle=self.handle, succeeded=True)



    def stream(self, data):

        servicename = data["e2servicename"][0].decode("utf-8")

        servicereference = data["e2servicereference"][0].decode("utf-8")

        reference = servicereference.split(":")

        mode = int(reference[2])



        data = urllib2.urlopen("http://" + self.ipaddress + "/web/stream.m3u?" + urllib.urlencode({"ref": servicereference.encode("utf-8")}))

        playlist = data.readlines()

        playlist[-1] = playlist[-1].replace(" ", "%20")

        data.close()



        li = xbmcgui.ListItem(servicename)

        mediatype = ""

        if mode == 1:

            mediatype = "video"

        elif mode == 2:

            mediatype = "music"

        if mediatype:

            li.setInfo(mediatype, {'Title': servicename })

        xbmc.Player().play(playlist[-1], li)

        

    def ts(self, data):

        servicename = data["e2servicename"][0].decode("utf-8")

        filename = data["e2filename"][0].decode("utf-8")

        servicereference = data["e2servicereference"][0].decode("utf-8")

        reference = servicereference.split(":")

        mode = int(reference[2])

        

        url = "http://" + self.ipaddress + "/file?file=" + filename.replace("/", "%2F").replace(" ", "%20")



        li = xbmcgui.ListItem(servicename)

        mediatype = ""

        if mode == 1:

            mediatype = "video"



        elif mode == 2:

            mediatype = "music"

        if mediatype:

            li.setInfo(mediatype, {'Title': servicename })

        xbmc.Player().play(url, li)