lib/python/Components/Sources/StreamService.py

   1 from Source import Source
   2 from Components.Element import cached
   3 from enigma import eServiceReference, getBestPlayableServiceReference
   4
   5 class StreamService(Source):
   6         def __init__(self, navcore):
   7                 Source.__init__(self)
   8                 self.ref = None
   9                 self.__service = None
  10                 self.navcore = navcore
  11
  12         def serviceEvent(self, event):
  13                 pass
  14
  15         @cached
  16         def getService(self):
  17                 return self.__service
  18
  19         service = property(getService)
  20
  21         def handleCommand(self, cmd):
  22                 print "StreamService handle command", cmd
  23                 self.ref = eServiceReference(cmd)
  24
  25         def recordEvent(self, service, event):
  26                 if service is self.__service:
  27                         return
  28                 print "RECORD event for us:", service
  29                 self.changed((self.CHANGED_ALL, ))
  30
  31         def execBegin(self):
  32                 print "StreamService execBegin", self.ref.toString()
  33                 if self.ref.flags & eServiceReference.isGroup:
  34                         playref = getBestPlayableServiceReference(self.ref, eServiceReference())
  35                         if playref:
  36                                 self.ref = playref
  37                 self.__service = self.navcore.recordService(self.ref)
  38                 self.navcore.record_event.append(self.recordEvent)
  39                 if self.__service is not None:
  40                         self.__service.prepareStreaming()
  41                         self.__service.start()
  42
  43         def execEnd(self):
  44                 print "StreamService execEnd", self.ref.toString()
  45                 self.navcore.record_event.remove(self.recordEvent)
  46                 if self.__service is not None:
  47                         self.navcore.stopRecordService(self.__service)
  48                         self.__service = None