From 0a5ed4ae7687f08ec99c3bfa8c0fd46c2a63da74 Mon Sep 17 00:00:00 2001 From: mkelvers Date: Wed, 13 May 2026 12:59:05 +0200 Subject: [PATCH] fix: add missing test helpers and fix interface assertion --- integrations/playback/allanime/client.go | 11 +++++++++++ integrations/playback/allanime/client_test.go | 2 +- 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/integrations/playback/allanime/client.go b/integrations/playback/allanime/client.go index d9bf486..cac7590 100644 --- a/integrations/playback/allanime/client.go +++ b/integrations/playback/allanime/client.go @@ -730,6 +730,17 @@ func detectStreamType(sourceURL string) string { return "unknown" } +func isLikelyM3U8(data []byte) bool { + return bytes.HasPrefix(bytes.TrimSpace(data), []byte("#EXTM3U")) +} + +func isLikelyMP4(data []byte) bool { + if len(data) < 8 { + return false + } + return string(data[4:8]) == "ftyp" +} + func detectEmbedType(rawURL string) string { lower := strings.ToLower(rawURL) embedHosts := []string{"streamwish", "streamsb", "mp4upload", "ok.ru", "gogoplay", "streamlare"} diff --git a/integrations/playback/allanime/client_test.go b/integrations/playback/allanime/client_test.go index ae2cdf5..55e448b 100644 --- a/integrations/playback/allanime/client_test.go +++ b/integrations/playback/allanime/client_test.go @@ -441,7 +441,7 @@ func TestAllAnimeClientImplementsInterfaces(t *testing.T) { var ( _ interface { - GetStreams(context.Context, int, string, string) (*domain.StreamResult, error) + GetStreams(context.Context, int, []string, string, string) (*domain.StreamResult, error) } = &AllAnimeProvider{} )