Merge pull request #4847 from kobergj/AddIsVersionToUploadReady

Add IsVersion flag to UploadReadyEvent

changelog/unreleased/add-version-to-urevent.md

@@ -0,0 +1,5 @@
+Enhancement: Add IsVersion to UploadReadyEvent
+
+Adds an IsVersion flag indicating that this upload is a version of an existing file
+
+https://github.com/cs3org/reva/pull/4847

pkg/events/postprocessing.go

@@ -180,8 +180,9 @@ type UploadReady struct {
 	SpaceOwner    *user.UserId
 	ExecutingUser *user.User
 	FileRef       *provider.Reference
-	Failed        bool
 	Timestamp     *types.Timestamp
+	Failed        bool
+	IsVersion     bool
 	// add reference here? We could use it to inform client pp is finished
 }
 

pkg/storage/utils/decomposedfs/decomposedfs.go

@@ -358,6 +358,14 @@ func (fs *Decomposedfs) Postprocessing(ch <-chan events.Event) {
 
 			fs.sessionStore.Cleanup(ctx, session, revertNodeMetadata, keepUpload, unmarkPostprocessing)
 
+			var isVersion bool
+			if session.NodeExists() {
+				info, err := session.GetInfo(ctx)
+				if err == nil && info.MetaData["versionsPath"] != "" {
+					isVersion = true
+				}
+			}
+
 			if err := events.Publish(
 				ctx,
 				fs.stream,
@@ -376,6 +384,7 @@ func (fs *Decomposedfs) Postprocessing(ch <-chan events.Event) {
 					},
 					Timestamp:  utils.TimeToTS(now),
 					SpaceOwner: n.SpaceOwnerOrManager(ctx),
+					IsVersion:  isVersion,
 				},
 			); err != nil {
 				sublog.Error().Err(err).Msg("Failed to publish UploadReady event")