Mercurial > code > home > repos > homeauto

annotate service/frontDoorLock/front_door_lock.py @ 1378:fecbac537f63

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