From ba0e5c6d21732f88b37a8c89a26dfb59bbd4e132 Mon Sep 17 00:00:00 2001
From: mkelvers <mikkelelvers@outlook.com>
Date: Fri, 3 Jul 2026 02:55:59 +0200
Subject: [PATCH] feat: add compression types and negotiation helpers

---
 internal/server/static_delivery.go | 54 +++++++++++++++++++++++++++++-
 1 file changed, 53 insertions(+), 1 deletion(-)

diff --git a/internal/server/static_delivery.go b/internal/server/static_delivery.go
index 11d9c985..51f015f2 100644
--- a/internal/server/static_delivery.go
+++ b/internal/server/static_delivery.go
@@ -6,6 +6,7 @@ import (
 	"net"
 	"net/http"
 	"path/filepath"
+	"strconv"
 	"strings"
 
 	"github.com/gin-gonic/gin"
@@ -41,7 +42,6 @@ func isCompressibleContentType(value string) bool {
 	}
 }
 
-//nolint:unused
 func isCompressedPath(path string) bool {
 	switch strings.ToLower(filepath.Ext(path)) {
 	case ".7z", ".avif", ".br", ".gif", ".gz", ".ico", ".jpeg", ".jpg", ".m4a", ".m4v", ".mov", ".mp3", ".mp4", ".oga", ".ogg", ".ogv", ".pdf", ".png", ".rar", ".webm", ".webp", ".woff", ".woff2", ".zip":
@@ -146,3 +146,55 @@ func StaticCacheMiddleware() gin.HandlerFunc {
 		c.Next()
 	}
 }
+
+//nolint:unused
+type compressionMode uint8
+
+const (
+	compressionUndecided compressionMode = iota //nolint:unused
+	compressionPlain                            //nolint:unused
+	compressionGzip                             //nolint:unused
+)
+
+//nolint:unused
+func acceptsGzip(value string) bool {
+	wildcard := false
+	for _, part := range strings.Split(value, ",") {
+		params := strings.Split(part, ";")
+		encoding := strings.TrimSpace(strings.ToLower(params[0]))
+		quality := 1.0
+		for _, param := range params[1:] {
+			name, raw, ok := strings.Cut(strings.TrimSpace(param), "=")
+			if !ok || !strings.EqualFold(name, "q") {
+				continue
+			}
+			parsed, err := strconv.ParseFloat(raw, 64)
+			if err != nil {
+				quality = 0
+			} else {
+				quality = parsed
+			}
+		}
+		if encoding == "gzip" {
+			return quality > 0
+		}
+		if encoding == "*" && quality > 0 {
+			wildcard = true
+		}
+	}
+	return wildcard
+}
+
+//nolint:unused
+func canNegotiateCompression(r *http.Request) bool {
+	if r.Method == http.MethodHead || r.Header.Get("Range") != "" {
+		return false
+	}
+	if strings.EqualFold(r.Header.Get("Connection"), "Upgrade") {
+		return false
+	}
+	if r.URL.Path == "/watch/proxy/stream" || r.URL.Path == "/watch/proxy/subtitle" {
+		return false
+	}
+	return !isCompressedPath(r.URL.Path)
+}