import struct
import os
from config import config, ConfigSelection, ConfigYesNo, ConfigSubsection, ConfigText
from enigma import eHdmiCEC, eRCInput
from Tools.StbHardware import getFPWasTimerWakeup
from enigma import eTimer

config.hdmicec = ConfigSubsection()
config.hdmicec.enabled = ConfigYesNo(default = True)
config.hdmicec.control_tv_standby = ConfigYesNo(default = True)
config.hdmicec.control_tv_wakeup = ConfigYesNo(default = True)
config.hdmicec.report_active_source = ConfigYesNo(default = True)
config.hdmicec.report_active_menu = ConfigYesNo(default = True)
config.hdmicec.handle_tv_standby = ConfigYesNo(default = True)
config.hdmicec.handle_tv_wakeup = ConfigYesNo(default = True)
config.hdmicec.tv_wakeup_detection = ConfigSelection(
   choices = {
   "wakeup": _("Wakeup"),
   "tvreportphysicaladdress": _("TV physical address report"),
   "sourcerequest": _("Source request"),
   "streamrequest": _("Stream request"),
   "osdnamerequest": _("OSD name request"),
   "vendorid": _("Vendor ID (LG)"),
   "activity": _("Any activity"),
   },
   default = "streamrequest")
config.hdmicec.fixed_physical_address = ConfigText(default = "0.0.0.0")
config.hdmicec.volume_forwarding = ConfigYesNo(default = False)
config.hdmicec.control_receiver_wakeup = ConfigYesNo(default = False)
config.hdmicec.control_receiver_standby = ConfigYesNo(default = False)
config.hdmicec.handle_deepstandby_events = ConfigYesNo(default = False)
choicelist = []
for i in (10, 50, 100, 150, 250):
   choicelist.append(("%d" % i, "%d ms" % i))
config.hdmicec.minimum_send_interval = ConfigSelection(default = "0", choices = [("0", _("Disabled"))] + choicelist)

