neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Disable zstd middleware

Browse Source
This commit is contained in:
Ingo Oppermann 2024-04-25 10:06:20 +02:00
parent 718bd3eb07
commit 495f9b2d35
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
2 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
http/middleware/zstd/zstd.go
View File

@ -194,15 +194,15 @@ func (w *zstdResponseWriter) Write(b []byte) (int, error) {
w.ResponseWriter.WriteHeader(w.code)
}
//return w.Encoder.Write(w.buffer.Bytes())
return w.ResponseWriter.Write(w.Encoder.EncodeAll(w.buffer.Bytes(), nil))
return w.Encoder.Write(w.buffer.Bytes())
//return w.ResponseWriter.Write(w.Encoder.EncodeAll(w.buffer.Bytes(), nil))
} else {
return n, err
}
}
//return w.Encoder.Write(b)
return w.ResponseWriter.Write(w.Encoder.EncodeAll(b, nil))
return w.Encoder.Write(b)
//return w.ResponseWriter.Write(w.Encoder.EncodeAll(b, nil))
}
func (w *zstdResponseWriter) Flush() {
@ -214,8 +214,8 @@ func (w *zstdResponseWriter) Flush() {
w.ResponseWriter.WriteHeader(w.code)
}
//w.Encoder.Write(w.buffer.Bytes())
w.ResponseWriter.Write(w.Encoder.EncodeAll(w.buffer.Bytes(), nil))
w.Encoder.Write(w.buffer.Bytes())
//w.ResponseWriter.Write(w.Encoder.EncodeAll(w.buffer.Bytes(), nil))
}
w.Encoder.Flush()

7
http/server.go
View File

@ -66,7 +66,6 @@ import (
mwmime "github.com/datarhei/core/v16/http/middleware/mime"
mwredirect "github.com/datarhei/core/v16/http/middleware/redirect"
mwsession "github.com/datarhei/core/v16/http/middleware/session"
mwzstd "github.com/datarhei/core/v16/http/middleware/zstd"
"github.com/labstack/echo/v4"
"github.com/labstack/echo/v4/middleware"
@ -490,11 +489,6 @@ func (s *server) setRoutes() {
MinLength: 1000,
Skipper: mwgzip.ContentTypeSkipper(nil),
})
zstdMiddleware := mwzstd.NewWithConfig(mwzstd.Config{
Level: mwzstd.BestSpeed,
MinLength: 1000,
Skipper: mwzstd.ContentTypeSkipper(nil),
})
// API router grouo
api := s.router.Group("/api")
@ -599,7 +593,6 @@ func (s *server) setRoutes() {
// APIv3 router group
v3 := api.Group("/v3")
v3.Use(zstdMiddleware)
v3.Use(gzipMiddleware)
s.setRoutesV3(v3)