diff --git a/internal/registry/obj_registry.go b/internal/registry/obj_registry.go index 3b01f32..b1ed3dd 100644 --- a/internal/registry/obj_registry.go +++ b/internal/registry/obj_registry.go @@ -81,10 +81,14 @@ func (o *ObjRegistry) SetObjectStatus(id uint64, oldStatus, newStatus string) er return fmt.Errorf("bucket doesn't exist: '%s'", oldStatus) } - objBytes := oldB.Get(encodeId(id)) + key := encodeId(id) + objBytes := oldB.Get(key) if objBytes == nil { return errors.New("object doesn't exist") } + if err := oldB.Delete(key); err != nil { + return fmt.Errorf("bucket.Delete: %w", err) + } obj := new(ObjectInfo) if err := obj.Unmarshal(objBytes); err != nil {