improoved encoding algo

Kirari04 · Jan 23, 2024 · c057daf · c057daf
1 parent 78c9190
commit c057daf
Showing 1 changed file with 26 additions and 22 deletions.
diff --git a/services/Encoder.go b/services/Encoder.go
@@ -114,17 +114,19 @@ func loadEncodingTasks() {
 
 	// AUDIOS
 	var encodingAudios []models.Audio
-	inits.DB.
-		Model(&models.Audio{}).
-		Preload("File").
-		Where(&models.Audio{
-			Encoding: false,
-			Ready:    false,
-			Failed:   false,
-		}, "Encoding", "Ready", "Failed").
-		Order("id ASC").
-		Limit(10).
-		Find(&encodingAudios)
+	if len(encodingSubs) < 10 {
+		inits.DB.
+			Model(&models.Audio{}).
+			Preload("File").
+			Where(&models.Audio{
+				Encoding: false,
+				Ready:    false,
+				Failed:   false,
+			}, "Encoding", "Ready", "Failed").
+			Order("id ASC").
+			Limit(10).
+			Find(&encodingAudios)
+	}
 
 	if len(encodingAudios) > 0 {
 		log.Printf("Loaded %v audios to encode", len(encodingAudios))
@@ -142,17 +144,19 @@ func loadEncodingTasks() {
 
 	// QUALITYS
 	var encodingQualitys []models.Quality
-	inits.DB.
-		Model(&models.Quality{}).
-		Preload("File").
-		Where(&models.Quality{
-			Encoding: false,
-			Ready:    false,
-			Failed:   false,
-		}, "Encoding", "Ready", "Failed").
-		Order("id ASC").
-		Limit(10).
-		Find(&encodingQualitys)
+	if len(encodingSubs) < 10 && len(encodingAudios) < 10 {
+		inits.DB.
+			Model(&models.Quality{}).
+			Preload("File").
+			Where(&models.Quality{
+				Encoding: false,
+				Ready:    false,
+				Failed:   false,
+			}, "Encoding", "Ready", "Failed").
+			Order("id ASC").
+			Limit(10).
+			Find(&encodingQualitys)
+	}
 
 	if len(encodingQualitys) > 0 {
 		log.Printf("Loaded %v qualitys to encode", len(encodingQualitys))