# HG changeset patch
# User drewp@bigasterisk.com
# Date 1544584386 28800
# Node ID 5b690bfc31b2c4a4cb5612499ab4fb360e290569
# Parent  b3dac05ab9fa8d8f7565f87e04d450bf0b603a21
docker/etc initial version of front door mqtt<->rdf using some rx
Ignore-this: 87ea28bde75a5b0d35fe89d61f11090a

diff -r b3dac05ab9fa -r 5b690bfc31b2 service/frontDoorLock/Dockerfile
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/service/frontDoorLock/Dockerfile	Tue Dec 11 19:13:06 2018 -0800
@@ -0,0 +1,12 @@
+FROM bang6:5000/base_x86
+
+WORKDIR /opt
+
+COPY requirements.txt ./
+RUN pip install -r requirements.txt
+
+COPY *.py *.html *.css *.js ./
+
+EXPOSE 10011:10011
+
+CMD [ "python", "./front_door_lock.py", "-v" ]
diff -r b3dac05ab9fa -r 5b690bfc31b2 service/frontDoorLock/front_door_lock.py
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/service/frontDoorLock/front_door_lock.py	Tue Dec 11 19:13:06 2018 -0800
@@ -0,0 +1,87 @@
+from docopt import docopt
+from patchablegraph import PatchableGraph, CycloneGraphHandler, CycloneGraphEventsHandler
+from rdflib import Namespace, URIRef, Literal, Graph
+from rdflib.parser import StringInputSource
+from twisted.internet import reactor
+import cyclone.web
+import sys, logging
+from mqtt_client import MqttClient
+
+ROOM = Namespace('http://projects.bigasterisk.com/room/')
+
+logging.basicConfig()
+log = logging.getLogger()
+
+ctx = ROOM['frontDoorControl']
+
+def rdfGraphBody(body, headers):
+    g = Graph()
+    g.parse(StringInputSource(body), format='nt')
+    return g
+
+def mqttMessageFromState(state):
+    return {
+        ROOM['locked']: b'OFF',
+        ROOM['unlocked']: b'ON',
+        }[state]
+
+def stateFromMqtt(msg):
+    return {
+        'OFF': ROOM['locked'],
+        'ON': ROOM['unlocked'],
+    }[msg.decode('ascii')]
+    
+class OutputPage(cyclone.web.RequestHandler):
+    def put(self):
+        arg = self.request.arguments
+        if arg.get('s') and arg.get('p'):
+            subj = URIRef(arg['s'][-1])
+            pred = URIRef(arg['p'][-1])
+            obj = URIRef(self.request.body)
+            stmt = (subj, pred, obj)
+        else:
+            g = rdfGraphBody(self.request.body, self.request.headers)
+            assert len(g) == 1, len(g)
+            stmt = g.triples((None, None, None)).next()
+        self._onStatement(stmt)
+            
+    def _onStatement(self, stmt):
+        if stmt[0:2] == (ROOM['frontDoorLock'], ROOM['state']):
+            self.settings.mqtt.publish("frontdoor/switch/strike/command",
+                                       mqttMessageFromState(stmt[2]))
+            self.settings.masterGraph.patchObject(ctx,
+                                                  stmt[0], stmt[1], stmt[2])
+            return
+        log.warn("ignoring %s", stmt)
+            
+if __name__ == '__main__':
+    arg = docopt("""
+    Usage: front_door_lock.py [options]
+
+    -v   Verbose
+    """)
+    log.setLevel(logging.WARN)
+    if arg['-v']:
+        from twisted.python import log as twlog
+        twlog.startLogging(sys.stdout)
+        log.setLevel(logging.DEBUG)
+
+    masterGraph = PatchableGraph()
+    mqtt = MqttClient(brokerPort=10010)
+
+    def toGraph(payload):
+        log.debug('toGraph %r', payload)
+        masterGraph.patchObject(ctx, ROOM['frontDoorLock'], ROOM['state'],
+                                stateFromMqtt(payload))
+
+    mqtt.subscribe("frontdoor/switch/strike/state").subscribe(on_next=toGraph)
+    port = 10011
+    reactor.listenTCP(port, cyclone.web.Application([
+        (r"/graph", CycloneGraphHandler, {'masterGraph': masterGraph}),
+        (r"/graph/events", CycloneGraphEventsHandler,
+         {'masterGraph': masterGraph}),
+        (r'/output', OutputPage),
+        ], mqtt=mqtt, masterGraph=masterGraph, debug=arg['-v']), interface='::')
+    log.warn('serving on %s', port)
+
+    reactor.run()
diff -r b3dac05ab9fa -r 5b690bfc31b2 service/frontDoorLock/makefile
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/service/frontDoorLock/makefile	Tue Dec 11 19:13:06 2018 -0800
@@ -0,0 +1,19 @@
+JOB=front_door_lock
+PORT=10011
+
+TAG=bang6:5000/${JOB}_x86:latest
+
+build_image:
+	rm -rf tmp_ctx
+	mkdir -p tmp_ctx
+	cp -a Dockerfile ../../lib/*.py *.py *.txt tmp_ctx
+	docker build --network=host -t ${TAG} tmp_ctx
+	docker push ${TAG}
+	rm -rf tmp_ctx
+
+
+shell:
+	docker run --rm -it --cap-add SYS_PTRACE --net=host bang6:5000/$(JOB)_x86:latest  /bin/sh
+
+local_run:
+	docker run --rm -it --net=host bang6:5000/$(JOB)_x86:latest
diff -r b3dac05ab9fa -r 5b690bfc31b2 service/frontDoorLock/requirements.txt
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/service/frontDoorLock/requirements.txt	Tue Dec 11 19:13:06 2018 -0800
@@ -0,0 +1,6 @@
+cyclone
+rdflib-jsonld==0.4.0
+rdflib==4.2.2
+twisted-mqtt==0.3.6
+https://projects.bigasterisk.com/rdfdb/rdfdb-0.3.0.tar.gz
+rx==1.6.1