from Components.Sources.Source import Source
-from ServiceReference import ServiceReference
from enigma import eServiceCenter, eServiceReference, eEPGCache
-class EPG( Source):
- NOW=0
- NEXT=1
- SERVICE=2
- TITLE=3
-
- def __init__(self, navcore, func=NOW):
- self.func = func
- Source.__init__(self)
- self.navcore = navcore
- self.epgcache = eEPGCache.getInstance()
- self.command = None
-
- def handleCommand(self, cmd):
- self.command = cmd
-
- def do_func(self):
- if not self.command is None:
- if self.func is self.TITLE:
- func = self.searchEvent
- elif self.func is self.SERVICE:
- func = self.getEPGofService
- elif self.func is self.NOW:
- func = self.getEPGNow
- elif self.func is self.NEXT:
- func = self.getEPGNext
-
- return func(self.command)
- else:
- return []
-
- def getEPGNow(self, bouqetref):
- return self.getEPGNowNext(bouqetref)
-
- def getEPGNext(self, bouqetref):
- return self.getEPGNowNext(bouqetref, False)
-
- def getEPGNowNext(self, bouqetref, now=True):
- print "getting EPG NOW/NEXT", bouqetref
- serviceHandler = eServiceCenter.getInstance()
- list = serviceHandler.list(eServiceReference(bouqetref))
- services = list and list.getContent('S')
-
- search = ['IBDTSERN']
- for service in services:
- if now:
- search.append((service,0,-1))
- else:
- search.append((service,1,-1))
-
- events = self.epgcache.lookupEvent(search);
- if events:
- return events
- else:
- return []
-
- def getEPGofService(self, cmd):
- print "getting EPG of Service", cmd
- events = self.epgcache.lookupEvent(['IBDTSERN',(cmd,0,-1,-1)]);
- if events:
- return events
- else:
- return []
-
- def searchEvent(self, cmd):
- print "getting EPG by title",cmd
- events = self.epgcache.search(('IBDTSERN',256,eEPGCache.PARTIAL_TITLE_SEARCH,cmd,1));
- if events:
- return events
- else:
- return []
-
- list = property(do_func)
- lut = {"EventID": 0, "TimeStart": 1,"Duration": 2, "Title": 3, "Description": 4, "DescriptionExtended": 5, "ServiceReference": 6, "ServiceName": 7 }
-
-
\ No newline at end of file
+class EPG(Source):
+ BOUQUETNOW = 0
+ BOUQUETNEXT = 1
+ SERVICENOW = 2
+ SERVICENEXT = 3
+ SERVICE = 4
+ SEARCH = 5
+ BOUQUET = 6
+ SEARCHSIMILAR = 7
+
+ def __init__(self, navcore, func=BOUQUETNOW, endtm=False):
+ self.func = func
+ Source.__init__(self)
+ self.navcore = navcore
+ self.epgcache = eEPGCache.getInstance()
+ self.command = None
+ self.endtime = endtm
+ self.search = False
+
+ def handleCommand(self, cmd):
+ print "[WebComponents.EPG] setting command to '%s' " %cmd
+ self.command = cmd
+
+ def do_func(self):
+ if not self.command is None:
+ if self.func is self.SEARCHSIMILAR:
+ func = self.searchSimilarEvent
+ elif self.func is self.SEARCH:
+ func = self.searchEvent
+ elif self.func is self.SERVICE:
+ func = self.getEPGofService
+ elif self.func is self.BOUQUETNOW:
+ func = self.getBouquetEPGNow
+ elif self.func is self.BOUQUETNEXT:
+ func = self.getBouquetEPGNext
+ elif self.func is self.BOUQUET:
+ func = self.getEPGofBouquet
+ elif self.func is self.SERVICENOW:
+ func = self.getServiceEPGNow
+ elif self.func is self.SERVICENEXT:
+ func = self.getServiceEPGNext
+
+ return func(self.command)
+ return ()
+
+ def getBouquetEPGNow(self, ref):
+ return self.getEPGNowNext(ref, 0)
+
+ def getBouquetEPGNext(self, ref):
+ return self.getEPGNowNext(ref, 1)
+
+ def getServiceEPGNow(self, ref):
+ return self.getEPGNowNext(ref, 0, True)
+
+ def getServiceEPGNext(self, ref):
+ return self.getEPGNowNext(ref, 1, True)
+
+ def getEPGNowNext(self, ref, type, service=False):
+ print "[WebComponents.EPG] getting EPG NOW/NEXT", ref
+
+ if service:
+ events = self.epgcache.lookupEvent(['IBDCTSERNX', (ref, type, -1)])
+ else:
+ serviceHandler = eServiceCenter.getInstance()
+ list = serviceHandler.list(eServiceReference(ref))
+ services = list and list.getContent('S')
+ search = ['IBDCTSERNX']
+
+ if services: # It's a Bouquet
+ search.extend([(service, type, -1) for service in services])
+
+ events = self.epgcache.lookupEvent(search)
+
+ if events:
+ return events
+ return ()
+
+ def getEPGofService(self, param, options='IBDCTSERN'):
+ print "[WebComponents.EPG] getEPGofService param: ", param
+
+ if "sRef" in param:
+ service = param["sRef"]
+ else:
+ return ()
+
+ time = -1
+ endtime = -1
+
+ if "time" in param:
+ if not param["time"] is None:
+ time = int(float(param["time"]))
+ if time < 0:
+ time = -1
+
+ if "endTime" in param:
+ if not param["endTime"] is None:
+ endtime = int( float(param["endTime"]) )
+ if endtime < 0:
+ endtime = -1
+
+ events = self.epgcache.lookupEvent([options , (service, 0, time, endtime)]);
+
+ if events:
+ if self.endtime:
+ list = self.insertEndTime(events)
+ return list
+
+ return events
+ return ()
+
+ def insertEndTime(self, events):
+ list = []
+ for event in events:
+ i = 0
+ evt = []
+ end = event[1] + event[2]
+ for item in event:
+ if i == 3:
+ evt.append(end)
+ i += 1
+
+ evt.append(item)
+ i += 1
+
+ list.append(evt)
+
+ return list
+
+ def getEPGofBouquet(self, param):
+ print "[WebComponents.EPG] getting EPG for Bouquet", param
+
+ if 'bRef' not in param:
+ return ()
+
+ time = -1
+
+ if "time" in param:
+ if not param["time"] is None:
+ time = int(float(param["time"]))
+ if time < 0:
+ time = -1
+
+ bRef = param['bRef']
+
+ serviceHandler = eServiceCenter.getInstance()
+ sl = serviceHandler.list(eServiceReference(bRef))
+ services = sl and sl.getContent('S')
+
+ search = ['IBDCTSERN']
+
+ search.extend([(service, 0, time) for service in services])
+ events = self.epgcache.lookupEvent(search)
+
+ if events:
+ return events
+ return ()
+
+ def searchEvent(self, needle):
+ print "[WebComponents.EPG] searching EPG: ", needle
+ self.search = True
+
+ events = self.epgcache.search(('IBDTSERN', 256, eEPGCache.PARTIAL_TITLE_SEARCH, needle, 1));
+ if events:
+ return events
+ return ()
+
+ def searchSimilarEvent(self, needle):
+ print "[WebComponents.EPG] searching similar eventid: ",needle
+
+ events = self.epgcache.search(('IBDCTSERN', 256, eEPGCache.SIMILAR_BROADCASTINGS_SEARCH, needle['sRef'], int(needle['eventid'])));
+ if events:
+ return events
+ return ()
+
+ def getLut(self):
+ #No Current-Time on EPGSEARCH
+ if self.search:
+ if self.endtime:
+ lut = {
+ "EventID": 0,
+ "TimeStart": 1,
+ "Duration": 2,
+ "TimeEnd": 3,
+ "Title": 4,
+ "Description": 5,
+ "DescriptionExtended": 6,
+ "ServiceReference": 7,
+ "ServiceName": 8
+ }
+ return lut
+ else:
+ lut = {
+ "EventID": 0,
+ "TimeStart": 1,
+ "Duration": 2,
+ "Title": 3,
+ "Description": 4,
+ "DescriptionExtended": 5,
+ "ServiceReference": 6,
+ "ServiceName": 7
+ }
+ else:
+
+ if self.endtime:
+ lut = {
+ "EventID": 0,
+ "TimeStart": 1,
+ "Duration": 2,
+ "TimeEnd": 3,
+ "CurrentTime": 4,
+ "Title": 5,
+ "Description": 6,
+ "DescriptionExtended": 7,
+ "ServiceReference": 8,
+ "ServiceName": 9
+ }
+ return lut
+ else:
+ lut = {
+ "EventID": 0,
+ "TimeStart": 1,
+ "Duration": 2,
+ "CurrentTime": 3,
+ "Title": 4,
+ "Description": 5,
+ "DescriptionExtended": 6,
+ "ServiceReference": 7,
+ "ServiceName": 8
+ }
+ return lut
+
+ list = property(do_func)
+
+ lut = property(getLut)
projects / vuplus_dvbapp-plugin / blobdiff