refactor: update components to use new reusable I/O abstractions

- Update transcode.go to use new StreamReader from io.go
- Update webrtc.go to use new StreamReader from io.go
- Update server/handlers_stream.go to use FindNextPageBoundary from ogg.go
- Maintain all existing functionality with cleaner architecture

Author: Datanoise

relay/transcode.go

@@ -135,13 +135,7 @@ func (tm *TranscoderManager) performTranscode(ctx context.Context, inst *Transco
 	offset, signal := input.Subscribe(id, 32*1024)
 	defer input.Unsubscribe(id)
 
-	reader := &StreamReader{
-		Stream: input,
-		Offset: offset,
-		Signal: signal,
-		Ctx:    ctx,
-		ID:     id,
-	}
+	reader := NewStreamReader(input.Buffer, offset, signal, ctx, id).WithOggSync(input)
 
 	// 3. Decode
 	decoder, err := mp3.NewDecoder(reader)

relay/webrtc.go

@@ -248,17 +248,11 @@ func (wm *WebRTCManager) streamToTrack(pc *webrtc.PeerConnection, track *webrtc.
 	}
 
 	if !foundSync {
-		logrus.Errorf("WebRTC: Could not find Ogg sync in first 512KB for %s. Is it an Opus stream?", stream.MountName)
+		logrus.WithField("mount", stream.MountName).Error("WebRTC: Could not find Ogg sync in first 512KB. Is it an Opus stream?")
 		return
 	}
 
-	reader := &StreamReader{
-		Stream: stream,
-		Offset: offset,
-		Signal: signal,
-		Ctx:    ctx,
-		ID:     id,
-	}
+	reader := NewStreamReader(stream.Buffer, offset, signal, ctx, id).WithOggSync(stream)
 
 	// We wrap the reader to prepend the OggHead if available.
 	// This ensures NewOpusReader always sees the ID/Tag headers.

server/handlers_stream.go

@@ -327,7 +327,7 @@ func (s *Server) serveStreamData(w http.ResponseWriter, r *http.Request, stream
 
 				n, next, skipped := stream.Buffer.ReadAt(offset, buf[:readLimit])
 				if skipped && stream.IsOggStream {
-					offset = stream.Buffer.FindNextPageBoundary(next)
+					offset = relay.FindNextPageBoundary(stream.Buffer.Data, stream.Buffer.Size, stream.Buffer.Head, next)
 					continue
 				}
 				if n == 0 {