From 684781b0bcb6a9cd6eac5a02c403283eaee06b1f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=B6rn=20Friedrich=20Dreyer?= Date: Thu, 24 Sep 2026 15:13:33 +0200 Subject: [PATCH] fix(storage-users): use user.oc. metadata prefix for stale node detection MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Jörn Friedrich Dreyer --- services/storage-users/pkg/command/uploads.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/services/storage-users/pkg/command/uploads.go b/services/storage-users/pkg/command/uploads.go index a514b04573..117c6b339e 100644 --- a/services/storage-users/pkg/command/uploads.go +++ b/services/storage-users/pkg/command/uploads.go @@ -28,13 +28,12 @@ import ( "github.com/opencloud-eu/reva/v2/pkg/storage" "github.com/opencloud-eu/reva/v2/pkg/storage/fs/registry" "github.com/opencloud-eu/reva/v2/pkg/storage/pkg/decomposedfs/lookup" + "github.com/opencloud-eu/reva/v2/pkg/storage/pkg/decomposedfs/metadata/prefixes" "github.com/opencloud-eu/reva/v2/pkg/storage/pkg/decomposedfs/node" "github.com/opencloud-eu/reva/v2/pkg/utils" ) const ( - MSGPACK_KEY_USER_OCIS_NODESTATUS = "user.ocis.nodestatus" - // Log indentation levels LOG_INDENT_L1 = " " // 2 spaces LOG_INDENT_L2 = LOG_INDENT_L1 + LOG_INDENT_L1 @@ -517,7 +516,7 @@ func extractProcessingID(mpkData map[string]any) string { processingID := "" for k, v := range mpkData { vStr := string(v.([]byte)) - if k == MSGPACK_KEY_USER_OCIS_NODESTATUS && strings.Contains(vStr, node.ProcessingStatus) { + if k == prefixes.StatusPrefix && strings.Contains(vStr, node.ProcessingStatus) { processingID = strings.Split(vStr, ":")[1] break }