import signal
import sys
from datetime import datetime, timedelta
from queue import Queue
from threading import Lock

from libretime_shared.logging import TRACE, setup_logger
from loguru import logger

from .player.liquidsoap_gateway import TelnetLiquidsoap
from .player.queue import PypoLiqQueue


def keyboardInterruptHandler(signum, frame):
    logger.info("\nKeyboard Interrupt\n")
    sys.exit(0)


signal.signal(signal.SIGINT, keyboardInterruptHandler)

# configure logging
setup_logger(TRACE)

telnet_lock = Lock()
pypoPush_q = Queue()


pypoLiq_q = Queue()
liq_queue_tracker = {
    "s0": None,
    "s1": None,
    "s2": None,
    "s3": None,
}

# dummy_telnet_liquidsoap = DummyTelnetLiquidsoap(telnet_lock)
dummy_telnet_liquidsoap = TelnetLiquidsoap(
    telnet_lock,
    "localhost",
    1234,
    liq_queue_tracker,
)

plq = PypoLiqQueue(pypoLiq_q, dummy_telnet_liquidsoap)
plq.daemon = True
plq.start()


print(f"Time now: {datetime.utcnow():s}")

media_schedule = {}

start_dt = datetime.utcnow() + timedelta(seconds=1)
end_dt = datetime.utcnow() + timedelta(seconds=6)

media_schedule[start_dt] = {
    "id": 5,
    "type": "file",
    "row_id": 9,
    "uri": "",
    "dst": "/home/martin/Music/ipod/Hot Chocolate - You Sexy Thing.mp3",
    "fade_in": 0,
    "fade_out": 0,
    "cue_in": 0,
    "cue_out": 300,
    "start": start_dt,
    "end": end_dt,
    "show_name": "Untitled",
    "replay_gain": 0,
}


start_dt = datetime.utcnow() + timedelta(seconds=2)
end_dt = datetime.utcnow() + timedelta(seconds=6)

media_schedule[start_dt] = {
    "id": 5,
    "type": "file",
    "row_id": 9,
    "uri": "",
    "dst": "/home/martin/Music/ipod/Good Charlotte - bloody valentine.mp3",
    "fade_in": 0,
    "fade_out": 0,
    "cue_in": 0,
    "cue_out": 300,
    "start": start_dt,
    "end": end_dt,
    "show_name": "Untitled",
    "replay_gain": 0,
}
pypoLiq_q.put(media_schedule)

plq.join()