fix(cdn): select item inside at least n storage_unit

sguiheux · sguiheux · commit c5ef4b8fe0bc · 2021-06-15T12:03:48.000+02:00
diff --git a/engine/cdn/storage/dao.go b/engine/cdn/storage/dao.go
@@ -149,7 +149,7 @@ func LoadAllSynchronizedItemIDs(db gorp.SqlExecutor, bufferUnitID string, maxSto
 	FROM storage_unit_item
 	WHERE item_id = ANY (select item_id from inBuffer)
 	GROUP BY item_id
-	HAVING COUNT(unit_id) = $1
+	HAVING COUNT(unit_id) >= $1
 	`
 	if _, err := db.Select(&itemIDs, query, maxStorageCount, bufferUnitID); err != nil {
 		return nil, sdk.WrapError(err, "unable to get item ids")

Original file line number	Diff line number	Diff line change
`@@ -149,7 +149,7 @@ func LoadAllSynchronizedItemIDs(db gorp.SqlExecutor, bufferUnitID string, maxSto`
`149`	`149`	`FROM storage_unit_item`
`150`	`150`	`WHERE item_id = ANY (select item_id from inBuffer)`
`151`	`151`	`GROUP BY item_id`
`152`		`- HAVING COUNT(unit_id) = $1`
	`152`	`+ HAVING COUNT(unit_id) >= $1`
`153`	`153`	`
`154`	`154`	`if _, err := db.Select(&itemIDs, query, maxStorageCount, bufferUnitID); err != nil {`
`155`	`155`	`return nil, sdk.WrapError(err, "unable to get item ids")`