light9 Changeset - 6906cacaa218

Changeset - 6906cacaa218

Parent rev.

Child rev.

[Not reviewed]

default

0 4 0

drewp@bigasterisk.com - 9 years ago 2016-06-12 00:24:57
drewp@bigasterisk.com

KC and SEQ share inotify code to reload effect code
Ignore-this: 2ae8142fda67b2290f4d0af219781c69

3 files changed with 29 insertions and 19 deletions:

bin/keyboardcomposer

light9/collector/device.py

light9/effect/sequencer.py

0 comments (0 inline, 0 general)

bin/keyboardcomposer

➞

Show inline comments

@@ @@ -19,6 +19,7 @@ from light9.namespaces import L9, RDF @@
 from light9.tkdnd import initTkdnd, dragSourceRegister, dropTargetRegister
 from light9.rdfdb import clientsession
 from light9.rdfdb.syncedgraph import SyncedGraph
 from light9.effect.sequencer import CodeWatcher
 import light9.effect.effecteval
 from bcf2000 import BCF2000
@@ @@ -163,7 +164,11 @@ class KeyboardComposer(tk.Frame, SubClie @@
         self.make_buttons()
         self.graph.addHandler(self.redraw_sliders)
         self.send_levels_loop()
         self.codeWatcher = CodeWatcher(
             onChange=lambda: self.graph.addHandler(self.redraw_sliders))
         self.send_levels_loop(delay=.05)
         self.graph.addHandler(self.rowFromGraph)
     def make_buttons(self):

light9/collector/device.py

➞

Show inline comments

@@ @@ -51,6 +51,7 @@ def resolve(deviceType, deviceAttr, valu @@
         rgbs = [hex_to_rgb(v) for v in values]
         return rgb_to_hex([max(*component) for component in zip(*rgbs)])
     # angles should perhaps use average; gobo choice use the most-open one
     return max(values)
 def toOutputAttrs(deviceType, deviceAttrSettings):

light9/effect/sequencer.py

➞

Show inline comments

@@ @@ -76,6 +76,26 @@ class Note(object): @@
         return self.effectEval.outputFromEffect(effectSettings, t)
 class CodeWatcher(object):
     def __init__(self, onChange):
         self.onChange = onChange
         self.notifier = INotify()
         self.notifier.startReading()
         self.notifier.watch(
             FilePath(effecteval.__file__.replace('.pyc', '.py')),
             callbacks=[self.codeChange])
     def codeChange(self, watch, path, mask):
         def go():
             log.info("reload effecteval")
             reload(effecteval)
             self.onChange()
         # in case we got an event at the start of the write
         reactor.callLater(.1, go)
 class Sequencer(object):
     def __init__(self, graph, sendToCollector):
         self.graph = graph
@@ @@ -88,29 +108,13 @@ class Sequencer(object): @@
         self.graph.addHandler(self.compileGraph)
         self.update()
         self.watchCode()
     def watchCode(self):
         self.notifier = INotify()
         self.notifier.startReading()
         self.notifier.watch(
             FilePath(effecteval.__file__.replace('.pyc', '.py')),
             callbacks=[self.codeChange])
     def codeChange(self, watch, path, mask):
         def go():
             reload(effecteval)
             self.graph.addHandler(self.compileGraph)
         # in case we got an event at the start of the write
         reactor.callLater(.1, go)
         self.codeWatcher = CodeWatcher(
             onChange=lambda: self.graph.addHandler(self.compileGraph))
     def compileGraph(self):
         """rebuild our data from the graph"""
         g = self.graph
         log.info("compileGraph")
         reload(effecteval)
         for song in g.subjects(RDF.type, L9['Song']):
             self.notes[song] = []
             for note in g.objects(song, L9['note']):

0 comments (0 inline, 0 general)