Method RollbackModule

cyclops-ctrl/internal/controller/modules.go:522–605

(ctx *gin.Context)

}

func (m *Modules) RollbackModule(ctx *gin.Context) {
	ctx.Header("Access-Control-Allow-Origin", "*")

	var request dto.RollbackRequest
	if err := ctx.BindJSON(&request); err != nil {
		fmt.Println(err)
		ctx.JSON(http.StatusBadRequest, dto.NewError("Error mapping module request", err.Error()))
		return
	}

	curr, err := m.kubernetesClient.GetModule(request.ModuleName)
	if err != nil {
		fmt.Println(err)
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Error fetching module", err.Error()))
		return
	}

	var targetGeneration *v1alpha1.HistoryEntry
	for _, entry := range curr.History {
		if entry.Generation == request.Generation {
			targetGeneration = &entry
			break
		}
	}

	if targetGeneration == nil {
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Invalid rollback generation provided", fmt.Sprintf("Generation %d does not exist", request.Generation)))
		return
	}

	module := curr.DeepCopy()

	module.Kind = "Module"
	module.APIVersion = "cyclops-ui.com/v1alpha1"

	history := module.History
	if module.History == nil {
		history = make([]v1alpha1.HistoryEntry, 0)
	}

	module.History = append([]v1alpha1.HistoryEntry{{
		Generation:      curr.Generation,
		TargetNamespace: curr.Spec.TargetNamespace,
		TemplateRef: v1alpha1.HistoryTemplateRef{
			URL:        curr.Spec.TemplateRef.URL,
			Path:       curr.Spec.TemplateRef.Path,
			Version:    curr.Status.TemplateResolvedVersion,
			SourceType: curr.Spec.TemplateRef.SourceType,
		},
		Values: curr.Spec.Values,
	}}, history...)

	if len(module.History) > 10 {
		module.History = module.History[:len(module.History)-1]
	}

	module.Spec.Values = targetGeneration.Values
	module.Spec.TemplateRef = v1alpha1.TemplateRef{