updated stageTime-informer 24.0206.2045 for tag version v0.1.89

stuttgart-things · Feb 6, 2024 · bacd5a2 · bacd5a2
1 parent d90c981
commit bacd5a2
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/internal/producer.go b/internal/producer.go
@@ -92,7 +92,9 @@ func setStageStatus(pipelineRunLabels map[string]string) {
 
 			currentStageID := stageStatusFromRedis.StageID
 			nextStageIDBuilder := strings.LastIndex(currentStageID, "-")
-			nextStageID := stageStatusFromRedis.StageID[:nextStageIDBuilder] + "-" + sthingsBase.ConvertIntegerToString(countCurrentStage+1)
+
+			nextStageID := replaceLastOccurrenceInSubstring(stageStatusFromRedis.StageID[:nextStageIDBuilder]+"+"+sthingsBase.ConvertIntegerToString(countCurrentStage+1), "-", "+")
+
 			fmt.Println("NEXT STAGE!?", nextStageID)
 			server.SendStageToMessageQueue(nextStageID)
 
@@ -114,3 +116,11 @@ func setStageStatus(pipelineRunLabels map[string]string) {
 	// }
 
 }
+
+func replaceLastOccurrenceInSubstring(subString, searchFor, replaceWith string) (x2 string) {
+	i := strings.LastIndex(subString, searchFor)
+	if i == -1 {
+		return subString
+	}
+	return subString[:i] + replaceWith + subString[i+len(searchFor):]
+}