melosh/mal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: skip error log on client disconnect in proxy handlers

Browse Source
This commit is contained in:
mkelvers
2026-06-13 22:38:51 +02:00
parent d2528ba4f1
commit c57ecf3d4b
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
internal/playback/handler/handler.go
View File

@@ -3,6 +3,7 @@ package handler
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"io" "io"
"mal/internal/domain" "mal/internal/domain"
@@ -302,8 +303,10 @@ func (h *PlaybackHandler) HandleProxyStream(c *gin.Context) {
resp, err := h.streamingClient.Do(req) resp, err := h.streamingClient.Do(req)
if err != nil { if err != nil {
observability.ErrorContext(c.Request.Context(), "proxy_stream_upstream_failed", "playback", "", map[string]any{"target_url": targetURL}, err) if !errors.Is(err, context.Canceled) {
_ = c.Error(err).SetType(gin.ErrorTypePrivate) observability.ErrorContext(c.Request.Context(), "proxy_stream_upstream_failed", "playback", "", map[string]any{"target_url": targetURL}, err)
_ = c.Error(err).SetType(gin.ErrorTypePrivate)
}
c.Status(http.StatusBadGateway) c.Status(http.StatusBadGateway)
return return
} }
@@ -490,8 +493,10 @@ func (h *PlaybackHandler) HandleProxySubtitle(c *gin.Context) {
resp, err := h.proxyClient.Do(req) resp, err := h.proxyClient.Do(req)
if err != nil { if err != nil {
observability.ErrorContext(c.Request.Context(), "proxy_subtitle_upstream_failed", "playback", "", map[string]any{"target_url": targetURL}, err) if !errors.Is(err, context.Canceled) {
_ = c.Error(err).SetType(gin.ErrorTypePrivate) observability.ErrorContext(c.Request.Context(), "proxy_subtitle_upstream_failed", "playback", "", map[string]any{"target_url": targetURL}, err)
_ = c.Error(err).SetType(gin.ErrorTypePrivate)
}
c.Status(http.StatusBadGateway) c.Status(http.StatusBadGateway)
return return
} }