boltindex: fix deletion

Mikaël Cluseau · Mikaël Cluseau · commit 53daffcafc17 · 2019-02-18T11:07:14.000+11:00
diff --git a/boltindex/boltindex.go b/boltindex/boltindex.go
@@ -113,11 +113,9 @@ func (i *Index) Index(kv KeyValue, resumeKey []byte) (err error) {
 		err = i.storeResumeKey(tx, resumeKey)
 	}
 
-	key := append([]byte("k:"), kv.Key...)
-
 	if len(kv.Value) == 0 {
 		// deletion
-		err = bucket.Delete(key)
+		err = bucket.Delete(kv.Key)
 		return
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -113,11 +113,9 @@ func (i *Index) Index(kv KeyValue, resumeKey []byte) (err error) {`
`113`	`113`	`err = i.storeResumeKey(tx, resumeKey)`
`114`	`114`	`}`
`115`	`115`
`116`		`- key := append([]byte("k:"), kv.Key...)`
`117`		`-`
`118`	`116`	`if len(kv.Value) == 0 {`
`119`	`117`	`// deletion`
`120`		`- err = bucket.Delete(key)`
	`118`	`+ err = bucket.Delete(kv.Key)`
`121`	`119`	`return`
`122`	`120`	`}`
`123`	`121`