initial commit

Author: petermoon

.gitignore

@@ -1,3 +1,5 @@
+config.json
+
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]

README.md

@@ -1,2 +1,10 @@
 # echoir
 Remote control skill for Alexa
+
+The client-side job runner only supports IguanaWorks IR.
+# On the machine (I use Raspberry PI) that has the IR transceiver set up, use the record_remote script to record some IR blasts you want to be able to initiate from the Echo.
+# Set up your Alexa skill on the Alexa website. This can't be automated at the moment.
+# Set up your AWS Lambda function.
+# Complete config_sample.json, rename to config.json, zip it up with echo_remote_lambda.py, then upload to Lambda.
+# Run echoremote.py on a machine with IguanaWorks IR blaster.
+# That's it.

config_sample.json

@@ -0,0 +1,15 @@
+{
+  "skills": {
+    "amzn1.echo-sdk-ams.app.sample1": "remote",
+    "amzn1.echo-sdk-ams.app.sample2": "apple tv",
+    "amzn1.echo-sdk-ams.app.sample3": "xbox"
+  },
+  "queue_url": "https://queue.amazonaws.com/123456789/queueName",
+  "responses": [
+    "<speak>Roger that.</speak>",
+    "<speak>Yes master.</speak>",
+    "<speak>Will do.</speak>",
+    "<speak>Done!</speak>",
+    "<speak>Dude.</speak>"
+  ]
+}

echo_remote_lambda.py

@@ -0,0 +1,84 @@
+import json
+import logging
+from random import randint
+import boto3
+
+logger = logging.getLogger()
+logger.setLevel(logging.INFO)
+
+with open('config.json') as config_file:
+    config = json.load(config_file)
+
+sqs = boto3.resource('sqs', region_name='us-east-1')
+queue = sqs.Queue(config['queue_url'])
+
+
+def lambda_handler(event, context):
+    app_id = event['session']['application']['applicationId']
+    logger.info('Application ID: {}'.format(app_id))
+    if app_id not in config['skills']:
+        raise Exception('Invalid application ID')
+
+    if event['request']['type'] == 'LaunchRequest':
+        handle_launch(config['skills'][app_id])
+    if event['request']['type'] == 'IntentRequest':
+        if config['skills'][app_id] == 'remote':
+            handle_remote(event['request'])
+        else:
+            handle_action(config['skills'][app_id], event['request'])
+    resp = build_ssml_response(get_random_speech())
+    logger.info('Response: {}'.format(resp))
+    return resp
+
+
+def handle_launch(activity):
+    msg = {
+        'name': 'Launch',
+        'slots': {
+            'Activity': {
+                'name': 'Activity',
+                'value': activity
+            }
+        }
+    }
+    send_message(json.dumps(msg))
+
+
+def handle_remote(req):
+    """
+    Handles power and volume intents from the generic remote skill
+    """
+    send_message(json.dumps(req['intent']))
+
+
+def handle_action(device, req):
+    """
+    Passes through intent requests from device-specific skills
+    after setting the device name
+    """
+    intent = req['intent']
+    intent['slots']['Device'] = {'name': 'Device', 'value': device}
+    send_message(json.dumps(intent))
+
+
+def send_message(body):
+    queue.send_message(MessageBody=body)
+
+
+def build_ssml_response(speech):
+    resp = {
+        'version': '1.0',
+        'response': {
+            'outputSpeech': {
+                'type': 'SSML',
+                'ssml': speech
+            },
+            'shouldEndSession': True
+        }
+    }
+    return resp
+
+
+def get_random_speech():
+    num_responses = len(config['responses'])
+    return config['responses'][randint(0, num_responses - 1)]

echoremote.py

