Mercurial > code > home > repos > homeauto

annotate service/frontDoorLock/front_door_lock.py @ 575:1209229cd56e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py Ignore-this: f8fca86291d3082cb309524fbd5baf1c
author drewp@bigasterisk.com
date Mon, 06 May 2019 21:06:08 -0700
parents 2d8a5532f1b5
children 150aa09c9723
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
425
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
1 """
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
2 :frontDoorLock :state :locked/:unlocked
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
3 is the true state of the lock, maintained in this process.
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
4
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
5 put :frontDoorLock :state ?s to this /output to request a change.
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
6
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
7 reasoning can infer :frontDoorLock :putState ?s to do that put request.
d495d4382a07 comments and console layout
drewp@bigasterisk.com
parents: 379
diff changeset
8 """
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
9 import time, json
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
10
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
11 from docopt import docopt
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
12 from rdflib import Namespace, URIRef, Literal, Graph
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
13 from rdflib.parser import StringInputSource
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
14 from twisted.internet import reactor, task
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
15 import cyclone.web
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
16
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
17 from mqtt_client import MqttClient
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
18 from patchablegraph import PatchableGraph, CycloneGraphHandler, CycloneGraphEventsHandler
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
19 from standardservice.logsetup import log, verboseLogging
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
20
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
21 ROOM = Namespace('http://projects.bigasterisk.com/room/')
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
22
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
23 ctx = ROOM['frontDoorControl']
568
2d8a5532f1b5 match esp hostname in py code
drewp@bigasterisk.com
parents: 563
diff changeset
24 espName = b'frontdoorlock' # from door.yaml
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
25
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
26 def rdfGraphBody(body, headers):
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
27 g = Graph()
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
28 g.parse(StringInputSource(body), format='nt')
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
29 return g
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
30
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
31 def mqttMessageFromState(state: URIRef):
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
32 return {
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
33 ROOM['locked']: b'OFF',
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
34 ROOM['unlocked']: b'ON',
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
35 }[state]
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
36
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
37 def stateFromMqtt(msg: bytes):
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
38 return {
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
39 b'OFF': ROOM['locked'],
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
40 b'ON': ROOM['unlocked'],
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
41 }[bytes(msg)]
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
42
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
43 class OutputPage(cyclone.web.RequestHandler):
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
44 def put(self):
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
45 try:
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
46 # what happened to the case-insens dict?
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
47 h = dict((k.lower(), v) for k,v in self.request.headers.items())
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
48 user = URIRef(h['x-foaf-agent'])
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
49 except KeyError:
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
50 log.warn('request without x-foaf-agent: %s', h)
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
51 self.set_status(403, 'need x-foaf-agent')
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
52 return
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
53 arg = self.request.arguments
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
54 if arg.get('s') and arg.get('p'):
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
55 subj = URIRef(arg['s'][-1])
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
56 pred = URIRef(arg['p'][-1])
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
57 obj = URIRef(self.request.body.strip().decode('ascii'))
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
58 stmt = (subj, pred, obj)
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
59 else:
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
60 g = rdfGraphBody(self.request.body, self.request.headers)
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
61 assert len(g) == 1, len(g)
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
62 stmt = next(g.triples((None, None, None)))
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
63 self._onStatement(user, stmt)
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
64 post = put
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
65
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
66 def _onStatement(self, user, stmt):
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
67 log.info('put statement %r', stmt)
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
68 if stmt[0:2] == (ROOM['frontDoorLock'], ROOM['state']):
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
69 if stmt[2] == ROOM['unlocked']:
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
70 log.info('unlock for %r', user)
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
71 self.settings.autoLock.onUnlockedStmt()
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
72 if stmt[2] == ROOM['locked']:
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
73 self.settings.autoLock.onLockedStmt()
568
2d8a5532f1b5 match esp hostname in py code
drewp@bigasterisk.com
parents: 563
diff changeset
74 self.settings.mqtt.publish(espName + b"/switch/strike/command",
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
75 mqttMessageFromState(stmt[2]))
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
76 return
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
77 log.warn("ignoring %s", stmt)
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
78
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
79
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
80 class AutoLock(object):
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
81 def __init__(self, masterGraph, mqtt):
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
82 self.masterGraph = masterGraph
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
83 self.mqtt = mqtt
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
84 self.timeUnlocked = None
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
85 self.autoLockSec = 6
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
86 self.subj = ROOM['frontDoorLock']
562
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
87 task.LoopingCall(self.pollCheck).start(1)
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
88
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
89 def relock(self):
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
90 log.info('autolock is up: requesting lock')
568
2d8a5532f1b5 match esp hostname in py code
drewp@bigasterisk.com
parents: 563
diff changeset
91 self.mqtt.publish(espName + b"/switch/strike/command",
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
92 mqttMessageFromState(ROOM['locked']))
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
93
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
94 def reportTimes(self, unlockedFor):
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
95 g = self.masterGraph
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
96 lockIn = self.autoLockSec - int(unlockedFor)
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
97 if lockIn < 0:
562
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
98 state = g._graph.value(self.subj, ROOM['state'])
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
99 log.warn(f"timeUnlocked {self.timeUnlocked}, state {state}, "
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
100 "unlockedFor {unlockedFor}, lockIn {lockIn}")
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
101 lockIn = 0
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
102 g.patchObject(ctx, self.subj, ROOM['unlockedForSec'],
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
103 Literal(int(unlockedFor)))
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
104 g.patchObject(ctx, self.subj, ROOM['autoLockInSec'],
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
105 Literal(lockIn))
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
106
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
107 def clearReport(self):
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
108 g = self.masterGraph
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
109 g.patchObject(ctx, self.subj, ROOM['unlockedForSec'], None)
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
110 g.patchObject(ctx, self.subj, ROOM['autoLockInSec'], None)
562
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
111
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
112 def pollCheck(self):
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
113 try:
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
114 self.check()
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
115 except Exception:
82e9480c3b7d fix a hang bug where polling stopped
drewp@bigasterisk.com
parents: 468
diff changeset
116 log.exception('poll failed')
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
117
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
118 def check(self):
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
119 g = self.masterGraph
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
120 now = time.time()
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
121 state = g._graph.value(self.subj, ROOM['state'])
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
122 if state == ROOM['unlocked']:
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
123 if self.timeUnlocked is None:
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
124 self.timeUnlocked = now
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
125 # *newly* unlocked- this resets on every input stmt
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
126 unlockedFor = now - self.timeUnlocked
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
127 if unlockedFor > self.autoLockSec:
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
128 self.relock()
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
129 else:
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
130 self.timeUnlocked = None
468
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
131 unlockedFor = 0
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
132 if unlockedFor > 3:
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
133 # only start showing the count if it looks like we're not
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
134 # being repeatedly held open. Time is hopefully more than
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
135 # the refresh rate of "reasoning.actions".
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
136 self.reportTimes(unlockedFor)
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
137 else:
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
138 self.clearReport()
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
139
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
140 def onUnlockedStmt(self):
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
141 self.timeUnlocked = None
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
142
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
143 def onLockedStmt(self):
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
144 pass
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
145
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
146 class BluetoothButton(cyclone.web.RequestHandler):
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
147 def post(self):
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
148 body = json.loads(self.request.body)
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
149 log.info('POST bluetoothButton %r', body)
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
150 if body['addr'] == 'zz:zz:zz:zz:zz:zz' and body['key'] == 'top':
756ff1170342 new graph view. some autolock and BT code
drewp@bigasterisk.com
parents: 426
diff changeset
151 log.info('unlock for %r', body['addr'])
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
152 self.settings.mqtt.publish(
568
2d8a5532f1b5 match esp hostname in py code
drewp@bigasterisk.com
parents: 563
diff changeset
153 espName + b"/switch/strike/command", b'ON')
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
154
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
155
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
156 if __name__ == '__main__':
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
157 arg = docopt("""
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
158 Usage: front_door_lock.py [options]
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
159
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
160 -v Verbose
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
161 """)
563
7f57d171d6d3 py3 and new build
drewp@bigasterisk.com
parents: 562
diff changeset
162 verboseLogging(arg['-v'])
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
163
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
164 masterGraph = PatchableGraph()
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
165 mqtt = MqttClient(brokerPort=10010)
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
166 autoclose = AutoLock(masterGraph, mqtt)
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
167
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
168 def toGraph(payload):
379
67cebf7a14de frontdoor autolock. logging improvements. use simpler mqtt interface.
drewp@bigasterisk.com
parents: 377
diff changeset
169 log.info('mqtt->graph %r', payload)
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
170 masterGraph.patchObject(ctx, ROOM['frontDoorLock'], ROOM['state'],
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
171 stateFromMqtt(payload))
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
172
568
2d8a5532f1b5 match esp hostname in py code
drewp@bigasterisk.com
parents: 563
diff changeset
173 mqtt.subscribe(espName + b"/switch/strike/state").subscribe(on_next=toGraph)
575
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
174
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
175 def setEspState(payload):
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
176 log.info('esp state change %r', payload)
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
177 masterGraph.patchObject(ctx, ROOM['frontDoorLock'], ROOM['espMqttConnection'],
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
178 ROOM['mqtt' + payload.decode('ascii').capitalize()])
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
179
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
180 mqtt.subscribe(espName + b"/status").subscribe(on_next=setEspState)
1209229cd56e faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py
drewp@bigasterisk.com
parents: 568
diff changeset
181
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
182 port = 10011
426
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
183 reactor.listenTCP(port, cyclone.web.Application(
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
184 [
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
185 (r"/()", cyclone.web.StaticFileHandler,
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
186 {"path": ".", "default_filename": "index.html"}),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
187 (r"/graph", CycloneGraphHandler, {'masterGraph': masterGraph}),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
188 (r"/graph/events", CycloneGraphEventsHandler,
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
189 {'masterGraph': masterGraph}),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
190 (r'/output', OutputPage),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
191 (r'/bluetoothButton', BluetoothButton),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
192 ],
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
193 mqtt=mqtt,
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
194 masterGraph=masterGraph,
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
195 autoLock=autoclose,
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
196 debug=arg['-v']),
bfe555dd0c91 talk to store graph, second button for holding unlocked, etc
drewp@bigasterisk.com
parents: 425
diff changeset
197 interface='::')
377
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
198 log.warn('serving on %s', port)
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
199
5b690bfc31b2 docker/etc initial version of front door mqtt<->rdf using some rx
drewp@bigasterisk.com
parents:
diff changeset
200 reactor.run()