fix: do not get item from an unsync backend (#5836)

Author: sguiheux

engine/cdn/cdn_item.go

@@ -351,6 +351,7 @@ func (s *Service) getRandomItemUnitIDByItemID(ctx context.Context, itemID string
 
 	itemUnits = s.Units.FilterItemUnitReaderByType(itemUnits)
 	itemUnits = s.Units.FilterItemUnitFromBuffer(itemUnits)
+	itemUnits = s.Units.FilterNotSyncBackend(itemUnits)
 
 	if len(itemUnits) == 0 {
 		return "", "", sdk.WithStack(fmt.Errorf("unable to find item units for item with id: %s", itemID))

engine/cdn/cdn_metrics.go

@@ -122,6 +122,9 @@ func (s *Service) ComputeMetrics(ctx context.Context) {
 
 			var storageStats []storage.Stat
 			for _, su := range s.Units.Storages {
+				if !su.CanSync() {
+					continue
+				}
 				storageStats = append(storageStats, s.countItemsForUnit(ctx, su)...)
 			}
 

engine/cdn/storage/types.go

@@ -286,6 +286,26 @@ func (x RunningStorageUnits) GetBuffer(bufferType sdk.CDNItemType) BufferUnit {
 	}
 }
 
+func (x *RunningStorageUnits) CanSync(unitID string) bool {
+	for _, unit := range x.Storages {
+		if unit.ID() == unitID {
+			return unit.CanSync()
+		}
+	}
+	return false
+}
+
+func (x *RunningStorageUnits) FilterNotSyncBackend(ius []sdk.CDNItemUnit) []sdk.CDNItemUnit {
+	itemsUnits := make([]sdk.CDNItemUnit, 0, len(ius))
+	for _, u := range ius {
+		if !x.CanSync(u.UnitID) {
+			continue
+		}
+		itemsUnits = append(itemsUnits, u)
+	}
+	return itemsUnits
+}
+
 func (x *RunningStorageUnits) FilterItemUnitFromBuffer(ius []sdk.CDNItemUnit) []sdk.CDNItemUnit {
 	itemsUnits := make([]sdk.CDNItemUnit, 0, len(ius))
 	for _, u := range ius {

engine/sql/cdn/014_cdn_type_index.sql

@@ -0,0 +1,7 @@
+-- +migrate Up
+SELECT create_index('item', 'idx_item_type_status', 'type,status');
+SELECT create_index('storage_unit_item', 'idx_storage_unit_type_item_unit_id', 'type,unit_id');
+
+-- +migrate Down
+DROP INDEX "idx_item_type_status";
+DROP INDEX "idx_storage_unit_type_item_unit_id"