Iris/mopidy_iris/frontend.py

import pykka
import logging
import functools
from mopidy.core import CoreListener
from .mem import iris

# import logger
logger = logging.getLogger(__name__)


class IrisFrontend(pykka.ThreadingActor, CoreListener):
    def __init__(self, config, core):
        super().__init__()

        # Pass our Mopidy config and core to the IrisCore instance
        iris.config = config
        iris.core = core

    def on_start(self):
        iris.start()

    def on_stop(self):
        iris.stop()

    def track_playback_ended(self, tl_track, time_position):
        if (
            iris.ioloop
            and "spotify" in iris.config
            and iris.config["spotify"]["enabled"]
        ):
            iris.ioloop.add_callback(
                functools.partial(iris.check_for_radio_update)
            )

    def tracklist_changed(self):
        if iris.ioloop:
            iris.ioloop.add_callback(
                functools.partial(iris.clean_queue_metadata)
            )