updated stageTime-informer 24.0220.1414 for tag version v0.1.94

stuttgart-things · Feb 20, 2024 · 722becb · 722becb
1 parent aac8d74
commit 722becb
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 8 deletions.
diff --git a/internal/producer.go b/internal/producer.go
@@ -158,19 +158,19 @@ func checkForNextStage(stageID, revisionRunID string, nextStage int) bool {
 // 	fmt.Println("CURRENT STAGE:", countCurrentStage)
 // 	fmt.Println("COUNT STAGES:", revisionRunFromRedis.CountStages)
 
-// 	if revisionRunFromRedis.CountStages > countCurrentStage {
+// if revisionRunFromRedis.CountStages > countCurrentStage {
 
-// 		if pipelineRunLabels["status"] != "SUCCEEDED" {
+// 	if pipelineRunLabels["status"] != "SUCCEEDED" {
 
-// 		fmt.Println("NEXT STAGE LETS GOOO")
+// 	fmt.Println("NEXT STAGE LETS GOOO")
 
-// 		currentStageID := stageStatusFromRedis.StageID
-// 		nextStageIDBuilder := strings.LastIndex(currentStageID, "-")
+// 	currentStageID := stageStatusFromRedis.StageID
+// 	nextStageIDBuilder := strings.LastIndex(currentStageID, "-")
 
-// 		nextStageID := replaceLastOccurrenceInSubstring(stageStatusFromRedis.StageID[:nextStageIDBuilder]+"+"+sthingsBase.ConvertIntegerToString(countCurrentStage+1), "-", "+")
+// 	nextStageID := replaceLastOccurrenceInSubstring(stageStatusFromRedis.StageID[:nextStageIDBuilder]+"+"+sthingsBase.ConvertIntegerToString(countCurrentStage+1), "-", "+")
 
-// 		fmt.Println("NEXT STAGE!?", nextStageID)
-// 		SendStageToMessageQueue(nextStageID)
+// 	fmt.Println("NEXT STAGE!?", nextStageID)
+// 	SendStageToMessageQueue(nextStageID)
 
 // 	} else {
 // 		fmt.Println("REVISION RUN FINISHED", pipelineRunLabels["stagetime/stage"])

diff --git a/internal/verification.go b/internal/verification.go
@@ -6,6 +6,7 @@ package internal
 
 import (
 	"fmt"
+	"strings"
 
 	sthingsBase "github.com/stuttgart-things/sthingsBase"
 )
@@ -64,6 +65,13 @@ func verifyInformerStatus(kind, function string, obj interface{}) {
 			// NO NEW STAGE AND CONTINUE = REVISION RUN WAS SUCCESFUL
 			if !nextStage {
 				setRevisionRunStatus(pipelineRunLabels["stagetime/commit"], stageID, true)
+			} else {
+				nextStageIDBuilder := strings.LastIndex(stageID, "-")
+
+				nextStageID := replaceLastOccurrenceInSubstring(stageID[:nextStageIDBuilder]+"+"+sthingsBase.ConvertIntegerToString(currentStageNumber+1), "-", "+")
+
+				fmt.Println("NEXT STAGE!?", nextStageID)
+				SendStageToMessageQueue(nextStageID)
 			}
 		}