Mercurial > code > home > repos > homeauto

changeset 931:e9fbd5d15e30

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rework shuttlepro's output statements Ignore-this: 8a9b1c041dc10c4105b846333602c934 darcs-hash:20131008060457-312f9-867c3837bc8c0a91b96d7d1b427f0705829fc617
author drewp <drewp@bigasterisk.com>
date Mon, 07 Oct 2013 23:04:57 -0700
parents 23d47a9a968b
children 5386db42a5c2
files service/shuttlepro/shuttlepro.py
diffstat 1 files changed, 22 insertions(+), 8 deletions(-) [+]
line wrap: on
line diff
--- a/service/shuttlepro/shuttlepro.py	Mon Oct 07 22:45:30 2013 -0700
+++ b/service/shuttlepro/shuttlepro.py	Mon Oct 07 23:04:57 2013 -0700
@@ -26,12 +26,14 @@
 modified by drewp@bigasterisk.com
 """
 
-import os, time
+import os, time, logging
 import sys
 import struct
 import exceptions
 import threading
 
+logging.basicConfig(level=logging.INFO)
+log = logging.getLogger()
 
 def hexint(mask):
   """
@@ -355,24 +357,36 @@
 import restkit
 reasoning = restkit.Resource("http://bang:9071/", timeout=1)
 
-from rdflib import Namespace, Graph
+from rdflib import Namespace, Graph, Literal
 SHUTTLEPRO = Namespace("http://projects.bigasterisk.com/room/livingRoom/shuttlepro/")
 ROOM = Namespace("http://projects.bigasterisk.com/room/")
 
 if __name__ == '__main__':
     import restkit
-    reasoning = restkit.Resource("http://plus:9071/")
+    reasoning = restkit.Resource("http://bang:9071/", timeout=1)
     def ev(what):
         print 'ev', what
-        if 'key' in what and what['press']:
-            g = Graph()
-            g.add((SHUTTLEPRO, ROOM['press'],
-                   SHUTTLEPRO['b' + what['key']['button']]))
+        g = Graph()
+        if 'key' in what:
+            g.add((SHUTTLEPRO['button%s' % what['key']['button']],
+                   ROOM['state'],
+                   ROOM['pres'] if what['key']['press'] else ROOM['release']))
+        elif 'shuttle' in what:
+            # this will send lots of repeats. It's really not a one-shot at all.
+            g.add((SHUTTLEPRO['shuttle'], ROOM['position'],
+                   Literal(what['shuttle'])))
+        elif 'dial' in what:
+            g.add((SHUTTLEPRO['dial'], ROOM['change'],
+                   ROOM['clockwise'] if what['dial'] == 1 else
+                   ROOM['counterclockwise']))
+        try:
             reasoning.post(
               "oneShot",
-              payload=g.serialize(format='text/n3'),
+              payload=g.serialize(format='nt'),
               headers={'Content-Type': 'text/n3'}
             ).body_string()
+        except restkit.errors.RequestTimeout, e:
+          log.error(e)
 
     p = powermate("/dev/input/by-id/usb-Contour_Design_ShuttlePRO-event-if00", ev)
     while True: