package tasks import ( "bufio" "encoding/json" "fmt" "os/exec" "time" "github.com/ansible-semaphore/semaphore/api/sockets" "github.com/ansible-semaphore/semaphore/util" log "github.com/sirupsen/logrus" ) func (t *TaskRunner) Log2(msg string, now time.Time) { for _, user := range t.users { b, err := json.Marshal(&map[string]interface{}{ "type": "log", "output": msg, "time": now, "task_id": t.Task.ID, "project_id": t.Task.ProjectID, }) util.LogPanic(err) sockets.Message(user, b) } t.pool.logger <- logRecord{ task: t, output: msg, time: now, } } func (t *TaskRunner) Log(msg string) { t.Log2(msg, time.Now()) } func (t *TaskRunner) Logf(format string, a ...any) { t.Log2(fmt.Sprintf(format, a...), time.Now()) } // Readln reads from the pipe func Readln(r *bufio.Reader) (string, error) { var ( isPrefix = true err error line, ln []byte ) for isPrefix && err == nil { line, isPrefix, err = r.ReadLine() ln = append(ln, line...) } return string(ln), err } func (t *TaskRunner) logPipe(reader *bufio.Reader) { line, err := Readln(reader) for err == nil { t.Log(line) line, err = Readln(reader) } if err != nil && err.Error() != "EOF" { //don't panic on these errors, sometimes it throws not dangerous "read |0: file already closed" error util.LogWarningWithFields(err, log.Fields{"error": "Failed to read TaskRunner output"}) } } func (t *TaskRunner) LogCmd(cmd *exec.Cmd) { stderr, _ := cmd.StderrPipe() stdout, _ := cmd.StdoutPipe() go t.logPipe(bufio.NewReader(stderr)) go t.logPipe(bufio.NewReader(stdout)) } func (t *TaskRunner) panicOnError(err error, msg string) { if err != nil { t.Log(msg) util.LogPanicWithFields(err, log.Fields{"error": msg}) } }