Skip to content
Snippets Groups Projects
Select Git revision
  • f34a11311f4c1c41bfb9a851b141917bb66147c5
  • master default protected
  • fix/PRXS-3401-ValidateValidationOpts
  • feature/PRXS-3383-CollectionsRankSortAPI
  • feature/3149-LocaleCodeAsID-Feature
  • feature/PRXS-3383-CollectionsSort
  • feature/3109-SerializeFeature
  • release/0.33
  • feature/3109-RecoverySchema
  • feature/3109-feature
  • fix/PRXS-3369-ValidateFields
  • refactor/PRXS-3306-MovePkgGroup1
  • refactor/6-pkg-refactor-expr
  • fix/PRXS-3360-TemplateBuilderPatch
  • feature/3293-MongoV2
  • feature/3272-GoVersionUp
  • feature/PRXS-3218-HideTemplateActions
  • feature/PRXS-3234-PruneIdents
  • feature/3146-UpdateItemStorageInterface
  • feature/3274-ObjectIndexesFixes
  • feature/PRXS-3143-3235-ReferenceOptions
  • v0.33.1
  • v0.32.0
  • v0.31.1
  • v0.31.0
  • v0.30.0
  • v0.29.0
  • v0.28.0
  • v0.27.0-alpha.1+16
  • v0.27.0-alpha.1+15
  • v0.27.0-alpha.1+14
  • v0.27.0-alpha.1+13
  • v0.27.0-alpha.1+12
  • v0.27.0-alpha.1+11
  • v0.27.0-alpha.1+10
  • v0.27.0-alpha.1+9
  • v0.27.0-alpha.1+8
  • v0.27.0-alpha.1+7
  • v0.27.0-alpha.1+6
  • v0.27.0-alpha.1+5
  • v0.27.0-alpha.1+4
41 results

collection_test.go

Blame
  • logging_middleware.go 5.09 KiB
    package middleware
    
    // Code generated by gowrap. DO NOT EDIT.
    // template: ../../../assets/templates/middleware/access_log
    // gowrap: http://github.com/hexdigest/gowrap
    
    //go:generate gowrap gen -p git.perx.ru/perxis/perxis-go/pkg/roles -i Roles -t ../../../assets/templates/middleware/access_log -o logging_middleware.go -l ""
    
    import (
    	"context"
    	"fmt"
    	"time"
    
    	"git.perx.ru/perxis/perxis-go/pkg/auth"
    	"git.perx.ru/perxis/perxis-go/pkg/roles"
    	"go.uber.org/zap"
    	"go.uber.org/zap/zapcore"
    )
    
    // loggingMiddleware implements roles.Roles that is instrumented with logging
    type loggingMiddleware struct {
    	logger *zap.Logger
    	next   roles.Roles
    }
    
    // LoggingMiddleware instruments an implementation of the roles.Roles with simple logging
    func LoggingMiddleware(logger *zap.Logger) Middleware {
    	return func(next roles.Roles) roles.Roles {
    		return &loggingMiddleware{
    			next:   next,
    			logger: logger,
    		}
    	}
    }
    
    func (m *loggingMiddleware) Create(ctx context.Context, role *roles.Role) (created *roles.Role, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":  ctx,
    		"role": role} {
    		if k == "ctx" {
    			fields = append(fields, zap.String("principal", fmt.Sprint(auth.GetPrincipal(ctx))))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Create.Request", fields...)
    
    	created, err = m.next.Create(ctx, role)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"created": created,
    		"err":     err} {
    		if k == "err" {
    			err, _ := v.(error)
    			fields = append(fields, zap.Error(err))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Create.Response", fields...)
    
    	return created, err
    }
    
    func (m *loggingMiddleware) Delete(ctx context.Context, spaceId string, roleId string) (err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":     ctx,
    		"spaceId": spaceId,
    		"roleId":  roleId} {
    		if k == "ctx" {
    			fields = append(fields, zap.String("principal", fmt.Sprint(auth.GetPrincipal(ctx))))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Delete.Request", fields...)
    
    	err = m.next.Delete(ctx, spaceId, roleId)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"err": err} {
    		if k == "err" {
    			err, _ := v.(error)
    			fields = append(fields, zap.Error(err))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Delete.Response", fields...)
    
    	return err
    }
    
    func (m *loggingMiddleware) Get(ctx context.Context, spaceId string, roleId string) (role *roles.Role, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":     ctx,
    		"spaceId": spaceId,
    		"roleId":  roleId} {
    		if k == "ctx" {
    			fields = append(fields, zap.String("principal", fmt.Sprint(auth.GetPrincipal(ctx))))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Get.Request", fields...)
    
    	role, err = m.next.Get(ctx, spaceId, roleId)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"role": role,
    		"err":  err} {
    		if k == "err" {
    			err, _ := v.(error)
    			fields = append(fields, zap.Error(err))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Get.Response", fields...)
    
    	return role, err
    }
    
    func (m *loggingMiddleware) List(ctx context.Context, spaceId string) (roles []*roles.Role, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":     ctx,
    		"spaceId": spaceId} {
    		if k == "ctx" {
    			fields = append(fields, zap.String("principal", fmt.Sprint(auth.GetPrincipal(ctx))))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("List.Request", fields...)
    
    	roles, err = m.next.List(ctx, spaceId)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"roles": roles,
    		"err":   err} {
    		if k == "err" {
    			err, _ := v.(error)
    			fields = append(fields, zap.Error(err))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("List.Response", fields...)
    
    	return roles, err
    }
    
    func (m *loggingMiddleware) Update(ctx context.Context, role *roles.Role) (err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":  ctx,
    		"role": role} {
    		if k == "ctx" {
    			fields = append(fields, zap.String("principal", fmt.Sprint(auth.GetPrincipal(ctx))))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Update.Request", fields...)
    
    	err = m.next.Update(ctx, role)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"err": err} {
    		if k == "err" {
    			err, _ := v.(error)
    			fields = append(fields, zap.Error(err))
    			continue
    		}
    		fields = append(fields, zap.Reflect(k, v))
    	}
    
    	m.logger.Debug("Update.Response", fields...)
    
    	return err
    }