refactor: a better DI-friendy logger implementation that doesn't suck
This commit is contained in:
@@ -20,6 +20,7 @@ import (
|
|||||||
|
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
"go.uber.org/fx"
|
"go.uber.org/fx"
|
||||||
|
"go.uber.org/zap"
|
||||||
|
|
||||||
"easywish/config"
|
"easywish/config"
|
||||||
docs "easywish/docs"
|
docs "easywish/docs"
|
||||||
@@ -42,6 +43,7 @@ func main() {
|
|||||||
fx.New(
|
fx.New(
|
||||||
fx.Provide(
|
fx.Provide(
|
||||||
logger.NewLogger,
|
logger.NewLogger,
|
||||||
|
logger.NewSyncLogger,
|
||||||
gin.Default,
|
gin.Default,
|
||||||
),
|
),
|
||||||
database.Module,
|
database.Module,
|
||||||
@@ -49,7 +51,7 @@ func main() {
|
|||||||
controllers.Module,
|
controllers.Module,
|
||||||
routes.Module,
|
routes.Module,
|
||||||
|
|
||||||
fx.Invoke(func(lc fx.Lifecycle, router *gin.Engine) {
|
fx.Invoke(func(lc fx.Lifecycle, router *gin.Engine, syncLogger *logger.SyncLogger) {
|
||||||
|
|
||||||
// Swagger
|
// Swagger
|
||||||
docs.SwaggerInfo.Schemes = []string{"http"}
|
docs.SwaggerInfo.Schemes = []string{"http"}
|
||||||
@@ -65,6 +67,7 @@ func main() {
|
|||||||
OnStart: func(ctx context.Context) error {
|
OnStart: func(ctx context.Context) error {
|
||||||
go func() {
|
go func() {
|
||||||
if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
|
if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
|
||||||
|
syncLogger.Fatal("Server failed", zap.Error(err))
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
return nil
|
return nil
|
||||||
@@ -72,7 +75,15 @@ func main() {
|
|||||||
OnStop: func(ctx context.Context) error {
|
OnStop: func(ctx context.Context) error {
|
||||||
shutdownCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
shutdownCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
||||||
defer cancel()
|
defer cancel()
|
||||||
return server.Shutdown(shutdownCtx)
|
|
||||||
|
if err := server.Shutdown(shutdownCtx); err != nil {
|
||||||
|
syncLogger.Error("Server shutdown error", zap.Error(err))
|
||||||
|
}
|
||||||
|
|
||||||
|
if err := syncLogger.Close(); err != nil {
|
||||||
|
syncLogger.Error("Logger sync error", zap.Error(err))
|
||||||
|
}
|
||||||
|
return nil
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
}),
|
}),
|
||||||
|
|||||||
@@ -8,40 +8,36 @@ import (
|
|||||||
"go.uber.org/zap"
|
"go.uber.org/zap"
|
||||||
)
|
)
|
||||||
|
|
||||||
type Logger interface {
|
|
||||||
Get() *zap.Logger
|
|
||||||
Sync() error
|
|
||||||
}
|
|
||||||
|
|
||||||
type loggerImpl struct {
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewLogger() Logger {
|
|
||||||
return &loggerImpl{}
|
|
||||||
}
|
|
||||||
|
|
||||||
var (
|
var (
|
||||||
logger *zap.Logger
|
instance *zap.Logger
|
||||||
once sync.Once
|
once sync.Once
|
||||||
)
|
)
|
||||||
|
|
||||||
func (l *loggerImpl) Get() *zap.Logger {
|
func NewLogger() *zap.Logger {
|
||||||
once.Do(func() {
|
once.Do(func() {
|
||||||
var err error
|
|
||||||
cfg := config.GetConfig()
|
cfg := config.GetConfig()
|
||||||
|
var err error
|
||||||
|
|
||||||
if cfg.Environment == "production" {
|
if cfg.Environment == "production" {
|
||||||
logger, err = zap.NewProduction()
|
instance, err = zap.NewProduction()
|
||||||
} else {
|
} else {
|
||||||
logger, err = zap.NewDevelopment()
|
instance, err = zap.NewDevelopment()
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic("failed to initialize logger: " + err.Error())
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
return logger
|
return instance
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *loggerImpl) Sync() error {
|
type SyncLogger struct {
|
||||||
return logger.Sync()
|
*zap.Logger
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewSyncLogger(logger *zap.Logger) *SyncLogger {
|
||||||
|
return &SyncLogger{logger}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SyncLogger) Close() error {
|
||||||
|
return s.Sync()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ package services
|
|||||||
import (
|
import (
|
||||||
"easywish/internal/database"
|
"easywish/internal/database"
|
||||||
errs "easywish/internal/errors"
|
errs "easywish/internal/errors"
|
||||||
"easywish/internal/logger"
|
|
||||||
"easywish/internal/models"
|
"easywish/internal/models"
|
||||||
"easywish/internal/utils"
|
"easywish/internal/utils"
|
||||||
|
|
||||||
@@ -18,11 +17,11 @@ type AuthService interface {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type authServiceImpl struct {
|
type authServiceImpl struct {
|
||||||
log logger.Logger
|
log *zap.Logger
|
||||||
dbctx database.DbContext
|
dbctx database.DbContext
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewAuthService(_log logger.Logger, _dbctx database.DbContext) AuthService {
|
func NewAuthService(_log *zap.Logger, _dbctx database.DbContext) AuthService {
|
||||||
return &authServiceImpl{log: _log, dbctx: _dbctx}
|
return &authServiceImpl{log: _log, dbctx: _dbctx}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -33,10 +32,10 @@ func (a *authServiceImpl) RegistrationBegin(request models.RegistrationBeginRequ
|
|||||||
user, err := db.TXQueries.CreateUser(db.CTX, request.Username) // TODO: validation
|
user, err := db.TXQueries.CreateUser(db.CTX, request.Username) // TODO: validation
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.log.Get().Error("Failed to add user to database", zap.Error(err))
|
a.log.Error("Failed to add user to database", zap.Error(err))
|
||||||
return false, errs.ErrServerError
|
return false, errs.ErrServerError
|
||||||
}
|
}
|
||||||
a.log.Get().Info("Registered a new user", zap.String("username", user.Username))
|
a.log.Info("Registered a new user", zap.String("username", user.Username))
|
||||||
|
|
||||||
helper.Commit()
|
helper.Commit()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user