From 1140ae71b60ceba859d373b03668e2a001316303 Mon Sep 17 00:00:00 2001 From: Giuseppe Lo Presti Date: Wed, 14 Aug 2024 10:34:40 +0200 Subject: [PATCH] Sanitize input --- pkg/ocm/storage/outcoming/ocm.go | 3 +++ pkg/storage/utils/eosfs/upload.go | 3 +++ 2 files changed, 6 insertions(+) diff --git a/pkg/ocm/storage/outcoming/ocm.go b/pkg/ocm/storage/outcoming/ocm.go index 28fd9a5c5c..b771106f2d 100644 --- a/pkg/ocm/storage/outcoming/ocm.go +++ b/pkg/ocm/storage/outcoming/ocm.go @@ -402,6 +402,9 @@ func (d *driver) Upload(ctx context.Context, ref *provider.Reference, content io if err != nil { return err } + if metadata == nil { + metadata = map[string]string{} + } return d.unwrappedOpFromShareCreator(ctx, share, rel, func(ctx context.Context, newRef *provider.Reference) error { initRes, err := d.gateway.InitiateFileUpload(ctx, &provider.InitiateFileUploadRequest{ diff --git a/pkg/storage/utils/eosfs/upload.go b/pkg/storage/utils/eosfs/upload.go index 8059ed5e18..fb46c2699d 100644 --- a/pkg/storage/utils/eosfs/upload.go +++ b/pkg/storage/utils/eosfs/upload.go @@ -76,6 +76,9 @@ func (fs *eosfs) Upload(ctx context.Context, ref *provider.Reference, r io.ReadC return err } + if metadata == nil { + metadata = map[string]string{} + } app := metadata["lockholder"] if app == "" { app = "reva_eosclient::write"