@@ -0,0 +1,109 @@
+#!/home/pi/.virtualenvs/python34/bin/python
+
+import boto3
+import boto3.session
+import json
+from subprocess import call
+from time import sleep
+import os.path
+from botocore.exceptions import ClientError
+from botocore.exceptions import BotoCoreError
+import logging
+LOG_FILENAME = '/home/pi/log/echoremote.log'
+logging.basicConfig(filename=LOG_FILENAME, level=logging.INFO)
+
+
+def log(msg):
+    logging.info(msg)
+
+sequences = {'all_off': ['tv_off.txt', 'receiver_off.txt',
+                         'xbox_off.txt', 'apple_tv_home.txt'],
+             'apple_tv': ['tv_on.txt',
+                          'receiver_apple_tv.txt',
+                          'apple_tv_home.txt'],
+             'xbox': ['tv_on.txt', 'receiver_xbox.txt', 'xbox_on.txt'],
+             'raspberry_pie': ['tv_on.txt', 'receiver_raspberry_pie.txt']}
+keys = ('ActionA', 'ActionB', 'ActionC', 'ActionD', 'ActionE', 'ActionF')
+signals_path = '/home/pi/scribbles/python/echoir/signals/'
+
+
+def handle_seq(sequence):
+    for signal in sequence:
+        send_signal(signal)
+        sleep(0.05)
+
+
+def send_signal(signal):
+    signal_full = os.path.join(signals_path, signal)
+    if os.path.isfile(signal_full):
+        call(['/usr/bin/igclient', '--send', signal_full])
+        log("    Sent: {}".format(signal))
+    else:
+        log("        NOT SENT: {}".format(signal))
+
+
+def process_msg(msg):
+    log(msg.body)
+    intent = json.loads(msg.body)
+    action = intent['name']
+    if action == 'Power':
+        handle_power(intent['slots'])
+    elif action == 'Volume':
+        handle_volume(intent['slots'])
+    elif action == 'Launch':
+        handle_launch(intent['slots'])
+    elif action == 'Action':
+        handle_action(intent['slots'])
+    msg.delete()
+
+
+def handle_power(slots):
+    device = slots['Device']['value'].replace('the ', '').replace(' ', '_')
+    onoff = slots['OnOff']['value']
+    if device == 'everything':
+        handle_seq(sequences['all_off'])
+    else:
+        signal = '{}_{}.txt'.format(device, onoff)
+        send_signal(signal)
+
+
+def handle_volume(slots):
+    signal = 'receiver_volume_{}.txt'.format(slots['UpDown']['value'])
+    reps = int(slots['Repeat']['value'])
+    sequence = [signal for i in range(reps)]
+    handle_seq(sequence)
+
+
+def handle_launch(slots):
+    action = slots['Activity']['value'].replace(' ', '_')
+    if action in sequences:
+        handle_seq(sequences[action])
+
+
+def handle_action(slots):
+    device = slots['Device']['value'].replace('the ', '').replace(' ', '_')
+    device = device.lower()
+    sequence = []
+    for key in keys:
+        if 'value' in slots[key] and slots[key]['value'] is not None:
+            sequence.append(slots[key]['value'].replace(' ', '_').lower())
+    signals = ['{}_{}.txt'.format(device, a) for a in sequence]
+    handle_seq(signals)
+
+
+url = 'https://queue.amazonaws.com/720549148055/echoRemote'
+s = boto3.session.Session(region_name='us-east-1')
+queue = s.resource('sqs').Queue(url)
+
+
+while True:
+    try:
+        log("Polling for messages...")
+        messages = queue.receive_messages(WaitTimeSeconds=20)
+        for message in messages:
+            log("    Processing a message.")
+            process_msg(message)
+    except (ClientError, BotoCoreError) as e:
+        log("Request failed. Sleeping for a minute.")
+        log(str(e))
+        sleep(60)

record.py

@@ -0,0 +1,36 @@
+import sys
+import re
+
+received = r"^received"
+receiver = r"^receiver"
+pulse = r"^pulse:"
+space = r"^space:"
+
+lastword = ''
+signals = []
+
+for line in sys.stdin:
+    words = line.strip().split(' ')
+    
+    if re.search(received, words[0]) or re.search(receiver, words[0]):
+        continue
+    words[1] = int(words[1])
+    if re.search(space, words[0]) and words[1] == 152917:
+        continue
+
+    word = re.sub(pulse, 'pulse', words[0])
+    word = re.sub(space, 'space', word)
+
+    if lastword == word:
+        item = signals.pop()
+        item[1] = item[1] + words[1]
+        signals.append(item)
+    elif lastword == '' and word == 'space':
+        continue
+    else:
+        signals.append([word, words[1]])
+    lastword = word
+
+for i in range(len(signals)):
+    if i < len(signals) - 1 or signals[i][0] != 'space':
+        print("{} {}".format(*signals[i]))

record_remote

@@ -0,0 +1,2 @@
+workon python34
+igclient --receiver-on --sleep 5 | python /home/pi/scribbles/python/echoir/record.py