1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package scepserver
import (
"context"
"time"
"github.com/go-kit/kit/log"
)
type loggingService struct {
logger log.Logger
Service
}
// NewLoggingService creates adds logging to the SCEP service
func NewLoggingService(logger log.Logger, s Service) Service {
return &loggingService{logger, s}
}
func (mw *loggingService) GetCACaps(ctx context.Context) (caps []byte, err error) {
defer func(begin time.Time) {
_ = mw.logger.Log(
"method", "GetCACaps",
"err", err,
"took", time.Since(begin),
)
}(time.Now())
caps, err = mw.Service.GetCACaps(ctx)
return
}
func (mw *loggingService) GetCACert(ctx context.Context, message string) (cert []byte, certNum int, err error) {
defer func(begin time.Time) {
_ = mw.logger.Log(
"method", "GetCACert",
"message", message,
"err", err,
"took", time.Since(begin),
)
}(time.Now())
cert, certNum, err = mw.Service.GetCACert(ctx, message)
return
}
func (mw *loggingService) PKIOperation(ctx context.Context, data []byte) (certRep []byte, err error) {
defer func(begin time.Time) {
_ = mw.logger.Log(
"method", "PKIOperation",
"err", err,
"took", time.Since(begin),
)
}(time.Now())
certRep, err = mw.Service.PKIOperation(ctx, data)
return
}
|
