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

refactor: update allanime client imports for flattened pkg/net

Browse Source
This commit is contained in:
mkelvers
2026-05-28 12:36:04 +02:00
committed by Milas Holsting
parent 5b8988ff14
commit 4b690ebd99
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
integrations/playback/allanime/client.go
View File

@@ -11,9 +11,7 @@ import (
"fmt" "fmt"
"io" "io"
"mal/internal/domain" "mal/internal/domain"
"mal/pkg/net/limits" netutil "mal/pkg/net"
"mal/pkg/net/useragent"
"mal/pkg/net/utls"
"net/http" "net/http"
"net/url" "net/url"
"strconv" "strconv"
@@ -25,7 +23,7 @@ const (
allAnimeBaseURL = "https://api.allanime.day" allAnimeBaseURL = "https://api.allanime.day"
allAnimeReferer = "https://allmanga.to/" allAnimeReferer = "https://allmanga.to/"
allAnimeOrigin = "https://youtu-chan.com" allAnimeOrigin = "https://youtu-chan.com"
defaultUserAgent = useragent.Firefox121 defaultUserAgent = netutil.Firefox121
) )
var ( var (
@@ -56,7 +54,7 @@ func NewAllAnimeProvider() *AllAnimeProvider {
Timeout: 30 * time.Second, Timeout: 30 * time.Second,
}, },
utlsClient: &http.Client{ utlsClient: &http.Client{
Transport: &utls.UtlsRoundTripper{}, Transport: &netutil.UtlsRoundTripper{},
Timeout: 30 * time.Second, Timeout: 30 * time.Second,
}, },
extractor: newProviderExtractor(), extractor: newProviderExtractor(),
@@ -280,7 +278,7 @@ func (c *AllAnimeProvider) graphqlRequest(ctx context.Context, query string, var
} }
defer func() { _ = resp.Body.Close() }() defer func() { _ = resp.Body.Close() }()
respBody, err := io.ReadAll(io.LimitReader(resp.Body, limits.MiB2)) respBody, err := io.ReadAll(io.LimitReader(resp.Body, netutil.MiB2))
if err != nil { if err != nil {
return nil, fmt.Errorf("read graphql response: %w", err) return nil, fmt.Errorf("read graphql response: %w", err)
} }
@@ -335,7 +333,7 @@ func (c *AllAnimeProvider) graphqlRequestWithHash(ctx context.Context, showID, e
} }
defer func() { _ = resp.Body.Close() }() defer func() { _ = resp.Body.Close() }()
respBody, err := io.ReadAll(io.LimitReader(resp.Body, limits.MiB2)) respBody, err := io.ReadAll(io.LimitReader(resp.Body, netutil.MiB2))
if err != nil { if err != nil {
return nil, fmt.Errorf("read response: %w", err) return nil, fmt.Errorf("read response: %w", err)
} }