# HG changeset patch # User drewp@bigasterisk.com # Date 1569457752 25200 # Node ID 92cb3245fdd18e428215c207a7d38498528d7385 # Parent 2baf1f0994e3972a82610c32a93c8914f00dbc88 index page is a data browser. support for -v Ignore-this: cbe181b141420e0d6872203e4738f86f diff -r 2baf1f0994e3 -r 92cb3245fdd1 service/store/index.html --- a/service/store/index.html Wed Sep 25 17:28:38 2019 -0700 +++ b/service/store/index.html Wed Sep 25 17:29:12 2019 -0700 @@ -2,18 +2,20 @@ store - + + + - + -
/stats/ /graph diff -r 2baf1f0994e3 -r 92cb3245fdd1 service/store/store.py --- a/service/store/store.py Wed Sep 25 17:28:38 2019 -0700 +++ b/service/store/store.py Wed Sep 25 17:29:12 2019 -0700 @@ -15,12 +15,10 @@ from twisted.internet import reactor from twisted.python.filepath import FilePath import cyclone.web +from standardservice.logsetup import log, verboseLogging ROOM = Namespace('http://projects.bigasterisk.com/room/') -logging.basicConfig() -log = logging.getLogger() - CTX = ROOM['stored'] class ValuesResource(cyclone.web.RequestHandler): @@ -40,7 +38,7 @@ except ValueError: obj = Literal(turtleLiteral) self._onStatements([(subj, pred, obj)]) - + def _onGraphBodyStatements(self, body, headers): # maybe quads only so we can track who made the input and from what interface? # Or your input of triples gets wrapped in a new quad in here? @@ -49,7 +47,7 @@ if not g: raise ValueError("expected graph body") self._onStatements(list(g.triples((None, None, None)))) - + def _onStatements(self, stmts): g = self.settings.masterGraph for s, p, o in stmts: @@ -59,24 +57,20 @@ g.patch(patch) nquads = g.serialize(None, format='nquads') self.settings.dbFile.setContent(nquads) - + if __name__ == '__main__': arg = docopt(""" Usage: store.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) + verboseLogging(arg['-v']) masterGraph = PatchableGraph() dbFile = FilePath('/opt/homeauto_store/db.nquads') if dbFile.exists(): masterGraph._graph.parse(dbFile.open(), format='nquads') - + port = 10015 reactor.listenTCP(port, cyclone.web.Application([ (r"/()", cyclone.web.StaticFileHandler,