Mercurial > code > home > repos > light9
view bin/clientdemo @ 798:5c158d37f1ce
autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
Ignore-this: 31e03cf07e5d460ea5c72d7beccefe7
author | drewp@bigasterisk.com |
---|---|
date | Mon, 16 Jul 2012 00:49:57 +0000 |
parents | 904913de4599 |
children | a38955ba6f40 |
line wrap: on
line source
#!bin/python import os, sys sys.path.append(".") from twisted.internet import reactor import cyclone.web, cyclone.httpclient, logging from rdflib import Namespace, Literal, URIRef from light9.rdfdb.patch import Patch from light9.rdfdb.syncedgraph import SyncedGraph if __name__ == "__main__": logging.basicConfig(level=logging.DEBUG) log = logging.getLogger() g = SyncedGraph("clientdemo") from light9.Submaster import PersistentSubmaster sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools")) #get sub to show its updating name, then push that all the way into KC gui so we can see just names refresh in there L9 = Namespace("http://light9.bigasterisk.com/") def updateDemoValue(): v = list(g.objects(L9['demo'], L9['is'])) print "demo value is %r" % v g.addHandler(updateDemoValue) def adj(): g.patch(Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()), L9['clientdemo'])], delQuads=[])) reactor.callLater(2, adj) reactor.run()