#!/bin/zsh

pnpm exec vite -c light9/ascoltami/vite.config.ts &

wait

import time, json, logging

from twisted.internet import reactor

from twisted.internet.defer import inlineCallbacks

import treq

from light9 import networking

log = logging.getLogger()

class MusicTime(object):

    """

            position = yield response.json()

            # this is meant to be the time when the server gave me its

            # report, and I don't know if that's closer to the

            # beginning of my request or the end of it (or some

            # fraction of the way through)

            self.positionFetchTime = time.time()

            self.position = position

            self.onChange(position)

        def eb(err):

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

        d = treq.get(networking.musicPlayer.path("time").toPython())

        d.addCallback(cb)

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

    def sendTime(self, t):

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

        treq.post(

            networking.musicPlayer.path('time'),

            data=json.dumps({

                "t": time

            }).encode('utf8'),

import logging

import socket

import subprocess

import time

from typing import cast

import cyclone.web

import cyclone.websocket

from cycloneerr import PrettyErrorHandler

from light9.metrics import metricsRoute

from light9.namespaces import L9

from light9.showconfig import getSongsFromShow, showUri, songOnDisk

from twisted.internet import reactor

from twisted.internet.interfaces import IReactorTime

log = logging.getLogger()

_songUris = {}  # locationUri : song

def songLocation(graph, songUri):

    loc = URIRef("file://%s" % songOnDisk(songUri))

    _songUris[loc] = songUri

    return loc

            self.lastSentTime = now

        if self.transport.connected:

            cast(IReactorTime, reactor).callLater(.2, self.loop)

    def connectionLost(self, reason):

        log.info("bye ws client %r: %s", self, reason)

class songs(PrettyErrorHandler, cyclone.web.RequestHandler):

    def get(self):

        songs = getSongsFromShow(graph, self.settings.app.show)

        self.set_header("Content-Type", "application/json")

class songResource(PrettyErrorHandler, cyclone.web.RequestHandler):

    def post(self):

        """post a uri of song to switch to (and start playing)"""

        graph = self.settings.app.graph

        self.settings.app.player.setSong(songLocation(graph, URIRef(self.request.body.decode('utf8'))))

        self.set_header("Content-Type", "text/plain")

        self.write("ok")