Mercurial > code > home > repos > light9

annotate bin/clientdemo @ 798:5c158d37f1ce

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
1 #!bin/python
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
2
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
3 import os, sys
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
4 sys.path.append(".")
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
5 from twisted.internet import reactor
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
6 import cyclone.web, cyclone.httpclient, logging
798
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
7 from rdflib import Namespace, Literal, URIRef
797
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
8 from light9.rdfdb.patch import Patch
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
9 from light9.rdfdb.syncedgraph import SyncedGraph
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
10
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
11 if __name__ == "__main__":
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
12 logging.basicConfig(level=logging.DEBUG)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
13 log = logging.getLogger()
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
14
797
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
15 g = SyncedGraph("clientdemo")
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
16
798
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
17 from light9.Submaster import PersistentSubmaster
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
18 sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools"))
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
19
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
20 #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
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
21
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
22
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
23 L9 = Namespace("http://light9.bigasterisk.com/")
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
24 def updateDemoValue():
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
25 v = list(g.objects(L9['demo'], L9['is']))
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
26 print "demo value is %r" % v
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
27
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
28 g.addHandler(updateDemoValue)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
29
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
30 def adj():
797
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
31 g.patch(Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()),
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
32 L9['clientdemo'])],
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
33 delQuads=[]))
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
34 reactor.callLater(2, adj)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
35 reactor.run()