class HdmiCec:
   instance = None

   def __init__(self):
      assert not HdmiCec.instance, "only one HdmiCec instance is allowed!"
      HdmiCec.instance = self

      self.wait = eTimer()
      self.wait.timeout.get().append(self.sendCmd)
      self.queue = []

      eHdmiCEC.getInstance().messageReceived.get().append(self.messageReceived)
      config.misc.standbyCounter.addNotifier(self.onEnterStandby, initial_call = False)
      config.misc.DeepStandby.addNotifier(self.onEnterDeepStandby, initial_call = False)
      self.setFixedPhysicalAddress(config.hdmicec.fixed_physical_address.value)

      self.volumeForwardingEnabled = False
      self.volumeForwardingDestination = 0
      eRCInput.getInstance().pyKeyEvent.get().append(self.keyEvent)
      config.hdmicec.volume_forwarding.addNotifier(self.configVolumeForwarding)
      if config.hdmicec.handle_deepstandby_events.value:
         if not getFPWasTimerWakeup():
            self.wakeupMessages()

   def getPhysicalAddress(self):
      physicaladdress = eHdmiCEC.getInstance().getPhysicalAddress()
      hexstring = '%04x' % physicaladdress
      return hexstring[0] + '.' + hexstring[1] + '.' + hexstring[2] + '.' + hexstring[3]

   def setFixedPhysicalAddress(self, address):
      if address != config.hdmicec.fixed_physical_address.value:
         config.hdmicec.fixed_physical_address.value = address
         config.hdmicec.fixed_physical_address.save()
      hexstring = address[0] + address[2] + address[4] + address[6]
      eHdmiCEC.getInstance().setFixedPhysicalAddress(int(float.fromhex(hexstring)))

   def sendMessage(self, address, message):
      cmd = 0
      data = ''
      if message == "wakeup":
         cmd = 0x04
      elif message == "sourceactive":
         address = 0x0f # use broadcast for active source command
         cmd = 0x82
         physicaladdress = eHdmiCEC.getInstance().getPhysicalAddress()
         data = str(struct.pack('BB', int(physicaladdress/256), int(physicaladdress%256)))
      elif message == "standby":
         cmd = 0x36
      elif message == "sourceinactive":
         physicaladdress = eHdmiCEC.getInstance().getPhysicalAddress()
         cmd = 0x9d
         data = str(struct.pack('BB', int(physicaladdress/256), int(physicaladdress%256)))
      elif message == "menuactive":
         cmd = 0x8e
         data = str(struct.pack('B', 0x00))
      elif message == "menuinactive":
         cmd = 0x8e
         data = str(struct.pack('B', 0x01))
      elif message == "givesystemaudiostatus":
         cmd = 0x7d
         address = 0x05
      elif message == "setsystemaudiomode":
         cmd = 0x70
         address = 0x05
         physicaladdress = eHdmiCEC.getInstance().getPhysicalAddress()
         data = str(struct.pack('BB', int(physicaladdress/256), int(physicaladdress%256)))
      elif message == "osdname":
         address = 0x0f
         cmd = 0x47
         data = os.uname()[1]
         data = data[:14]
      elif message == "poweractive":
         cmd = 0x90
         data = str(struct.pack('B', 0x00))
      elif message == "powerinactive":
         cmd = 0x90
         data = str(struct.pack('B', 0x01))
      elif message == "reportaddress":
         address = 0x0f # use broadcast address
         cmd = 0x84
         physicaladdress = eHdmiCEC.getInstance().getPhysicalAddress()
         devicetype = eHdmiCEC.getInstance().getDeviceType()
         data = str(struct.pack('BBB', int(physicaladdress/256), int(physicaladdress%256), devicetype))
      elif message == "vendorid":
         address = 0x0f
         cmd = 0x87
         data = '\xB0\x90\x74'
      elif message == "keypoweron":
         cmd = 0x44
         data = str(struct.pack('B', 0x6d))
      elif message == "keypoweroff":
         cmd = 0x44
         data = str(struct.pack('B', 0x6c))
      if cmd:
         if config.hdmicec.minimum_send_interval.value != "0":
            self.queue.append((address, cmd, data))
            if not self.wait.isActive():
               self.wait.start(int(config.hdmicec.minimum_send_interval.value), True)
         else:
            eHdmiCEC.getInstance().sendMessage(address, cmd, data, len(data))

   def sendCmd(self):
      if len(self.queue):
         (address, cmd, data) = self.queue.pop(0)
         eHdmiCEC.getInstance().sendMessage(address, cmd, data, len(data))
         self.wait.start(int(config.hdmicec.minimum_send_interval.value), True)

   def sendMessages(self, address, messages):
      for message in messages:
         self.sendMessage(address, message)

   def wakeupMessages(self):
      if config.hdmicec.enabled.value:
         messages = []
         if config.hdmicec.control_tv_wakeup.value:
            messages.append("wakeup")
         if config.hdmicec.report_active_source.value:
            messages.append("sourceactive")
         if config.hdmicec.report_active_menu.value:
            messages.append("menuactive")
         if messages:
            self.sendMessages(0, messages)

         if config.hdmicec.control_receiver_wakeup.value:
            self.sendMessage(5, "keypoweron")
            self.sendMessage(5, "setsystemaudiomode")

   def standbyMessages(self):
      if config.hdmicec.enabled.value:
         messages = []
         if config.hdmicec.control_tv_standby.value:
            messages.append("standby")
         else:
            if config.hdmicec.report_active_source.value:
               messages.append("sourceinactive")
            if config.hdmicec.report_active_menu.value:
               messages.append("menuinactive")
         if messages:
            self.sendMessages(0, messages)

         if config.hdmicec.control_receiver_standby.value:
            self.sendMessage(5, "keypoweroff")
            self.sendMessage(5, "standby")

   def onLeaveStandby(self):
      self.wakeupMessages()

   def onEnterStandby(self, configElement):
      from Screens.Standby import inStandby
      inStandby.onClose.append(self.onLeaveStandby)
      self.standbyMessages()

   def onEnterDeepStandby(self, configElement):
      if config.hdmicec.handle_deepstandby_events.value:
         self.standbyMessages()

   def standby(self):
      from Screens.Standby import Standby, inStandby
      if not inStandby:
         from Tools import Notifications
         Notifications.AddNotification(Standby)

   def wakeup(self):
      from Screens.Standby import Standby, inStandby
      if inStandby:
         inStandby.Power()

   def messageReceived(self, message):
      if config.hdmicec.enabled.value:
         from Screens.Standby import inStandby
         cmd = message.getCommand()
         data = 16 * '\x00'
         length = message.getData(data, len(data))
         if cmd == 0x00: # feature abort
            if data[0] == '\x44':
               print 'eHdmiCec: volume forwarding not supported by device %02x'%(message.getAddress())
               self.volumeForwardingEnabled = False;
         elif cmd == 0x46: # request name
            self.sendMessage(message.getAddress(), 'osdname')
         elif cmd == 0x7e or cmd == 0x72: # system audio mode status
            if data[0] == '\x01':
               self.volumeForwardingDestination = 5; # on: send volume keys to receiver
            else:
               self.volumeForwardingDestination = 0; # off: send volume keys to tv
            if config.hdmicec.volume_forwarding.value:
               print 'eHdmiCec: volume forwarding to device %02x enabled'%(self.volumeForwardingDestination)
               self.volumeForwardingEnabled = True;
         elif cmd == 0x8f: # request power status
            if inStandby:
               self.sendMessage(message.getAddress(), 'powerinactive')
            else:
               self.sendMessage(message.getAddress(), 'poweractive')
         elif cmd == 0x83: # request address
            self.sendMessage(message.getAddress(), 'reportaddress')
         elif cmd == 0x86: # request streaming path
            physicaladdress = ord(data[0]) * 256 + ord(data[1])
            ouraddress = eHdmiCEC.getInstance().getPhysicalAddress()
            if physicaladdress == ouraddress:
               if not inStandby:
                  if config.hdmicec.report_active_source.value:
                     self.sendMessage(message.getAddress(), 'sourceactive')
         elif cmd == 0x85: # request active source
            if not inStandby:
               if config.hdmicec.report_active_source.value:
                  self.sendMessage(message.getAddress(), 'sourceactive')
         elif cmd == 0x8c: # request vendor id
            self.sendMessage(message.getAddress(), 'vendorid')
         elif cmd == 0x8d: # menu request
            requesttype = ord(data[0])
            if requesttype == 2: # query
               if inStandby:
                  self.sendMessage(message.getAddress(), 'menuinactive')
               else:
                  self.sendMessage(message.getAddress(), 'menuactive')

         # handle standby request from the tv
         if cmd == 0x36 and config.hdmicec.handle_tv_standby.value:
            self.standby()

         # handle wakeup requests from the tv
         if config.hdmicec.handle_tv_wakeup.value:
            if cmd == 0x04 and config.hdmicec.tv_wakeup_detection.value == "wakeup":
               self.wakeup()
            elif cmd == 0x84 and config.hdmicec.tv_wakeup_detection.value == "tvreportphysicaladdress":
               if (ord(data[0]) * 256 + ord(data[1])) == 0 and ord(data[2]) == 0:
                  self.wakeup()
            elif cmd == 0x85 and config.hdmicec.tv_wakeup_detection.value == "sourcerequest":
               self.wakeup()
            elif cmd == 0x86 and config.hdmicec.tv_wakeup_detection.value == "streamrequest":
               physicaladdress = ord(data[0]) * 256 + ord(data[1])
               ouraddress = eHdmiCEC.getInstance().getPhysicalAddress()
               if physicaladdress == ouraddress:
                  self.wakeup()
            elif cmd == 0x46 and config.hdmicec.tv_wakeup_detection.value == "osdnamerequest":
               self.wakeup()
            elif cmd == 0x87 and (ord(data[0])==0x00 and ord(data[1])==0xE0 and ord(data[2])==0x91) and config.hdmicec.tv_wakeup_detection.value == "vendorid":
               self.wakeup()
            elif cmd != 0x36 and config.hdmicec.tv_wakeup_detection.value == "activity":
               self.wakeup()

   def configVolumeForwarding(self, configElement):
      if configElement.value:
         self.volumeForwardingEnabled = True
         self.sendMessage(0x05, 'givesystemaudiostatus')
      else:
         self.volumeForwardingEnabled = False

   def keyEvent(self, keyCode, keyEvent):
      if not self.volumeForwardingEnabled: return
      cmd = 0
      data = ''
      print "keyEvent hdmi: %d %d"%(keyCode, keyEvent)
      if keyEvent == 0:
         if keyCode == 115:
            cmd = 0x44
            data = str(struct.pack('B', 0x41))
         if keyCode == 114:
            cmd = 0x44
            data = str(struct.pack('B', 0x42))
         if keyCode == 113:
            cmd = 0x44
            data = str(struct.pack('B', 0x43))
      if keyEvent == 2:
         if keyCode == 115:
            cmd = 0x44
            data = str(struct.pack('B', 0x41))
         if keyCode == 114:
            cmd = 0x44
            data = str(struct.pack('B', 0x42))
      if keyEvent == 1:
         if keyCode == 115 or keyCode == 114 or keyCode == 113:
            cmd = 0x45
      if cmd:
         eHdmiCEC.getInstance().sendMessage(self.volumeForwardingDestination, cmd, data, len(data))

