# HG changeset patch # User drewp@bigasterisk.com # Date 1631901666 25200 # Node ID 78024b27f9ec030e5513dc02a4f3a78960122fb2 # Parent 5403c6343fa4d0b1f074e805c764bdbffcf869ed serve graph/config diff -r 5403c6343fa4 -r 78024b27f9ec service/mqtt_to_rdf/mqtt_to_rdf.py --- a/service/mqtt_to_rdf/mqtt_to_rdf.py Wed Sep 15 23:56:21 2021 -0700 +++ b/service/mqtt_to_rdf/mqtt_to_rdf.py Fri Sep 17 11:01:06 2021 -0700 @@ -6,6 +6,8 @@ import logging import os +from rdfdb.patch import Patch + from mqtt_message import graphFromMessage import os import time @@ -396,6 +398,9 @@ inference=inference)) log.info(f'set up {len(srcs)} sources') + peg = PatchableGraph() + peg.patch(Patch(addQuads=[(s,p,o,URIRef('/config')) for s,p,o in expandedConfig])) + port = 10018 reactor.listenTCP(port, cyclone.web.Application([ @@ -406,6 +411,9 @@ (r"/build/(bundle.js)", cyclone.web.StaticFileHandler, { "path": "build" }), + (r"/graph/config", CycloneGraphHandler, { + 'masterGraph': peg, + }), (r"/graph/mqtt", CycloneGraphHandler, { 'masterGraph': masterGraph }),