package http

import (
	"dwelling-radio/internal/radio"
	"dwelling-radio/pkg/oggtag"
	"encoding/json"
	"fmt"
	"log"
	"net/http"
	"os"
	"time"
)

var songList radio.SongList

type DJHandlers struct {
	listeners *radio.ListenerCounter
	playlist  *radio.Playlist
}

func NewDJHandlers(l *radio.ListenerCounter, p *radio.Playlist, slLen int) *DJHandlers {
	songList = *radio.NewSongList(slLen)
	return &DJHandlers{listeners: l, playlist: p}
}

func (dj *DJHandlers) ListenersGet(w http.ResponseWriter, _ *http.Request) {
	w.Header().Add("Content-Type", "text/plain")
	fmt.Fprint(w, dj.listeners.Current(), dj.listeners.Peak())
}

func (dj *DJHandlers) ListenersInc(w http.ResponseWriter, _ *http.Request) {
	l := dj.listeners.Inc()
	go func() {
		if l > songList.Current().MaxListeners {
			songList.Current().MaxListeners = l
		}
	}()
	w.WriteHeader(http.StatusCreated)
	w.Header().Add("Content-Type", "text/plain")
	fmt.Fprint(w, l)
}

func (dj *DJHandlers) ListenersDec(w http.ResponseWriter, _ *http.Request) {
	l, err := dj.listeners.Dec()
	if err != nil {
		log.Print(err)
		http.Error(w, err.Error(), http.StatusBadRequest)
	}
	w.WriteHeader(http.StatusOK)
	w.Header().Add("Content-Type", "text/plain")
	fmt.Fprint(w, l)
}

func (dj *DJHandlers) PlaylistNext(w http.ResponseWriter, _ *http.Request) {
	w.Header().Add("Content-Type", "text/plain")
	nxt := dj.playlist.Next()
	if nxt == "" {
		log.Println("the end of a playlist has been reached")
	} else {
		go func() {
			f, err := os.Open(nxt)
			if err != nil {
				log.Println("cannot open file \"", nxt, "\" to read tags")
			}

			buf := make([]byte, 4096)
			f.Read(buf)

			song := radio.Song_{
				Artist:       oggtag.OggGetTag(buf, "artist"),
				Title:        oggtag.OggGetTag(buf, "title"),
				MaxListeners: dj.listeners.Current(),
				StartAt:      time.Now()}
			// radio.CheckAndUpdateMostListenedSong(song, currentSong)
			songList.Add(song)
		}()
	}
	fmt.Fprint(w, nxt)
}

func (dj *DJHandlers) Song(w http.ResponseWriter, r *http.Request) {
	w.Header().Add("Content-Type", "application/json")
	err := json.NewEncoder(w).Encode(songList.Current())
	if err != nil {
		log.Println("DJHandlers.Song:", err)
		http.Error(w, "cannot obtain current song", http.StatusInternalServerError)
	}
}

func (dj *DJHandlers) Songs(w http.ResponseWriter, r *http.Request) {
	w.Header().Add("Content-Type", "application/json")
	err := json.NewEncoder(w).Encode(songList.List())
	if err != nil {
		log.Println("DJHandlers.Songs:", err)
		http.Error(w, "cannot obtain list of last songs", http.StatusInternalServerError)
	}
}

		if err != nil {
			log.Println("DJHandlers.Song current:", err)
		}
	}
}