light9 Changeset - 81b48e21ba46

Changeset - 81b48e21ba46

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

drewp@bigasterisk.com - 20 months ago 2023-06-01 21:47:35
drewp@bigasterisk.com

multi device supt

1 file changed with 41 insertions and 22 deletions:

light9/midifade/midifade.py

0 comments (0 inline, 0 general)

light9/midifade/midifade.py

➞

Show inline comments

@@ @@ -5,6 +5,7 @@ Read midi events, write fade levels to g @@
 import asyncio
 import logging
 import traceback
 from typing import Dict
 import mido
 from rdfdb.syncedgraph.syncedgraph import SyncedGraph
@@ @@ -28,24 +29,35 @@ def setFader(graph: SyncedGraph, ctx, fa @@
     graph.patchObject(ctx, fadeSet, L9['value'], valueLit)
 def onMessage(graph: SyncedGraph, ctx: URIRef, m: mido.Message):
     md = m.dict()
     if md['type'] == 'active_sensing':
 def onMessage(graph: SyncedGraph, ctx: URIRef, m: Dict):
     if m['type'] == 'active_sensing':
         return
     if m.is_cc():
         if md['control'] == 81: setFader(graph, ctx, L9['show/dance2023/fadePage1f0'], md['value'] / 127)
         if md['control'] == 82: setFader(graph, ctx, L9['show/dance2023/fadePage1f1'], md['value'] / 127)
         if md['control'] == 83: setFader(graph, ctx, L9['show/dance2023/fadePage1f2'], md['value'] / 127)
         if md['control'] == 84: setFader(graph, ctx, L9['show/dance2023/fadePage1f3'], md['value'] / 127)
         if md['control'] == 85: setFader(graph, ctx, L9['show/dance2023/fadePage1f4'], md['value'] / 127)
         if md['control'] == 86: setFader(graph, ctx, L9['show/dance2023/fadePage1f5'], md['value'] / 127)
         if md['control'] == 87: setFader(graph, ctx, L9['show/dance2023/fadePage1f6'], md['value'] / 127)
         if md['control'] == 88: setFader(graph, ctx, L9['show/dance2023/fadePage1f7'], md['value'] / 127)
         else:
             log.info(f'unhandled cc message {md}')
     if m['type'] == 'control_change':
         try:
             fader = {
                 'quneo': {
 : L9['show/dance2023/fadePage1f0'],
 : L9['show/dance2023/fadePage1f0'],
 : L9['show/dance2023/fadePage1f0'],
                 },
                 'bcf2000': {
 : L9['show/dance2023/fadePage1f0'],
 : L9['show/dance2023/fadePage1f1'],
 : L9['show/dance2023/fadePage1f2'],
 : L9['show/dance2023/fadePage1f3'],
 : L9['show/dance2023/fadePage1f4'],
 : L9['show/dance2023/fadePage1f5'],
 : L9['show/dance2023/fadePage1f6'],
 : L9['show/dance2023/fadePage1f7'],
+                }
             }[m['dev']][m['control']]
         except KeyError:
             log.info(f'unknown control {m}')
             return
         setFader(graph, ctx, fader, m['value'] / 127)
     else:
-        log.info(f'unhandled message {md}')
+        log.info(f'unhandled message {m}')
 async def main():
@@ @@ -59,8 +71,8 @@ async def main(): @@
     msgs = asyncio.Queue()
     loop = asyncio.get_event_loop()
     def onMessageMidoThread(message):
         loop.call_soon_threadsafe(msgs.put_nowait, message)
     def onMessageMidoThread(dev, message):
         loop.call_soon_threadsafe(msgs.put_nowait, message.dict() | {'dev': dev})
     async def reader():
         while True:
@@ @@ -75,11 +87,18 @@ async def main(): @@
             await asyncio.sleep(1 / MAX_SEND_RATE)
     asyncio.create_task(reader())
     log.info(f'{mido.get_input_names()}')
     port = mido.open_input(
         #'Keystation:Keystation MIDI 1 20:0',
         'BCF2000:BCF2000 MIDI 1 20:0',
          callback=onMessageMidoThread)
     for inputName in mido.get_input_names():
         if inputName.startswith('Keystation'):
             dev = "keystation"
         elif inputName.startswith('BCF2000'):
             dev = 'bcf2000'
         elif inputName.startswith('QUNEO'):
             dev = 'quneo'
         else:
             continue
         log.info(f'listening on input {inputName} {dev=}')
         port = mido.open_input(inputName, callback=lambda message: onMessageMidoThread(dev, message))
     while True:
         await asyncio.sleep(1)

0 comments (0 inline, 0 general)