forked from TrueCloudLab/frostfs-node
87 lines
2.7 KiB
Go
87 lines
2.7 KiB
Go
|
package container
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"sync/atomic"
|
||
|
|
|
||
|
|
"git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/container"
|
||
|
|
container_grpc "git.frostfs.info/TrueCloudLab/frostfs-api-go/v2/container/grpc"
|
||
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/internal/audit"
|
||
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/util/logger"
|
||
|
|
cid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/container/id"
|
||
|
|
"git.frostfs.info/TrueCloudLab/frostfs-sdk-go/user"
|
||
|
|
)
|
||
|
|
|
||
|
|
var _ Server = (*auditService)(nil)
|
||
|
|
|
||
|
|
type auditService struct {
|
||
|
|
next Server
|
||
|
|
log *logger.Logger
|
||
|
|
enabled *atomic.Bool
|
||
|
|
}
|
||
|
|
|
||
|
|
func NewAuditService(next Server, log *logger.Logger, enabled *atomic.Bool) Server {
|
||
|
|
return &auditService{
|
||
|
|
next: next,
|
||
|
|
log: log,
|
||
|
|
enabled: enabled,
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Delete implements Server.
|
||
|
|
func (a *auditService) Delete(ctx context.Context, req *container.DeleteRequest) (*container.DeleteResponse, error) {
|
||
|
|
res, err := a.next.Delete(ctx, req)
|
||
|
|
if !a.enabled.Load() {
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
audit.LogRequest(a.log, container_grpc.ContainerService_Delete_FullMethodName, req,
|
||
|
|
audit.TargetFromRef(req.GetBody().GetContainerID(), &cid.ID{}), err == nil)
|
||
|
|
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Get implements Server.
|
||
|
|
func (a *auditService) Get(ctx context.Context, req *container.GetRequest) (*container.GetResponse, error) {
|
||
|
|
res, err := a.next.Get(ctx, req)
|
||
|
|
if !a.enabled.Load() {
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
audit.LogRequest(a.log, container_grpc.ContainerService_Get_FullMethodName, req,
|
||
|
|
audit.TargetFromRef(req.GetBody().GetContainerID(), &cid.ID{}), err == nil)
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// GetExtendedACL implements Server.
|
||
|
|
func (a *auditService) GetExtendedACL(ctx context.Context, req *container.GetExtendedACLRequest) (*container.GetExtendedACLResponse, error) {
|
||
|
|
res, err := a.next.GetExtendedACL(ctx, req)
|
||
|
|
if !a.enabled.Load() {
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
audit.LogRequest(a.log, container_grpc.ContainerService_GetExtendedACL_FullMethodName, req,
|
||
|
|
audit.TargetFromRef(req.GetBody().GetContainerID(), &cid.ID{}), err == nil)
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// List implements Server.
|
||
|
|
func (a *auditService) List(ctx context.Context, req *container.ListRequest) (*container.ListResponse, error) {
|
||
|
|
res, err := a.next.List(ctx, req)
|
||
|
|
if !a.enabled.Load() {
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
audit.LogRequest(a.log, container_grpc.ContainerService_List_FullMethodName, req,
|
||
|
|
audit.TargetFromRef(req.GetBody().GetOwnerID(), &user.ID{}), err == nil)
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
|
||
|
|
// Put implements Server.
|
||
|
|
func (a *auditService) Put(ctx context.Context, req *container.PutRequest) (*container.PutResponse, error) {
|
||
|
|
res, err := a.next.Put(ctx, req)
|
||
|
|
if !a.enabled.Load() {
|
||
|
|
return res, err
|
||
|
|
}
|
||
|
|
audit.LogRequest(a.log, container_grpc.ContainerService_Put_FullMethodName, req,
|
||
|
|
audit.TargetFromRef(res.GetBody().GetContainerID(), &cid.ID{}), err == nil)
|
||
|
|
return res, err
|
||
|
|
}
|