Bump reva

changelog/unreleased/bump-reva.md

@@ -2,5 +2,6 @@ Enhancement: Bump Reva
 
 bumps reva version
 
+https://github.com/owncloud/ocis/pull/8795
 https://github.com/owncloud/ocis/pull/8701
 https://github.com/owncloud/ocis/pull/8606

go.mod

@@ -14,7 +14,7 @@ require (
 	github.com/cenkalti/backoff v2.2.1+incompatible
 	github.com/coreos/go-oidc/v3 v3.10.0
 	github.com/cs3org/go-cs3apis v0.0.0-20231023073225-7748710e0781
-	github.com/cs3org/reva/v2 v2.19.2-0.20240404085416-251ba8d12f6f
+	github.com/cs3org/reva/v2 v2.19.2-0.20240405190914-ef59ba20ef0e
 	github.com/dhowden/tag v0.0.0-20230630033851-978a0926ee25
 	github.com/disintegration/imaging v1.6.2
 	github.com/dutchcoders/go-clamd v0.0.0-20170520113014-b970184f4d9e

go.sum

@@ -1022,8 +1022,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/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/reva/v2 v2.19.2-0.20240404085416-251ba8d12f6f h1:t4jFaaEmPX8J/jvybuvI7aC1TbU2zSGZabUDQvA5Mr8=
-github.com/cs3org/reva/v2 v2.19.2-0.20240404085416-251ba8d12f6f/go.mod h1:GRUrOp5HbFVwZTgR9bVrMZ/MvVy+Jhxw1PdMmhhKP9E=
+github.com/cs3org/reva/v2 v2.19.2-0.20240405190914-ef59ba20ef0e h1:RAmS/42ZYRrkhvVLWgvJhwjna9zSAqa2DJ8xS7R3Rx0=
+github.com/cs3org/reva/v2 v2.19.2-0.20240405190914-ef59ba20ef0e/go.mod h1:GRUrOp5HbFVwZTgR9bVrMZ/MvVy+Jhxw1PdMmhhKP9E=
 github.com/cyberdelia/templates v0.0.0-20141128023046-ca7fffd4298c/go.mod h1:GyV+0YP4qX0UQ7r2MoYZ+AvYDp12OF5yg4q8rGnyNh4=
 github.com/cyphar/filepath-securejoin v0.2.4 h1:Ugdm7cg7i6ZK6x3xDF1oEu1nfkyfH53EtKeQYTC3kyg=
 github.com/cyphar/filepath-securejoin v0.2.4/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4=

ocis/pkg/command/migrate.go

@@ -106,11 +106,11 @@ func RebuildJSONCS3Indexes(cfg *config.Config) *cli.Command {
 			if err != nil {
 				return err
 			}
-			gc, err := pool.GetGatewayServiceClient(conf.GatewayAddr)
+			gatewaySelector, err := pool.GatewaySelector(conf.GatewayAddr)
 			if err != nil {
 				return err
 			}
-			mgr, err := jsoncs3.New(s, gc, 0, nil, 1)
+			mgr, err := jsoncs3.New(s, gatewaySelector, 0, nil, 1)
 			if err != nil {
 				return err
 			}

vendor/github.com/cs3org/reva/v2/pkg/publicshare/manager/owncloudsql/conversions.go

@@ -33,8 +33,6 @@ import (
 	"github.com/jellydator/ttlcache/v2"
 )
 
-//go:generate make --no-print-directory -C ../../../.. mockery NAME=UserConverter
-
 // DBShare stores information about user and public shares.
 type DBShare struct {
 	ID           string

vendor/github.com/cs3org/reva/v2/pkg/share/manager/jsoncs3/jsoncs3.go

@@ -29,14 +29,6 @@ import (
 	rpcv1beta1 "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
 	collaboration "github.com/cs3org/go-cs3apis/cs3/sharing/collaboration/v1beta1"
 	provider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
-	"github.com/google/uuid"
-	"github.com/mitchellh/mapstructure"
-	"github.com/pkg/errors"
-	"github.com/rs/zerolog/log"
-	"go.opentelemetry.io/otel/codes"
-	"golang.org/x/sync/errgroup"
-	"google.golang.org/genproto/protobuf/field_mask"
-
 	"github.com/cs3org/reva/v2/pkg/appctx"
 	ctxpkg "github.com/cs3org/reva/v2/pkg/ctx"
 	"github.com/cs3org/reva/v2/pkg/errtypes"
@@ -52,6 +44,13 @@ import (
 	"github.com/cs3org/reva/v2/pkg/storage/utils/metadata" // nolint:staticcheck // we need the legacy package to convert V1 to V2 messages
 	"github.com/cs3org/reva/v2/pkg/storagespace"
 	"github.com/cs3org/reva/v2/pkg/utils"
+	"github.com/google/uuid"
+	"github.com/mitchellh/mapstructure"
+	"github.com/pkg/errors"
+	"go.opentelemetry.io/otel/codes"
+	"golang.org/x/sync/errgroup"
+	"google.golang.org/genproto/protobuf/field_mask"
+	"google.golang.org/protobuf/types/known/fieldmaskpb"
 )
 
 /*
@@ -153,8 +152,8 @@ type Manager struct {
 
 	MaxConcurrency int
 
-	gateway     gatewayv1beta1.GatewayAPIClient
-	eventStream events.Stream
+	gatewaySelector pool.Selectable[gatewayv1beta1.GatewayAPIClient]
+	eventStream     events.Stream
 }
 
 // NewDefault returns a new manager instance with default dependencies
@@ -170,7 +169,7 @@ func NewDefault(m map[string]interface{}) (share.Manager, error) {
 		return nil, err
 	}
 
-	gc, err := pool.GetGatewayServiceClient(c.GatewayAddr)
+	gatewaySelector, err := pool.GatewaySelector(c.GatewayAddr)
 	if err != nil {
 		return nil, err
 	}
@@ -183,11 +182,11 @@ func NewDefault(m map[string]interface{}) (share.Manager, error) {
 		}
 	}
 
-	return New(s, gc, c.CacheTTL, es, c.MaxConcurrency)
+	return New(s, gatewaySelector, c.CacheTTL, es, c.MaxConcurrency)
 }
 
 // New returns a new manager instance.
-func New(s metadata.Storage, gc gatewayv1beta1.GatewayAPIClient, ttlSeconds int, es events.Stream, maxconcurrency int) (*Manager, error) {
+func New(s metadata.Storage, gatewaySelector pool.Selectable[gatewayv1beta1.GatewayAPIClient], ttlSeconds int, es events.Stream, maxconcurrency int) (*Manager, error) {
 	ttl := time.Duration(ttlSeconds) * time.Second
 	return &Manager{
 		Cache:              providercache.New(s, ttl),
@@ -195,7 +194,7 @@ func New(s metadata.Storage, gc gatewayv1beta1.GatewayAPIClient, ttlSeconds int,
 		UserReceivedStates: receivedsharecache.New(s, ttl),
 		GroupReceivedCache: sharecache.New(s, "groups", "received.json", ttl),
 		storage:            s,
-		gateway:            gc,
+		gatewaySelector:    gatewaySelector,
 		eventStream:        es,
 		MaxConcurrency:     maxconcurrency,
 	}, nil
@@ -411,6 +410,7 @@ func (m *Manager) get(ctx context.Context, ref *collaboration.ShareReference) (s
 func (m *Manager) GetShare(ctx context.Context, ref *collaboration.ShareReference) (*collaboration.Share, error) {
 	ctx, span := appctx.GetTracerProvider(ctx).Tracer(tracerName).Start(ctx, "GetShare")
 	defer span.End()
+	sublog := appctx.GetLogger(ctx).With().Str("id", ref.GetId().GetOpaqueId()).Str("key", ref.GetKey().String()).Str("driver", "jsoncs3").Str("handler", "GetShare").Logger()
 	if err := m.initialize(ctx); err != nil {
 		return nil, err
 	}
@@ -421,7 +421,7 @@ func (m *Manager) GetShare(ctx context.Context, ref *collaboration.ShareReferenc
 	}
 	if share.IsExpired(s) {
 		if err := m.removeShare(ctx, s); err != nil {
-			log.Error().Err(err).
+			sublog.Error().Err(err).
 				Msg("failed to unshare expired share")
 		}
 		if err := events.Publish(ctx, m.eventStream, events.ShareExpired{
@@ -432,7 +432,7 @@ func (m *Manager) GetShare(ctx context.Context, ref *collaboration.ShareReferenc
 			GranteeUserID:  s.GetGrantee().GetUserId(),
 			GranteeGroupID: s.GetGrantee().GetGroupId(),
 		}); err != nil {
-			log.Error().Err(err).
+			sublog.Error().Err(err).
 				Msg("failed to publish share expired event")
 		}
 	}
@@ -445,8 +445,15 @@ func (m *Manager) GetShare(ctx context.Context, ref *collaboration.ShareReferenc
 
 	req := &provider.StatRequest{
 		Ref: &provider.Reference{ResourceId: s.ResourceId},
+		FieldMask: &fieldmaskpb.FieldMask{
+			Paths: []string{"permissions"},
+		},
 	}
-	res, err := m.gateway.Stat(ctx, req)
+	client, err := m.gatewaySelector.Next()
+	if err != nil {
+		return nil, err
+	}
+	res, err := client.Stat(ctx, req)
 	if err == nil &&
 		res.Status.Code == rpcv1beta1.Code_CODE_OK &&
 		res.Info.PermissionSet.ListGrants {
@@ -523,8 +530,15 @@ func (m *Manager) UpdateShare(ctx context.Context, ref *collaboration.ShareRefer
 	if !share.IsCreatedByUser(toUpdate, user) {
 		req := &provider.StatRequest{
 			Ref: &provider.Reference{ResourceId: toUpdate.ResourceId},
+			FieldMask: &fieldmaskpb.FieldMask{
+				Paths: []string{"permissions"},
+			},
 		}
-		res, err := m.gateway.Stat(ctx, req)
+		client, err := m.gatewaySelector.Next()
+		if err != nil {
+			return nil, err
+		}
+		res, err := client.Stat(ctx, req)
 		if err != nil ||
 			res.Status.Code != rpcv1beta1.Code_CODE_OK ||
 			!res.Info.PermissionSet.UpdateGrant {
@@ -583,6 +597,7 @@ func (m *Manager) ListShares(ctx context.Context, filters []*collaboration.Filte
 func (m *Manager) listSharesByIDs(ctx context.Context, user *userv1beta1.User, filters []*collaboration.Filter) ([]*collaboration.Share, error) {
 	ctx, span := appctx.GetTracerProvider(ctx).Tracer(tracerName).Start(ctx, "listSharesByIDs")
 	defer span.End()
+	sublog := appctx.GetLogger(ctx).With().Str("userid", user.GetId().GetOpaqueId()).Str("useridp", user.GetId().GetIdp()).Str("driver", "jsoncs3").Str("handler", "listSharesByIDs").Logger()
 
 	providerSpaces := make(map[string]map[string]struct{})
 	for _, f := range share.FilterFiltersByType(filters, collaboration.Filter_TYPE_RESOURCE_ID) {
@@ -604,19 +619,21 @@ func (m *Manager) listSharesByIDs(ctx context.Context, user *userv1beta1.User, f
 			}
 
 			for _, s := range shares.Shares {
+				resourceID := s.GetResourceId()
+				sublog = sublog.With().Str("storageid", resourceID.GetStorageId()).Str("spaceid", resourceID.GetSpaceId()).Str("opaqueid", resourceID.GetOpaqueId()).Logger()
 				if share.IsExpired(s) {
 					if err := m.removeShare(ctx, s); err != nil {
-						log.Error().Err(err).
+						sublog.Error().Err(err).
 							Msg("failed to unshare expired share")
 					}
 					if err := events.Publish(ctx, m.eventStream, events.ShareExpired{
 						ShareOwner:     s.GetOwner(),
-						ItemID:         s.GetResourceId(),
+						ItemID:         resourceID,
 						ExpiredAt:      time.Unix(int64(s.GetExpiration().GetSeconds()), int64(s.GetExpiration().GetNanos())),
 						GranteeUserID:  s.GetGrantee().GetUserId(),
 						GranteeGroupID: s.GetGrantee().GetGroupId(),
 					}); err != nil {
-						log.Error().Err(err).
+						sublog.Error().Err(err).
 							Msg("failed to publish share expired event")
 					}
 					continue
@@ -626,17 +643,33 @@ func (m *Manager) listSharesByIDs(ctx context.Context, user *userv1beta1.User, f
 				}
 
 				if !(share.IsCreatedByUser(s, user) || share.IsGrantedToUser(s, user)) {
-					key := storagespace.FormatResourceID(*s.ResourceId)
+					key := storagespace.FormatResourceID(*resourceID)
 					if _, hit := statCache[key]; !hit {
 						req := &provider.StatRequest{
-							Ref: &provider.Reference{ResourceId: s.ResourceId},
+							Ref: &provider.Reference{ResourceId: resourceID},
+							FieldMask: &fieldmaskpb.FieldMask{
+								Paths: []string{"permissions"},
+							},
 						}
-						res, err := m.gateway.Stat(ctx, req)
-						if err != nil ||
-							res.Status.Code != rpcv1beta1.Code_CODE_OK ||
-							!res.Info.PermissionSet.ListGrants {
+						client, err := m.gatewaySelector.Next()
+						if err != nil {
+							sublog.Error().Err(err).Msg("failed to select next gateway client")
 							continue
 						}
+						res, err := client.Stat(ctx, req)
+						if err != nil {
+							sublog.Error().Err(err).Msg("failed to make stat call")
+							continue
+						}
+						if res.Status.Code != rpcv1beta1.Code_CODE_OK {
+							sublog.Debug().Str("code", res.GetStatus().GetCode().String()).Msg(res.GetStatus().GetMessage())
+							continue
+						}
+						if !res.Info.PermissionSet.ListGrants {
+							sublog.Debug().Msg("user has no list grants permission")
+							continue
+						}
+						sublog.Debug().Msg("listing share for non participating user")
 						statCache[key] = struct{}{}
 					}
 				}
@@ -652,6 +685,7 @@ func (m *Manager) listSharesByIDs(ctx context.Context, user *userv1beta1.User, f
 func (m *Manager) listCreatedShares(ctx context.Context, user *userv1beta1.User, filters []*collaboration.Filter) ([]*collaboration.Share, error) {
 	ctx, span := appctx.GetTracerProvider(ctx).Tracer(tracerName).Start(ctx, "listCreatedShares")
 	defer span.End()
+	sublog := appctx.GetLogger(ctx).With().Str("userid", user.GetId().GetOpaqueId()).Str("useridp", user.GetId().GetIdp()).Str("driver", "jsoncs3").Str("handler", "listCreatedShares").Logger()
 
 	list, err := m.CreatedCache.List(ctx, user.Id.OpaqueId)
 	if err != nil {
@@ -694,7 +728,7 @@ func (m *Manager) listCreatedShares(ctx context.Context, user *userv1beta1.User,
 				// fetch all shares from space with one request
 				_, err := m.Cache.ListSpace(ctx, storageID, spaceID)
 				if err != nil {
-					log.Error().Err(err).
+					sublog.Error().Err(err).
 						Str("storageid", storageID).
 						Str("spaceid", spaceID).
 						Msg("failed to list shares in space")
@@ -707,7 +741,7 @@ func (m *Manager) listCreatedShares(ctx context.Context, user *userv1beta1.User,
 					}
 					if share.IsExpired(s) {
 						if err := m.removeShare(ctx, s); err != nil {
-							log.Error().Err(err).
+							sublog.Error().Err(err).
 								Msg("failed to unshare expired share")
 						}
 						if err := events.Publish(ctx, m.eventStream, events.ShareExpired{
@@ -717,7 +751,7 @@ func (m *Manager) listCreatedShares(ctx context.Context, user *userv1beta1.User,
 							GranteeUserID:  s.GetGrantee().GetUserId(),
 							GranteeGroupID: s.GetGrantee().GetGroupId(),
 						}); err != nil {
-							log.Error().Err(err).
+							sublog.Error().Err(err).
 								Msg("failed to publish share expired event")
 						}
 						continue
@@ -762,6 +796,7 @@ func (m *Manager) listCreatedShares(ctx context.Context, user *userv1beta1.User,
 func (m *Manager) ListReceivedShares(ctx context.Context, filters []*collaboration.Filter, forUser *userv1beta1.UserId) ([]*collaboration.ReceivedShare, error) {
 	ctx, span := appctx.GetTracerProvider(ctx).Tracer(tracerName).Start(ctx, "ListReceivedShares")
 	defer span.End()
+	sublog := appctx.GetLogger(ctx).With().Str("driver", "jsoncs3").Str("handler", "ListReceivedShares").Logger()
 
 	if err := m.initialize(ctx); err != nil {
 		return nil, err
@@ -769,7 +804,11 @@ func (m *Manager) ListReceivedShares(ctx context.Context, filters []*collaborati
 
 	user := ctxpkg.ContextMustGetUser(ctx)
 	if user.GetId().GetType() == userv1beta1.UserType_USER_TYPE_SERVICE {
-		u, err := utils.GetUser(forUser, m.gateway)
+		client, err := m.gatewaySelector.Next()
+		if err != nil {
+			return nil, err
+		}
+		u, err := utils.GetUser(forUser, client)
 		if err != nil {
 			return nil, errtypes.BadRequest("user not found")
 		}
@@ -852,12 +891,11 @@ func (m *Manager) ListReceivedShares(ctx context.Context, filters []*collaborati
 		g.Go(func() error {
 			for w := range work {
 				storageID, spaceID, _ := shareid.Decode(w.ssid)
+				sublogr := sublog.With().Str("storageid", storageID).Str("spaceid", spaceID).Logger()
 				// fetch all shares from space with one request
 				_, err := m.Cache.ListSpace(ctx, storageID, spaceID)
 				if err != nil {
-					log.Error().Err(err).
-						Str("storageid", storageID).
-						Str("spaceid", spaceID).
+					sublogr.Error().Err(err).
 						Msg("failed to list shares in space")
 					continue
 				}
@@ -866,9 +904,10 @@ func (m *Manager) ListReceivedShares(ctx context.Context, filters []*collaborati
 					if err != nil || s == nil {
 						continue
 					}
+					sublogr = sublogr.With().Str("shareid", shareID).Logger()
 					if share.IsExpired(s) {
 						if err := m.removeShare(ctx, s); err != nil {
-							log.Error().Err(err).
+							sublogr.Error().Err(err).
 								Msg("failed to unshare expired share")
 						}
 						if err := events.Publish(ctx, m.eventStream, events.ShareExpired{
@@ -878,7 +917,7 @@ func (m *Manager) ListReceivedShares(ctx context.Context, filters []*collaborati
 							GranteeUserID:  s.GetGrantee().GetUserId(),
 							GranteeGroupID: s.GetGrantee().GetGroupId(),
 						}); err != nil {
-							log.Error().Err(err).
+							sublogr.Error().Err(err).
 								Msg("failed to publish share expired event")
 						}
 						continue
@@ -959,6 +998,7 @@ func (m *Manager) GetReceivedShare(ctx context.Context, ref *collaboration.Share
 func (m *Manager) getReceived(ctx context.Context, ref *collaboration.ShareReference) (*collaboration.ReceivedShare, error) {
 	ctx, span := appctx.GetTracerProvider(ctx).Tracer(tracerName).Start(ctx, "getReceived")
 	defer span.End()
+	sublog := appctx.GetLogger(ctx).With().Str("id", ref.GetId().GetOpaqueId()).Str("key", ref.GetKey().String()).Str("driver", "jsoncs3").Str("handler", "getReceived").Logger()
 
 	s, err := m.get(ctx, ref)
 	if err != nil {
@@ -970,7 +1010,7 @@ func (m *Manager) getReceived(ctx context.Context, ref *collaboration.ShareRefer
 	}
 	if share.IsExpired(s) {
 		if err := m.removeShare(ctx, s); err != nil {
-			log.Error().Err(err).
+			sublog.Error().Err(err).
 				Msg("failed to unshare expired share")
 		}
 		if err := events.Publish(ctx, m.eventStream, events.ShareExpired{
@@ -980,7 +1020,7 @@ func (m *Manager) getReceived(ctx context.Context, ref *collaboration.ShareRefer
 			GranteeUserID:  s.GetGrantee().GetUserId(),
 			GranteeGroupID: s.GetGrantee().GetGroupId(),
 		}); err != nil {
-			log.Error().Err(err).
+			sublog.Error().Err(err).
 				Msg("failed to publish share expired event")
 		}
 	}

vendor/github.com/cs3org/reva/v2/pkg/share/manager/owncloudsql/conversions.go

@@ -37,8 +37,6 @@ import (
 	"github.com/jellydator/ttlcache/v2"
 )
 
-//go:generate make --no-print-directory -C ../../../.. mockery NAME=UserConverter
-
 // DBShare stores information about user and public shares.
 type DBShare struct {
 	ID           string

vendor/github.com/cs3org/reva/v2/pkg/share/share.go

@@ -36,8 +36,6 @@ const (
 	NoState collaboration.ShareState = -1
 )
 
-//go:generate make --no-print-directory -C ../.. mockery NAME=Manager
-
 // Metadata contains Metadata for a share
 type Metadata struct {
 	ETag  string

vendor/github.com/cs3org/reva/v2/pkg/storage/fs/posix/tree/tree.go

@@ -54,8 +54,6 @@ func init() {
 	tracer = otel.Tracer("github.com/cs3org/reva/pkg/storage/utils/decomposedfs/tree")
 }
 
-//go:generate make --no-print-directory -C ../../../../.. mockery NAME=Blobstore
-
 // Blobstore defines an interface for storing blobs in a blobstore
 type Blobstore interface {
 	Upload(node *node.Node, source string) error

vendor/github.com/cs3org/reva/v2/pkg/storage/registry/spaces/spaces.go

@@ -48,8 +48,6 @@ import (
 	"google.golang.org/grpc"
 )
 
-//go:generate make --no-print-directory -C ../../../.. mockery NAME=StorageProviderClient
-
 func init() {
 	pkgregistry.Register("spaces", NewDefault)
 }

vendor/github.com/cs3org/reva/v2/pkg/storage/utils/decomposedfs/node/node.go

@@ -54,8 +54,6 @@ import (
 	"go.opentelemetry.io/otel/trace"
 )
 
-//go:generate make --no-print-directory -C ../../../../.. mockery NAME=Tree
-
 var tracer trace.Tracer
 
 func init() {

vendor/github.com/cs3org/reva/v2/pkg/storage/utils/decomposedfs/permissions/spacepermissions.go

@@ -16,9 +16,6 @@ import (
 	"google.golang.org/grpc"
 )
 
-//go:generate make --no-print-directory -C ../../../../.. mockery NAME=PermissionsChecker
-//go:generate make --no-print-directory -C ../../../../.. mockery NAME=CS3PermissionsClient
-
 var (
 	tracer trace.Tracer
 )

vendor/github.com/cs3org/reva/v2/pkg/storage/utils/decomposedfs/tree/tree.go

@@ -53,8 +53,6 @@ func init() {
 	tracer = otel.Tracer("github.com/cs3org/reva/pkg/storage/utils/decomposedfs/tree")
 }
 
-//go:generate make --no-print-directory -C ../../../../.. mockery NAME=Blobstore
-
 // Blobstore defines an interface for storing blobs in a blobstore
 type Blobstore interface {
 	Upload(node *node.Node, source string) error

vendor/github.com/cs3org/reva/v2/pkg/storage/utils/indexer/indexer.go

@@ -36,8 +36,6 @@ import (
 	"github.com/cs3org/reva/v2/pkg/storage/utils/sync"
 )
 
-//go:generate make --no-print-directory -C ../../../.. mockery NAME=Indexer
-
 // Indexer is a facade to configure and query over multiple indices.
 type Indexer interface {
 	AddIndex(t interface{}, indexBy option.IndexBy, pkName, entityDirName, indexType string, bound *option.Bound, caseInsensitive bool) error

vendor/github.com/cs3org/reva/v2/pkg/storage/utils/metadata/storage.go

@@ -28,8 +28,6 @@ import (
 	provider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
 )
 
-//go:generate make --no-print-directory -C ../../../.. mockery NAME=Storage
-
 // UploadRequest represents an upload request and its options
 type UploadRequest struct {
 	Path    string

vendor/github.com/cs3org/reva/v2/tests/cs3mocks/mocks/CollaborationAPIClient.go

@@ -16,7 +16,7 @@
 // granted to it by virtue of its status as an Intergovernmental Organization
 // or submit itself to any jurisdiction.
 
-// Code generated by mockery v2.22.1. DO NOT EDIT.
+// Code generated by mockery v2.40.2. DO NOT EDIT.
 
 package mocks
 
@@ -35,6 +35,14 @@ type CollaborationAPIClient struct {
 	mock.Mock
 }
 
+type CollaborationAPIClient_Expecter struct {
+	mock *mock.Mock
+}
+
+func (_m *CollaborationAPIClient) EXPECT() *CollaborationAPIClient_Expecter {
+	return &CollaborationAPIClient_Expecter{mock: &_m.Mock}
+}
+
 // CreateShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) CreateShare(ctx context.Context, in *collaborationv1beta1.CreateShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.CreateShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -46,6 +54,10 @@ func (_m *CollaborationAPIClient) CreateShare(ctx context.Context, in *collabora
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for CreateShare")
+	}
+
 	var r0 *collaborationv1beta1.CreateShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.CreateShareRequest, ...grpc.CallOption) (*collaborationv1beta1.CreateShareResponse, error)); ok {
@@ -68,6 +80,43 @@ func (_m *CollaborationAPIClient) CreateShare(ctx context.Context, in *collabora
 	return r0, r1
 }
 
+// CollaborationAPIClient_CreateShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateShare'
+type CollaborationAPIClient_CreateShare_Call struct {
+	*mock.Call
+}
+
+// CreateShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.CreateShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) CreateShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_CreateShare_Call {
+	return &CollaborationAPIClient_CreateShare_Call{Call: _e.mock.On("CreateShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_CreateShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.CreateShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_CreateShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.CreateShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_CreateShare_Call) Return(_a0 *collaborationv1beta1.CreateShareResponse, _a1 error) *CollaborationAPIClient_CreateShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_CreateShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.CreateShareRequest, ...grpc.CallOption) (*collaborationv1beta1.CreateShareResponse, error)) *CollaborationAPIClient_CreateShare_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // GetReceivedShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) GetReceivedShare(ctx context.Context, in *collaborationv1beta1.GetReceivedShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.GetReceivedShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -79,6 +128,10 @@ func (_m *CollaborationAPIClient) GetReceivedShare(ctx context.Context, in *coll
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for GetReceivedShare")
+	}
+
 	var r0 *collaborationv1beta1.GetReceivedShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.GetReceivedShareRequest, ...grpc.CallOption) (*collaborationv1beta1.GetReceivedShareResponse, error)); ok {
@@ -101,6 +154,43 @@ func (_m *CollaborationAPIClient) GetReceivedShare(ctx context.Context, in *coll
 	return r0, r1
 }
 
+// CollaborationAPIClient_GetReceivedShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetReceivedShare'
+type CollaborationAPIClient_GetReceivedShare_Call struct {
+	*mock.Call
+}
+
+// GetReceivedShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.GetReceivedShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) GetReceivedShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_GetReceivedShare_Call {
+	return &CollaborationAPIClient_GetReceivedShare_Call{Call: _e.mock.On("GetReceivedShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_GetReceivedShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.GetReceivedShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_GetReceivedShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.GetReceivedShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_GetReceivedShare_Call) Return(_a0 *collaborationv1beta1.GetReceivedShareResponse, _a1 error) *CollaborationAPIClient_GetReceivedShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_GetReceivedShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.GetReceivedShareRequest, ...grpc.CallOption) (*collaborationv1beta1.GetReceivedShareResponse, error)) *CollaborationAPIClient_GetReceivedShare_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // GetShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) GetShare(ctx context.Context, in *collaborationv1beta1.GetShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.GetShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -112,6 +202,10 @@ func (_m *CollaborationAPIClient) GetShare(ctx context.Context, in *collaboratio
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for GetShare")
+	}
+
 	var r0 *collaborationv1beta1.GetShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.GetShareRequest, ...grpc.CallOption) (*collaborationv1beta1.GetShareResponse, error)); ok {
@@ -134,6 +228,43 @@ func (_m *CollaborationAPIClient) GetShare(ctx context.Context, in *collaboratio
 	return r0, r1
 }
 
+// CollaborationAPIClient_GetShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetShare'
+type CollaborationAPIClient_GetShare_Call struct {
+	*mock.Call
+}
+
+// GetShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.GetShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) GetShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_GetShare_Call {
+	return &CollaborationAPIClient_GetShare_Call{Call: _e.mock.On("GetShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_GetShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.GetShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_GetShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.GetShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_GetShare_Call) Return(_a0 *collaborationv1beta1.GetShareResponse, _a1 error) *CollaborationAPIClient_GetShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_GetShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.GetShareRequest, ...grpc.CallOption) (*collaborationv1beta1.GetShareResponse, error)) *CollaborationAPIClient_GetShare_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // ListReceivedShares provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) ListReceivedShares(ctx context.Context, in *collaborationv1beta1.ListReceivedSharesRequest, opts ...grpc.CallOption) (*collaborationv1beta1.ListReceivedSharesResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -145,6 +276,10 @@ func (_m *CollaborationAPIClient) ListReceivedShares(ctx context.Context, in *co
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for ListReceivedShares")
+	}
+
 	var r0 *collaborationv1beta1.ListReceivedSharesResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.ListReceivedSharesRequest, ...grpc.CallOption) (*collaborationv1beta1.ListReceivedSharesResponse, error)); ok {
@@ -167,6 +302,43 @@ func (_m *CollaborationAPIClient) ListReceivedShares(ctx context.Context, in *co
 	return r0, r1
 }
 
+// CollaborationAPIClient_ListReceivedShares_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListReceivedShares'
+type CollaborationAPIClient_ListReceivedShares_Call struct {
+	*mock.Call
+}
+
+// ListReceivedShares is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.ListReceivedSharesRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) ListReceivedShares(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_ListReceivedShares_Call {
+	return &CollaborationAPIClient_ListReceivedShares_Call{Call: _e.mock.On("ListReceivedShares",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_ListReceivedShares_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.ListReceivedSharesRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_ListReceivedShares_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.ListReceivedSharesRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_ListReceivedShares_Call) Return(_a0 *collaborationv1beta1.ListReceivedSharesResponse, _a1 error) *CollaborationAPIClient_ListReceivedShares_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_ListReceivedShares_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.ListReceivedSharesRequest, ...grpc.CallOption) (*collaborationv1beta1.ListReceivedSharesResponse, error)) *CollaborationAPIClient_ListReceivedShares_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // ListShares provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) ListShares(ctx context.Context, in *collaborationv1beta1.ListSharesRequest, opts ...grpc.CallOption) (*collaborationv1beta1.ListSharesResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -178,6 +350,10 @@ func (_m *CollaborationAPIClient) ListShares(ctx context.Context, in *collaborat
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for ListShares")
+	}
+
 	var r0 *collaborationv1beta1.ListSharesResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.ListSharesRequest, ...grpc.CallOption) (*collaborationv1beta1.ListSharesResponse, error)); ok {
@@ -200,6 +376,43 @@ func (_m *CollaborationAPIClient) ListShares(ctx context.Context, in *collaborat
 	return r0, r1
 }
 
+// CollaborationAPIClient_ListShares_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListShares'
+type CollaborationAPIClient_ListShares_Call struct {
+	*mock.Call
+}
+
+// ListShares is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.ListSharesRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) ListShares(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_ListShares_Call {
+	return &CollaborationAPIClient_ListShares_Call{Call: _e.mock.On("ListShares",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_ListShares_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.ListSharesRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_ListShares_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.ListSharesRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_ListShares_Call) Return(_a0 *collaborationv1beta1.ListSharesResponse, _a1 error) *CollaborationAPIClient_ListShares_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_ListShares_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.ListSharesRequest, ...grpc.CallOption) (*collaborationv1beta1.ListSharesResponse, error)) *CollaborationAPIClient_ListShares_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // RemoveShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) RemoveShare(ctx context.Context, in *collaborationv1beta1.RemoveShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.RemoveShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -211,6 +424,10 @@ func (_m *CollaborationAPIClient) RemoveShare(ctx context.Context, in *collabora
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for RemoveShare")
+	}
+
 	var r0 *collaborationv1beta1.RemoveShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.RemoveShareRequest, ...grpc.CallOption) (*collaborationv1beta1.RemoveShareResponse, error)); ok {
@@ -233,6 +450,43 @@ func (_m *CollaborationAPIClient) RemoveShare(ctx context.Context, in *collabora
 	return r0, r1
 }
 
+// CollaborationAPIClient_RemoveShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveShare'
+type CollaborationAPIClient_RemoveShare_Call struct {
+	*mock.Call
+}
+
+// RemoveShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.RemoveShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) RemoveShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_RemoveShare_Call {
+	return &CollaborationAPIClient_RemoveShare_Call{Call: _e.mock.On("RemoveShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_RemoveShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.RemoveShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_RemoveShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.RemoveShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_RemoveShare_Call) Return(_a0 *collaborationv1beta1.RemoveShareResponse, _a1 error) *CollaborationAPIClient_RemoveShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_RemoveShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.RemoveShareRequest, ...grpc.CallOption) (*collaborationv1beta1.RemoveShareResponse, error)) *CollaborationAPIClient_RemoveShare_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // UpdateReceivedShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) UpdateReceivedShare(ctx context.Context, in *collaborationv1beta1.UpdateReceivedShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.UpdateReceivedShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -244,6 +498,10 @@ func (_m *CollaborationAPIClient) UpdateReceivedShare(ctx context.Context, in *c
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for UpdateReceivedShare")
+	}
+
 	var r0 *collaborationv1beta1.UpdateReceivedShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.UpdateReceivedShareRequest, ...grpc.CallOption) (*collaborationv1beta1.UpdateReceivedShareResponse, error)); ok {
@@ -266,6 +524,43 @@ func (_m *CollaborationAPIClient) UpdateReceivedShare(ctx context.Context, in *c
 	return r0, r1
 }
 
+// CollaborationAPIClient_UpdateReceivedShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateReceivedShare'
+type CollaborationAPIClient_UpdateReceivedShare_Call struct {
+	*mock.Call
+}
+
+// UpdateReceivedShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.UpdateReceivedShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) UpdateReceivedShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_UpdateReceivedShare_Call {
+	return &CollaborationAPIClient_UpdateReceivedShare_Call{Call: _e.mock.On("UpdateReceivedShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_UpdateReceivedShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.UpdateReceivedShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_UpdateReceivedShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.UpdateReceivedShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_UpdateReceivedShare_Call) Return(_a0 *collaborationv1beta1.UpdateReceivedShareResponse, _a1 error) *CollaborationAPIClient_UpdateReceivedShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_UpdateReceivedShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.UpdateReceivedShareRequest, ...grpc.CallOption) (*collaborationv1beta1.UpdateReceivedShareResponse, error)) *CollaborationAPIClient_UpdateReceivedShare_Call {
+	_c.Call.Return(run)
+	return _c
+}
+
 // UpdateShare provides a mock function with given fields: ctx, in, opts
 func (_m *CollaborationAPIClient) UpdateShare(ctx context.Context, in *collaborationv1beta1.UpdateShareRequest, opts ...grpc.CallOption) (*collaborationv1beta1.UpdateShareResponse, error) {
 	_va := make([]interface{}, len(opts))
@@ -277,6 +572,10 @@ func (_m *CollaborationAPIClient) UpdateShare(ctx context.Context, in *collabora
 	_ca = append(_ca, _va...)
 	ret := _m.Called(_ca...)
 
+	if len(ret) == 0 {
+		panic("no return value specified for UpdateShare")
+	}
+
 	var r0 *collaborationv1beta1.UpdateShareResponse
 	var r1 error
 	if rf, ok := ret.Get(0).(func(context.Context, *collaborationv1beta1.UpdateShareRequest, ...grpc.CallOption) (*collaborationv1beta1.UpdateShareResponse, error)); ok {
@@ -299,13 +598,49 @@ func (_m *CollaborationAPIClient) UpdateShare(ctx context.Context, in *collabora
 	return r0, r1
 }
 
-type mockConstructorTestingTNewCollaborationAPIClient interface {
-	mock.TestingT
-	Cleanup(func())
+// CollaborationAPIClient_UpdateShare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateShare'
+type CollaborationAPIClient_UpdateShare_Call struct {
+	*mock.Call
+}
+
+// UpdateShare is a helper method to define mock.On call
+//   - ctx context.Context
+//   - in *collaborationv1beta1.UpdateShareRequest
+//   - opts ...grpc.CallOption
+func (_e *CollaborationAPIClient_Expecter) UpdateShare(ctx interface{}, in interface{}, opts ...interface{}) *CollaborationAPIClient_UpdateShare_Call {
+	return &CollaborationAPIClient_UpdateShare_Call{Call: _e.mock.On("UpdateShare",
+		append([]interface{}{ctx, in}, opts...)...)}
+}
+
+func (_c *CollaborationAPIClient_UpdateShare_Call) Run(run func(ctx context.Context, in *collaborationv1beta1.UpdateShareRequest, opts ...grpc.CallOption)) *CollaborationAPIClient_UpdateShare_Call {
+	_c.Call.Run(func(args mock.Arguments) {
+		variadicArgs := make([]grpc.CallOption, len(args)-2)
+		for i, a := range args[2:] {
+			if a != nil {
+				variadicArgs[i] = a.(grpc.CallOption)
+			}
+		}
+		run(args[0].(context.Context), args[1].(*collaborationv1beta1.UpdateShareRequest), variadicArgs...)
+	})
+	return _c
+}
+
+func (_c *CollaborationAPIClient_UpdateShare_Call) Return(_a0 *collaborationv1beta1.UpdateShareResponse, _a1 error) *CollaborationAPIClient_UpdateShare_Call {
+	_c.Call.Return(_a0, _a1)
+	return _c
+}
+
+func (_c *CollaborationAPIClient_UpdateShare_Call) RunAndReturn(run func(context.Context, *collaborationv1beta1.UpdateShareRequest, ...grpc.CallOption) (*collaborationv1beta1.UpdateShareResponse, error)) *CollaborationAPIClient_UpdateShare_Call {
+	_c.Call.Return(run)
+	return _c
 }
 
 // NewCollaborationAPIClient creates a new instance of CollaborationAPIClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
-func NewCollaborationAPIClient(t mockConstructorTestingTNewCollaborationAPIClient) *CollaborationAPIClient {
+// The first argument is typically a *testing.T value.
+func NewCollaborationAPIClient(t interface {
+	mock.TestingT
+	Cleanup(func())
+}) *CollaborationAPIClient {
 	mock := &CollaborationAPIClient{}
 	mock.Mock.Test(t)
 

vendor/modules.txt

@@ -366,7 +366,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/tx/v1beta1
 github.com/cs3org/go-cs3apis/cs3/types/v1beta1
-# github.com/cs3org/reva/v2 v2.19.2-0.20240404085416-251ba8d12f6f
+# github.com/cs3org/reva/v2 v2.19.2-0.20240405190914-ef59ba20ef0e
 ## explicit; go 1.21
 github.com/cs3org/reva/v2/cmd/revad/internal/grace
 github.com/cs3org/reva/v2/cmd/revad/runtime