dstepanov-yadro
/
frostfs-node
forked from TrueCloudLab/frostfs-node
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[#13] services/object: Implement GetRangeHash handlers 

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
support/v0.27
Leonard Lyubich 2020-08-25 19:18:24 +03:00 committed by Alex Vanin
parent 7765671502
commit 0c83e84613
2 changed files with 31 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/services/object/executor.go
View File

@ -205,6 +205,15 @@ func (s *executorSvc) GetRange(ctx context.Context, req *object.GetRangeRequest)
}, nil
}
func (*executorSvc) GetRangeHash(context.Context, *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error) {
panic("implement me")
func (s *executorSvc) GetRangeHash(ctx context.Context, req *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error) {
respBody, err := s.exec.GetRangeHash(ctx, req.GetBody())
if err != nil {
return nil, errors.Wrap(err, "could not execute GetRangeHash request")
}
resp := new(object.GetRangeHashResponse)
resp.SetBody(respBody)
resp.SetMetaHeader(s.metaHeader)
return resp, nil
}

28
pkg/services/object/sign.go
View File

@ -13,12 +13,13 @@ import (
type signService struct {
key *ecdsa.PrivateKey
searchSigService *util.UnarySignService
getSigService *util.UnarySignService
putService object.Service
rangeSigService *util.UnarySignService
headSigService *util.UnarySignService
delSigService *util.UnarySignService
searchSigService *util.UnarySignService
getSigService *util.UnarySignService
putService object.Service
rangeSigService *util.UnarySignService
headSigService *util.UnarySignService
delSigService *util.UnarySignService
rangeHashSigService *util.UnarySignService
}
type searchStreamSigner struct {
@ -79,6 +80,12 @@ func NewSignService(key *ecdsa.PrivateKey, svc object.Service) object.Service {
return svc.Delete(ctx, req.(*object.DeleteRequest))
},
),
rangeHashSigService: util.NewUnarySignService(
key,
func(ctx context.Context, req interface{}) (interface{}, error) {
return svc.GetRangeHash(ctx, req.(*object.GetRangeHashRequest))
},
),
}
}
@ -208,6 +215,11 @@ func (s *signService) GetRange(ctx context.Context, req *object.GetRangeRequest)
}, nil
}
func (s *signService) GetRangeHash(context.Context, *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error) {
panic("implement me")
func (s *signService) GetRangeHash(ctx context.Context, req *object.GetRangeHashRequest) (*object.GetRangeHashResponse, error) {
resp, err := s.rangeHashSigService.HandleUnaryRequest(ctx, req)
if err != nil {
return nil, err
}
return resp.(*object.GetRangeHashResponse), nil
}