# HG changeset patch
# User drewp <drewp@bigasterisk.com>
# Date 1557201968 25200
# Node ID fecbac537f63ead122fb5d612d88f66fe527309f
# Parent  12d6ce6f6bc1a1aadb2df1fefce7e65834a549fc
faster keepalive from esp chip. report aliveness into the graph. more programming tasks in tasks.py

Ignore-this: f8fca86291d3082cb309524fbd5baf1c

darcs-hash:9ef8e6bfe77887aa8450596fd3f662acd969d8ef

diff -r 12d6ce6f6bc1 -r fecbac537f63 service/frontDoorLock/door.yaml
--- a/service/frontDoorLock/door.yaml	Mon May 06 00:19:08 2019 -0700
+++ b/service/frontDoorLock/door.yaml	Mon May 06 21:06:08 2019 -0700
@@ -18,9 +18,10 @@
 mqtt:
   broker: '10.2.0.1'
   port: 10010
+  keepalive: 5
   username: ''
   password: ''
-
+  
 logger:
   baud_rate: 115200
   level: DEBUG
diff -r 12d6ce6f6bc1 -r fecbac537f63 service/frontDoorLock/front_door_lock.py
--- a/service/frontDoorLock/front_door_lock.py	Mon May 06 00:19:08 2019 -0700
+++ b/service/frontDoorLock/front_door_lock.py	Mon May 06 21:06:08 2019 -0700
@@ -171,6 +171,14 @@
                                 stateFromMqtt(payload))
 
     mqtt.subscribe(espName + b"/switch/strike/state").subscribe(on_next=toGraph)
+
+    def setEspState(payload):
+        log.info('esp state change %r', payload)
+        masterGraph.patchObject(ctx, ROOM['frontDoorLock'], ROOM['espMqttConnection'],
+                                ROOM['mqtt' + payload.decode('ascii').capitalize()])
+    
+    mqtt.subscribe(espName + b"/status").subscribe(on_next=setEspState)
+    
     port = 10011
     reactor.listenTCP(port, cyclone.web.Application(
         [
diff -r 12d6ce6f6bc1 -r fecbac537f63 service/frontDoorLock/tasks.py
--- a/service/frontDoorLock/tasks.py	Mon May 06 00:19:08 2019 -0700
+++ b/service/frontDoorLock/tasks.py	Mon May 06 21:06:08 2019 -0700
@@ -36,3 +36,16 @@
 def monitor_usb(ctx):
     tag = 'esphome/esphome'
     ctx.run(f"docker run --rm -v `pwd`:/config --device=/dev/ttyUSB0 -it {tag} door.yaml logs", pty=True)
+
+@task
+def tail_mqtt(ctx):
+    ctx.run(f'mosquitto_sub -h bang -p 10010 -d -v -t \#')
+
+@task
+def mqtt_force_open(ctx):
+    ctx.run(f'mosquitto_pub -h bang -p 10010 -t frontdoorlock/switch/strike/command -m ON')
+
+@task
+def mqtt_force_lock(ctx):
+    ctx.run(f'mosquitto_pub -h bang -p 10010 -t frontdoorlock/switch/strike/command -m OFF')
+