JOJ/JOJ3
25
6
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

feat: more logs
All checks were successful
build / build (push) Successful in 1m17s
Details
build / trigger-build-image (push) Successful in 5s
Details

Browse Source
This commit is contained in:
张泊明518370910136 2024-10-02 16:45:54 -04:00
parent d723d98de0
commit f5ba04b8e7
Signed by: 张泊明518370910136
GPG Key ID: D47306D7062CDA9D
4 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/joj3/conf.go
View File

@ -133,5 +133,6 @@ func parseMsg(confRoot, confName, msg string) (conf Conf, group string, err erro
strings.ToLower(conventionalCommit.Description), "joj") { strings.ToLower(conventionalCommit.Description), "joj") {
group = "joj" group = "joj"
} }
slog.Debug("conf loaded", "conf", conf)
return return
} }

3
cmd/joj3/log.go
View File

@ -70,5 +70,8 @@ func setupSlog(logPath string) error {
// Set the default logger // Set the default logger
logger := slog.New(multiHandler) logger := slog.New(multiHandler)
slog.SetDefault(logger) slog.SetDefault(logger)
if logPath != "" {
slog.Info("debug log", "path", logPath)
}
return nil return nil
} }

7
cmd/joj3/main.go
View File

@ -71,10 +71,13 @@ func generateStages(conf Conf, group string) ([]stage.Stage, error) {
ParserConf: s.Parser.With, ParserConf: s.Parser.With,
}) })
} }
slog.Debug("stages generated", "stages", stages)
return stages, nil return stages, nil
} }
func outputResult(outputPath string, results []stage.StageResult) error { func outputResult(outputPath string, results []stage.StageResult) error {
slog.Info("output result start", "path", outputPath)
slog.Debug("output result start", "path", outputPath, "results", results)
content, err := json.Marshal(results) content, err := json.Marshal(results)
if err != nil { if err != nil {
return err return err
@ -124,22 +127,18 @@ func mainImpl() error {
if err := setupSlog(conf.LogPath); err != nil { // after conf is loaded if err := setupSlog(conf.LogPath); err != nil { // after conf is loaded
return err return err
} }
slog.Info("debug log", "path", conf.LogPath)
slog.Debug("conf loaded", "conf", conf)
executors.InitWithConf(conf.SandboxExecServer, conf.SandboxToken) executors.InitWithConf(conf.SandboxExecServer, conf.SandboxToken)
stages, err := generateStages(conf, group) stages, err := generateStages(conf, group)
if err != nil { if err != nil {
slog.Error("generate stages", "error", err) slog.Error("generate stages", "error", err)
return err return err
} }
slog.Debug("stages generated", "stages", stages)
defer stage.Cleanup() defer stage.Cleanup()
results, err := stage.Run(stages) results, err := stage.Run(stages)
if err != nil { if err != nil {
slog.Error("run stages", "error", err) slog.Error("run stages", "error", err)
return err return err
} }
slog.Debug("stages run done", "results", results)
if err := outputResult(conf.OutputPath, results); err != nil { if err := outputResult(conf.OutputPath, results); err != nil {
slog.Error("output result", "error", err) slog.Error("output result", "error", err)
return err return err

14
internal/stage/run.go
View File

@ -9,10 +9,12 @@ func Run(stages []Stage) (stageResults []StageResult, err error) {
var executorResults []ExecutorResult var executorResults []ExecutorResult
var parserResults []ParserResult var parserResults []ParserResult
var forceQuit bool var forceQuit bool
slog.Info("stage run start")
for _, stage := range stages { for _, stage := range stages {
slog.Info("stage start", "name", stage.Name) slog.Info("stage start", "name", stage.Name)
slog.Info("executor run start") slog.Info("executor run start", "name", stage.ExecutorName)
slog.Debug("executor run start", "cmds", stage.ExecutorCmds) slog.Debug("executor run start", "name", stage.ExecutorName,
"cmds", stage.ExecutorCmds)
executor, ok := executorMap[stage.ExecutorName] executor, ok := executorMap[stage.ExecutorName]
if !ok { if !ok {
slog.Error("executor not found", "name", stage.ExecutorName) slog.Error("executor not found", "name", stage.ExecutorName)
@ -28,8 +30,9 @@ func Run(stages []Stage) (stageResults []StageResult, err error) {
for _, executorResult := range executorResults { for _, executorResult := range executorResults {
slog.Debug("executor run done", "result.Files", executorResult.Files) slog.Debug("executor run done", "result.Files", executorResult.Files)
} }
slog.Info("parser run start") slog.Info("parser run start", "name", stage.ParserName)
slog.Debug("parser run start", "conf", stage.ParserConf) slog.Debug("parser run start", "name", stage.ParserName,
"conf", stage.ParserConf)
parser, ok := parserMap[stage.ParserName] parser, ok := parserMap[stage.ParserName]
if !ok { if !ok {
slog.Error("parser not found", "name", stage.ParserName) slog.Error("parser not found", "name", stage.ParserName)
@ -56,12 +59,11 @@ func Run(stages []Stage) (stageResults []StageResult, err error) {
} }
func Cleanup() { func Cleanup() {
slog.Info("stage cleanup start")
for name, executor := range executorMap { for name, executor := range executorMap {
slog.Debug("executor cleanup start", "name", name)
err := executor.Cleanup() err := executor.Cleanup()
if err != nil { if err != nil {
slog.Error("executor cleanup error", "name", name, "error", err) slog.Error("executor cleanup error", "name", name, "error", err)
} }
slog.Debug("executor cleanup done", "name", name)
} }
} }