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

refactor: update playback handler imports for flattened pkg/net

Browse Source
This commit is contained in:
mkelvers
2026-05-28 12:36:31 +02:00
parent 866d293419
commit 9695d7772d
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -5,9 +5,7 @@ import (
"io" "io"
"mal/internal/domain" "mal/internal/domain"
"mal/internal/server" "mal/internal/server"
"mal/pkg/net/limits" netutil "mal/pkg/net"
"mal/pkg/net/proxytransport"
"mal/pkg/net/useragent"
"net/http" "net/http"
"strconv" "strconv"
"strings" "strings"
@@ -29,8 +27,8 @@ func NewPlaybackHandler(svc domain.PlaybackService, animeSvc domain.AnimePlaybac
return &PlaybackHandler{ return &PlaybackHandler{
svc: svc, svc: svc,
animeSvc: animeSvc, animeSvc: animeSvc,
proxyClient: proxytransport.NewClient(), proxyClient: netutil.NewClient(),
streamingClient: proxytransport.NewStreamingClient(), streamingClient: netutil.NewStreamingClient(),
subtitleCache: newSubtitleCache(10*time.Minute, 256), subtitleCache: newSubtitleCache(10*time.Minute, 256),
} }
} }
@@ -330,7 +328,7 @@ func (h *PlaybackHandler) HandleProxyStream(c *gin.Context) {
if ifRangeHeader := c.GetHeader("If-Range"); ifRangeHeader != "" { if ifRangeHeader := c.GetHeader("If-Range"); ifRangeHeader != "" {
req.Header.Set("If-Range", ifRangeHeader) req.Header.Set("If-Range", ifRangeHeader)
} }
req.Header.Set("User-Agent", useragent.Firefox121) req.Header.Set("User-Agent", netutil.Firefox121)
resp, err := h.streamingClient.Do(req) resp, err := h.streamingClient.Do(req)
if err != nil { if err != nil {
@@ -385,7 +383,7 @@ func (h *PlaybackHandler) HandleProxySubtitle(c *gin.Context) {
if referer != "" { if referer != "" {
req.Header.Set("Referer", referer) req.Header.Set("Referer", referer)
} }
req.Header.Set("User-Agent", useragent.Firefox121) req.Header.Set("User-Agent", netutil.Firefox121)
resp, err := h.proxyClient.Do(req) resp, err := h.proxyClient.Do(req)
if err != nil { if err != nil {
@@ -394,7 +392,7 @@ func (h *PlaybackHandler) HandleProxySubtitle(c *gin.Context) {
} }
defer func() { _ = resp.Body.Close() }() defer func() { _ = resp.Body.Close() }()
body, err := io.ReadAll(io.LimitReader(resp.Body, limits.MiB2)) body, err := io.ReadAll(io.LimitReader(resp.Body, netutil.MiB2))
if err != nil { if err != nil {
c.Status(http.StatusBadGateway) c.Status(http.StatusBadGateway)
return return