Select Git revision
logging_middleware.go 4.51 KiB
package middleware
import (
"context"
"git.perx.ru/perxis/perxis-go/id"
"git.perx.ru/perxis/perxis-go/pkg/environments"
logzap "git.perx.ru/perxis/perxis-go/zap"
"go.uber.org/zap"
)
type loggingMiddleware struct {
logger *zap.Logger
next environments.Environments
}
func LoggingMiddleware(logger *zap.Logger) Middleware {
return func(next environments.Environments) environments.Environments {
return &loggingMiddleware{
next: next,
logger: logger.With(logzap.Component("Environments")),
}
}
}
func (m *loggingMiddleware) Create(ctx context.Context, env *environments.Environment) (created *environments.Environment, err error) {
logger := m.logger.With(
logzap.Caller(ctx),
logzap.Event(environments.EventCreate),
logzap.Object(env),
)
created, err = m.next.Create(ctx, env)
if err != nil {
logger.Error("Failed to create", zap.Error(err), logzap.Channels(logzap.Userlog, logzap.Syslog))
return
}
logger.Info("Environment created", logzap.Channels(logzap.Userlog))
return created, err
}
func (m *loggingMiddleware) Delete(ctx context.Context, spaceId string, envId string) (err error) {
logger := m.logger.With(
logzap.Caller(ctx),
logzap.Event(environments.EventDelete),
logzap.Object(id.NewEnvironmentId(spaceId, envId)),
)
err = m.next.Delete(ctx, spaceId, envId)
if err != nil {
logger.Error("Failed to delete", zap.Error(err), logzap.Channels(logzap.Userlog, logzap.Syslog))
return
}
logger.Info("Environment deleted", logzap.Channels(logzap.Userlog))
return err
}
func (m *loggingMiddleware) Get(ctx context.Context, spaceId string, envId string) (env *environments.Environment, err error) {
logger := m.logger.With(
logzap.Caller(ctx),
logzap.Object(id.NewEnvironmentId(spaceId, envId)),
)
env, err = m.next.Get(ctx, spaceId, envId)
if err != nil {