add debug logs

Author: ad-astra-video

trickle/local_publisher.go

@@ -55,6 +55,7 @@ func (c *TrickleLocalPublisher) Write(data io.Reader) error {
 	totalRead := 0
 	for {
 		n, err := data.Read(buf)
+		slog.Info("Reading published data", "channel", c.channelName, "seq", seq, "bytes read", n, "err", err)
 		if n > 0 {
 			segment.writeData(buf[:n])
 			totalRead += n

trickle/trickle_publisher.go

@@ -7,6 +7,7 @@ import (
 	"io"
 	"log/slog"
 	"net/http"
+	"strings"
 	"sync"
 )
 
@@ -213,7 +214,9 @@ func (p *pendingPost) Write(data io.Reader) (int64, error) {
 
 	// Start streaming data to the current POST request
 	n, ioError := io.Copy(writer, data)
-
+	if strings.Contains(p.client.baseURL, "control") {
+		slog.Info("Streaming data to segment", "index", index, "bytes written", n, "ioError", ioError)
+	}
 	// if no io errors, close the writer
 	var closeErr error
 	if ioError == nil {

trickle/trickle_server.go

@@ -390,6 +390,10 @@ func (s *Stream) handlePost(w http.ResponseWriter, r *http.Request, idx int) {
 	totalRead := 0
 	for {
 		n, err := reader.Read(buf)
+		if strings.Contains(s.name, "control") {
+			slog.Info("Reading POST body", "stream", s.name, "idx", idx, "bytes read", n, "err", err)
+		}
+
 		if n > 0 {
 			if totalRead == 0 {
 				s.mutex.Lock()
@@ -546,6 +550,9 @@ func (s *Stream) handleGet(w http.ResponseWriter, r *http.Request, idx int) {
 			}
 
 			data, eof := subscriber.readData()
+			if strings.Contains(s.name, "control") {
+				slog.Info("Sending data to client", "stream", s.name, "idx", segment.idx, "dataLen", len(data), "eof", eof)
+			}
 			if len(data) > 0 {
 				if totalWrites <= 0 {
 					if segment.idx != latestSeq {