mirror of
https://github.com/semaphoreui/semaphore.git
synced 2024-11-25 06:15:56 +01:00
102 lines
2.3 KiB
Go
102 lines
2.3 KiB
Go
package tasks
|
|
|
|
import (
|
|
"bufio"
|
|
"encoding/json"
|
|
"os/exec"
|
|
"time"
|
|
|
|
"github.com/ansible-semaphore/semaphore/api/sockets"
|
|
"github.com/ansible-semaphore/semaphore/db"
|
|
"github.com/ansible-semaphore/semaphore/util"
|
|
log "github.com/Sirupsen/logrus"
|
|
)
|
|
|
|
func (t *task) log(msg string) {
|
|
now := time.Now()
|
|
|
|
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.projectID,
|
|
})
|
|
|
|
util.LogPanic(err)
|
|
|
|
sockets.Message(user, b)
|
|
}
|
|
|
|
go func() {
|
|
_, err := db.Mysql.Exec("insert into task__output (task_id, task, output, time) VALUES (?, '', ?, ?)", t.task.ID, msg, now)
|
|
util.LogPanicWithFields(err, log.Fields{"error": "Failed to insert task output"})
|
|
}()
|
|
}
|
|
|
|
func (t *task) updateStatus() {
|
|
for _, user := range t.users {
|
|
b, err := json.Marshal(&map[string]interface{}{
|
|
"type": "update",
|
|
"start": t.task.Start,
|
|
"end": t.task.End,
|
|
"status": t.task.Status,
|
|
"task_id": t.task.ID,
|
|
"project_id": t.projectID,
|
|
})
|
|
|
|
util.LogPanic(err)
|
|
|
|
sockets.Message(user, b)
|
|
}
|
|
|
|
if _, err := db.Mysql.Exec("update task set status=?, start=?, end=? where id=?", t.task.Status, t.task.Start, t.task.End, t.task.ID); err != nil {
|
|
t.panicOnError(err, "Failed to update task status")
|
|
}
|
|
}
|
|
|
|
// 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 *task) 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 this errors, sometimes it throw not dangerous "read |0: file already closed" error
|
|
util.LogWarningWithFields(err, log.Fields{"error": "Failed to read task output"})
|
|
}
|
|
|
|
}
|
|
|
|
func (t *task) logCmd(cmd *exec.Cmd) {
|
|
stderr, _ := cmd.StderrPipe()
|
|
stdout, _ := cmd.StdoutPipe()
|
|
|
|
go t.logPipe(bufio.NewReader(stderr))
|
|
go t.logPipe(bufio.NewReader(stdout))
|
|
}
|
|
|
|
func (t *task) panicOnError(err error, msg string) {
|
|
if err != nil {
|
|
t.log(msg)
|
|
util.LogPanicWithFields(err, log.Fields{"error": msg})
|
|
}
|
|
}
|