#!bin/python
import sys
sys.path.append('/usr/lib/python2.7/dist-packages') # For gtk
from twisted.internet import gtk3reactor
gtk3reactor.install()
from twisted.internet import reactor
from rdflib import URIRef
import optparse, logging, urllib, time
from gi.repository import Gtk
from run_local import log
from light9 import showconfig, networking
from light9.rdfdb import clientsession
from light9.rdfdb.syncedgraph import SyncedGraph
import cyclone.httpclient

class App(object):
    def __init__(self):
        parser = optparse.OptionParser()
        parser.set_usage("%prog [opts] [curve uri]")
        parser.add_option("--debug", action="store_true",
                          help="log at DEBUG")
        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 = SyncedGraph("inputdemo")

        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
        
        reactor.run()

    def launch(self):
        win = Gtk.Window()

        slider = Gtk.Scale.new_with_range(orientation=Gtk.Orientation.VERTICAL,
                                          min=0, max=1, step=.001)
        slider.props.inverted = True
        slider.connect('value-changed', self.onChanged)

        win.add(slider)
        win.parse_geometry('50x250')
        win.connect("delete-event", lambda *a: reactor.crash())
        win.connect("destroy", lambda *a: reactor.crash())
        win.show_all()

    def onChanged(self, scale):
        f = cyclone.httpclient.fetch(
            networking.curveCalc.path('liveInputPoint'),
            method='POST', timeout=1,
            postdata=urllib.urlencode({
                'curve': self.curve,
                'value': str(scale.get_value()),
            }))
        @f.addCallback
        def cb(result):
            if result.code // 100 != 2:
                log.error("curveCalc said %s: %s", result.code, result.body)
            print "posted in %.1f ms" % (1000 * (time.time() - t1))
        @f.addErrback
        def eb(err):
            print "err", err

App()