Mercurial > code > home > repos > light9

annotate bin/clientdemo @ 1447:8a9a9b58a4e2

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
live page now knows that collector needs all settings on each request Ignore-this: 79ad8d1e001b98b6fce6d14f75f92745
author drewp@bigasterisk.com
date Sat, 11 Jun 2016 21:40:37 +0000
parents a38955ba6f40
children 6fa4288da8a6
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
1114
a38955ba6f40 rdfdb port is now in the config
Drew Perttula <drewp@bigasterisk.com>
parents: 798
diff changeset
8 from light9 import networking
797
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
9 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
10 from light9.rdfdb.syncedgraph import SyncedGraph
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
11
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
12 if __name__ == "__main__":
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
13 logging.basicConfig(level=logging.DEBUG)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
14 log = logging.getLogger()
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
15
1114
a38955ba6f40 rdfdb port is now in the config
Drew Perttula <drewp@bigasterisk.com>
parents: 798
diff changeset
16 g = SyncedGraph(networking.rdfdb.url, "clientdemo")
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
17
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
18 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
19 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
20
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 #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
22
5c158d37f1ce autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds.
drewp@bigasterisk.com
parents: 797
diff changeset
23
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
24 L9 = Namespace("http://light9.bigasterisk.com/")
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
25 def updateDemoValue():
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
26 v = list(g.objects(L9['demo'], L9['is']))
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
27 print "demo value is %r" % v
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
28
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
29 g.addHandler(updateDemoValue)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
30
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
31 def adj():
797
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
32 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
33 L9['clientdemo'])],
904913de4599 deletes are now quads. refactor files. named clients. auto client port
drewp@bigasterisk.com
parents: 796
diff changeset
34 delQuads=[]))
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
35 reactor.callLater(2, adj)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
36 reactor.run()