self.pauseTrace = False

        self.scale = SubScale(self, variable=self.slider_var, width=20)

        self.namelabel = tk.Label(self,

                                  font="Arial 9",

                                  bg=darkBg,

                                  fg='white',

                                  pady=0)

        self.graph.addHandler(self.updateName)

        self.namelabel.pack(side=tk.TOP)

        self.levellabel = tk.Label(self,

        self.levellabel.pack(side=tk.TOP)

        self.scale.pack(side=tk.BOTTOM, expand=1, fill=tk.BOTH)

        for w in [self, self.namelabel, self.levellabel]:

            dragSourceRegister(w, 'copy', 'text/uri-list', sub)

        self._slider_var_trace = self.slider_var.trace('w', self.slider_changed)

        self.graph.addHandler(self.updateLevelFromGraph)

        # initial position

        # stil need? dispatcher.send("send_to_hw", sub=sub.uri, hwCol=col + 1)

    def getVal(self) -> float:

        return self._val

    def setVal(self, newVal: float) -> None:

        if self.scale is None:

            return

        try:

            self.scale.set(newVal)

            self.levellabel.config(text=str(newVal))

        except Exception:

            log.warn("disabling handlers on broken subbox")

            self.scale = None

    def cleanup(self):

        self.slider_var.trace_vdelete('w', self._slider_var_trace)

    def updateLevelFromGraph(self):

        """read rdf level, write it to subbox.slider_var"""

        # move this to syncedgraph readMapping

        graph = self.graph

        for setting in graph.objects(self.session, L9['subSetting']):

            if graph.value(setting, L9['sub']) == self.sub:

                self.pauseTrace = True  # don't bounce this update back to server

                try:

                    self.setVal(graph.value(setting, L9['level']).toPython())

                finally:

                    self.pauseTrace = False

    def updateName(self):

        if self.scale is None:

            return

        def shortUri(u):

            return '.../' + u.split('/')[-1]

        try:

            self.namelabel.config(

                text=self.graph.label(self.sub) or shortUri(self.sub))

        except Exception:

            log.warn("disabling handlers on broken subbox")

            self.scale = None

class KeyboardComposer(tk.Frame, SubClient):

                               predicate=L9['group'],

                               newObject=group)

    def highlight_row(self, row):

        row = self.rows[row]

        row['bg'] = 'red'

    def unhighlight_row(self, row):

        row = self.rows[row]

        row['bg'] = 'black'

    def get_levels(self):

    def get_output_settings(self, _graph=None):

        _graph = _graph or self.graph

        outputSettings = []

        for setting in _graph.objects(self.session, L9['subSetting']):

            effect = _graph.value(setting, L9['sub'])

            strength = _graph.value(setting, L9['level'])

            if strength:

                now = time.time()

                out, report = self.effectEval[effect].outputFromEffect(

                    [(L9['strength'], strength)],

                    songTime=now,

from tkinter import tix

from time import time

class Mass:

    def __init__(self):

        self.x = 0  # position

        self.xgoal = 0  # position goal

        self.v = 0  # velocity

        self.maxspeed = .8  # maximum speed, in position/second

        self.maxaccel = 3  # maximum acceleration, in position/second^2

        self.eps = .03  # epsilon - numbers within this much are considered the same

        self._lastupdate = time()

    def ident(self):

        return (self.name, tuple(sorted(self.levels.items())))

    def __repr__(self):

        items = sorted(list(getattr(self, 'levels', {}).items()))

        levels = ' '.join(["%s:%.2f" % item for item in items])

        return "<'%s': [%s]>" % (getattr(self, 'name', 'no name yet'), levels)

    def __cmp__(self, other):

        # not sure how useful this is

        if not isinstance(other, Submaster):

            return -1

    def __hash__(self):

        return hash(self.ident())

    def get_dmx_list(self):

        leveldict = self.get_levels()  # gets levels of sub contents

        levels = []

        for k, v in list(leveldict.items()):

            if v == 0:

                continue

            try:

        except xmlrpc.client.Fault as e:

            log.error("outputlevels had xml fault: %s" % e)

            time.sleep(1)

    else:

        _dmx.send(clientid, levellist)

        return defer.succeed(None)

dummy = os.getenv('DMXDUMMY')

if dummy:

    print("dmxclient: DMX is in dummy mode.")

        pass

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

            for effectUri in self.graph.objects(sub, L9['drivesEffect']):

                self.currentEffects.append(EffectNode(self.graph, effectUri))

        log.info('now we have %s effects', len(self.currentEffects))

    @inlineCallbacks

    def getSongTime(self):

        now = time.time()

        old = now - self.requestTime

        if old > self.coastSecs:

            try:

                response = yield r.json_content()

            except TimeoutError:

                log.warning("TimeoutError: using stale time from %.1f ago", old)

            else:

                self.requestTime = now

                self.currentPlaying = response['playing']

                self.songTimeFromRequest = response['t']

                returnValue((response['t'], (response['song'] and

                                             URIRef(response['song']))))

        estimated = self.songTimeFromRequest

        if self.currentSong is not None and self.currentPlaying:

from lib.ipython_view import IPythonView

from gi.repository import Gtk

from gi.repository import Pango

def togglePyConsole(self, item, user_ns):

    """

    toggles a toplevel window with an ipython console inside.

    self is an object we can stick the pythonWindow attribute on

    item is a checkedmenuitem

def songOnDisk(song: URIRef) -> bytes:

    """given a song URI, where's the on-disk file that mpd would read?"""

    graph = getGraph()

    root = graph.value(showUri(), L9['musicRoot'])

    if not root:

        raise ValueError("%s has no :musicRoot" % showUri())

    name = graph.value(song, L9['songFilename'])

    if not name:

        raise ValueError("Song %r has no :songFilename" % song)

def songFilenameFromURI(uri: URIRef) -> bytes:

    """

    'http://light9.bigasterisk.com/show/dance2007/song8' -> 'song8'

    everything that uses this should be deprecated for real URIs

    everywhere"""

    assert isinstance(uri, URIRef)

    return str(uri).split('/')[-1].encode('ascii')

from glob import glob

from os.path import join, basename

from typing import Dict, Any

class TkdndEvent(object):

    """

    see http://www.ellogon.org/petasis/tcltk-projects/tkdnd/tkdnd-man-page

    for details on the fields

    The longer attribute names (action instead of %A) were made up for

    this API.

    Not all attributes are visible yet, since I have not thought

    through what conversions they should receive and I don't want to

    unnecessarily change their types later.

    """

    if par != ".":

        ev.widget.nametowidget(par).event_generate(sequence, **evdict)

    #else the event made it all the way to the top, unhandled

def colorlabel(label):

    """color a label based on its own text"""

    txt = label['text'] or "0"

    lev = float(txt) / 100

    low = (80, 80, 180)

    high = (255, 55, 0o50)

    out = [int(l + lev * (h - l)) for h, l in zip(high, low)]

    label.config(bg=col)

# TODO: get everyone to use this

def colorfade(low, high, percent):

    '''not foolproof.  make sure 0 < percent < 1'''

    out = [int(l + percent * (h - l)) for h, l in zip(high, low)]

    return col

def colortotuple(anytkobj, colorname):

    'pass any tk object and a color name, like "yellow"'

    rgb = anytkobj.winfo_rgb(colorname)

    return [v / 256 for v in rgb]

class Togglebutton(Button):

    """works like a single radiobutton, but it's a button so the

    label's on the button face, not to the side. the optional command

        def eb(err):

            if self.lastHoverTime:

                log.warn("talking to curveCalc: %s", err.getErrorMessage())

            self.lastHoverTime = None

            reactor.callLater(2, self.pollCurvecalcTime)

        d = treq.get(networking.curveCalc.path("hoverTime"))

        d.addCallback(cb)

        d.addErrback(eb)  # note this includes errors in cb()

    def sendTime(self, t):

        """request that the player go to this time"""

        )

    sources = ' '.join(bin_sources + pkg_sources())

    ctx.run(f'env/bin/flake8 --ignore=E115,E123,E124,E126,E225,E231,E261,E262,E265,E301,E302,E303,E305,E306,E401,E402,E501,E701,E731,W291,W293,W391,W504 {sources}', warn=True)

    sources = ' '.join(pkg_sources())

    run(['bin/rdfdb'])

    run(['bin/keyboardcomposer'])

    #for src in bin_sources:

    #    print(f"mypy {src}")

    #    run([src])# + pkg_sources())

@task

def reformat(ctx):

@task

def test(ctx):

    ctx.run('docker build -f Dockerfile.build -t light9_build:latest .')

    ctx.run('docker run --rm -it -v `pwd`:/opt light9_build:latest'

            ' nose2 -v light9.currentstategraphapi_test light9.graphfile_test',

            pty=True)