live stream metadata

Author: script-php

main.go

@@ -25,6 +25,12 @@ func icecastNormalizerFeeder() {
 		// Transition: Source connected, start Icecast mode
 		if hasSource && !isIcecastProcessing {
 			modules.Logger.Info("Icecast source connected - switching to Icecast mode")
+			
+			// Close current file and advance to next song before switching modes
+			// This ensures: 1) current file is released (no lock for cleanup), 2) next song is ready when Icecast disconnects
+			modules.MusicReader.SkipToNext()
+			modules.Logger.Info("Advancing to next song in preparation for Icecast mode")
+			
 			modules.MusicReader.EnableIcecastMode()
 
 			// Create a channel to signal when processor is done

routes/fm.go

@@ -126,9 +126,18 @@ func GetFMStream(ctx echo.Context) error {
 			// Check if we haven't received data for too long
 			// Send heartbeat metadata to keep connection alive
 			if wantMetadata && time.Since(lastBufferUpdateTime) > maxNoDataTimeout {
-				musicInfo := modules.MusicReader.GetMusicInfo()
-				if musicInfo != nil && musicInfo.Filename != "" {
-					metadata := BuildIcecastMetadata(musicInfo.Filename, musicInfo.Url)
+				var metadata []byte
+				if modules.MusicReader.IsIcecastMode {
+					// Live streaming mode - send generic live metadata
+					metadata = BuildIcecastMetadata("Live Stream", modules.Config.URL)
+				} else {
+					// File mode - send current song metadata
+					musicInfo := modules.MusicReader.GetMusicInfo()
+					if musicInfo != nil && musicInfo.Filename != "" {
+						metadata = BuildIcecastMetadata(musicInfo.Filename, musicInfo.Url)
+					}
+				}
+				if len(metadata) > 0 {
 					_, err := res.Write(metadata)
 					if err != nil {
 						modules.Logger.Info(fmt.Sprintf("[%s] Client %s disconnected", requestID, ip))
@@ -193,9 +202,18 @@ func GetFMStream(ctx echo.Context) error {
 
 				// If we hit metadata boundary, inject metadata
 				if sinceMetaBlock >= metaintInterval && offset < bufLen {
-					musicInfo := modules.MusicReader.GetMusicInfo()
-					if musicInfo != nil && musicInfo.Filename != "" {
-						metadata := BuildIcecastMetadata(musicInfo.Filename, musicInfo.Url)
+					var metadata []byte
+					if modules.MusicReader.IsIcecastMode {
+						// Live streaming mode - send generic live metadata
+						metadata = BuildIcecastMetadata("Live Stream", modules.Config.URL)
+					} else {
+						// File mode - send current song metadata
+						musicInfo := modules.MusicReader.GetMusicInfo()
+						if musicInfo != nil && musicInfo.Filename != "" {
+							metadata = BuildIcecastMetadata(musicInfo.Filename, musicInfo.Url)
+						}
+					}
+					if len(metadata) > 0 {
 						_, err := res.Write(metadata)
 						if err != nil {
 							modules.Logger.Info(fmt.Sprintf("[%s] Client %s disconnected", requestID, ip))