Use index from requests in buildQuickSyncPipeline

pkg/app/pipedv1/plugin/kubernetes/deployment/pipeline.go

@@ -105,24 +105,24 @@
 	}
 }
 
-func buildQuickSyncPipeline(autoRollback bool, now time.Time) []*model.PipelineStage {
+func buildQuickSyncPipeline(index int32, autoRollback bool, now time.Time) []*model.PipelineStage {
 	var (
 		preStageID = ""
 		stage, _   = GetPredefinedStage(PredefinedStageK8sSync)
 		stages     = []config.PipelineStage{stage}
 		out        = make([]*model.PipelineStage, 0, len(stages))
 	)
 
-	for i, s := range stages {
+	for _, s := range stages {
 		id := s.ID
 		if id == "" {
-			id = fmt.Sprintf("stage-%d", i)
+			id = fmt.Sprintf("kubernetes-stage-%d", index)
 		}
 		stage := &model.PipelineStage{
 			Id:         id,
 			Name:       s.Name.String(),
 			Desc:       s.Desc,
-			Index:      int32(i),
+			Index:      int32(index),
 			Predefined: true,
 			Visible:    true,
 			Status:     model.StageStatus_STAGE_NOT_STARTED_YET,

pkg/app/pipedv1/plugin/kubernetes/deployment/pipeline_test.go

@@ -29,11 +29,13 @@ func TestBuildQuickSyncPipeline(t *testing.T) {
 
 	tests := []struct {
 		name         string
+		index        int32
 		autoRollback bool
 		expected     []*model.PipelineStage
 	}{
 		{
 			name:         "without auto rollback",
+			index:        0,
 			autoRollback: false,
 			expected: []*model.PipelineStage{
 				{
@@ -52,6 +54,7 @@ func TestBuildQuickSyncPipeline(t *testing.T) {
 		},
 		{
 			name:         "with auto rollback",
+			index:        0,
 			autoRollback: true,
 			expected: []*model.PipelineStage{
 				{
@@ -82,7 +85,7 @@ func TestBuildQuickSyncPipeline(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
-			actual := buildQuickSyncPipeline(tt.autoRollback, now)
+			actual := buildQuickSyncPipeline(tt.index, tt.autoRollback, now)
 			assert.Equal(t, tt.expected, actual)
 		})
 	}

pkg/app/pipedv1/plugin/kubernetes/deployment/server.go

@@ -72,7 +72,7 @@
 // BuildQuickSyncStages implements deployment.DeploymentServiceServer.
 func (a *DeploymentService) BuildQuickSyncStages(ctx context.Context, request *deployment.BuildQuickSyncStagesRequest) (*deployment.BuildQuickSyncStagesResponse, error) {
 	now := time.Now()
-	stages := buildQuickSyncPipeline(request.GetRollback(), now)
+	stages := buildQuickSyncPipeline(request.GetStageIndex(), request.GetRollback(), now)
 	return &deployment.BuildQuickSyncStagesResponse{
 		Stages: stages,
 	}, nil