'''

copies from effectloop.py, which this should replace

'''

import asyncio

import logging

import time

import traceback

from typing import Callable, Coroutine, Dict, List, cast

from louie import All, dispatcher

from rdfdb.syncedgraph.syncedgraph import SyncedGraph

from rdflib import URIRef

from twisted.internet import reactor

from twisted.internet.inotify import INotify

from twisted.python.filepath import FilePath

from light9.ascoltami.musictime_client import MusicTime

from light9.effect import effecteval

from light9.effect.sequencer import Note

from light9.effect.settings import DeviceSettings

from light9.effect.simple_outputs import SimpleOutputs

from light9.metrics import metrics

from light9.namespaces import L9, RDF

from light9.newtypes import NoteUri, Song

log = logging.getLogger('sequencer')

class StateUpdate(All):

    pass

class CodeWatcher:

    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")

            self.onChange()

        # in case we got an event at the start of the write

        reactor.callLater(.1, go) # type: ignore

class Sequencer:

    """Notes from the graph + current song playback -> sendToCollector"""

    def __init__(self,

                 graph: SyncedGraph,

                 sendToCollector: Callable[[DeviceSettings], Coroutine[None ,None,None]],

                 fps=40,

                 ):

        self.graph = graph

        self.fps = fps

        metrics('update_loop_goal_fps').set(self.fps)

        metrics('update_loop_goal_latency').set(1 / self.fps)

        self.sendToCollector = sendToCollector

        self.music = MusicTime(period=.2)

        self.recentUpdateTimes: List[float] = []

        self.lastStatLog = 0.0

        self._compileGraphCall = None

        self.notes: Dict[Song, List[Note]] = {}  # song: [notes]