mechanics.py

import json
# Global configurations
config = json.loads(open('config.json').read())
# This variable decides if commands are executed locally or on a remote machine
remote = config['remote']
remoteMachine = config['identities']['pal-command']

import requests as r
import os
import voice
import stocks

commandServer ='http://' + config['servers']['pal-command']['server'] + ':' + config['servers']['pal-command']['port'] + '/'

def weatherIntent(params):
    import weather
    return weather.actuate(params)

def startIntent(params):
    applications = json.loads(open('data/applications.json').read())
    foundApplication = False
    applicationName = None
    applicationPath = None
    for i in applications:
        for a in i['keywords']:
            if params['Application'] == a.lower():
                foundApplication = True
                applicationPath = i['path']
                applicationName = i['name']
                break
    if foundApplication:
        if remote:
            r.post(commandServer + 'add/' + remoteMachine, json={'command': {'action': 'open', 'path': applicationPath}})
        else:
            os.system('open ' + applicationPath)
    if not foundApplication:
        return "Application not supported yet."
    else:
        return "Launching application " + applicationName + '.'

def switchIntent(params):
    toReturn = 'Switching ' + params['Item'] + ' ' + params['SwitchPosition']
    cmd = 'SPEAK.VOICE_ON'
    if params['Item'] == 'voice':
        if params['SwitchPosition'] == 'on':
            if params['SPEAK.VOICE_STATUS']:
                toReturn = 'My voice is already on.'
            else:
                speak = True
        elif params['SwitchPosition'] == 'off':
            cmd = 'SPEAK.VOICE_OFF'
            if params['SPEAK.VOICE_STATUS']:
                speak = False
            else:
                toReturn = 'My voice is already off.'
    else:
        toReturn = 'Desired item can\'t be controlled.'
    return {'message': toReturn, 'cmd': cmd}

def lastFMCount(params):
    toReturn = 'Sorry. I don\'t support that period.'
    try:
        if params['Period'] == 'today':
            period = 'today'
        else:
            toReturn = 'Unfortunately I don\'t support the provided period.'
    except:
        # Default to today if no period is specified
        period = 'today'
    if period == 'today':
        import lastfm
        output = lastfm.today_count()
        toReturn = 'You have scrobbled ' + str(output['dailyCount']) + ' tracks. ' + str(output['expectedCount']) + ' scrobbles expected.'
    return toReturn

def simonSays(params):
    if remote:
        r.post(commandServer + 'add/' + remoteMachine, json={'command': {'action': 'speak', 'text': params['Text']}})
    else:
        voice.speak(params['Text'])
    return 'Speaking: ' + params['Text']

def shellExecute(params):
    os.system(params['Command'])
    return 'Command executed.'

def todoistAdd(params):
    if not config['keys']['todoist'] == 'None':
        if not params['Text'] == None:
            dataToSend = {
                'token': config['keys']['todoist'],
                'text': params['Text']
                }
            try:
                dataToSend['text'] += ' ' + params['TodoistDate']
            except:
                doNothing = True
            r.post('https://todoist.com/API/v7/quick/add', dataToSend)
            return 'Task added to Todoist.'
        else:
            return 'Task addition failed due to lack of task text.'
    else:
        return 'You need to configure the Todoist skill with your Todoist API key.'

def stockSum(params):
    sumOfIt = stocks.netAssets()
    return 'Your current stock valuation is $' + str(sumOfIt) + '.'

def stockIncrease(params):
    profits = stocks.currentProfits()
    return 'Your current stock increase is $' + str(profits) + '.'

def nomieLog(params):
    nomieProxyServer = config['servers']['nomie-proxy']
    r.get(nomieProxyServer['url'] + nomieProxyServer['secret'] + '/' + params['NomieItem'])
    return 'I have logged that you ' + params['NomieItem'] + '.'

def nomieCount(params):
    nomieComputeServer = config['servers']['compute-nomie']
    data = json.loads(r.get(nomieComputeServer['url'] + 'count', { 'label': params['NomieTrackername'], 'start': 1 }).text)
    if data['success']:
        return 'The count for tracker ' + params['NomieTrackername'] + ' is ' + str(data['count'])
    else:
        return 'Server responded with a failure and the message ' + data['message']

def exerciseManager(params):
    try:
        strava_id = params['strava']['id']
        strava_token = params['strava']['token']
        import strava
        myData = strava.StravaData(strava_id, strava_token)
        print(myData.getActivities())
        response = "Your ID is " + str(strava_id)
        return response
    except:
        return "Skill failure."

def search(params):
    import webbrowser
    baseUrl = 'https://www.google.com/search?q='
    fullUrl = baseUrl + params['Query'].replace(' ', '+')
    webbrowser.open(fullUrl)
    return "Query complete for " + params['Query'] + '.'

def setLocation(params):
    location_data = json.loads(open('data/gps.json').read())
    location_list = location_data['locations']
    location_name = params['NewLocation']
    old_location_name = location_data['current_location']['name']
    for i in location_list:
        if i['name'].lower() == location_name.lower():
            location_data['current_location']['name'] = i['name']
            location_data['current_location']['latlong'] = i['latlong']
            # Save new location information
            open('data/gps.json', 'w').write(json.dumps(location_data, indent=4))
            msg = 'Changed location from {0} to {1}'.format(old_location_name, i['name'])
            return { 'message': msg, 'cmd': 'LOCATION.REFRESH' }
    return 'Location {0} not found in currently known ones'.format(location_name)


def dictionary(params):
    try:
        from PyDictionary import PyDictionary
    except:
        return "You need to install PyDictionary library"
    dictionary=PyDictionary()
    word = params['DictionaryWord']
    definition = dictionary.meaning(word)
    if not definition:
        return 'Word not found. Try again.'
    response = ""
    for i in definition.keys():
        definitions = list('{0}) {1}. '.format(j+1,val) for j,val in enumerate(definition[i]))
        formatted_definitions = ''
        for j in definitions:
            formatted_definitions += j
        response += "{0}: {1}\n".format(i, formatted_definitions)
    response = response[:-1]
    return response

def palBud(params):
    if not config['keys']['particle'] == 'None':
        var = 'lightLevel'
        device = 'Arduino-Terra'
        accessToken = config['keys']['particle']
        response = r.get('https://api.particle.io/v1/devices/Arduino-Terra/' + var + '?access_token=' + accessToken)
        data = json.loads(response.text)
        value = data['result']
        return 'The light level is {}'.format(value)
    else:
        return 'You need to configure the pal bud feature'

def testIntent(params):
    print(params)
    return 'Test complete'

functions = {
        'WeatherIntent': weatherIntent,
        'StartIntent': startIntent,
        'SwitchIntent': switchIntent,
        'LastFMCount': lastFMCount,
        'SimonSays': simonSays,
        'ShellExecute': shellExecute,
        'TodoistAdd': todoistAdd,
        'StockSum': stockSum,
        'StockIncrease': stockIncrease,
        'NomieLog': nomieLog,
        'NomieCount': nomieCount,
        'ExerciseManager': exerciseManager,
        'Search': search,
        'SetLocation': setLocation,
        'Dictionary': dictionary,
        'PalBud': palBud,
        'TestIntent': testIntent
        }