self-hosted/woodpecker
1
0
Fork 0
mirror of https://github.com/woodpecker-ci/woodpecker.git synced 2025-07-12 22:21:40 +02:00
Code Issues Releases Activity

Migrate to Xorm (#474)

Browse Source 
close #234

* Migrate store
* Migrate tests
* Rewrite migrations
* Init fresh DB in on step
* Rm old stuff (meddler, sql files, dead code, ...)
This commit is contained in:
6543
2021-11-13 20:18:06 +01:00
committed by GitHub
parent aca5fddcf3
commit ca8e215cfa
582 changed files with 81745 additions and 17600 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
server/api/build.go
View File

@ -62,7 +62,7 @@ func GetBuild(c *gin.Context) {
}
repo := session.Repo(c)
num, err := strconv.Atoi(c.Param("number"))
num, err := strconv.ParseInt(c.Param("number"), 10, 64)
if err != nil {
c.AbortWithError(http.StatusBadRequest, err)
return
@ -103,7 +103,7 @@ func GetBuildLogs(c *gin.Context) {
// parse the build number and job sequence number from
// the request parameter.
num, _ := strconv.Atoi(c.Params.ByName("number"))
num, _ := strconv.ParseInt(c.Params.ByName("number"), 10, 64)
ppid, _ := strconv.Atoi(c.Params.ByName("pid"))
name := c.Params.ByName("proc")
@ -137,7 +137,7 @@ func GetProcLogs(c *gin.Context) {
// parse the build number and job sequence number from
// the request parameter.
num, _ := strconv.Atoi(c.Params.ByName("number"))
num, _ := strconv.ParseInt(c.Params.ByName("number"), 10, 64)
pid, _ := strconv.Atoi(c.Params.ByName("pid"))
build, err := store_.GetBuildNumber(repo, num)
@ -168,7 +168,7 @@ func GetProcLogs(c *gin.Context) {
func DeleteBuild(c *gin.Context) {
store_ := store.FromContext(c)
repo := session.Repo(c)
num, _ := strconv.Atoi(c.Params.ByName("number"))
num, _ := strconv.ParseInt(c.Params.ByName("number"), 10, 64)
build, err := store_.GetBuildNumber(repo, num)
if err != nil {
@ -250,9 +250,7 @@ func PostApproval(c *gin.Context) {
store_ = store.FromContext(c)
repo = session.Repo(c)
user = session.User(c)
num, _ = strconv.Atoi(
c.Params.ByName("number"),
)
num, _ = strconv.ParseInt(c.Params.ByName("number"), 10, 64)
)
build, err := store_.GetBuildNumber(repo, num)
@ -307,7 +305,7 @@ func PostApproval(c *gin.Context) {
var yamls []*remote.FileMeta
for _, y := range configs {
yamls = append(yamls, &remote.FileMeta{Data: []byte(y.Data), Name: y.Name})
yamls = append(yamls, &remote.FileMeta{Data: y.Data, Name: y.Name})
}
b := shared.ProcBuilder{
@ -360,9 +358,7 @@ func PostDecline(c *gin.Context) {
repo = session.Repo(c)
user = session.User(c)
num, _ = strconv.Atoi(
c.Params.ByName("number"),
)
num, _ = strconv.ParseInt(c.Params.ByName("number"), 10, 64)
)
build, err := store_.GetBuildNumber(repo, num)
@ -404,7 +400,7 @@ func PostBuild(c *gin.Context) {
store_ := store.FromContext(c)
repo := session.Repo(c)
num, err := strconv.Atoi(c.Param("number"))
num, err := strconv.ParseInt(c.Param("number"), 10, 64)
if err != nil {
c.AbortWithError(http.StatusBadRequest, err)
return
@ -519,7 +515,7 @@ func PostBuild(c *gin.Context) {
var yamls []*remote.FileMeta
for _, y := range configs {
yamls = append(yamls, &remote.FileMeta{Data: []byte(y.Data), Name: y.Name})
yamls = append(yamls, &remote.FileMeta{Data: y.Data, Name: y.Name})
}
b := shared.ProcBuilder{
@ -565,7 +561,7 @@ func DeleteBuildLogs(c *gin.Context) {
repo := session.Repo(c)
user := session.User(c)
num, _ := strconv.Atoi(c.Params.ByName("number"))
num, _ := strconv.ParseInt(c.Params.ByName("number"), 10, 64)
build, err := store_.GetBuildNumber(repo, num)
if err != nil {

4
server/api/file.go
View File

@ -29,7 +29,7 @@ import (
// FileList gets a list file by build.
func FileList(c *gin.Context) {
store_ := store.FromContext(c)
num, err := strconv.Atoi(c.Param("number"))
num, err := strconv.ParseInt(c.Param("number"), 10, 64)
if err != nil {
c.AbortWithError(http.StatusBadRequest, err)
return
@ -63,7 +63,7 @@ func FileGet(c *gin.Context) {
}()
)
num, err := strconv.Atoi(c.Param("number"))
num, err := strconv.ParseInt(c.Param("number"), 10, 64)
if err != nil {
c.AbortWithError(http.StatusBadRequest, err)
return

2
server/api/hook.go
View File

@ -340,7 +340,7 @@ func findOrPersistPipelineConfig(repo *model.Repo, build *model.Build, remoteYam
if err != nil {
conf = &model.Config{
RepoID: build.RepoID,
Data: string(remoteYamlConfig.Data),
Data: remoteYamlConfig.Data,
Hash: sha,
Name: shared.SanitizePath(remoteYamlConfig.Name),
}

2
server/api/stream.go
View File

@ -138,7 +138,7 @@ func LogStreamSSE(c *gin.Context) {
// // parse the build number and job sequence number from
// // the repquest parameter.
buildn, _ := strconv.Atoi(c.Param("build"))
buildn, _ := strconv.ParseInt(c.Param("build"), 10, 64)
jobn, _ := strconv.Atoi(c.Param("number"))
build, err := store_.GetBuildNumber(repo, buildn)