Method ResourcesForModule

cyclops-ctrl/internal/controller/modules.go:640–696

(ctx *gin.Context)

}

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

	module, err := m.kubernetesClient.GetModule(ctx.Param("name"))
	if err != nil {
		ctx.JSON(http.StatusBadRequest, dto.NewError("Error mapping module request", err.Error()))
		return
	}

	templateVersion := module.Status.TemplateResolvedVersion
	if len(templateVersion) == 0 {
		templateVersion = module.Spec.TemplateRef.Version
	}

	t, err := m.templatesRepo.GetTemplate(
		module.Spec.TemplateRef.URL,
		module.Spec.TemplateRef.Path,
		templateVersion,
		module.Status.TemplateResolvedVersion,
		module.Spec.TemplateRef.SourceType,
	)
	if err != nil {
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Error fetching template", err.Error()))
		return
	}

	resources, err := m.kubernetesClient.GetResourcesForModule(ctx.Param("name"))
	if err != nil {
		fmt.Println(err)
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Error fetching module resources", err.Error()))
		return
	}

	manifest, err := m.renderer.HelmTemplate(*module, t)
	if err != nil {
		fmt.Println("error rendering manifest", err)
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Error rendering Module manifest", err.Error()))
		return
	}

	resources, err = m.kubernetesClient.GetDeletedResources(resources, manifest, module.Spec.TargetNamespace)
	if err != nil {
		fmt.Println(err)
		ctx.JSON(http.StatusInternalServerError, dto.NewError("Error fetching deleted module resources", err.Error()))
		return
	}

	sort.Slice(resources, func(i, j int) bool {
		if resources[i].GetGroupVersionKind() != resources[j].GetGroupVersionKind() {
			return resources[i].GetGroupVersionKind() < resources[j].GetGroupVersionKind()
		}

		return resources[i].GetName() < resources[j].GetName()
	})

	ctx.JSON(http.StatusOK, resources)
}