Add phpfpm.ErrLog parser

Author: anahan

pkg/phpfpm/errlog_parser.go

@@ -0,0 +1,70 @@
+package phpfpm
+
+import (
+	"bufio"
+	"context"
+	"errors"
+	"fmt"
+	"io"
+	"regexp"
+	"time"
+
+	"github.com/code-tool/docker-fpm-wrapper/pkg/line"
+)
+
+type ErrLogEntry struct {
+	CreatedAt time.Time
+	Level     LogLevel
+	Message   string
+}
+
+type ErrLogParser struct {
+	//
+}
+
+func NewErrLogParser() *ErrLogParser {
+	return &ErrLogParser{}
+}
+
+var errLogEntryRegexp = regexp.MustCompile(`^\[([^]]+)]\s+(ALERT|ERROR|WARNING|NOTICE|DEBUG):\s+([^\n]+)\n$`)
+
+func (p *ErrLogParser) ParseOne(r *bufio.Reader) (ErrLogEntry, error) {
+	result := ErrLogEntry{}
+	buf, err := line.ReadOne(r)
+	if err != nil {
+		return result, err
+	}
+
+	matches := errLogEntryRegexp.FindSubmatchIndex(buf)
+	if len(matches) == 0 {
+		return result, errors.New("unexpected log line format")
+	}
+	//
+	result.CreatedAt, err = time.Parse("02-Jan-2006 15:04:05", string(buf[matches[2]:matches[3]]))
+	if err != nil {
+		return result, fmt.Errorf("can't parse timestamp: %w", err)
+	}
+
+	result.Level = LogLevel(buf[matches[4]:matches[5]])
+	result.Message = string(buf[matches[6]:matches[7]])
+
+	return result, nil
+}
+
+func (p *ErrLogParser) Parse(ctx context.Context, r io.Reader, out chan ErrLogEntry) error {
+	bufioReader := bufio.NewReader(r)
+
+	for {
+		entry, err := p.ParseOne(bufioReader)
+		if err != nil {
+			return err
+		}
+
+		select {
+		case <-ctx.Done():
+			return nil
+		default:
+			out <- entry
+		}
+	}
+}

pkg/phpfpm/log.go

@@ -0,0 +1,13 @@
+package phpfpm
+
+type LogLevel string
+
+const (
+	LogLevelAlert   = "ALERT"
+	LogLevelError   = "ERROR"
+	LogLevelWarning = "WARNING"
+	LogLevelNotice  = "NOTICE"
+	LogLevelDebug   = "DEBUG"
+)
+
+const logTimeFormat = "02-Jan-2006 15:04:05"

pkg/phpfpm/slowlog_entry.go

@@ -35,7 +35,7 @@ func (se *SlowlogEntry) String() string {
 		b   strings.Builder
 	)
 
-	_, err = fmt.Fprintf(&b, "[%s]  [pool %s] pid %d\n", se.CreatedAt.Format(slowlogTimeFormat), se.PoolName, se.Pid)
+	_, err = fmt.Fprintf(&b, "[%s]  [pool %s] pid %d\n", se.CreatedAt.Format(logTimeFormat), se.PoolName, se.Pid)
 	if err != nil {
 		return ""
 	}

pkg/phpfpm/slowlog_parser.go

@@ -20,7 +20,6 @@ const (
 )
 
 const stacktraceParsingTimeout = 25 * time.Millisecond
-const slowlogTimeFormat = "02-Jan-2006 15:04:05"
 
 var (
 	headerRegexp          = regexp.MustCompile(`^\[([^]]+)]\s+\[pool\s([^]]+)]\s+pid\s+(\d+)(?:[\r\n]|$)`)