更新 gotemplate 的参数注入

This commit is contained in:
dragon
2025-04-15 17:23:23 +08:00
parent 2b2617200d
commit 3f63988e2d
4 changed files with 71 additions and 50 deletions

View File

@@ -8,6 +8,8 @@ import (
"path/filepath"
"time"
sprig "github.com/go-task/slim-sprig/v3"
"github.com/alecthomas/units"
"code.d7z.net/d7z-project/gitea-pages/pkg"
@@ -52,13 +54,13 @@ func (c *Config) NewPageServerOptions() (*pkg.ServerOptions, error) {
if c.Page.DefaultBranch == "" {
c.Page.DefaultBranch = "gh-pages"
}
defaultErr := template.Must(template.New("err").Parse(defaultErrPage))
defaultErr := template.Must(template.New("err").Funcs(sprig.FuncMap()).Parse(defaultErrPage))
if c.Page.ErrUnknownPage != "" {
data, err := os.ReadFile(c.Page.ErrUnknownPage)
if err != nil {
return nil, errors.Wrapf(err, "failed to read file %s", string(data))
}
c.pageErrUnknown = template.Must(template.New("err").Parse(c.Page.ErrUnknownPage))
c.pageErrUnknown = template.Must(template.New("err").Funcs(sprig.FuncMap()).Parse(c.Page.ErrUnknownPage))
} else {
c.pageErrUnknown = defaultErr
}
@@ -67,7 +69,7 @@ func (c *Config) NewPageServerOptions() (*pkg.ServerOptions, error) {
if err != nil {
return nil, errors.Wrapf(err, "failed to read file %s", c.Page.ErrNotFoundPage)
}
c.pageErrNotFound = template.Must(template.New("err").Parse(string(data)))
c.pageErrNotFound = template.Must(template.New("err").Funcs(sprig.FuncMap()).Parse(string(data)))
} else {
c.pageErrNotFound = defaultErr
}
@@ -96,20 +98,18 @@ func (c *Config) NewPageServerOptions() (*pkg.ServerOptions, error) {
func (c *Config) ErrorHandler(w http.ResponseWriter, r *http.Request, err error) {
if errors.Is(err, os.ErrNotExist) {
w.WriteHeader(http.StatusNotFound)
if err = c.pageErrNotFound.Execute(w, map[string]any{
"err": err,
"req": r,
"code": 404,
}); err != nil {
if err = c.pageErrNotFound.Execute(w, utils.NewTemplateInject(r, map[string]any{
"Error": err,
"Code": 404,
})); err != nil {
zap.L().Error("failed to render error page", zap.Error(err))
}
} else {
w.WriteHeader(http.StatusInternalServerError)
if err = c.pageErrUnknown.Execute(w, map[string]any{
"err": err,
"req": r,
"code": 500,
}); err != nil {
if err = c.pageErrUnknown.Execute(w, utils.NewTemplateInject(r, map[string]any{
"Error": err,
"Code": 500,
})); err != nil {
zap.L().Error("failed to render error page", zap.Error(err))
}
}

View File

@@ -3,11 +3,11 @@ package renders
import (
"bytes"
"io"
"net"
"net/http"
"strings"
"text/template"
"code.d7z.net/d7z-project/gitea-pages/pkg/utils"
sprig "github.com/go-task/slim-sprig/v3"
)
@@ -24,47 +24,13 @@ func (g GoTemplate) Render(w http.ResponseWriter, r *http.Request, input io.Read
}
out := &bytes.Buffer{}
parse, err := template.New("tmpl").Funcs(sprig.FuncMap()).Option("missingkey=error").Parse(string(dataB))
headers := make(map[string]string)
for k, vs := range r.Header {
headers[k] = strings.Join(vs, ",")
}
if err != nil {
return err
}
err = parse.Execute(out, map[string]interface{}{
"Request": map[string]any{
"Headers": headers,
"Request": r.RequestURI,
"RemoteAddr": r.RemoteAddr,
"RemoteIP": GetRemoteIP(r),
},
})
err = parse.Execute(out, utils.NewTemplateInject(r, nil))
if err != nil {
return err
}
_, err = out.WriteTo(w)
return err
}
// 注意,相关 ip 获取未做反向代理安全判断,可能导致安全降级
func GetRemoteIP(r *http.Request) string {
// 最先取 cloudflare 的头
if ip := r.Header.Get("CF-Connecting-IP"); ip != "" {
return ip
}
if forwardedFor := r.Header.Get("X-Forwarded-For"); forwardedFor != "" {
ips := strings.Split(forwardedFor, ",")
if len(ips) > 0 {
return strings.TrimSpace(ips[0])
}
}
if realIP := r.Header.Get("X-Real-IP"); realIP != "" {
return realIP
}
ip, _, err := net.SplitHostPort(r.RemoteAddr)
if err != nil {
return r.RemoteAddr
}
return ip
}

30
pkg/utils/net.go Normal file
View File

@@ -0,0 +1,30 @@
package utils
import (
"net"
"net/http"
"strings"
)
// 注意,相关 ip 获取未做反向代理安全判断,可能导致安全降级
func GetRemoteIP(r *http.Request) string {
// 最先取 cloudflare 的头
if ip := r.Header.Get("CF-Connecting-IP"); ip != "" {
return ip
}
if forwardedFor := r.Header.Get("X-Forwarded-For"); forwardedFor != "" {
ips := strings.Split(forwardedFor, ",")
if len(ips) > 0 {
return strings.TrimSpace(ips[0])
}
}
if realIP := r.Header.Get("X-Real-IP"); realIP != "" {
return realIP
}
ip, _, err := net.SplitHostPort(r.RemoteAddr)
if err != nil {
return r.RemoteAddr
}
return ip
}

25
pkg/utils/template.go Normal file
View File

@@ -0,0 +1,25 @@
package utils
import (
"net/http"
"strings"
)
func NewTemplateInject(r *http.Request, def map[string]any) map[string]any {
if def == nil {
def = make(map[string]any)
}
headers := make(map[string]string)
for k, vs := range r.Header {
headers[k] = strings.Join(vs, ",")
}
def["Request"] = map[string]any{
"Headers": headers,
"Path": r.URL.Path,
"Method": r.Method,
"RequestURI": r.RequestURI,
"RemoteAddr": r.RemoteAddr,
"RemoteIP": GetRemoteIP(r),
}
return def
}