Method pipeOutputs

common/utils/fork/process.go:162–224

(cmd *exec.Cmd)

}

func (p *Process) pipeOutputs(cmd *exec.Cmd) error {
	stdout, err := cmd.StdoutPipe()
	if err != nil {
		return err
	}
	stderr, err := cmd.StderrPipe()
	if err != nil {
		return err
	}
	scannerOut := bufio.NewScanner(stdout)
	defaultLogContext := runtime.WithServiceName(p.ctx, p.o.name)

	logs := regexp.MustCompile("^(?P<log_date>[^\t]+)\t(?P<log_level>[^\t]+)\t(?P<log_name>[^\t]+)\t(?P<log_message>[^\t]+)(\t)?(?P<log_fields>[^\t]*)$")

	// prefix := fmt.Sprintf("%-14s", "["+p.o.name+"]")
	go func() {
		var sb strings.Builder

		for scannerOut.Scan() {
			sb.Reset()
			// sb.WriteString(prefix)
			text := strings.TrimRight(scannerOut.Text(), "\n")
			// merged := false
			if parsed := logs.FindStringSubmatch(text); len(parsed) >= 5 {
				sb.WriteString(text)
				sb.WriteString("\n")

				log.StdOut.WriteString(sb.String())
			} else {
				sb.WriteString(text)

				log.Logger(defaultLogContext).Info(sb.String())
			}
		}
	}()
	scannerErr := bufio.NewScanner(stderr)
	go func() {
		var sb strings.Builder
		for scannerErr.Scan() {
			sb.Reset()
			// sb.WriteString(prefix)

			text := strings.TrimRight(scannerErr.Text(), "\n")
			merged := false
			for _, sName := range p.serviceNames {
				if strings.Contains(text, sName) {
					sb.WriteString(text)
					sb.WriteString("\n")

					log.StdOut.WriteString(sb.String())
					merged = true
					break
				}
			}
			if !merged {
				sb.WriteString(text)

				log.Logger(defaultLogContext).Info(sb.String())