pkg/local_object_storage/writecache/writecachebadger/delete.go

@@ -39,10 +39,10 @@ func (c *cache) Delete(ctx context.Context, addr oid.Address) error {
 		return writecache.ErrReadOnly
 	}
 
-	saddr := addr.EncodeToString()
+	key := addr2key(addr)
 
 	err := c.db.Update(func(tx *badger.Txn) error {
-		it, err := tx.Get([]byte(saddr))
+		it, err := tx.Get(key[:])
 		if err != nil {
 			if err == badger.ErrKeyNotFound {
 				return logicerr.Wrap(new(apistatus.ObjectNotFound))
@@ -51,10 +51,10 @@ func (c *cache) Delete(ctx context.Context, addr oid.Address) error {
 		}
 		if it.ValueSize() > 0 {
 			storageType = writecache.StorageTypeDB
-			err := tx.Delete([]byte(saddr))
+			err := tx.Delete(key[:])
 			if err == nil {
 				storagelog.Write(c.log,
-					storagelog.AddressField(saddr),
+					storagelog.AddressField(addr.EncodeToString()),
 					storagelog.StorageTypeField(wcStorageType),
 					storagelog.OpField("db DELETE"),
 				)

pkg/local_object_storage/writecache/writecachebadger/flush_test.go

@@ -52,8 +52,9 @@ func TestFlush(t *testing.T) {
 			Desc: "db, invalid object",
 			InjectFn: func(t *testing.T, wc writecache.Cache) {
 				c := wc.(*cache)
+				key := addr2key(oidtest.Address())
 				require.NoError(t, c.db.Update(func(tx *badger.Txn) error {
-					return tx.Set([]byte(oidtest.Address().EncodeToString()), []byte{1, 2, 3})
+					return tx.Set(key[:], []byte{1, 2, 3})
 				}))
 			},
 		},