Method Write

utils/service_utils/service_functions.go:91–140

(p []byte)

}

func (lb *LogBuffer) Write(p []byte) (n int, err error) {
	lb.mu.Lock()

	content := string(p)

	if lb.UsePTY {
		content = stripControlSequences(content)
	}

	content = strings.ReplaceAll(content, "\r\n", "\n")

	if !strings.Contains(content, "\n") && strings.Contains(content, "\r") {
		parts := strings.Split(content, "\r")
		content = parts[len(parts)-1]
	} else {
		content = strings.ReplaceAll(content, "\r", "\n")
	}

	lines := strings.Split(content, "\n")

	var toSend []string

	for _, line := range lines {
		line = strings.TrimSpace(line)
		if line == "" || line == "\\" || line == "\\\\" {
			continue
		}

		trimmed := strings.Trim(line, "\\")
		if trimmed == "" {
			continue
		}

		if len(lb.Lines) >= lb.MaxLines {
			lb.Lines = lb.Lines[1:]
		}

		lb.Lines = append(lb.Lines, line)
		toSend = append(toSend, line)
	}

	serviceName := lb.ServiceName
	lb.mu.Unlock()

	for _, line := range toSend {
		NewServiceLog(serviceName, line)
	}

	return len(p), nil
}

func NewServiceLog(serviceName string, logStr string) {
	newLog, err := json.Marshal(fiber.Map{