homeauto: service/reasoning/actions.py annotate

annotate service/reasoning/actions.py @ 1409:e78b8806ad05

actually set put payload this time. add treq dep Ignore-this: b6a05c294d9a5ee6052972cad4ecb5c5 darcs-hash:d41a16eb44db885ff391ddbe64352245b885a838

author	drewp <drewp@bigasterisk.com>
date	Tue, 23 Jul 2019 17:37:24 -0700
parents	89bf0d204b29
children	7f5451a76a80

rev	line source
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	1 from rdflib import URIRef, Namespace, RDF, Literal
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	2 from twisted.internet import reactor
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	3 import logging
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	4 import urllib
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	5
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	6 import treq
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	7 log = logging.getLogger('output')
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	8
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	9 ROOM = Namespace("http://projects.bigasterisk.com/room/")
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	10 DEV = Namespace("http://projects.bigasterisk.com/device/")
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	11 REASONING = Namespace("http://projects.bigasterisk.com/ns/reasoning/")
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	12
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	13 class HttpPutOutput(object):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	14 def __init__(self, url):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	15 self.url = url
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	16 self.payload = None
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	17 self.foafAgent = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	18 self.nextCall = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	19 self.numRequests = 0
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	20
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	21 def setPayload(self, payload, foafAgent):
e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	22 if self.numRequests > 0 and (self.payload == payload or self.foafAgent == foafAgent):
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	23 return
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	24 self.payload = payload
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	25 self.foafAgent = foafAgent
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	26 self.makeRequest()
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	27
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	28 def makeRequest(self):
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	29 if self.payload is None:
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	30 log.info("PUT None to %s - waiting", self.url)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	31 return
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	32 h = {}
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	33 if self.foafAgent:
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	34 h['x-foaf-agent'] = self.foafAgent
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	35 if self.nextCall and self.nextCall.active():
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	36 self.nextCall.cancel()
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	37 self.nextCall = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	38 self.lastErr = None
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	39 log.info("PUT %s payload=%s agent=%s", self.url, self.payload, self.foafAgent)
e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	40 self.currentRequest = treq.put(self.url, data=self.payload, headers=h, timeout=3)
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	41 self.currentRequest.addCallback(self.onResponse).addErrback(self.onError)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	42 self.numRequests += 1
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	43
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	44 def onResponse(self, resp):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	45 log.info(" PUT %s ok", self.url)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	46 self.lastErr = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	47 self.currentRequest = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	48 self.nextCall = reactor.callLater(3, self.makeRequest)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	49
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	50 def onError(self, err):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	51 self.lastErr = err
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	52 log.info(' PUT %s failed: %s', self.url, err)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	53 self.currentRequest = None
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	54 self.nextCall = reactor.callLater(5, self.makeRequest)
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	55
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	56 class HttpPutOutputs(object):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	57 """these grow forever"""
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	58 def __init__(self):
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	59 self.state = {} # url: HttpPutOutput
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	60
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	61 def put(self, url, payload, foafAgent):
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	62 if url not in self.state:
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	63 self.state[url] = HttpPutOutput(url)
1409 e78b8806ad05 actually set put payload this time. add treq dep drewp <drewp@bigasterisk.com> parents: 1408 diff changeset	64 self.state[url].setPayload(payload, foafAgent)
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	65 log.info('PutOutputs has %s urls', len(self.state))
89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	66
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	67 class Actions(object):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	68 def __init__(self, sendToLiveClients):
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	69 self.putOutputs = HttpPutOutputs()
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	70 self.sendToLiveClients = sendToLiveClients
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	71
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	72 def putResults(self, deviceGraph, inferred):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	73 """
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	74 some conclusions in the inferred graph lead to PUT requests
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	75 getting made
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	76
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	77 if the graph contains (?d ?p ?o) and ?d and ?p are a device
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	78 and predicate we support PUTs for, then we look up
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	79 (?d :putUrl ?url) and (?o :putValue ?val) and call
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	80 PUT ?url <- ?val
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	81
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	82 If the graph doesn't contain any matches, we use (?d
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	83 :zeroValue ?val) for the value and PUT that.
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	84 """
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	85 activated = set() # (subj,pred) pairs for which we're currently putting some value
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	86 activated.update(self._putDevices(deviceGraph, inferred))
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	87 self._oneShotPostActions(deviceGraph, inferred)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	88 for dev, pred in [
1052 2434e88d8bb0 add bed buttons drewp <drewp@bigasterisk.com> parents: 1047 diff changeset	89 #(URIRef('http://bigasterisk.com/host/bang/monitor'), ROOM.powerState),
2434e88d8bb0 add bed buttons drewp <drewp@bigasterisk.com> parents: 1047 diff changeset	90 (URIRef('http://bigasterisk.com/host/dash/monitor'), ROOM.powerState),
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	91 (URIRef('http://bigasterisk.com/host/frontdoor/monitor'), ROOM.powerState),
1069 c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	92 (ROOM['storageCeilingLedLong'], ROOM.brightness),
c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	93 (ROOM['storageCeilingLedCross'], ROOM.brightness),
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	94 (ROOM['garageOverhead'], ROOM.brightness),
1069 c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	95 (ROOM['headboardWhite'], ROOM.brightness),
c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	96 (ROOM['changingWhite'], ROOM.brightness),
c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	97 (ROOM['starTrekLight'], ROOM.brightness),
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	98 (ROOM['kitchenLight'], ROOM.brightness),
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	99 (ROOM['kitchenCounterLight'], ROOM.brightness),
1069 c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	100 (ROOM['livingRoomLamp1'], ROOM.brightness),
c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	101 (ROOM['livingRoomLamp2'], ROOM.brightness),
1406 b2e9cd28d202 loftdesk config drewp <drewp@bigasterisk.com> parents: 1405 diff changeset	102 (ROOM['loftDeskStrip'], ROOM.x),
1069 c5b14fe5c387 rules updates drewp <drewp@bigasterisk.com> parents: 1064 diff changeset	103 (ROOM['bedLedStrip'], ROOM.color),
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	104 ]:
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	105 url = deviceGraph.value(dev, ROOM.putUrl)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	106
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	107 log.debug('inferredObjects of dev=%s pred=%s',
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	108 deviceGraph.qname(dev),
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	109 deviceGraph.qname(pred))
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	110 inferredObjects = list(inferred.objects(dev, pred))
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	111 if len(inferredObjects) == 0:
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	112 # rm this- use activated instead
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	113 self._putZero(deviceGraph, dev, pred, url)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	114 elif len(inferredObjects) == 1:
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	115 log.debug(' inferredObject: %s %s %r',
1085 dda3f1524a52 lots of logging updates (patch may be imprecise) drewp <drewp@bigasterisk.com> parents: 1069 diff changeset	116 deviceGraph.qname(dev),
dda3f1524a52 lots of logging updates (patch may be imprecise) drewp <drewp@bigasterisk.com> parents: 1069 diff changeset	117 deviceGraph.qname(pred),
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	118 inferredObjects[0].toPython())
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	119 activated.add((dev, pred))
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	120 self._putInferred(deviceGraph, url, inferredObjects[0])
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	121 elif len(inferredObjects) > 1:
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	122 log.info(" conflict, ignoring: %s has %s of %s" %
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	123 (dev, pred, inferredObjects))
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	124 # write about it to the inferred graph?
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	125 self.putDefaults(deviceGraph, activated)
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	126
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	127 def putDefaults(self, deviceGraph, activated):
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	128 """
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	129 If inferring (:a :b :c) would cause a PUT, you can say
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	130
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	131 reasoning:defaultOutput reasoning:default [
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	132 :subject :a
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	133 :predicate :b
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	134 :defaultObject :c
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	135 ]
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	136
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	137 and we'll do that PUT if no rule has put anything else with
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	138 (:a :b *).
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	139 """
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	140
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	141 defaultStmts = set()
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	142 for defaultDesc in deviceGraph.objects(REASONING['defaultOutput'],
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	143 REASONING['default']):
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	144 s = deviceGraph.value(defaultDesc, ROOM['subject'])
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	145 p = deviceGraph.value(defaultDesc, ROOM['predicate'])
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	146 if (s, p) not in activated:
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	147 obj = deviceGraph.value(defaultDesc, ROOM['defaultObject'])
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	148
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	149 defaultStmts.add((s, p, obj))
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	150 self._putDevices(deviceGraph, defaultStmts)
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	151
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	152 def _oneShotPostActions(self, deviceGraph, inferred):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	153 """
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	154 Inferred graph may contain some one-shot statements. We'll send
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	155 statement objects to anyone on web sockets, and also generate
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	156 POST requests as described in the graph.
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	157
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	158 one-shot statement ?s ?p ?o
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	159 with this in the graph:
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	160 ?osp a :OneShotPost
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	161 ?osp :subject ?s
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	162 ?osp :predicate ?p
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	163 this will cause a post to ?o
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	164 """
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	165 # nothing in this actually makes them one-shot yet. they'll
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	166 # just fire as often as we get in here, which is not desirable
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	167 log.info("_oneShotPostActions")
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	168 def err(e):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	169 log.warn("post %s failed", postTarget)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	170 for osp in deviceGraph.subjects(RDF.type, ROOM['OneShotPost']):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	171 s = deviceGraph.value(osp, ROOM['subject'])
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	172 p = deviceGraph.value(osp, ROOM['predicate'])
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	173 if s is None or p is None:
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	174 continue
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	175 #log.info("checking for %s %s", s, p)
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	176 for postTarget in inferred.objects(s, p):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	177 log.info("post target %r", postTarget)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	178 # this packet ought to have 'oneShot' in it somewhere
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	179 self.sendToLiveClients({"s":s, "p":p, "o":postTarget})
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	180
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	181 log.info(" POST %s", postTarget)
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	182 treq.post(postTarget, timeout=2).addErrback(err)
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	183
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	184 def _putDevices(self, deviceGraph, inferred):
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	185 activated = set()
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	186 agentFor = {}
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	187 for stmt in inferred:
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	188 if stmt[1] == ROOM['putAgent']:
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	189 agentFor[stmt[0]] = stmt[2]
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	190 for stmt in inferred:
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	191 log.info('inferred stmt we might PUT: %s', stmt)
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	192 putUrl = deviceGraph.value(stmt[0], ROOM['putUrl'])
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	193 putPred = deviceGraph.value(stmt[0], ROOM['putPredicate'])
1266 ee5698ef64dd add separate :matchPredicate support. some build and log edits. drewp <drewp@bigasterisk.com> parents: 1197 diff changeset	194 matchPred = deviceGraph.value(stmt[0], ROOM['matchPredicate'],
ee5698ef64dd add separate :matchPredicate support. some build and log edits. drewp <drewp@bigasterisk.com> parents: 1197 diff changeset	195 default=putPred)
ee5698ef64dd add separate :matchPredicate support. some build and log edits. drewp <drewp@bigasterisk.com> parents: 1197 diff changeset	196 if putUrl and matchPred == stmt[1]:
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	197 log.info('putDevices: stmt %r %r %r leds to putting at %r',
69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	198 stmt[0], stmt[1], stmt[2], putUrl)
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	199 self._put(putUrl + '?' + urllib.urlencode([
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	200 ('s', str(stmt[0])),
1266 ee5698ef64dd add separate :matchPredicate support. some build and log edits. drewp <drewp@bigasterisk.com> parents: 1197 diff changeset	201 ('p', str(putPred))]),
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	202 str(stmt[2].toPython()),
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	203 agent=agentFor.get(stmt[0], None))
1405 882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	204 activated.add((stmt[0],
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	205 # didn't test that this should be
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	206 # stmt[1] and not putPred
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	207 stmt[1]))
882159ac1301 support for default values for http PUT outputs drewp <drewp@bigasterisk.com> parents: 1403 diff changeset	208 return activated
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	209
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	210 def _putInferred(self, deviceGraph, putUrl, obj):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	211 """
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	212 HTTP PUT to putUrl, with a payload that's either obj's :putValue
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	213 or obj itself.
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	214 """
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	215 value = deviceGraph.value(obj, ROOM.putValue)
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	216 if value is not None:
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	217 self._put(putUrl, payload=str(value))
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	218 elif isinstance(obj, Literal):
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	219 self._put(putUrl, payload=str(obj))
a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	220 else:
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	221 log.warn(" don't know what payload to put for %s. obj=%r",
1045 a328cc370b22 ipv6 fetch support. refactor Actions to new class and file drewp <drewp@bigasterisk.com> parents: diff changeset	222 putUrl, obj)
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	223
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	224 def _putZero(self, deviceGraph, dev, pred, putUrl):
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	225 # zerovalue should be a function of pred as well.
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	226 value = deviceGraph.value(dev, ROOM.zeroValue)
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	227 if value is not None:
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	228 log.info(" put zero (%r) to %s", value.toPython(), putUrl)
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	229 self._put(putUrl, payload=str(value))
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	230 # this should be written back into the inferred graph
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	231 # for feedback
1403 69b3f5b3aeda comments and logging drewp <drewp@bigasterisk.com> parents: 1266 diff changeset	232
1197 d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	233 def _put(self, url, payload, agent=None):
d8acab2b01f5 mqtt has two devices now. various older cleanups. drewp <drewp@bigasterisk.com> parents: 1133 diff changeset	234 assert isinstance(payload, bytes)
1408 89bf0d204b29 reasoning output using treq, and keep writing to PUT calls forever (but not as fast as the reasoning loop runs) drewp <drewp@bigasterisk.com> parents: 1406 diff changeset	235 self.putOutputs.put(url, payload, agent)

Mercurial > code > home > repos > homeauto

annotate service/reasoning/actions.py @ 1409:e78b8806ad05