feat: professional AutoDJ upgrades, AJAX UI, and TCP-level security

Author: Datanoise

config/config.go

@@ -59,6 +59,7 @@ type AutoDJConfig struct {
 	MPDEnabled     bool     `json:"mpd_enabled"`
 	MPDPort        string   `json:"mpd_port"`
 	MPDPassword    string   `json:"mpd_password"`
+	Visible        bool     `json:"visible"`
 }
 
 type Config struct {

relay/client.go

@@ -1,6 +1,7 @@
 package relay
 
 import (
+	"bytes"
 	"context"
 	"fmt"
 	"io"
@@ -184,15 +185,46 @@ func (rm *RelayManager) performPull(ctx context.Context, inst *RelayInstance) {
 }
 
 func (rm *RelayManager) pullSimple(ctx context.Context, body io.Reader, stream *Stream) {
-	buf := make([]byte, 8192)
+	buf := make([]byte, 16384)
 	for {
 		select {
 		case <-ctx.Done():
 			return
 		default:
 			n, err := body.Read(buf)
 			if n > 0 {
-				stream.Broadcast(buf[:n], rm.relay)
+				data := buf[:n]
+				stream.Broadcast(data, rm.relay)
+
+				// Sniff for Opus metadata (Vorbis comments) in Ogg pages
+				// Look for "OpusTags" magic
+				if idx := bytes.Index(data, []byte("OpusTags")); idx != -1 {
+					// Found tags! Extract title if possible
+					// Skip "OpusTags" (8 bytes)
+					tagsData := data[idx+8:]
+					if len(tagsData) > 8 {
+						// Simple sniffer for "TITLE="
+						tagsStr := string(tagsData)
+						if strings.Contains(tagsStr, "TITLE=") {
+							title := strings.Split(tagsStr, "TITLE=")[1]
+							// Titles in Ogg are often null-terminated or limited by length
+							// For simplicity, we just take a reasonable chunk and trim
+							if len(title) > 100 {
+								title = title[:100]
+							}
+							// Clean up
+							title = strings.Map(func(r rune) rune {
+								if r < 32 || r > 126 {
+									return -1
+								}
+								return r
+							}, title)
+							if title != "" {
+								stream.SetCurrentSong(title, rm.relay)
+							}
+						}
+					}
+				}
 			}
 			if err != nil {
 				return

relay/relay.go

@@ -121,16 +121,15 @@ type Stream struct {
 	BytesDropped int64 // Track total bytes dropped due to slow listeners
 	CurrentSong  string
 	Public       bool
-		Visible        bool
-		IsTranscoded   bool // True if this stream is an output of a transcoder
-		IsOggStream    bool // Pre-calculated for speed
-	
-		LastDataReceived time.Time
-	
-
-	OggHead         []byte // Store Ogg headers for Opus/Ogg streams
-	OggHeaderOffset int64  // Absolute buffer offset where headers end
-	LastPageOffset  int64  // Absolute offset of the last valid Ogg page start
+	Visible      bool
+	IsTranscoded bool // True if this stream is an output of a transcoder
+	IsOggStream  bool // Pre-calculated for speed
+
+	LastDataReceived time.Time
+
+	OggHead         []byte  // Store Ogg headers for Opus/Ogg streams
+	OggHeaderOffset int64   // Absolute buffer offset where headers end
+	LastPageOffset  int64   // Absolute offset of the last valid Ogg page start
 	PageOffsets     []int64 // Circular list of last ~100 page starts
 	PageIndex       int
 
@@ -152,7 +151,7 @@ func (r *StreamReader) Read(p []byte) (int, error) {
 	for {
 		n, next, skipped := r.Stream.Buffer.ReadAt(r.Offset, p)
 		if skipped && r.Stream.IsOggStream {
-			// If we were skipped forward because the buffer wrapped around, 
+			// If we were skipped forward because the buffer wrapped around,
 			// we MUST re-align to the next Ogg page start.
 			r.Offset = r.Stream.Buffer.FindNextPageBoundary(next)
 			continue // Retry read at aligned offset
@@ -248,9 +247,8 @@ func (r *Relay) GetStream(mount string) (*Stream, bool) {
 }
 
 func (r *Relay) UpdateMetadata(mount, song string) {
-	if st, ok := r.GetStream(mount); ok {
-		st.SetCurrentSong(song, r)
-	}
+	st := r.GetOrCreateStream(mount)
+	st.SetCurrentSong(song, r)
 }
 
 // IsOgg returns true if the stream is Ogg-based (Ogg/Vorbis, Ogg/Opus, etc)
@@ -346,15 +344,19 @@ func (s *Stream) Subscribe(id string, burstSize int) (int64, chan struct{}) {
 	// For Ogg/Opus, align to the oldest known page boundary within the valid buffer range
 	if s.IsOggStream {
 		validStart := s.Buffer.Head - s.Buffer.Size
-		if validStart < 0 { validStart = 0 }
-		
-		// If we have an OggHead persistent storage, we want to start reading 
+		if validStart < 0 {
+			validStart = 0
+		}
+
+		// If we have an OggHead persistent storage, we want to start reading
 		// from the Buffer AFTER the initial headers to avoid duplicates.
 		if s.OggHeaderOffset > start {
 			start = s.OggHeaderOffset
 		}
 
-		if start < validStart { start = validStart }
+		if start < validStart {
+			start = validStart
+		}
 
 		bestAlign := s.LastPageOffset
 		found := false
@@ -373,7 +375,7 @@ func (s *Stream) Subscribe(id string, burstSize int) (int64, chan struct{}) {
 			start = s.Buffer.Head // Fallback to now if nothing valid found
 		}
 	}
-	
+
 	// Ensure we don't go back further than the buffer allows
 	if s.Buffer.Head-start > s.Buffer.Size {
 		start = s.Buffer.Head - s.Buffer.Size
@@ -498,7 +500,7 @@ func (s *Stream) Snapshot() StreamStats {
 
 	bi := atomic.LoadInt64(&s.BytesIn)
 	bd := atomic.LoadInt64(&s.BytesDropped)
-	
+
 	// Health calculation
 	// 1. Loss-based health
 	health := 100.0
@@ -548,7 +550,6 @@ func (s *Stream) Snapshot() StreamStats {
 	}
 }
 
-
 // uptimeLocked returns the formatted uptime string assuming the lock is already held
 func (s *Stream) uptimeLocked() string {
 	d := time.Since(s.Started).Round(time.Second)