1
0
dwelling-radio/internal/http/dj_handlers.go

96 lines
2.3 KiB
Go

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.Listeners
playlist *radio.Playlist
}
func NewDJHandlers(l *radio.Listeners, 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) {
isList := r.URL.Query().Has("list")
w.Header().Add("Content-Type", "application/json")
if isList {
err := json.NewEncoder(w).Encode(songList.List())
if err != nil {
log.Println("DJHandlers.Song list:", err)
}
} else {
err := json.NewEncoder(w).Encode(songList.Current())
if err != nil {
log.Println("DJHandlers.Song current:", err)
}
}
}