From 295ab22fd96490639c4107e559f34ec1974be70b Mon Sep 17 00:00:00 2001 From: mkelvers Date: Mon, 27 Apr 2026 20:39:39 +0200 Subject: [PATCH] log: only log errors, remove debug noise --- api/playback/allanime_client.go | 20 +++----------------- pkg/middleware/logging.go | 7 +++++-- 2 files changed, 8 insertions(+), 19 deletions(-) diff --git a/api/playback/allanime_client.go b/api/playback/allanime_client.go index eebdd5b..18bfbb4 100644 --- a/api/playback/allanime_client.go +++ b/api/playback/allanime_client.go @@ -11,6 +11,7 @@ import ( "encoding/json" "fmt" "io" + "log" "net" "net/http" "net/url" @@ -53,7 +54,6 @@ var ( type utlsRoundTripper struct{} func (rt *utlsRoundTripper) RoundTrip(req *http.Request) (*http.Response, error) { - fmt.Printf("[uTLS] RoundTrip: %s %s\n", req.Method, req.URL.Host) dialer := &net.Dialer{Timeout: 10 * time.Second} host := req.URL.Hostname() port := req.URL.Port() @@ -177,7 +177,6 @@ func (c *allAnimeClient) graphqlRequest(ctx context.Context, query string, varia const episodeQueryHash = "d405d0edd690624b66baba3068e0edc3ac90f1597d898a1ec8db4e5c43c00fec" func (c *allAnimeClient) graphqlRequestWithHash(ctx context.Context, showID, episode, mode string) (map[string]any, error) { - fmt.Printf("[ALLANIME] graphqlRequestWithHash called: showID=%s mode=%s ep=%s\n", showID, mode, episode) // Ensure mode is lowercase mode = strings.ToLower(mode) @@ -221,12 +220,6 @@ func (c *allAnimeClient) graphqlRequestWithHash(ctx context.Context, showID, epi return nil, fmt.Errorf("read response: %w", err) } - bodyPreview := string(respBody) - if len(bodyPreview) > 300 { - bodyPreview = bodyPreview[:300] - } - fmt.Printf("[uTLS] Response status=%d body=%s\n", resp.StatusCode, bodyPreview) - if resp.StatusCode != http.StatusOK { return nil, fmt.Errorf("GET status %d: %s", resp.StatusCode, string(respBody)) } @@ -258,13 +251,10 @@ func (c *allAnimeClient) graphqlRequestWithHash(ctx context.Context, showID, epi } if toBeParsed != "" { - fmt.Printf("[uTLS] Got tobeparsed (len=%d), attempting decrypt...\n", len(toBeParsed)) decrypted, err := decryptTobeparsed(toBeParsed) if err != nil { - fmt.Printf("[uTLS] Decrypt error: %v\n", err) return nil, fmt.Errorf("decrypt tobeparsed: %w", err) } - fmt.Printf("[uTLS] Decrypted OK (len=%d), preview: %s\n", len(decrypted), string(decrypted[:min(len(decrypted), 200)])) var ep map[string]any if jerr := json.Unmarshal(decrypted, &ep); jerr != nil { @@ -281,7 +271,6 @@ func (c *allAnimeClient) graphqlRequestWithHash(ctx context.Context, showID, epi } } - fmt.Printf("[uTLS] Found sourceUrls: len=%d\n", len(sourceURLs)) if len(sourceURLs) > 0 { return map[string]any{ "episode": map[string]any{ @@ -373,6 +362,7 @@ func (c *allAnimeClient) extractSourceURLsFromData(data map[string]any) []Stream extracted, err := c.extractor.ExtractVideoLinks(ctx, decoded) if err != nil { + log.Printf("source extraction failed for %s: %v", decoded, err) continue } @@ -518,13 +508,9 @@ func (c *allAnimeClient) GetEpisodeSources(ctx context.Context, showID string, e // First try persistent query approach (GET with query hash) result, err := c.graphqlRequestWithHash(ctx, showID, episode, mode) - if err != nil { - fmt.Printf("[ALLANIME] graphqlRequestWithHash err: %v\n", err) - } else { - fmt.Printf("[ALLANIME] graphqlRequestWithHash got result, top keys: %v\n", getMapKeys(result)) + if err == nil { // Result is already in shape {"episode": {"sourceUrls": [...]}} sources := c.extractSourceURLsFromData(result) - fmt.Printf("[ALLANIME] extractSourceURLsFromData returned %d sources\n", len(sources)) if len(sources) > 0 { return sources, nil } diff --git a/pkg/middleware/logging.go b/pkg/middleware/logging.go index cc96813..4687485 100644 --- a/pkg/middleware/logging.go +++ b/pkg/middleware/logging.go @@ -73,7 +73,8 @@ func RequestLogger(next http.Handler) http.Handler { strings.HasPrefix(r.URL.Path, "/static/") || strings.HasPrefix(r.URL.Path, "/watch/proxy/stream") || strings.HasPrefix(r.URL.Path, "/watch/proxy/segment") || - r.URL.Path == "/favicon.ico" { + r.URL.Path == "/favicon.ico" || + r.URL.Path == "/robots.txt" { next.ServeHTTP(w, r) return } @@ -82,6 +83,8 @@ func RequestLogger(next http.Handler) http.Handler { next.ServeHTTP(recorder, r) - log.Printf("%s %s %d %s", r.Method, r.URL.Path, recorder.statusCode, time.Since(start)) + if recorder.statusCode >= 400 { + log.Printf("%s %s %d %s", r.Method, r.URL.Path, recorder.statusCode, time.Since(start)) + } }) }