Files @ 771f50f19b4b
Branch filter:

Location: light9/bin/effecteval - annotation

Drew Perttula
single-line effect code now evals by changing <uri> into a suitable python object
Ignore-this: cde829f021be54bc7cfd63bddde43aa9
e28a443bd153
9937e2e3d17b
e28a443bd153
9937e2e3d17b
9937e2e3d17b
a38414bd3929
b370618ce723
be016cd5e5c5
e28a443bd153
e28a443bd153
b5ee7aa9341a
fce46850ed8c
fce46850ed8c
1583e997fe0e
fce46850ed8c
b370618ce723
a2081b9adfe4
fce46850ed8c
9937e2e3d17b
e28a443bd153
473db8bebb8f
e28a443bd153
4595a82f5a90
e28a443bd153
e28a443bd153
4595a82f5a90
4595a82f5a90
4595a82f5a90
4595a82f5a90
4595a82f5a90
4595a82f5a90
4595a82f5a90
4595a82f5a90
6ce00faec207
a2081b9adfe4
a2081b9adfe4
a2081b9adfe4
dc474426845d
a2081b9adfe4
6ce00faec207
dc474426845d
dc474426845d
be016cd5e5c5
6ce00faec207
dc474426845d
dc474426845d
fce46850ed8c
fce46850ed8c
fce46850ed8c
fce46850ed8c
6ce00faec207
be016cd5e5c5
a2081b9adfe4
a2081b9adfe4
a2081b9adfe4
771f50f19b4b
a2081b9adfe4
dc474426845d
fce46850ed8c
a2081b9adfe4
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
4595a82f5a90
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
aa45e5379c5a
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
3074f635ee23
3074f635ee23
3074f635ee23
3074f635ee23
3074f635ee23
771f50f19b4b
771f50f19b4b
3074f635ee23
3074f635ee23
3074f635ee23
3074f635ee23
3074f635ee23
3074f635ee23
771f50f19b4b
3074f635ee23
5939fce98fad
5939fce98fad
a38414bd3929
5939fce98fad
b5ee7aa9341a
5939fce98fad
a38414bd3929
a38414bd3929
a38414bd3929
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
b5ee7aa9341a
5939fce98fad
5939fce98fad
5939fce98fad
5939fce98fad
b5ee7aa9341a
5939fce98fad
5939fce98fad
b5ee7aa9341a
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
aa45e5379c5a
aa45e5379c5a
9937e2e3d17b
9937e2e3d17b
9937e2e3d17b
9937e2e3d17b
9937e2e3d17b
9937e2e3d17b
9937e2e3d17b
aa45e5379c5a
9937e2e3d17b
9937e2e3d17b
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
a4632a7b2e17
a4632a7b2e17
3074f635ee23
a4632a7b2e17
e28a443bd153
5939fce98fad
a2081b9adfe4
5939fce98fad
9937e2e3d17b
9937e2e3d17b
aa45e5379c5a
aa45e5379c5a
9937e2e3d17b
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
e28a443bd153
#!bin/python
from __future__ import division
from run_local import log
from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks, returnValue
import cyclone.web, cyclone.websocket, cyclone.httpclient
import sys, optparse, logging, subprocess, json, time, traceback
from rdflib import URIRef, Literal

sys.path.append(".")
from light9 import networking, showconfig, Submaster, dmxclient
from light9.curvecalc.curve import CurveResource
from light9.effecteval.effect import EffectNode
from light9.effecteval.effectloop import EffectLoop
from light9.greplin_cyclone import StatsForCyclone
from light9.namespaces import L9, RDF, RDFS
from light9.rdfdb.patch import Patch
from light9.rdfdb.syncedgraph import SyncedGraph
from greplin import scales

from lib.cycloneerr import PrettyErrorHandler

class EffectEdit(PrettyErrorHandler, cyclone.web.RequestHandler):
    def get(self):
        self.write(open("light9/effecteval/effect.html").read())
    def delete(self):
        graph = self.settings.graph
        uri = URIRef(self.get_argument('uri'))
        with graph.currentState(tripleFilter=(None, L9['effect'], uri)) as g:
            song = ctx = list(g.subjects(L9['effect'], uri))[0]
        self.settings.graph.patch(Patch(delQuads=[
            (song, L9['effect'], uri, ctx),
            ]))
        
class SongEffects(PrettyErrorHandler, cyclone.web.RequestHandler):
    def post(self):
        song = URIRef(self.get_argument('uri'))
        dropped = URIRef(self.get_argument('drop'))
        ctx = song
        graph = self.settings.graph
        effect = graph.sequentialUri(song + "/effect-")
        curve = graph.sequentialUri(song + "/curve-")

        with graph.currentState(
                tripleFilter=(dropped, RDFS.label, None)) as g:
            droppedSubLabel = g.label(dropped)
            
        cr = CurveResource(graph, curve)
        cr.newCurve(ctx, label=Literal('sub %s' % droppedSubLabel))
        cr.saveCurve()
        graph.patch(Patch(addQuads=[
            (song, L9['curve'], curve, ctx),
            (song, L9['effect'], effect, ctx),
            (effect, RDF.type, L9['Effect'], ctx),
            (effect, L9['code'],
             Literal('out = %s * %s' % (dropped.n3(), curve.n3())),
             ctx),
            ]))
        
        
