enable php-fpm errlog parsing

Author: anahan

cmd/docker-fpm-wrapper/errlog.go

@@ -0,0 +1,44 @@
+package main
+
+import (
+	"context"
+
+	"go.uber.org/zap"
+
+	"github.com/code-tool/docker-fpm-wrapper/internal/zapx"
+	"github.com/code-tool/docker-fpm-wrapper/pkg/phpfpm"
+)
+
+func startSlowlogProxy(ctx context.Context, log *zap.Logger, fPath string) error {
+	if fPath == "" {
+		return nil
+	}
+
+	f, err := createFIFOByPathCtx(ctx, fPath)
+	if err != nil {
+		return err
+	}
+
+	entryCh := make(chan phpfpm.ErrLogEntry)
+	go func() {
+		for {
+			select {
+			case entry := <-entryCh:
+				// todo Map Level
+				if ce := log.Check(zapx.MapFpmLogLevel(entry.Level), entry.Message); ce != nil {
+					ce.Time = entry.CreatedAt
+					ce.Write()
+				}
+			case <-ctx.Done():
+				return
+			}
+		}
+	}()
+
+	logParser := phpfpm.NewErrLogParser()
+	go func() {
+		_ = logParser.Parse(ctx, f, entryCh)
+	}()
+
+	return nil
+}

cmd/docker-fpm-wrapper/main.go

@@ -72,6 +72,10 @@ func main() {
 		os.Exit(1)
 	}
 
+	if err := startSlowlogProxy(ctx, log.Named("php-fpm"), fpmConfig.ErrorLog); err != nil {
+		log.Error("can't start err_log proxy", zap.Error(err))
+	}
+
 	if !cfg.FpmSlowlogProxyDisabled {
 		if err = startSlowlogProxies(ctx, fpmConfig, log); err != nil {
 			log.Fatal("Can't start slowlog proxies", zap.Error(err))

internal/zapx/level.go

@@ -0,0 +1,25 @@
+package zapx
+
+import (
+	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
+
+	"github.com/code-tool/docker-fpm-wrapper/pkg/phpfpm"
+)
+
+func MapFpmLogLevel(ll phpfpm.LogLevel) zapcore.Level {
+	switch ll {
+	case phpfpm.LogLevelAlert:
+		return zap.FatalLevel
+	case phpfpm.LogLevelError:
+		return zap.ErrorLevel
+	case phpfpm.LogLevelWarning:
+		return zap.WarnLevel
+	case phpfpm.LogLevelNotice:
+		return zap.InfoLevel
+	case phpfpm.LogLevelDebug:
+		return zap.DebugLevel
+	default:
+		return zap.DebugLevel
+	}
+}