import asyncio

import logging

import traceback

log = logging.getLogger()

@dataclass

class Event:

    dev: str

    type: str

    control: int

    value: int

    def __repr__(self):

        return f"<Event {self.dev}/{self.type}/{self.control}->{self.value}>"

class EventQueue:

    """midi events come in fast; graph consumes them slower"""

    def __init__(self, MAX_SEND_RATE: float, onMessage) -> None:

        self.MAX_SEND_RATE = MAX_SEND_RATE

        self.onMessage = onMessage

        self.newEvents: asyncio.Queue[Event] = asyncio.Queue()

"""

Read midi events, write fade levels to graph

Device troubleshooting:

    amidi -l

"""

import asyncio

from functools import partial

import mido

from light9 import networking

from light9.effect.edit import clamp

from light9.midifade.eventqueue import Event, EventQueue

from light9.midifade.mididevs import connectToMidiOutput, listenToMidiInputs

from light9.midifade.pages import Pages

from light9.namespaces import L9

from light9.newtypes import decimalLiteral

from light9.run_local import log

from light9.showconfig import showUri

from rdfdb.syncedgraph.syncedgraph import SyncedGraph

import asyncio

import logging

from dataclasses import dataclass

from typing import cast

import mido

from light9.midifade.pages import Pages

from light9.namespaces import L9

from rdfdb.syncedgraph.syncedgraph import SyncedGraph

from rdflib import Literal

log = logging.getLogger()

@dataclass

class WriteBackFaders:

    graph: SyncedGraph

    pages: Pages

    bcf_out: mido.ports.BaseOutput

    _lastSet: dict[int, int]

    def getCurrentValue(self, f):