class SongEffectsUpdates(cyclone.websocket.WebSocketHandler):
    def connectionMade(self, *args, **kwargs):
        self.graph = self.settings.graph
        self.graph.addHandler(self.updateClient)
        
    def updateClient(self):
        # todo: abort if client is gone
        playlist = self.graph.value(showconfig.showUri(), L9['playList'])
        songs = list(self.graph.items(playlist))
        out = []
        for s in songs:
            out.append({'uri': s, 'label': self.graph.label(s)})
            out[-1]['effects'] = [{'uri': uri} for uri in sorted(self.graph.objects(s, L9['effect']))]
        self.sendMessage({'songs': out})
        
        
class EffectUpdates(cyclone.websocket.WebSocketHandler):
    """
    stays alive for the life of the effect page
    """
    def connectionMade(self, *args, **kwargs):
        log.info("websocket opened")
        self.uri = URIRef(self.get_argument('uri'))
        self.sendMessage({'hello': repr(self)})

        self.graph = self.settings.graph
        self.graph.addHandler(self.updateClient)

    def updateClient(self):
        # todo: if client has dropped, abort and don't get any more
        # graph updates
        self.sendMessage({'code': self.graph.value(self.uri, L9['code'])})
        
    def connectionLost(self, reason):
        log.info("websocket closed")

    def messageReceived(self, message):
        log.info("got message %s" % message)
        # write a patch back to the graph

class Code(PrettyErrorHandler, cyclone.web.RequestHandler):
    def put(self):
        effect = URIRef(self.get_argument('uri'))
        code = Literal(self.get_argument('code'))
        with self.settings.graph.currentState(
                tripleFilter=(None, L9['effect'], effect)) as g:
            song = g.subjects(L9['effect'], effect).next()
        self.settings.graph.patchObject(
            context=song,
            subject=effect,
            predicate=L9['code'],
            newObject=code)
        # right here we could tell if the code has a python error and return it
        self.send_error(202)
        
class EffectEval(PrettyErrorHandler, cyclone.web.RequestHandler):
    @inlineCallbacks
    def get(self):
        # return dmx list for that effect
        uri = URIRef(self.get_argument('uri'))
        response = yield cyclone.httpclient.fetch(
            networking.musicPlayer.path('time'))
        songTime = json.loads(response.body)['t']

        node = EffectNode(self.settings.graph, uri)
        outSub = node.eval(songTime)
        self.write(json.dumps(outSub.get_dmx_list()))


# Completely not sure where the effect background loop should
# go. Another process could own it, and get this request repeatedly:
class SongEffectsEval(PrettyErrorHandler, cyclone.web.RequestHandler):
    def get(self):
        song = URIRef(self.get_argument('song'))
        effects = effectsForSong(self.settings.graph, song)
        raise NotImplementedError
        self.write(maxDict(effectDmxDict(e) for e in effects))
        # return dmx dict for all effects in the song, already combined

class App(object):
    def __init__(self, show):
        self.show = show
        self.graph = SyncedGraph("effectEval")
        self.graph.initiallySynced.addCallback(self.launch)

        self.stats = scales.collection('/',
                                       scales.PmfStat('sendLevels'),
                                       scales.PmfStat('getMusic'),
                                       scales.PmfStat('writeDmx'),
                                       scales.IntStat('errors'),
                                       )

    def launch(self, *args):
        self.loop = EffectLoop(self.graph, self.stats)
        
        SFH = cyclone.web.StaticFileHandler
        self.cycloneApp = cyclone.web.Application(handlers=[
            (r'/()', SFH,
             {'path': 'light9/effecteval', 'default_filename': 'index.html'}),
            (r'/effect', EffectEdit),
            (r'/(websocket\.js)', SFH, {'path': 'light9/rdfdb/web/'}),
            (r'/effect\.js', StaticCoffee, {'src': 'light9/effecteval/effect.coffee'}),
            (r'/index\.js', StaticCoffee, {'src': 'light9/effecteval/index.coffee'}),
            (r'/effectUpdates', EffectUpdates),
            (r'/code', Code),
            (r'/songEffectsUpdates', SongEffectsUpdates),
            (r'/static/(.*)', SFH, {'path': 'static/'}),
            (r'/effect/eval', EffectEval),
            (r'/songEffects', SongEffects),
            (r'/songEffects/eval', SongEffectsEval),
            (r'/stats', StatsForCyclone),
        ], debug=True, graph=self.graph, stats=self.stats)
        reactor.listenTCP(networking.effectEval.port, self.cycloneApp)
        log.info("listening on %s" % networking.effectEval.port)
        
class StaticCoffee(PrettyErrorHandler, cyclone.web.RequestHandler):
    def initialize(self, src):
        super(StaticCoffee, self).initialize()
        self.src = src
    def get(self):
        self.set_header('Content-Type', 'application/javascript')
        self.write(subprocess.check_output([
            '/usr/bin/coffee', '--compile', '--print', self.src]))

        
if __name__ == "__main__":
    parser = optparse.OptionParser()
    parser.add_option('--show',
        help='show URI, like http://light9.bigasterisk.com/show/dance2008',
                      default=showconfig.showUri())
    parser.add_option("-v", "--verbose", action="store_true",
                      help="logging.DEBUG")
    parser.add_option("--twistedlog", action="store_true",
                      help="twisted logging")
    (options, args) = parser.parse_args()

    log.setLevel(logging.DEBUG if options.verbose else logging.INFO)

    if not options.show:
        raise ValueError("missing --show http://...")
            
    app = App(URIRef(options.show))
    if options.twistedlog:
        from twisted.python import log as twlog
        twlog.startLogging(sys.stderr)
    reactor.run()