annotate bin/clientdemo @ 2050:7ed414bdaab9

wip porting asco to TS and not-jquery
author drewp@bigasterisk.com
date Wed, 11 May 2022 00:07:13 -0700
parents f066d6e874db
children
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
1692
6fa4288da8a6 rdfdb is its own package now
drewp@bigasterisk.com
parents: 1114
diff changeset
9 from rdfdb.patch import Patch
6fa4288da8a6 rdfdb is its own package now
drewp@bigasterisk.com
parents: 1114
diff changeset
10 from 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
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
19 sub = PersistentSubmaster(
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
20 graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools"))
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
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 #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
23
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
24 L9 = Namespace("http://light9.bigasterisk.com/")
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
25
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
26 def updateDemoValue():
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
27 v = list(g.objects(L9['demo'], L9['is']))
1859
f066d6e874db 2to3 with these fixers: all idioms set_literal
drewp@bigasterisk.com
parents: 1858
diff changeset
28 print("demo value is %r" % v)
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
29
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
30 g.addHandler(updateDemoValue)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
31
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
32 def adj():
1858
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
33 g.patch(
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
34 Patch(addQuads=[(L9['demo'], L9['is'], Literal(os.getpid()),
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
35 L9['clientdemo'])],
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
36 delQuads=[]))
7772cc48e016 reformat all python
drewp@bigasterisk.com
parents: 1692
diff changeset
37
796
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
38 reactor.callLater(2, adj)
37d05bd17b10 rdfdb first pass
drewp@bigasterisk.com
parents:
diff changeset
39 reactor.run()