add some logs

contrib/codecs/broker/server.go

@@ -2,6 +2,7 @@ package broker
 
 import (
 	"context"
+	"log/slog"
 
 	"gfx.cafe/open/jrpc/pkg/server"
 )
@@ -26,7 +27,10 @@ func (s *Server) ServeSpoke(ctx context.Context, stream ServerSpoke) {
 		}
 		cd := NewCodec(req, fn)
 		go func() {
-			s.Server.ServeCodec(ctx, cd)
+			err := s.Server.ServeCodec(ctx, cd)
+			if err != nil {
+				slog.Error("codec err", "err", err)
+			}
 			cd.Close()
 		}()
 	}

contrib/codecs/http/handler.go

 package http
 
 import (
+	"log/slog"
 	"net/http"
 	"sync"
 
@@ -29,7 +30,10 @@ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	c := codecPool.Get().(*Codec)
 	c.Reset(w, r)
 	w.Header().Set("content-type", contentType)
-	s.Server.ServeCodec(r.Context(), c)
+	err := s.Server.ServeCodec(r.Context(), c)
+	if err != nil {
+		slog.Error("codec err", "err", err)
+	}
 	go func() {
 		<-c.Closed()
 		codecPool.Put(c)

contrib/codecs/websocket/handler.go

 package websocket
 
 import (
+	"log/slog"
 	"net/http"
 
 	"gfx.cafe/open/websocket"
@@ -23,7 +24,10 @@ func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 	c := newWebsocketCodec(r.Context(), conn, "", r.Header)
-	s.Server.ServeCodec(r.Context(), c)
+	err = s.Server.ServeCodec(r.Context(), c)
+	if err != nil {
+		slog.Error("codec err", "error", err)
+	}
 }
 
 // WebsocketHandler returns a handler that serves JSON-RPC to WebSocket connections.
@@ -41,6 +45,9 @@ func WebsocketHandler(s *server.Server, allowedOrigins []string) http.Handler {
 			return
 		}
 		codec := newWebsocketCodec(r.Context(), conn, r.Host, r.Header)
-		s.ServeCodec(r.Context(), codec)
+		err = s.ServeCodec(r.Context(), codec)
+		if err != nil {
+			slog.Error("codec err", "error", err)
+		}
 	})
 }