import os, sys

sys.path.append(".")

from twisted.internet import reactor

import cyclone.web, cyclone.httpclient, logging

from rdflib import Namespace, Literal, URIRef

from light9.rdfdb.patch import Patch

from light9.rdfdb.syncedgraph import SyncedGraph

if __name__ == "__main__":

    logging.basicConfig(level=logging.DEBUG)

    log = logging.getLogger()

    from light9.Submaster import PersistentSubmaster

    sub = PersistentSubmaster(graph=g, uri=URIRef("http://light9.bigasterisk.com/sub/bcools"))

    #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

    log.debug("startup: music %s", time.time() - startTime)

    session = clientsession.getUri('curvecalc', opts)

    music = Music()

    graph.initiallySynced.addCallback(

        lambda _: launch(args, graph, session, opts, startTime, music))

    from light9 import prof

    prof.run(reactor.run, profile=opts.profile)

        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):

        self.show = show

        self.graph.initiallySynced.addCallback(self.launch)

        self.stats = scales.collection('/',

                                       scales.PmfStat('sendLevels'),

                                       scales.PmfStat('getMusic'),

                                       scales.PmfStat('writeDmx'),

#!bin/python

import run_local

import gtk

import sys

sys.path.append(".")

from rdflib import URIRef

from light9.editchoicegtk import EditChoice, Local

from light9.observable import Observable

from light9.rdfdb.syncedgraph import SyncedGraph

win = gtk.Window()

r1 = URIRef("http://example.com/interestingThing")

v = Observable(r1)

win.add(EditChoice(graph, v))

win.show_all()

gtk.main()

        clientsession.add_option(parser)

        opts, args = parser.parse_args()

        log.setLevel(logging.DEBUG if opts.debug else logging.INFO)

        self.session = clientsession.getUri('inputdemo', opts)

        self.graph.initiallySynced.addCallback(lambda _: self.launch())

        self.curve = args[0] if args else URIRef('http://light9.bigasterisk.com/show/dance2014/song1/curve/c-1401259747.675542')

        print "sending points on curve %s" % self.curve

    clientsession.add_option(parser)

    parser.add_option('-v', action='store_true', help="log info level")

    opts, args = parser.parse_args()

    log.setLevel(logging.INFO if opts.v else logging.WARN)

    # i think this also needs delayed start (like subcomposer has), to have a valid graph

    # before setting any stuff from the ui

    root = Tk()

    initTkdnd(root.tk, 'tkdnd/trunk/')

compdef _songs curvecalc

"""

from run_local import log

from twisted.internet import reactor

from rdflib import RDF

from light9.namespaces import L9

from light9.rdfdb.syncedgraph import SyncedGraph

@graph.initiallySynced.addCallback

def printSongs(result):

    with graph.currentState() as current:

        for song in current.subjects(RDF.type, L9['Song']):

            print song

    root=tk.Tk()

    root.config(bg='black')

    root.tk_setPalette("#004633")

    initTkdnd(root.tk, 'tkdnd/trunk/')

    session = clientsession.getUri('subcomposer', opts)

    graph.initiallySynced.addCallback(lambda _: launch(opts, args, root, graph, session))

    root.protocol('WM_DELETE_WINDOW', reactor.stop)

    tksupport.install(root,ms=10)

    parser.add_option("-v", "--verbose", action="store_true",

                      help="logging.DEBUG")

    (options, args) = parser.parse_args()

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

    d = {}

    def updateSubs():

        subs = []

        for sub in sorted(graph.subjects(RDF.type, L9['Submaster'])):

            rec = {'uri' : sub}

            traceback.print_exc()

            raise

class SnapshotPic(cyclone.web.StaticFileHandler):

    pass

gui = Gui(graph)

port = networking.vidref.port

reactor.listenTCP(port, cyclone.web.Application(handlers=[

    (r'/()', cyclone.web.StaticFileHandler,

    parser = optparse.OptionParser()

    parser.add_option("-v", "--verbose", action="store_true",

                      help="logging.DEBUG")

    (options, args) = parser.parse_args()

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

    # deliberately conflict with vidref since they can't talk at once to cam

    port = networking.vidref.port 

    reactor.listenTCP(port, cyclone.web.Application(handlers=[

        (r'/pic', RedirToCamera),

musicPlayer = ServiceAddress(L9['musicPlayer'])

keyboardComposer = ServiceAddress(L9['keyboardComposer'])

curveCalc = ServiceAddress(L9['curveCalc'])

vidref = ServiceAddress(L9['vidref'])

effectEval = ServiceAddress(L9['effectEval'])

picamserve = ServiceAddress(L9['picamserve'])

    statements unless we have the correct graph.

    If we get out of sync, we abandon our local graph (even any

    pending local changes) and get the data again from the

    server.

    """

        """

        label is a string that the server will display in association

        with your connection

        """

        self.initiallySynced = defer.Deferred()

        self._graph = ConjunctiveGraph()

        self._receiver = PatchReceiver(label, self._onPatch)

                                   self._receiver.updateResource)

        AutoDepGraphApi.__init__(self)

        # this needs more state to track if we're doing a resync (and

        # everything has to error or wait) or if we're live

    def resync(self):

        should just fail them. There should be a notification back to

        UIs who want to show that we're doing a resync.

        """

        self._sender.cancelAll()

        # this should be locked so only one resync goes on at once

        return cyclone.httpclient.fetch(

            method="GET",

            headers={'Accept':['x-trig']},

            ).addCallback(self._resyncGraph)

    def _resyncGraph(self, response):

        log.warn("new graph in")

@prefix : <http://light9.bigasterisk.com/> .

@prefix show: <http://light9.bigasterisk.com/show/> .

@prefix sh: <http://light9.bigasterisk.com/show/dance2014/> .

show:dance2014 :networking sh:netHome .

  :effectEval       <http://dash:8070/>;

  :musicPlayer      <http://dash:8040/>;

  :dmxServer        <http://dash:8030/>;

  :oscDmxServer     <udp://dash:9050/>;

  :curveCalc        <http://dash:8060/>;

  :keyboardComposer <http://dash:8050/>;