Avoid collisions by appending cid

ipfs · Jul 2, 2019 · 2ef67c9 · 2ef67c9
1 parent b10e389
commit 2ef67c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/provider/queue/queue.go b/provider/queue/queue.go
@@ -110,7 +110,8 @@ func (q *Queue) work() {
 
 			select {
 			case toQueue := <-q.enqueue:
-				nextKey := datastore.NewKey(fmt.Sprintf("%d", time.Now().UnixNano()))
+				keyPath := fmt.Sprintf("%d/%s", time.Now().UnixNano(), c.String())
+				nextKey := datastore.NewKey(keyPath)
 
 				if err := q.ds.Put(nextKey, toQueue.Bytes()); err != nil {
 					log.Errorf("Failed to enqueue cid: %s", err)