aniani/gitea
1
0
Fork 0
mirror of https://github.com/go-gitea/gitea.git synced 2025-05-18 00:49:09 -04:00
Code

chore: debug runner log reporting

Browse Source
This commit is contained in:
Jason Song 2022-10-11 18:27:52 +08:00
parent 79966763c6
commit 32a5797608
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
routers/api/bots/runner/runner.go
View File

@ -17,6 +17,7 @@ import (
"code.gitea.io/gitea/models/repo"
"code.gitea.io/gitea/models/user"
"code.gitea.io/gitea/modules/json"
"code.gitea.io/gitea/modules/log"
runnerv1 "gitea.com/gitea/proto-go/runner/v1"
"gitea.com/gitea/proto-go/runner/v1/runnerv1connect"
@ -164,6 +165,10 @@ func (s *Service) UpdateTask(
req *connect.Request[runnerv1.UpdateTaskRequest],
) (*connect.Response[runnerv1.UpdateTaskResponse], error) {
res := connect.NewResponse(&runnerv1.UpdateTaskResponse{})
// to debug
log.Info("task state: %+v", req.Msg.State)
return res, nil
}
@ -173,6 +178,13 @@ func (s *Service) UpdateLog(
req *connect.Request[runnerv1.UpdateLogRequest],
) (*connect.Response[runnerv1.UpdateLogResponse], error) {
res := connect.NewResponse(&runnerv1.UpdateLogResponse{})
// to debug
for i, row := range req.Msg.Rows {
log.Info("log[%v]: %v %v", req.Msg.Index+int64(i), row.Time.AsTime().Local().Format(time.RFC3339), row.Content)
}
res.Msg.AckIndex = req.Msg.Index + int64(len(req.Msg.Rows))
return res, nil
}