# addon.py
import xbmc
import xbmcgui
import xbmcaddon
import sys
import socket
import select
import time
#import random
import threading
import Queue

xbmc.executebuiltin('Skin.SetString(seekdown,False)')
xbmc.executebuiltin('Skin.SetString(seekup,False)')

host = "192.168.47.140"
port = 7844
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.connect((host, port))
s.settimeout(300)
q = Queue.Queue()
monitor = xbmc.Monitor()
live = True

def receiver() : # Thread T
    xbmc.log("RadioHD receiver thread started %s" % time.time(), level=xbmc.LOGNOTICE)
    while True :
        data = s.recv(1000)
        q.put(data)
        if not data :
            xbmc.log('[script.radioHD] Disconnected from radio server! Bailing...')
            print '\n\tDisconnected from Radio Server!\n'
            sys.exit()
        else :
            formatData(q)
            time.sleep(.001)



def sender(command) :
    command = command + '\n'
    print 'Sending command: ' + command
    s.send(command)

def myui() : # Thread M
    rCurr = 'True'
    xbmc.log("RadioHD myui thread started %s" % time.time(), level=xbmc.LOGNOTICE)

    while True :
        skUP = xbmc.getInfoLabel('Skin.String(seekup)')
        skDN = xbmc.getInfoLabel('Skin.String(seekdown)')
        tnUP = xbmc.getInfoLabel('Skin.String(tuneup)')
        tnDN = xbmc.getInfoLabel('Skin.String(tunedown)')
        rACT = xbmc.getInfoLabel('Skin.String(RadioActive)')
        if 'True' in skUP :
            #print '\t Seek UP Requested'
            xbmc.executebuiltin('Skin.SetString(seekup,False)')
            sender('seekup')
            time.sleep(.01)
        elif 'True' in skDN :
            #print '\t Seek DOWN Requested'
            xbmc.executebuiltin('Skin.SetString(seekdown,False)')
            sender('seekdown')
            time.sleep(.01)
        elif 'True' in tnUP :
            #print '\t Seek UP Requested'
            xbmc.executebuiltin('Skin.SetString(tuneup,False)')
            sender('tuneup')
            time.sleep(.01)
        elif 'True' in tnDN :
            #print '\t Seek DOWN Requested'
            xbmc.executebuiltin('Skin.SetString(tunedown,False)')
            sender('tunedown')
            time.sleep(.01)
        if rACT == rCurr :
            # Do Nothing
            time.sleep(.01)
            pass
        elif 'True' in rACT :
                sender('muteoff')
                rCurr = 'True'
                time.sleep(.01)
        elif 'False' in rACT :
                sender('muteon')
                rCurr = 'False'
                time.sleep(.01)
        else :
            time.sleep(.01)
            pass

def formatData(q) :
    while not q.empty() :
        data = q.get()
        if data.count('|') != 2 :
            return
        elif data.count('|') == 2 :
            data = data.replace('|','')
            cmd, val = data.split(':',1)
            val = val.replace(':',' ')
            val = val.replace('  ','')
            val = val.replace('\n','')
            if 'seek' in cmd :
                mpt = ''
                xbmcgui.Window(10000).setProperty('Tune', val)
                xbmcgui.Window(10000).setProperty('HDArtist', mpt)
                xbmcgui.Window(10000).setProperty('HDArtist2', mpt)
                xbmcgui.Window(10000).setProperty('HDTitle', mpt)
                xbmcgui.Window(10000).setProperty('HDTitle2', mpt)
                xbmcgui.Window(10000).setProperty('HDCallsign', mpt)
                xbmcgui.Window(10000).setProperty('HDStreamlock', 'False')
                xbmcgui.Window(10000).setProperty('HDActive', 'False')
                xbmcgui.Window(10000).setProperty('HDSubs', mpt)
            elif 'hd' in cmd :
                if 'artist' in cmd :
                    if '1' in val[0]:
                        val = val.replace('1 ','',1) # <~~ Does this work?
                        xbmcgui.Window(10000).setProperty('HDArtist', val)
                        #print 'HD Artist (1) ' + val
                    if '2' in val[0]:
                        val = val.replace('2 ','',1)
                        xbmcgui.Window(10000).setProperty('HDArtist2', val)
                        #print 'HD Artist (2) ' + val
                elif 'title' in cmd :
                    if '1' in val[0]:
                        val = val.replace('1 ','',1)
                        xbmcgui.Window(10000).setProperty('HDTitle', val)
                        #print 'HD Title  (1) ' + val
                    if '2' in val[0]:
                        val = val.replace('2 ','',1)
                        xbmcgui.Window(10000).setProperty('HDTitle2', val)
                        #print 'HD Title  (2) ' + val
                elif 'call' in cmd :
                    xbmcgui.Window(10000).setProperty('HDCallsign', val)
                    #print 'HD Callsign ' + val
                elif 'active' in cmd :
                    if 'false' in val:
                        xbmcgui.Window(10000).setProperty('HDActive', 'False')
                        #pass
                    if 'true' in val:
                        xbmcgui.Window(10000).setProperty('HDActive', 'True')
                        #print 'HD Active'
                        #pass
                elif 'streamlock' in cmd:
                    if 'false' in val :
                        xbmcgui.Window(10000).setProperty('HDStreamlock', 'False')
                        #print 'No stream lock'
                        #pass
                    if 'true' in val :
                        xbmcgui.Window(10000).setProperty('HDStreamlock', 'True')
                        #print 'Stream locked'
                        #pass
                elif 'subchannel' in cmd :
                    if val < '0':
                        xbmcgui.Window(10000).setProperty('HDSubs', val)
                        #print val + ' subchannels available'
                        #pass
                else :
                    #print 'Else! ' + val
                    pass

            elif 'rds' in cmd:
                if 'enable' in cmd :
                    #print 'RDS Enabled'
                    xbmcgui.Window(10000).setProperty('HDArtist2', 'RDS')
                    #pass
                elif 'service' in cmd :
                    #print 'T.0 ' + val
                    xbmcgui.Window(10000).setProperty('HDArtist', val)
                    #pass
                elif 'text' in cmd :
                    xbmcgui.Window(10000).setProperty('HDTitle', val)
                    #print 'T.1 ' + val
                    #pass
                elif 'genre' in cmd:
                    xbmcgui.Window(10000).setProperty('HDTitle2', val)
                    #print 'Genre ' + val
                    #pass

            elif 'tune' in cmd :
                val = val.replace('FM ','',1)
                xbmcgui.Window(10000).setProperty('Tune', val)
                #print '\tStation: ' + val
        time.sleep(.001)

if __name__ == '__main__':
    xbmc.log("RadioHD script starting %s" % time.time(), level=xbmc.LOGNOTICE)

    t = threading.Thread(name='receiver', target=receiver)
    t.daemon = True
    xbmc.log("RadioHD receiver thread starting %s" % time.time(), level=xbmc.LOGNOTICE)
    t.start()
    m = threading.Thread(name='myui', target=myui)
    m.daemon = True
    xbmc.log("RadioHD myui thread starting %s" % time.time(), level=xbmc.LOGNOTICE)
    m.start()
    sender('tune 1027 fm')
    sender('volume 100')
    sender('bass 10')
    sender('treble 10')



    while not monitor.abortRequested():
        if monitor.waitForAbort(1) :
            xbmc.log("**************RadioHD*********************", level=xbmc.LOGNOTICE)
            xbmc.log("RadioHD %s" % time.time(), level=xbmc.LOGNOTICE)
            break