refact(zap): custom lumberjack with sync.WaitGroup

logger/drivers/zap/log.go

@@ -1,12 +1,13 @@
 package zap
 
 import (
+	"github.com/ArtisanCloud/PowerLibs/v3/fmt"
 	"github.com/ArtisanCloud/PowerLibs/v3/logger/contract"
+	lumberjack "github.com/ArtisanCloud/PowerLibs/v3/logger/lib"
 	"github.com/ArtisanCloud/PowerLibs/v3/object"
 	os2 "github.com/ArtisanCloud/PowerLibs/v3/os"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
-	"gopkg.in/natefinch/lumberjack.v2"
 	"os"
 	"time"
 )
@@ -71,6 +72,8 @@ func newZapLogger(config *object.HashMap) (logger *zap.Logger, err error) {
 		Compress:   true, // disabled by default
 	})
 
+	fmt.Dump(outputWriter)
+
 	//errorSyncer, err := newFileWriteSyncer(errorFile)
 	//if err != nil {
 	//	return nil, err

logger/lib/chown.go

@@ -0,0 +1,11 @@
+// +build !linux
+
+package lumberjack
+
+import (
+	"os"
+)
+
+func chown(_ string, _ os.FileInfo) error {
+	return nil
+}

logger/lib/chown_linux.go

@@ -0,0 +1,19 @@
+package lumberjack
+
+import (
+	"os"
+	"syscall"
+)
+
+// osChown is a var so we can mock it out during tests.
+var osChown = os.Chown
+
+func chown(name string, info os.FileInfo) error {
+	f, err := os.OpenFile(name, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, info.Mode())
+	if err != nil {
+		return err
+	}
+	f.Close()
+	stat := info.Sys().(*syscall.Stat_t)
+	return osChown(name, int(stat.Uid), int(stat.Gid))
+}