pages-server/server/upstream/helper.go

56 lines
1.7 KiB
Go
Raw Normal View History

2021-12-05 13:47:33 +00:00
package upstream
import (
"time"
"github.com/valyala/fasthttp"
"github.com/valyala/fastjson"
2021-12-05 14:53:46 +00:00
"codeberg.org/codeberg/pages/server/cache"
2021-12-05 13:47:33 +00:00
)
type branchTimestamp struct {
Branch string
Timestamp time.Time
}
// GetBranchTimestamp finds the default branch (if branch is "") and returns the last modification time of the branch
// (or nil if the branch doesn't exist)
2021-12-05 14:53:46 +00:00
func GetBranchTimestamp(owner, repo, branch, giteaRoot, giteaApiToken string, branchTimestampCache cache.SetGetKey) *branchTimestamp {
2021-12-05 13:47:33 +00:00
if result, ok := branchTimestampCache.Get(owner + "/" + repo + "/" + branch); ok {
if result == nil {
return nil
}
return result.(*branchTimestamp)
}
result := &branchTimestamp{}
result.Branch = branch
if branch == "" {
// Get default branch
var body = make([]byte, 0)
// TODO: use header for API key?
status, body, err := fasthttp.GetTimeout(body, giteaRoot+"/api/v1/repos/"+owner+"/"+repo+"?access_token="+giteaApiToken, 5*time.Second)
if err != nil || status != 200 {
2021-12-05 15:24:26 +00:00
_ = branchTimestampCache.Set(owner+"/"+repo+"/"+branch, nil, defaultBranchCacheTimeout)
2021-12-05 13:47:33 +00:00
return nil
}
result.Branch = fastjson.GetString(body, "default_branch")
}
var body = make([]byte, 0)
status, body, err := fasthttp.GetTimeout(body, giteaRoot+"/api/v1/repos/"+owner+"/"+repo+"/branches/"+branch+"?access_token="+giteaApiToken, 5*time.Second)
if err != nil || status != 200 {
return nil
}
result.Timestamp, _ = time.Parse(time.RFC3339, fastjson.GetString(body, "commit", "timestamp"))
2021-12-05 15:24:26 +00:00
_ = branchTimestampCache.Set(owner+"/"+repo+"/"+branch, result, branchExistenceCacheTimeout)
2021-12-05 13:47:33 +00:00
return result
}
type fileResponse struct {
exists bool
mimeType string
body []byte
}