Mercurial > code > home > repos > homeauto

diff service/reasoning/reasoning.py @ 919:6ee2a90fc816

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bugs in async http client. move trig helpers to rdflibtrig, which can work with rdflib 4 Ignore-this: 81dc30256f5d2658e53fce60abea66db darcs-hash:20130910073852-312f9-f863b729e4c75f160d0740ae9038b5fab084b86b
author drewp <drewp@bigasterisk.com>
date Tue, 10 Sep 2013 00:38:52 -0700
parents 1c3cc9633a6e
children 7179284779fd
line wrap: on
line diff
--- a/service/reasoning/reasoning.py	Tue Sep 10 00:36:52 2013 -0700
+++ b/service/reasoning/reasoning.py	Tue Sep 10 00:38:52 2013 -0700
@@ -30,7 +30,7 @@
 
 sys.path.append("../../lib")
 from logsetup import log
-log.setLevel(logging.DEBUG)
+log.setLevel(logging.INFO)
 outlog = logging.getLogger('output')
 outlog.setLevel(logging.DEBUG)
 
@@ -238,14 +238,14 @@
         fetch("http://bang:8014/reasoningChange",
               method="POST",
               timeout=2,
-              payload=body,
+              postdata=body,
               headers={"content-type" : ["application/json"]}).addErrback(err)
 
     def _put(self, url, payload):
         def err(e):
-            outlog.warn("put %s falied", url)
+            outlog.warn("put %s failed", url)
         outlog.info("PUT %s payload=%r", url, payload)
-        fetch(url, method="PUT", payload=payload, timeout=2).addErrback(err)
+        fetch(url, method="PUT", postdata=payload, timeout=2).addErrback(err)
 
     def putResults(self, inferred):
         """
@@ -317,7 +317,7 @@
         value = deviceGraph.value(dev, ROOM.zeroValue)
         if value is not None:
             outlog.info("put zero (%r) to %s", value, putUrl)
-            self._put(putUrl, payload=value)
+            self._put(putUrl, payload=str(value))
             # this should be written back into the inferred graph
             # for feedback
 
@@ -325,7 +325,7 @@
         value = deviceGraph.value(obj, ROOM.putValue)
         if value is not None:
             outlog.info("put %s to %s", value, putUrl)
-            self._put(putUrl, payload=value)
+            self._put(putUrl, payload=str(value))
         else:
             outlog.warn("%s %s %s has no :putValue" %
                      (dev, pred, obj))
@@ -337,7 +337,7 @@
             return
         url = deviceGraph.value(DEV.frontDoorLcdBrightness, ROOM.putUrl)
         outlog.info("put lcd %s brightness %s", url, brt)
-        self._put(str(url) + "?brightness=%s" % str(brt))
+        self._put(str(url) + "?brightness=%s" % str(brt), payload='')
 
         msg = "open %s motion %s" % (
             inferred.value(DEV['frontDoorOpenIndicator'], ROOM.text),