mirror of
https://codeberg.org/Codeberg/pages-server.git
synced 2024-11-05 14:07:01 +00:00
876a53d9a2
- Actually log useful information at their respective log level. - Add logs in hot-paths to be able to deep-dive and debug specific requests (see server/handler.go) - Add more information to existing fields(e.g. the host that the user is visiting, this was noted by @fnetX). Co-authored-by: Gusted <williamzijl7@hotmail.com> Reviewed-on: https://codeberg.org/Codeberg/pages-server/pulls/116 Reviewed-by: 6543 <6543@noreply.codeberg.org> Co-authored-by: Gusted <gusted@noreply.codeberg.org> Co-committed-by: Gusted <gusted@noreply.codeberg.org>
53 lines
1.7 KiB
Go
53 lines
1.7 KiB
Go
package server
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/rs/zerolog/log"
|
|
"github.com/valyala/fasthttp"
|
|
|
|
"codeberg.org/codeberg/pages/server/cache"
|
|
"codeberg.org/codeberg/pages/server/utils"
|
|
)
|
|
|
|
type fasthttpLogger struct{}
|
|
|
|
func (fasthttpLogger) Printf(format string, args ...interface{}) {
|
|
log.Printf("FastHTTP: %s", fmt.Sprintf(format, args...))
|
|
}
|
|
|
|
func SetupServer(handler fasthttp.RequestHandler) *fasthttp.Server {
|
|
// Enable compression by wrapping the handler with the compression function provided by FastHTTP
|
|
compressedHandler := fasthttp.CompressHandlerBrotliLevel(handler, fasthttp.CompressBrotliBestSpeed, fasthttp.CompressBestSpeed)
|
|
|
|
return &fasthttp.Server{
|
|
Handler: compressedHandler,
|
|
DisablePreParseMultipartForm: true,
|
|
NoDefaultServerHeader: true,
|
|
NoDefaultDate: true,
|
|
ReadTimeout: 30 * time.Second, // needs to be this high for ACME certificates with ZeroSSL & HTTP-01 challenge
|
|
Logger: fasthttpLogger{},
|
|
}
|
|
}
|
|
|
|
func SetupHTTPACMEChallengeServer(challengeCache cache.SetGetKey) *fasthttp.Server {
|
|
challengePath := []byte("/.well-known/acme-challenge/")
|
|
|
|
return &fasthttp.Server{
|
|
Handler: func(ctx *fasthttp.RequestCtx) {
|
|
if bytes.HasPrefix(ctx.Path(), challengePath) {
|
|
challenge, ok := challengeCache.Get(string(utils.TrimHostPort(ctx.Host())) + "/" + string(bytes.TrimPrefix(ctx.Path(), challengePath)))
|
|
if !ok || challenge == nil {
|
|
ctx.SetStatusCode(http.StatusNotFound)
|
|
ctx.SetBodyString("no challenge for this token")
|
|
}
|
|
ctx.SetBodyString(challenge.(string))
|
|
} else {
|
|
ctx.Redirect("https://"+string(ctx.Host())+string(ctx.RequestURI()), http.StatusMovedPermanently)
|
|
}
|
|
},
|
|
}
|
|
}
|