chore: update reva
This commit is contained in:
@@ -13,7 +13,7 @@ require (
|
|||||||
github.com/coreos/go-oidc v2.2.1+incompatible
|
github.com/coreos/go-oidc v2.2.1+incompatible
|
||||||
github.com/coreos/go-oidc/v3 v3.8.0
|
github.com/coreos/go-oidc/v3 v3.8.0
|
||||||
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781
|
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781
|
||||||
github.com/cs3org/reva/v2 v2.16.1-0.20231201122033-a389ddc645c4
|
github.com/cs3org/reva/v2 v2.16.1-0.20231206110211-7198abf507f6
|
||||||
github.com/dhowden/tag v0.0.0-20230630033851-978a0926ee25
|
github.com/dhowden/tag v0.0.0-20230630033851-978a0926ee25
|
||||||
github.com/disintegration/imaging v1.6.2
|
github.com/disintegration/imaging v1.6.2
|
||||||
github.com/dutchcoders/go-clamd v0.0.0-20170520113014-b970184f4d9e
|
github.com/dutchcoders/go-clamd v0.0.0-20170520113014-b970184f4d9e
|
||||||
|
|||||||
@@ -1017,8 +1017,8 @@ github.com/crewjam/saml v0.4.14 h1:g9FBNx62osKusnFzs3QTN5L9CVA/Egfgm+stJShzw/c=
|
|||||||
github.com/crewjam/saml v0.4.14/go.mod h1:UVSZCf18jJkk6GpWNVqcyQJMD5HsRugBPf4I1nl2mME=
|
github.com/crewjam/saml v0.4.14/go.mod h1:UVSZCf18jJkk6GpWNVqcyQJMD5HsRugBPf4I1nl2mME=
|
||||||
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781 h1:BUdwkIlf8IS2FasrrPg8gGPHQPOrQ18MS1Oew2tmGtY=
|
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781 h1:BUdwkIlf8IS2FasrrPg8gGPHQPOrQ18MS1Oew2tmGtY=
|
||||||
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781/go.mod h1:UXha4TguuB52H14EMoSsCqDj7k8a/t7g4gVP+bgY5LY=
|
github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781/go.mod h1:UXha4TguuB52H14EMoSsCqDj7k8a/t7g4gVP+bgY5LY=
|
||||||
github.com/cs3org/reva/v2 v2.16.1-0.20231201122033-a389ddc645c4 h1:61AwMfov2OxrUElWXXKHZfBsuxgNIVwZVQW4PlJoqnM=
|
github.com/cs3org/reva/v2 v2.16.1-0.20231206110211-7198abf507f6 h1:wR1XlTT8ilWd5Yd943yayvRPyz1GBaAt7vZ9SOxHzqI=
|
||||||
github.com/cs3org/reva/v2 v2.16.1-0.20231201122033-a389ddc645c4/go.mod h1:zcrrYVsBv/DwhpyO2/W5hoSZ/k6az6Z2EYQok65uqZY=
|
github.com/cs3org/reva/v2 v2.16.1-0.20231206110211-7198abf507f6/go.mod h1:zcrrYVsBv/DwhpyO2/W5hoSZ/k6az6Z2EYQok65uqZY=
|
||||||
github.com/cyberdelia/templates v0.0.0-20141128023046-ca7fffd4298c/go.mod h1:GyV+0YP4qX0UQ7r2MoYZ+AvYDp12OF5yg4q8rGnyNh4=
|
github.com/cyberdelia/templates v0.0.0-20141128023046-ca7fffd4298c/go.mod h1:GyV+0YP4qX0UQ7r2MoYZ+AvYDp12OF5yg4q8rGnyNh4=
|
||||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
|
||||||
@@ -1682,6 +1682,8 @@ github.com/maxymania/go-system v0.0.0-20170110133659-647cc364bf0b h1:Q53idHrTuQD
|
|||||||
github.com/maxymania/go-system v0.0.0-20170110133659-647cc364bf0b/go.mod h1:KirJrATYGbTyUwVR26xIkaipRqRcMRXBf8N5dacvGus=
|
github.com/maxymania/go-system v0.0.0-20170110133659-647cc364bf0b/go.mod h1:KirJrATYGbTyUwVR26xIkaipRqRcMRXBf8N5dacvGus=
|
||||||
github.com/mendsley/gojwk v0.0.0-20141217222730-4d5ec6e58103 h1:Z/i1e+gTZrmcGeZyWckaLfucYG6KYOXLWo4co8pZYNY=
|
github.com/mendsley/gojwk v0.0.0-20141217222730-4d5ec6e58103 h1:Z/i1e+gTZrmcGeZyWckaLfucYG6KYOXLWo4co8pZYNY=
|
||||||
github.com/mendsley/gojwk v0.0.0-20141217222730-4d5ec6e58103/go.mod h1:o9YPB5aGP8ob35Vy6+vyq3P3bWe7NQWzf+JLiXCiMaE=
|
github.com/mendsley/gojwk v0.0.0-20141217222730-4d5ec6e58103/go.mod h1:o9YPB5aGP8ob35Vy6+vyq3P3bWe7NQWzf+JLiXCiMaE=
|
||||||
|
github.com/micbar/reva/v2 v2.0.0-20231206102158-0fd5eba44b02 h1:J28bUNh/2K4OUFJdWoCt6zGQF2QALu4K/r6H3bTYodQ=
|
||||||
|
github.com/micbar/reva/v2 v2.0.0-20231206102158-0fd5eba44b02/go.mod h1:zcrrYVsBv/DwhpyO2/W5hoSZ/k6az6Z2EYQok65uqZY=
|
||||||
github.com/miekg/dns v1.0.14/go.mod h1:W1PPwlIAgtquWBMBEV9nkV9Cazfe8ScdGz/Lj7v3Nrg=
|
github.com/miekg/dns v1.0.14/go.mod h1:W1PPwlIAgtquWBMBEV9nkV9Cazfe8ScdGz/Lj7v3Nrg=
|
||||||
github.com/miekg/dns v1.1.26/go.mod h1:bPDLeHnStXmXAq1m/Ch/hvfNHr14JKNPMBo3VZKjuso=
|
github.com/miekg/dns v1.1.26/go.mod h1:bPDLeHnStXmXAq1m/Ch/hvfNHr14JKNPMBo3VZKjuso=
|
||||||
github.com/miekg/dns v1.1.40/go.mod h1:KNUDUusw/aVsxyTYZM1oqvCicbwhgbNgztCETuNZ7xM=
|
github.com/miekg/dns v1.1.40/go.mod h1:KNUDUusw/aVsxyTYZM1oqvCicbwhgbNgztCETuNZ7xM=
|
||||||
|
|||||||
Generated
Vendored
+3
-3
@@ -123,9 +123,9 @@ func (s *svc) updateShare(ctx context.Context, req *collaboration.UpdateShareReq
|
|||||||
if s.c.CommitShareToStorageGrant {
|
if s.c.CommitShareToStorageGrant {
|
||||||
creator := ctxpkg.ContextMustGetUser(ctx)
|
creator := ctxpkg.ContextMustGetUser(ctx)
|
||||||
grant := &provider.Grant{
|
grant := &provider.Grant{
|
||||||
Grantee: req.GetShare().GetGrantee(),
|
Grantee: res.GetShare().GetGrantee(),
|
||||||
Permissions: req.GetShare().GetPermissions().GetPermissions(),
|
Permissions: res.GetShare().GetPermissions().GetPermissions(),
|
||||||
Expiration: req.GetShare().GetExpiration(),
|
Expiration: res.GetShare().GetExpiration(),
|
||||||
Creator: creator.GetId(),
|
Creator: creator.GetId(),
|
||||||
}
|
}
|
||||||
updateGrantStatus, err := s.updateGrant(ctx, res.GetShare().GetResourceId(), grant, nil)
|
updateGrantStatus, err := s.updateGrant(ctx, res.GetShare().GetResourceId(), grant, nil)
|
||||||
|
|||||||
Generated
Vendored
+223
-18
@@ -20,10 +20,21 @@ package publicshareprovider
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"fmt"
|
||||||
"regexp"
|
"regexp"
|
||||||
|
"strconv"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
gateway "github.com/cs3org/go-cs3apis/cs3/gateway/v1beta1"
|
||||||
rpc "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
|
rpc "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
|
||||||
link "github.com/cs3org/go-cs3apis/cs3/sharing/link/v1beta1"
|
link "github.com/cs3org/go-cs3apis/cs3/sharing/link/v1beta1"
|
||||||
|
provider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/password"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/permission"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/rgrpc/todo/pool"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/sharedconf"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/storage/utils/grants"
|
||||||
|
"github.com/cs3org/reva/v2/pkg/utils"
|
||||||
"github.com/mitchellh/mapstructure"
|
"github.com/mitchellh/mapstructure"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
"google.golang.org/grpc"
|
"google.golang.org/grpc"
|
||||||
@@ -38,6 +49,8 @@ import (
|
|||||||
"github.com/cs3org/reva/v2/pkg/rgrpc/status"
|
"github.com/cs3org/reva/v2/pkg/rgrpc/status"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
const getUserCtxErrMsg = "error getting user from context"
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
rgrpc.Register("publicshareprovider", New)
|
rgrpc.Register("publicshareprovider", New)
|
||||||
}
|
}
|
||||||
@@ -45,9 +58,21 @@ func init() {
|
|||||||
type config struct {
|
type config struct {
|
||||||
Driver string `mapstructure:"driver"`
|
Driver string `mapstructure:"driver"`
|
||||||
Drivers map[string]map[string]interface{} `mapstructure:"drivers"`
|
Drivers map[string]map[string]interface{} `mapstructure:"drivers"`
|
||||||
|
GatewayAddr string `mapstructure:"gateway_addr"`
|
||||||
AllowedPathsForShares []string `mapstructure:"allowed_paths_for_shares"`
|
AllowedPathsForShares []string `mapstructure:"allowed_paths_for_shares"`
|
||||||
EnableExpiredSharesCleanup bool `mapstructure:"enable_expired_shares_cleanup"`
|
EnableExpiredSharesCleanup bool `mapstructure:"enable_expired_shares_cleanup"`
|
||||||
WriteableShareMustHavePassword bool `mapstructure:"writeable_share_must_have_password"`
|
WriteableShareMustHavePassword bool `mapstructure:"writeable_share_must_have_password"`
|
||||||
|
PublicShareMustHavePassword bool `mapstructure:"public_share_must_have_password"`
|
||||||
|
PasswordPolicy map[string]interface{} `mapstructure:"password_policy"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type passwordPolicy struct {
|
||||||
|
MinCharacters int `mapstructure:"min_characters"`
|
||||||
|
MinLowerCaseCharacters int `mapstructure:"min_lowercase_characters"`
|
||||||
|
MinUpperCaseCharacters int `mapstructure:"min_uppercase_characters"`
|
||||||
|
MinDigits int `mapstructure:"min_digits"`
|
||||||
|
MinSpecialCharacters int `mapstructure:"min_special_characters"`
|
||||||
|
BannedPasswordsList map[string]struct{} `mapstructure:"banned_passwords_list"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *config) init() {
|
func (c *config) init() {
|
||||||
@@ -59,7 +84,9 @@ func (c *config) init() {
|
|||||||
type service struct {
|
type service struct {
|
||||||
conf *config
|
conf *config
|
||||||
sm publicshare.Manager
|
sm publicshare.Manager
|
||||||
|
gatewaySelector pool.Selectable[gateway.GatewayAPIClient]
|
||||||
allowedPathsForShares []*regexp.Regexp
|
allowedPathsForShares []*regexp.Regexp
|
||||||
|
passwordValidator password.Validator
|
||||||
}
|
}
|
||||||
|
|
||||||
func getShareManager(c *config) (publicshare.Manager, error) {
|
func getShareManager(c *config) (publicshare.Manager, error) {
|
||||||
@@ -84,12 +111,21 @@ func (s *service) Register(ss *grpc.Server) {
|
|||||||
func parseConfig(m map[string]interface{}) (*config, error) {
|
func parseConfig(m map[string]interface{}) (*config, error) {
|
||||||
c := &config{}
|
c := &config{}
|
||||||
if err := mapstructure.Decode(m, c); err != nil {
|
if err := mapstructure.Decode(m, c); err != nil {
|
||||||
err = errors.Wrap(err, "error decoding conf")
|
err = errors.Wrap(err, "error decoding config")
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return c, nil
|
return c, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func parsePasswordPolicy(m map[string]interface{}) (*passwordPolicy, error) {
|
||||||
|
p := &passwordPolicy{}
|
||||||
|
if err := mapstructure.Decode(m, p); err != nil {
|
||||||
|
err = errors.Wrap(err, "error decoding password policy config")
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return p, nil
|
||||||
|
}
|
||||||
|
|
||||||
// New creates a new user share provider svc
|
// New creates a new user share provider svc
|
||||||
func New(m map[string]interface{}, ss *grpc.Server) (rgrpc.Service, error) {
|
func New(m map[string]interface{}, ss *grpc.Server) (rgrpc.Service, error) {
|
||||||
|
|
||||||
@@ -97,6 +133,10 @@ func New(m map[string]interface{}, ss *grpc.Server) (rgrpc.Service, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
p, err := parsePasswordPolicy(c.PasswordPolicy)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
c.init()
|
c.init()
|
||||||
|
|
||||||
@@ -114,15 +154,36 @@ func New(m map[string]interface{}, ss *grpc.Server) (rgrpc.Service, error) {
|
|||||||
allowedPathsForShares = append(allowedPathsForShares, regex)
|
allowedPathsForShares = append(allowedPathsForShares, regex)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
gatewaySelector, err := pool.GatewaySelector(sharedconf.GetGatewaySVC(c.GatewayAddr))
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
service := &service{
|
service := &service{
|
||||||
conf: c,
|
conf: c,
|
||||||
sm: sm,
|
sm: sm,
|
||||||
|
gatewaySelector: gatewaySelector,
|
||||||
allowedPathsForShares: allowedPathsForShares,
|
allowedPathsForShares: allowedPathsForShares,
|
||||||
|
passwordValidator: newPasswordPolicy(p),
|
||||||
}
|
}
|
||||||
|
|
||||||
return service, nil
|
return service, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func newPasswordPolicy(c *passwordPolicy) password.Validator {
|
||||||
|
if c == nil {
|
||||||
|
return password.NewPasswordPolicy(0, 0, 0, 0, 0, nil)
|
||||||
|
}
|
||||||
|
return password.NewPasswordPolicy(
|
||||||
|
c.MinCharacters,
|
||||||
|
c.MinLowerCaseCharacters,
|
||||||
|
c.MinUpperCaseCharacters,
|
||||||
|
c.MinDigits,
|
||||||
|
c.MinSpecialCharacters,
|
||||||
|
c.BannedPasswordsList,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
func (s *service) isPathAllowed(path string) bool {
|
func (s *service) isPathAllowed(path string) bool {
|
||||||
if len(s.allowedPathsForShares) == 0 {
|
if len(s.allowedPathsForShares) == 0 {
|
||||||
return true
|
return true
|
||||||
@@ -139,33 +200,129 @@ func (s *service) CreatePublicShare(ctx context.Context, req *link.CreatePublicS
|
|||||||
log := appctx.GetLogger(ctx)
|
log := appctx.GetLogger(ctx)
|
||||||
log.Info().Str("publicshareprovider", "create").Msg("create public share")
|
log.Info().Str("publicshareprovider", "create").Msg("create public share")
|
||||||
|
|
||||||
if !conversions.SufficientCS3Permissions(req.GetResourceInfo().GetPermissionSet(), req.GetGrant().GetPermissions().GetPermissions()) {
|
gatewayClient, err := s.gatewaySelector.Next()
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
isInternalLink := grants.PermissionsEqual(req.GetGrant().GetPermissions().GetPermissions(), &provider.ResourcePermissions{})
|
||||||
|
|
||||||
|
sRes, err := gatewayClient.Stat(ctx, &provider.StatRequest{Ref: &provider.Reference{ResourceId: req.GetResourceInfo().GetId()}})
|
||||||
|
if err != nil {
|
||||||
|
log.Err(err).Interface("resource_id", req.GetResourceInfo().GetId()).Msg("failed to stat resource to share")
|
||||||
return &link.CreatePublicShareResponse{
|
return &link.CreatePublicShareResponse{
|
||||||
Status: status.NewInvalid(ctx, "insufficient permissions to create that kind of share"),
|
Status: status.NewInternal(ctx, "failed to stat resource to share"),
|
||||||
|
}, err
|
||||||
|
}
|
||||||
|
|
||||||
|
// all users can create internal links
|
||||||
|
if !isInternalLink {
|
||||||
|
// check if the user has the permission in the user role
|
||||||
|
ok, err := utils.CheckPermission(ctx, permission.WritePublicLink, gatewayClient)
|
||||||
|
if err != nil {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInternal(ctx, "failed check user permission to write public link"),
|
||||||
|
}, err
|
||||||
|
}
|
||||||
|
if !ok {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewPermissionDenied(ctx, nil, "no permission to create public links"),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// check that user has share permissions
|
||||||
|
if !sRes.GetInfo().GetPermissionSet().AddGrant {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInvalidArg(ctx, "no share permission"),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !s.isPathAllowed(req.ResourceInfo.Path) {
|
// check if the user can share with the desired permissions
|
||||||
|
if !conversions.SufficientCS3Permissions(sRes.GetInfo().GetPermissionSet(), req.GetGrant().GetPermissions().GetPermissions()) {
|
||||||
return &link.CreatePublicShareResponse{
|
return &link.CreatePublicShareResponse{
|
||||||
Status: status.NewInvalid(ctx, "share creation is not allowed for the specified path"),
|
Status: status.NewInvalidArg(ctx, "insufficient permissions to create that kind of share"),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// validate path
|
||||||
|
if !s.isPathAllowed(req.GetResourceInfo().GetPath()) {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewFailedPrecondition(ctx, nil, "share creation is not allowed for the specified path"),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// check that this is a not a personal space root
|
||||||
|
if req.GetResourceInfo().GetId().GetOpaqueId() == req.GetResourceInfo().GetId().GetSpaceId() &&
|
||||||
|
req.GetResourceInfo().GetSpace().GetSpaceType() == "personal" {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInvalidArg(ctx, "cannot create link on personal space root"),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// quick link returns the existing one if already present
|
||||||
|
quickLink, err := checkQuicklink(req.GetResourceInfo())
|
||||||
|
if err != nil {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInvalidArg(ctx, "invalid quicklink value"),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
if quickLink {
|
||||||
|
f := []*link.ListPublicSharesRequest_Filter{publicshare.ResourceIDFilter(req.GetResourceInfo().GetId())}
|
||||||
|
req := link.ListPublicSharesRequest{Filters: f}
|
||||||
|
res, err := s.ListPublicShares(ctx, &req)
|
||||||
|
if err != nil || res.GetStatus().GetCode() != rpc.Code_CODE_OK {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInternal(ctx, "could not list public links"),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
for _, l := range res.GetShare() {
|
||||||
|
if l.Quicklink {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewOK(ctx),
|
||||||
|
Share: l,
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
grant := req.GetGrant()
|
grant := req.GetGrant()
|
||||||
if grant != nil && s.conf.WriteableShareMustHavePassword &&
|
|
||||||
publicshare.IsWriteable(grant.GetPermissions()) && grant.Password == "" {
|
// validate expiration date
|
||||||
|
if grant.GetExpiration() != nil {
|
||||||
|
expirationDateTime := utils.TSToTime(grant.GetExpiration()).UTC()
|
||||||
|
if expirationDateTime.Before(time.Now().UTC()) {
|
||||||
|
msg := fmt.Sprintf("expiration date is in the past: %s", expirationDateTime.Format(time.RFC3339))
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInvalidArg(ctx, msg),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// enforce password if needed
|
||||||
|
setPassword := grant.GetPassword()
|
||||||
|
if !isInternalLink && enforcePassword(grant, s.conf) && len(setPassword) == 0 {
|
||||||
return &link.CreatePublicShareResponse{
|
return &link.CreatePublicShareResponse{
|
||||||
Status: status.NewInvalid(ctx, "writeable shares must have a password protection"),
|
Status: status.NewInvalidArg(ctx, "password protection is enforced"),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// validate password policy
|
||||||
|
if len(setPassword) > 0 {
|
||||||
|
if err := s.passwordValidator.Validate(setPassword); err != nil {
|
||||||
|
return &link.CreatePublicShareResponse{
|
||||||
|
Status: status.NewInvalidArg(ctx, err.Error()),
|
||||||
|
}, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
u, ok := ctxpkg.ContextGetUser(ctx)
|
u, ok := ctxpkg.ContextGetUser(ctx)
|
||||||
if !ok {
|
if !ok {
|
||||||
log.Error().Msg("error getting user from context")
|
log.Error().Msg(getUserCtxErrMsg)
|
||||||
}
|
}
|
||||||
|
|
||||||
res := &link.CreatePublicShareResponse{}
|
res := &link.CreatePublicShareResponse{}
|
||||||
share, err := s.sm.CreatePublicShare(ctx, u, req.ResourceInfo, req.Grant)
|
share, err := s.sm.CreatePublicShare(ctx, u, req.GetResourceInfo(), req.GetGrant())
|
||||||
switch {
|
switch {
|
||||||
case err != nil:
|
case err != nil:
|
||||||
log.Error().Err(err).Interface("request", req).Msg("could not write public share")
|
log.Error().Err(err).Interface("request", req).Msg("could not write public share")
|
||||||
@@ -179,11 +336,37 @@ func (s *service) CreatePublicShare(ctx context.Context, req *link.CreatePublicS
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *service) RemovePublicShare(ctx context.Context, req *link.RemovePublicShareRequest) (*link.RemovePublicShareResponse, error) {
|
func (s *service) RemovePublicShare(ctx context.Context, req *link.RemovePublicShareRequest) (*link.RemovePublicShareResponse, error) {
|
||||||
|
gatewayClient, err := s.gatewaySelector.Next()
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
log := appctx.GetLogger(ctx)
|
log := appctx.GetLogger(ctx)
|
||||||
log.Info().Str("publicshareprovider", "remove").Msg("remove public share")
|
log.Info().Str("publicshareprovider", "remove").Msg("remove public share")
|
||||||
|
|
||||||
user := ctxpkg.ContextMustGetUser(ctx)
|
user := ctxpkg.ContextMustGetUser(ctx)
|
||||||
err := s.sm.RevokePublicShare(ctx, user, req.Ref)
|
ps, err := s.sm.GetPublicShare(ctx, user, req.GetRef(), false)
|
||||||
|
if err != nil {
|
||||||
|
return &link.RemovePublicShareResponse{
|
||||||
|
Status: status.NewInternal(ctx, "error loading public share"),
|
||||||
|
}, err
|
||||||
|
}
|
||||||
|
if !publicshare.IsCreatedByUser(*ps, user) {
|
||||||
|
sRes, err := gatewayClient.Stat(ctx, &provider.StatRequest{Ref: &provider.Reference{ResourceId: ps.ResourceId}})
|
||||||
|
if err != nil {
|
||||||
|
log.Err(err).Interface("resource_id", ps.ResourceId).Msg("failed to stat shared resource")
|
||||||
|
return &link.RemovePublicShareResponse{
|
||||||
|
Status: status.NewInternal(ctx, "failed to stat shared resource"),
|
||||||
|
}, err
|
||||||
|
}
|
||||||
|
|
||||||
|
if !sRes.GetInfo().GetPermissionSet().RemoveGrant {
|
||||||
|
return &link.RemovePublicShareResponse{
|
||||||
|
Status: status.NewPermissionDenied(ctx, nil, "no permission to delete public share"),
|
||||||
|
}, err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
err = s.sm.RevokePublicShare(ctx, user, req.Ref)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return &link.RemovePublicShareResponse{
|
return &link.RemovePublicShareResponse{
|
||||||
Status: status.NewInternal(ctx, "error deleting public share"),
|
Status: status.NewInternal(ctx, "error deleting public share"),
|
||||||
@@ -227,7 +410,7 @@ func (s *service) GetPublicShare(ctx context.Context, req *link.GetPublicShareRe
|
|||||||
|
|
||||||
u, ok := ctxpkg.ContextGetUser(ctx)
|
u, ok := ctxpkg.ContextGetUser(ctx)
|
||||||
if !ok {
|
if !ok {
|
||||||
log.Error().Msg("error getting user from context")
|
log.Error().Msg(getUserCtxErrMsg)
|
||||||
}
|
}
|
||||||
|
|
||||||
ps, err := s.sm.GetPublicShare(ctx, u, req.Ref, req.GetSign())
|
ps, err := s.sm.GetPublicShare(ctx, u, req.Ref, req.GetSign())
|
||||||
@@ -281,16 +464,11 @@ func (s *service) UpdatePublicShare(ctx context.Context, req *link.UpdatePublicS
|
|||||||
|
|
||||||
u, ok := ctxpkg.ContextGetUser(ctx)
|
u, ok := ctxpkg.ContextGetUser(ctx)
|
||||||
if !ok {
|
if !ok {
|
||||||
log.Error().Msg("error getting user from context")
|
log.Error().Msg(getUserCtxErrMsg)
|
||||||
}
|
}
|
||||||
|
|
||||||
updateR, err := s.sm.UpdatePublicShare(ctx, u, req)
|
updateR, err := s.sm.UpdatePublicShare(ctx, u, req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if errors.Is(err, publicshare.ErrShareNeedsPassword) {
|
|
||||||
return &link.UpdatePublicShareResponse{
|
|
||||||
Status: status.NewInvalid(ctx, err.Error()),
|
|
||||||
}, nil
|
|
||||||
}
|
|
||||||
return &link.UpdatePublicShareResponse{
|
return &link.UpdatePublicShareResponse{
|
||||||
Status: status.NewInternal(ctx, err.Error()),
|
Status: status.NewInternal(ctx, err.Error()),
|
||||||
}, nil
|
}, nil
|
||||||
@@ -302,3 +480,30 @@ func (s *service) UpdatePublicShare(ctx context.Context, req *link.UpdatePublicS
|
|||||||
}
|
}
|
||||||
return res, nil
|
return res, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func enforcePassword(grant *link.Grant, conf *config) bool {
|
||||||
|
if conf.PublicShareMustHavePassword {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
isReadOnly := conversions.SufficientCS3Permissions(conversions.NewViewerRole(true).CS3ResourcePermissions(), grant.GetPermissions().GetPermissions())
|
||||||
|
return !isReadOnly && conf.WriteableShareMustHavePassword
|
||||||
|
}
|
||||||
|
|
||||||
|
func checkQuicklink(info *provider.ResourceInfo) (bool, error) {
|
||||||
|
if info == nil {
|
||||||
|
return false, nil
|
||||||
|
}
|
||||||
|
if m := info.GetArbitraryMetadata().GetMetadata(); m != nil {
|
||||||
|
q, ok := m["quicklink"]
|
||||||
|
// empty string would trigger an error in ParseBool()
|
||||||
|
if !ok || q == "" {
|
||||||
|
return false, nil
|
||||||
|
}
|
||||||
|
quickLink, err := strconv.ParseBool(q)
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
|
return quickLink, nil
|
||||||
|
}
|
||||||
|
return false, nil
|
||||||
|
}
|
||||||
|
|||||||
Generated
Vendored
+2
-2
@@ -156,13 +156,13 @@ func (s *service) CreateShare(ctx context.Context, req *collaboration.CreateShar
|
|||||||
req.GetGrant().GetPermissions().GetPermissions(),
|
req.GetGrant().GetPermissions().GetPermissions(),
|
||||||
); !shareCreationAllowed {
|
); !shareCreationAllowed {
|
||||||
return &collaboration.CreateShareResponse{
|
return &collaboration.CreateShareResponse{
|
||||||
Status: status.NewInvalid(ctx, "insufficient permissions to create that kind of share"),
|
Status: status.NewPermissionDenied(ctx, nil, "insufficient permissions to create that kind of share"),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
if !s.isPathAllowed(req.GetResourceInfo().GetPath()) {
|
if !s.isPathAllowed(req.GetResourceInfo().GetPath()) {
|
||||||
return &collaboration.CreateShareResponse{
|
return &collaboration.CreateShareResponse{
|
||||||
Status: status.NewInvalid(ctx, "share creation is not allowed for the specified path"),
|
Status: status.NewFailedPrecondition(ctx, nil, "share creation is not allowed for the specified path"),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+17
-30
@@ -76,7 +76,7 @@ func NewFile(c map[string]interface{}) (publicshare.Manager, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p, conf.WriteableShareMustHavePassword)
|
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p)
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewMemory returns a new in-memory public shares manager.
|
// NewMemory returns a new in-memory public shares manager.
|
||||||
@@ -93,7 +93,7 @@ func NewMemory(c map[string]interface{}) (publicshare.Manager, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p, conf.WriteableShareMustHavePassword)
|
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p)
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewCS3 returns a new cs3 public shares manager.
|
// NewCS3 returns a new cs3 public shares manager.
|
||||||
@@ -115,19 +115,18 @@ func NewCS3(c map[string]interface{}) (publicshare.Manager, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p, conf.WriteableShareMustHavePassword)
|
return New(conf.GatewayAddr, conf.SharePasswordHashCost, conf.JanitorRunInterval, conf.EnableExpiredSharesCleanup, p)
|
||||||
}
|
}
|
||||||
|
|
||||||
// New returns a new public share manager instance
|
// New returns a new public share manager instance
|
||||||
func New(gwAddr string, pwHashCost, janitorRunInterval int, enableCleanup bool, p persistence.Persistence, writeableShareMustHavePassword bool) (publicshare.Manager, error) {
|
func New(gwAddr string, pwHashCost, janitorRunInterval int, enableCleanup bool, p persistence.Persistence) (publicshare.Manager, error) {
|
||||||
m := &manager{
|
m := &manager{
|
||||||
gatewayAddr: gwAddr,
|
gatewayAddr: gwAddr,
|
||||||
mutex: &sync.Mutex{},
|
mutex: &sync.Mutex{},
|
||||||
passwordHashCost: pwHashCost,
|
passwordHashCost: pwHashCost,
|
||||||
janitorRunInterval: janitorRunInterval,
|
janitorRunInterval: janitorRunInterval,
|
||||||
enableExpiredSharesCleanup: enableCleanup,
|
enableExpiredSharesCleanup: enableCleanup,
|
||||||
persistence: p,
|
persistence: p,
|
||||||
writeableShareMustHavePassword: writeableShareMustHavePassword,
|
|
||||||
}
|
}
|
||||||
|
|
||||||
go m.startJanitorRun()
|
go m.startJanitorRun()
|
||||||
@@ -135,11 +134,10 @@ func New(gwAddr string, pwHashCost, janitorRunInterval int, enableCleanup bool,
|
|||||||
}
|
}
|
||||||
|
|
||||||
type commonConfig struct {
|
type commonConfig struct {
|
||||||
GatewayAddr string `mapstructure:"gateway_addr"`
|
GatewayAddr string `mapstructure:"gateway_addr"`
|
||||||
SharePasswordHashCost int `mapstructure:"password_hash_cost"`
|
SharePasswordHashCost int `mapstructure:"password_hash_cost"`
|
||||||
JanitorRunInterval int `mapstructure:"janitor_run_interval"`
|
JanitorRunInterval int `mapstructure:"janitor_run_interval"`
|
||||||
EnableExpiredSharesCleanup bool `mapstructure:"enable_expired_shares_cleanup"`
|
EnableExpiredSharesCleanup bool `mapstructure:"enable_expired_shares_cleanup"`
|
||||||
WriteableShareMustHavePassword bool `mapstructure:"writeable_share_must_have_password"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type fileConfig struct {
|
type fileConfig struct {
|
||||||
@@ -171,10 +169,9 @@ type manager struct {
|
|||||||
mutex *sync.Mutex
|
mutex *sync.Mutex
|
||||||
persistence persistence.Persistence
|
persistence persistence.Persistence
|
||||||
|
|
||||||
passwordHashCost int
|
passwordHashCost int
|
||||||
janitorRunInterval int
|
janitorRunInterval int
|
||||||
enableExpiredSharesCleanup bool
|
enableExpiredSharesCleanup bool
|
||||||
writeableShareMustHavePassword bool
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *manager) startJanitorRun() {
|
func (m *manager) startJanitorRun() {
|
||||||
@@ -343,12 +340,6 @@ func (m *manager) UpdatePublicShare(ctx context.Context, u *user.User, req *link
|
|||||||
old, _ := json.Marshal(share.Permissions)
|
old, _ := json.Marshal(share.Permissions)
|
||||||
new, _ := json.Marshal(req.Update.GetGrant().Permissions)
|
new, _ := json.Marshal(req.Update.GetGrant().Permissions)
|
||||||
|
|
||||||
if m.writeableShareMustHavePassword &&
|
|
||||||
publicshare.IsWriteable(req.GetUpdate().GetGrant().GetPermissions()) &&
|
|
||||||
(!share.PasswordProtected && req.GetUpdate().GetGrant().GetPassword() == "") {
|
|
||||||
return nil, publicshare.ErrShareNeedsPassword
|
|
||||||
}
|
|
||||||
|
|
||||||
if req.GetUpdate().GetGrant().GetPassword() != "" {
|
if req.GetUpdate().GetGrant().GetPassword() != "" {
|
||||||
passwordChanged = true
|
passwordChanged = true
|
||||||
h, err := bcrypt.GenerateFromPassword([]byte(req.Update.GetGrant().Password), m.passwordHashCost)
|
h, err := bcrypt.GenerateFromPassword([]byte(req.Update.GetGrant().Password), m.passwordHashCost)
|
||||||
@@ -369,10 +360,6 @@ func (m *manager) UpdatePublicShare(ctx context.Context, u *user.User, req *link
|
|||||||
case link.UpdatePublicShareRequest_Update_TYPE_PASSWORD:
|
case link.UpdatePublicShareRequest_Update_TYPE_PASSWORD:
|
||||||
passwordChanged = true
|
passwordChanged = true
|
||||||
if req.Update.GetGrant().Password == "" {
|
if req.Update.GetGrant().Password == "" {
|
||||||
if m.writeableShareMustHavePassword && publicshare.IsWriteable(share.Permissions) {
|
|
||||||
return nil, publicshare.ErrShareNeedsPassword
|
|
||||||
}
|
|
||||||
|
|
||||||
share.PasswordProtected = false
|
share.PasswordProtected = false
|
||||||
newPasswordEncoded = ""
|
newPasswordEncoded = ""
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
-6
@@ -24,7 +24,6 @@ import (
|
|||||||
"crypto/sha256"
|
"crypto/sha256"
|
||||||
"crypto/sha512"
|
"crypto/sha512"
|
||||||
"encoding/hex"
|
"encoding/hex"
|
||||||
"errors"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
user "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
|
user "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
|
||||||
@@ -41,11 +40,6 @@ const (
|
|||||||
StorageIDFilterType link.ListPublicSharesRequest_Filter_Type = 4
|
StorageIDFilterType link.ListPublicSharesRequest_Filter_Type = 4
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
|
||||||
// ErrShareNeedsPassword is an error which is returned when a public share must have a password.
|
|
||||||
ErrShareNeedsPassword = errors.New("the public share needs to have a password")
|
|
||||||
)
|
|
||||||
|
|
||||||
// Manager manipulates public shares.
|
// Manager manipulates public shares.
|
||||||
type Manager interface {
|
type Manager interface {
|
||||||
CreatePublicShare(ctx context.Context, u *user.User, md *provider.ResourceInfo, g *link.Grant) (*link.PublicShare, error)
|
CreatePublicShare(ctx context.Context, u *user.User, md *provider.ResourceInfo, g *link.Grant) (*link.PublicShare, error)
|
||||||
|
|||||||
Vendored
+1
-1
@@ -359,7 +359,7 @@ github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1
|
|||||||
github.com/cs3org/go-cs3apis/cs3/storage/registry/v1beta1
|
github.com/cs3org/go-cs3apis/cs3/storage/registry/v1beta1
|
||||||
github.com/cs3org/go-cs3apis/cs3/tx/v1beta1
|
github.com/cs3org/go-cs3apis/cs3/tx/v1beta1
|
||||||
github.com/cs3org/go-cs3apis/cs3/types/v1beta1
|
github.com/cs3org/go-cs3apis/cs3/types/v1beta1
|
||||||
# github.com/cs3org/reva/v2 v2.16.1-0.20231201122033-a389ddc645c4
|
# github.com/cs3org/reva/v2 v2.16.1-0.20231206110211-7198abf507f6
|
||||||
## explicit; go 1.20
|
## explicit; go 1.20
|
||||||
github.com/cs3org/reva/v2/cmd/revad/internal/grace
|
github.com/cs3org/reva/v2/cmd/revad/internal/grace
|
||||||
github.com/cs3org/reva/v2/cmd/revad/runtime
|
github.com/cs3org/reva/v2/cmd/revad/runtime
|
||||||
|
|||||||
Reference in New Issue
Block a user