Mercurial > code > home > repos > light9

annotate bin/subserver @ 1097:f7618f29bb89

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rewrite CurveSet. remove sliders support from curvecalc. curve edits now write quickly to the graph. Ignore-this: d0338e3a21636d992958594e878962e
author Drew Perttula <drewp@bigasterisk.com>
date Mon, 09 Jun 2014 03:05:32 +0000
parents 473db8bebb8f
children 448fe9f81501
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
1 #!bin/python
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
2 """
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
3 live web display of all existing subs with pictures, mainly for
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
4 dragging them into CC
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
5 """
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
6 from run_local import log
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
7 import sys, optparse, logging, json, subprocess, datetime
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
8 from dateutil.tz import tzlocal
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
9 from twisted.internet import reactor, defer
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
10 import cyclone.web, cyclone.httpclient, cyclone.websocket
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
11 from rdflib import RDF, URIRef, Literal
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
12 import pyjade.utils
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
13 from light9.rdfdb.syncedgraph import SyncedGraph
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
14 from light9.rdfdb.patch import Patch
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
15 from light9.namespaces import L9, DCTERMS
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
16 from light9 import networking, showconfig
222
bb4d1e9b30c1 outline of new subserver
drewp@bigasterisk.com
parents:
diff changeset
17
1060
473db8bebb8f install a copy of cycloneerr.py
Drew Perttula <drewp@bigasterisk.com>
parents: 1041
diff changeset
18 from lib.cycloneerr import PrettyErrorHandler
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
19
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
20 liveClients = set()
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
21 def sendToLiveClients(d=None, asJson=None):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
22 j = asJson or json.dumps(d)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
23 for c in liveClients:
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
24 c.sendMessage(j)
222
bb4d1e9b30c1 outline of new subserver
drewp@bigasterisk.com
parents:
diff changeset
25
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
26 class Live(cyclone.websocket.WebSocketHandler):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
27 def connectionMade(self, *args, **kwargs):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
28 log.info("websocket opened")
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
29 liveClients.add(self)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
30 self.settings.onNewClient()
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
31
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
32 def connectionLost(self, reason):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
33 log.info("websocket closed")
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
34 liveClients.remove(self)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
35
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
36 def messageReceived(self, message):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
37 log.info("got message %s" % message)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
38 self.sendMessage(message)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
39
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
40 class Static(PrettyErrorHandler, cyclone.web.StaticFileHandler):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
41 def get(self, path, *args, **kw):
953
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
42 if path in ['', 'chases']:
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
43 return self.respondStaticJade("light9/subserver/%s.jade" %
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
44 (path or 'index'))
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
45
1041
a4632a7b2e17 upgrade knockout and jquery, simplify the static/ dirs for all web services
Drew Perttula <drewp@bigasterisk.com>
parents: 976
diff changeset
46 if path.endswith(".js"):
953
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
47 return self.responseStaticCoffee(
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
48 'light9/subserver/%s' %
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
49 path.replace(".js", ".coffee")) # potential security hole
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
50
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
51 cyclone.web.StaticFileHandler.get(self, path, *args, **kw)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
52
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
53 def respondStaticJade(self, src):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
54 html = pyjade.utils.process(open(src).read())
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
55 self.write(html)
222
bb4d1e9b30c1 outline of new subserver
drewp@bigasterisk.com
parents:
diff changeset
56
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
57 def responseStaticCoffee(self, src):
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
58 self.write(subprocess.check_output([
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
59 '/usr/bin/coffee', '--compile', '--print', src]))
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
60
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
61 class Snapshot(PrettyErrorHandler, cyclone.web.RequestHandler):
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
62 @defer.inlineCallbacks
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
63 def post(self):
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
64 about = URIRef(self.get_argument("about"))
976
cfc748f4ad2e add timeout from subserver to vidref
drewp@bigasterisk.com
parents: 953
diff changeset
65 response = yield cyclone.httpclient.fetch(networking.vidref.path("snapshot"), method="POST", timeout=1)
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
66
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
67 snapUri = URIRef(json.loads(response.body)['snapshot'])
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
68 # vidref could write about when it was taken, etc. would it be
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
69 # better for us to tell vidref where to attach the result in
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
70 # the graph, and then it doesn't even have to return anything?
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
71
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
72 ctx = showconfig.showUri() + "/snapshots"
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
73
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
74 self.settings.graph.patch(Patch(addQuads=[
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
75 (about, L9['image'], snapUri, ctx),
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
76 (snapUri, DCTERMS['created'],
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
77 Literal(datetime.datetime.now(tzlocal())), ctx),
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
78 ]))
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
79
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
80 self.write(json.dumps({'snapshot': snapUri}))
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
81
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
82 def newestImage(subject):
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
83 newest = (None, None)
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
84 for img in graph.objects(subject, L9['image']):
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
85 created = graph.value(img, DCTERMS['created'])
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
86 if created > newest[0]:
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
87 newest = (created, img)
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
88 return newest[1]
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
89
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
90 if __name__ == "__main__":
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
91 parser = optparse.OptionParser()
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
92 parser.add_option("-v", "--verbose", action="store_true",
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
93 help="logging.DEBUG")
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
94 (options, args) = parser.parse_args()
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
95
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
96 log.setLevel(logging.DEBUG if options.verbose else logging.INFO)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
97
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
98 graph = SyncedGraph("subserver")
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
99
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
100 d = {}
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
101 def updateSubs():
923
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
102 subs = []
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
103 for sub in sorted(graph.subjects(RDF.type, L9['Submaster'])):
923
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
104 rec = {'uri' : sub}
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
105 rec['isLocal'] = graph.contains((sub, RDF.type,
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
106 L9['LocalSubmaster']))
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
107 rec['label'] = graph.label(sub)
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
108 rec['img'] = newestImage(sub)
923
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
109 subs.append(rec)
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
110
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
111 d.clear()
923
8b95d2865643 subserver shows real submasters, stays live. pretty sweet
drewp@bigasterisk.com
parents: 919
diff changeset
112 d.update({'subs': subs})
953
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
113
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
114 d['chases'] = []
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
115 for chase in sorted(graph.subjects(RDF.type, L9['Chase'])):
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
116 fakeLabel = chase.rsplit('/', 1)[-1]
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
117 d['chases'].append({
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
118 'uri': chase,
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
119 'label': fakeLabel,
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
120 })
891f2d75c686 subserver now also serves some premade subterms with the defined chases
drewp@bigasterisk.com
parents: 942
diff changeset
121
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
122 sendToLiveClients(d=d)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
123 def onNewClient():
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
124 sendToLiveClients(d=d)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
125
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
126 graph.addHandler(updateSubs)
222
bb4d1e9b30c1 outline of new subserver
drewp@bigasterisk.com
parents:
diff changeset
127
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
128
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
129 port = 8052
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
130 reactor.listenTCP(port, cyclone.web.Application(handlers=[
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
131 (r'/live', Live),
942
dd896321faee subserver can get a snapshot from vidref and display it on the sub
drewp@bigasterisk.com
parents: 923
diff changeset
132 (r'/snapshot', Snapshot),
1041
a4632a7b2e17 upgrade knockout and jquery, simplify the static/ dirs for all web services
Drew Perttula <drewp@bigasterisk.com>
parents: 976
diff changeset
133 (r'/static/(.*)', cyclone.web.StaticFileHandler, {'path': 'static/'}),
919
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
134 (r'/(.*)', Static,
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
135 {"path" : "light9/subserver",
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
136 "default_filename" : "index.jade"}),
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
137 ], debug=True, graph=graph, onNewClient=onNewClient))
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
138 log.info("serving on %s" % port)
33a5a98e9bf1 start subserver webapp with websockets, cyclone, jade, coffee
drewp@bigasterisk.com
parents: 310
diff changeset
139 reactor.run()