widgetFunctions.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

import os
import sys
import xbmc
import xbmcgui
import xbmcplugin
import xbmcaddon
import xbmcvfs
import random
import urllib
import datetime
import socket
from traceback import print_exc
from time import gmtime, strftime

if sys.version_info < (2, 7):
    import simplejson
else:
    import json as simplejson
    
__addon__        = xbmcaddon.Addon()
__addonversion__ = __addon__.getAddonInfo('version')
__addonid__      = __addon__.getAddonInfo('id')
__addonname__    = __addon__.getAddonInfo('name')
__localize__     = __addon__.getLocalizedString

def log(txt):
    message = '%s: %s' % (__addonname__, txt.encode('ascii', 'ignore'))
    xbmc.log(msg=message, level=xbmc.LOGDEBUG)

class Main:
    def __init__(self):
        self._parse_argv()
        
        try:
            clientsocket = socket.socket( socket.AF_INET, socket.SOCK_STREAM )
            clientsocket.connect( ( "localhost", 45354 ) )
            if self.ID is None:
                log( "### (WIDGET) Sending message %s|%s" %( self.TYPE, sys.argv[ 1 ] ) )
                clientsocket.send( "%s|%s" %( self.TYPE, sys.argv[ 1 ] ) )
            else:
                log( "### (WIDGET) Sending message %s|%s|%s" %( self.TYPE, self.ID, sys.argv[ 1 ] ) )
                clientsocket.send( "%s|%s|%s" %( self.TYPE, self.ID, sys.argv[ 1 ] ) )
            message = clientsocket.recv( 128 )
            log( "### (WIDGET) Recieved message: " + message )
            clientsocket.close()

        except:
            log( "Unable to establish connection to service" )
            xbmcplugin.endOfDirectory(handle= int(sys.argv[1]))
            
    def _parse_argv( self ):
        try:
            params = dict( arg.split( "=" ) for arg in sys.argv[ 2 ].split( "&" ) )
        except:
            params = {}
        self.TYPE = params.get( "?type", "" )
        self.ID = params.get( "id", None )