WIP: commit msg parser #39

Closed
周赵嘉程521432910016 wants to merge 24 commits from commit-parser into master

View File

@ -1,19 +1,25 @@
package main package main
import ( import (
"fmt"
"log/slog" "log/slog"
"regexp"
"strings"
"focs.ji.sjtu.edu.cn/git/FOCS-dev/JOJ3/internal/stage" "focs.ji.sjtu.edu.cn/git/FOCS-dev/JOJ3/internal/stage"
"github.com/go-git/go-git/v5" "github.com/go-git/go-git/v5"
"github.com/koding/multiconfig" "github.com/koding/multiconfig"
) )
type Conf struct { type JobType int
SandboxExecServer string `default:"localhost:5051"`
SandboxToken string `default:""` const (
LogLevel int `default:"0"` HC JobType = iota
OutputPath string `default:"joj3_result.json"` CQ
Stages []struct { OJ
)
type Stage struct {
Name string Name string
Executor struct { Executor struct {
Name string Name string
@ -27,6 +33,13 @@ type Conf struct {
With interface{} With interface{}
} }
} }
type Conf struct {
SandboxExecServer string `default:"localhost:5051"`
SandboxToken string `default:""`
LogLevel int `default:"0"`
OutputPath string `default:"joj3_result.json"`
Stages []Stage
} }
type OptionalCmd struct { type OptionalCmd struct {
@ -60,40 +73,113 @@ type OptionalCmd struct {
AddressSpaceLimit *bool AddressSpaceLimit *bool
} }
func parseConfFile(path string) (conf Conf, err error) { func parseConfFile(path string, jobtype JobType) (conf Conf, err error) {
d := &multiconfig.DefaultLoader{} d := &multiconfig.DefaultLoader{}
d.Loader = multiconfig.MultiLoader( d.Loader = multiconfig.MultiLoader(
&multiconfig.TagLoader{}, &multiconfig.TagLoader{},
&multiconfig.JSONLoader{Path: path}, &multiconfig.JSONLoader{Path: path},
) )
d.Validator = multiconfig.MultiValidator(&multiconfig.RequiredValidator{}) d.Validator = multiconfig.MultiValidator(&multiconfig.RequiredValidator{})
if err = d.Load(&conf); err != nil { if err = d.Load(&conf); err != nil {
slog.Error("parse stages conf", "error", err) slog.Error("parse stages conf", "error", err)
return return
} }
if err = d.Validate(&conf); err != nil { if err = d.Validate(&conf); err != nil {
slog.Error("validate stages conf", "error", err) slog.Error("validate stages conf", "error", err)
return return
} }
filteredStages := []Stage{}
for _, stage := range conf.Stages {
if filterStage(stage, jobtype) {
filteredStages = append(filteredStages, stage)
}
}
conf.Stages = filteredStages
return return
} }
func filterStage(stage Stage, jobtype JobType) bool {
switch jobtype {
case HC:
return stage.Name == "healthcheck"
case CQ:
return stage.Name == "compile" || stage.Name == "healthcheck"
case OJ:
return true
default:
return false
}
}
func validateHw(hw string) error {
matched, err := regexp.MatchString(`^hw[0-9]+$`, hw)
if err != nil {
return fmt.Errorf("error compiling regex: %w", err)
}
if !matched {
return fmt.Errorf("error: hw does not match the required pattern")
}
return nil
}
func commitMsgToConf() (conf Conf, err error) { func commitMsgToConf() (conf Conf, err error) {
r, err := git.PlainOpen(".") r, err := git.PlainOpen(".")
if err != nil { if err != nil {
return return
} }
ref, err := r.Head() ref, err := r.Head()
if err != nil { if err != nil {
return return
} }
commit, err := r.CommitObject(ref.Hash()) commit, err := r.CommitObject(ref.Hash())
if err != nil { if err != nil {
return return
} }
file := "conf.json"
jobtype := HC
msg := commit.Message msg := commit.Message
slog.Debug("commit msg to conf", "msg", msg) slog.Debug("commit msg to conf", "msg", msg)
// TODO: parse msg to conf name if msg == "" {
conf, err = parseConfFile("conf.json") conf, err = parseConfFile(file, jobtype)
return
}
line := strings.Split(msg, "\n")[0]
words := strings.Fields(line)
head := words[0]
var hw string
if strings.HasSuffix(head, ":") || strings.HasSuffix(head, ".") {
head = head[:len(head)-1]
}
if len(words) == 3 {
hw = words[1]
if err = validateHw(hw); err != nil {
return
}
switch head {
case "feat", "fix", "refactor", "perf", "test", "build", "revert":
file = strings.Replace(file, "conf", "conf-"+hw, 1)
jobtype = CQ
case "joj", "grading":
file = strings.Replace(file, "conf", "conf-"+hw, 1)
jobtype = OJ
}
}
conf, err = parseConfFile(file, jobtype)
return return
} }