frostfs-node/internal/audit/request.go

package audit

import (
	"context"

	crypto "git.frostfs.info/TrueCloudLab/frostfs-crypto"
	"git.frostfs.info/TrueCloudLab/frostfs-node/internal/logs"
	"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/util/logger"
	"git.frostfs.info/TrueCloudLab/frostfs-sdk-go/api/session"
	"github.com/nspcc-dev/neo-go/pkg/crypto/keys"
	"go.uber.org/zap"
)

type Request interface {
	GetVerificationHeader() *session.RequestVerificationHeader
}

type Target interface {
	String() string
}

func LogRequest(ctx context.Context, log *logger.Logger, operation string, req Request, target Target, status bool) {
	var key []byte
	if req != nil {
		key = req.GetVerificationHeader().GetBodySignature().GetKey()
	}
	LogRequestWithKey(ctx, log, operation, key, target, status)
}

func LogRequestWithKey(ctx context.Context, log *logger.Logger, operation string, key []byte, target Target, status bool) {
	object, subject := NotDefined, NotDefined

	publicKey := crypto.UnmarshalPublicKey(key)
	if publicKey != nil {
		subject = ((*keys.PublicKey)(publicKey)).StringCompressed()
	}

	if target != nil {
		object = target.String()
	}

	log.Info(ctx, logs.AuditEventLogRecord,
		zap.String("operation", operation),
		zap.String("object", object),
		zap.String("subject", subject),
		zap.Bool("success", status))
}