hdmi_cec = HdmiCec()

BusyBox v1.21.0 (2013-03-24 22:19:36 AMT) built-in shell (ash)
Enter 'help' for a list of built-in commands.

spark:~# ps
  PID USER       VSZ STAT COMMAND
    1 root      1388 S    {init} ini
    2 root         0 SW   [kthreadd]
    3 root         0 SW   [ksoftirqd/0]
    4 root         0 SW   [events/0]
    5 root         0 SW   [khelper]
   10 root         0 SW   [async/mgr]
  162 root         0 SW   [sync_supers]
  164 root         0 SW   [bdi-default]
  166 root         0 SW   [kblockd/0]
  179 root         0 SW   [khubd]
  182 root         0 SW   [kseriod]
  198 root         0 SW   [rpciod/0]
  203 root         0 SW   [kswapd0]
  204 root         0 SW   [aio/0]
  205 root         0 SW   [nfsiod]
  207 root         0 SW   [jfsIO]
  208 root         0 SW   [jfsCommit]
  209 root         0 SW   [jfsSync]
  240 root         0 SW   [mtdblockd]
  303 root         0 SW   [usbhid_resumer]
  388 root         0 SWN  [jffs2_gcd_mtd6]
  391 root      1388 S    {init} ini
  392 root      2180 S    {rcS} /bin/sh /etc/init.d/rcS
  397 root         0 SW   [led thread]
  398 root         0 SW   [led thread]
  436 bin       1372 S    /sbin/portmap
  447 root      2144 S    /usr/sbin/automount --timeout=5 /autofs file /etc/au
  466 root      2620 S    /usr/sbin/telnetd -l /bin/autologin
  478 root         0 SW   [hdmid/0]
  501 root         0 SW   [EMBXSHM-NewPort]
  502 root         0 SW   [EMBXSHM-PortClo]
  557 root         0 DW<  [pti_task]
  581 root         0 DW   [Havana player E]
  594 root         0 DW   [SMART/0]
  599 root         0 DW   [cec_repeater]
  603 root         0 SW<  [kslowd001]
  604 root         0 SW<  [kslowd000]
  648 root      1664 S <  /usr/bin/lircd /etc/lircd.conf.09_00_07
  651 root      9812 S    /bin/evremote2
  670 root      2148 S    /usr/bin/vsftpd
  671 root      2180 S    /usr/sbin/inetd
  941 root         0 SW   [kdvb-ad-0-fe-0]
  994 root     80488 S    /usr/local/bin/enigma2
 1006 root         0 DW   [button/0]
 1267 root     92980 S    /var/emu/wicardd -d -c /var/keys/wicardd.conf
 4853 root         0 SW   [HostRec40800010]
 4854 root         0 SW   [Player Aud Mixe]
 4855 root         0 DW   [Player Aud   0]
 4856 root         0 DW   [Player Aud   1]
 4857 root         0 DW   [Player Aud   2]
 4858 root         0 DW   [Player Aud   3]
 4859 root         0 SW   [HostRec40800011]
 4860 root         0 DW   [H264 Codec Int]
 4861 root         0 SW   [Manifestor Buff]
 4862 root         0 DW   [Manifestor Disp]
 4863 root         0 DW   [Interocitor  0]
 4864 root         0 DW   [Interocitor  1]
 4865 root         0 DW   [Interocitor  2]
 4866 root         0 DW   [Interocitor  3]
 4867 root         0 SW   [HostRec40800012]
 5033 root      2180 S    {autologin} /bin/sh /bin/autologin
 5034 root      2620 S    -sh
 5040 root      2620 R    ps
spark:~#