Skip to content
Snippets Groups Projects
Select Git revision
  • 4ac27b9c4d77e79c184841ecd06a4116dca8c30a
  • 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

service.go

Blame
  • logging_middleware.go 5.51 KiB
    package service
    
    // 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/invitations -i Invitations -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/invitations"
    	"git.perx.ru/perxis/perxis-go/pkg/options"
    	"go.uber.org/zap"
    	"go.uber.org/zap/zapcore"
    )
    
    // loggingMiddleware implements invitations.Invitations that is instrumented with logging
    type loggingMiddleware struct {
    	logger *zap.Logger
    	next   invitations.Invitations
    }
    
    // LoggingMiddleware instruments an implementation of the invitations.Invitations with simple logging
    func LoggingMiddleware(logger *zap.Logger) Middleware {
    	return func(next invitations.Invitations) invitations.Invitations {
    		return &loggingMiddleware{
    			next:   next,
    			logger: logger,
    		}
    	}
    }
    
    func (m *loggingMiddleware) Accept(ctx context.Context, invitationId string, userId string) (err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":          ctx,
    		"invitationId": invitationId,
    		"userId":       userId} {
    		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("Accept.Request", fields...)
    
    	err = m.next.Accept(ctx, invitationId, userId)
    
    	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("Accept.Response", fields...)
    
    	return err
    }
    
    func (m *loggingMiddleware) Create(ctx context.Context, invitation *invitations.Invitation) (created *invitations.Invitation, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":        ctx,
    		"invitation": invitation} {
    		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, invitation)
    
    	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, invitationId string) (err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":          ctx,
    		"invitationId": invitationId} {
    		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, invitationId)
    
    	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) Find(ctx context.Context, filter *invitations.Filter, opts *options.FindOptions) (invitations []*invitations.Invitation, total int, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":    ctx,
    		"filter": filter,
    		"opts":   opts} {
    		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("Find.Request", fields...)
    
    	invitations, total, err = m.next.Find(ctx, filter, opts)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"invitations": invitations,
    		"total":       total,
    		"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("Find.Response", fields...)
    
    	return invitations, total, err
    }
    
    func (m *loggingMiddleware) Get(ctx context.Context, invitationId string) (invitation *invitations.Invitation, err error) {
    	begin := time.Now()
    	var fields []zapcore.Field
    	for k, v := range map[string]interface{}{
    		"ctx":          ctx,
    		"invitationId": invitationId} {
    		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...)
    
    	invitation, err = m.next.Get(ctx, invitationId)
    
    	fields = []zapcore.Field{
    		zap.Duration("time", time.Since(begin)),
    	}
    
    	for k, v := range map[string]interface{}{
    		"invitation": invitation,
    		"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 invitation, err
    }