feat: add renderer pipeline support to manifest generation in

pkg/manifests/template/template.go

@@ -25,6 +25,39 @@ type Template interface {
 }
 
 func Render(dir string, svc *console.ServiceDeploymentForAgent, utilFactory util.Factory) ([]unstructured.Unstructured, error) {
+	if len(svc.Renderers) == 0 {
+		return renderDefault(dir, svc, utilFactory)
+	}
+
+	var allManifests []unstructured.Unstructured
+	for _, renderer := range svc.Renderers {
+		var manifests []unstructured.Unstructured
+		var err error
+
+		switch renderer.Type {
+		case console.RendererTypeAuto:
+			manifests, err = renderDefault(renderer.Path, svc, utilFactory)
+		case console.RendererTypeRaw:
+			manifests, err = NewRaw(renderer.Path).Render(svc, utilFactory)
+		case console.RendererTypeHelm:
+			manifests, err = NewHelm(renderer.Path).Render(svc, utilFactory)
+		case console.RendererTypeKustomize:
+			manifests, err = NewKustomize(renderer.Path).Render(svc, utilFactory)
+		default:
+			return nil, fmt.Errorf("unknown renderer type: %s", renderer.Type)
+		}
+
+		if err != nil {
+			return nil, fmt.Errorf("error rendering path %s with type %s: %w", renderer.Path, renderer.Type, err)
+		}
+
+		allManifests = append(allManifests, manifests...)
+	}
+
+	return allManifests, nil
+}
+
+func renderDefault(dir string, svc *console.ServiceDeploymentForAgent, utilFactory util.Factory) ([]unstructured.Unstructured, error) {
 	renderer := RendererRaw
 
 	_ = filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {

pkg/manifests/template/template_test.go

@@ -0,0 +1,203 @@
+package template
+
+import (
+	"context"
+	"log"
+	"net/http"
+	"path/filepath"
+	"sort"
+	"strings"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+	console "github.com/pluralsh/console/go/client"
+	"github.com/samber/lo"
+)
+
+var _ = Describe("Default template", func() {
+
+	svc := &console.ServiceDeploymentForAgent{
+		Namespace:     "default",
+		Configuration: make([]*console.ServiceDeploymentForAgent_Configuration, 0),
+	}
+	Context("Render raw template with no renderers provided", func() {
+		const name = "nginx"
+		It("should successfully render the raw template", func() {
+			dir := filepath.Join("..", "..", "..", "test", "raw")
+			svc.Configuration = []*console.ServiceDeploymentForAgent_Configuration{
+				{
+					Name:  "name",
+					Value: name,
+				},
+			}
+			svc.Cluster = &console.ServiceDeploymentForAgent_Cluster{
+				ID:   "123",
+				Name: "test",
+			}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(1))
+			Expect(resp[0].GetName()).To(Equal(name))
+		})
+		It("should skip templating liquid", func() {
+			dir := filepath.Join("..", "..", "..", "test", "rawTemplated")
+			svc.Templated = lo.ToPtr(false)
+			svc.Renderers = []*console.RendererFragment{{Path: dir, Type: console.RendererTypeAuto}}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(1))
+			Expect(resp[0].GetName()).To(Equal(name))
+		})
+
+	})
+})
+
+var _ = Describe("Default template, AUTO", func() {
+
+	svc := &console.ServiceDeploymentForAgent{
+		Namespace:     "default",
+		Configuration: make([]*console.ServiceDeploymentForAgent_Configuration, 0),
+	}
+	Context("Render raw template ", func() {
+		const name = "nginx"
+		It("should successfully render the raw template", func() {
+			dir := filepath.Join("..", "..", "..", "test", "raw")
+			svc.Configuration = []*console.ServiceDeploymentForAgent_Configuration{
+				{
+					Name:  "name",
+					Value: name,
+				},
+			}
+			svc.Cluster = &console.ServiceDeploymentForAgent_Cluster{
+				ID:   "123",
+				Name: "test",
+			}
+			svc.Renderers = []*console.RendererFragment{{Path: dir, Type: console.RendererTypeAuto}}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(1))
+			Expect(resp[0].GetName()).To(Equal(name))
+		})
+		It("should skip templating liquid", func() {
+			dir := filepath.Join("..", "..", "..", "test", "rawTemplated")
+			svc.Templated = lo.ToPtr(false)
+			svc.Renderers = []*console.RendererFragment{{Path: dir, Type: console.RendererTypeAuto}}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(1))
+			Expect(resp[0].GetName()).To(Equal(name))
+		})
+
+	})
+})
+
+var _ = Describe("KUSTOMIZE template, AUTO", func() {
+
+	svc := &console.ServiceDeploymentForAgent{
+		Namespace:     "default",
+		Configuration: make([]*console.ServiceDeploymentForAgent_Configuration, 0),
+	}
+	Context("Render kustomize template ", func() {
+		It("should successfully render the kustomize template", func() {
+			dir := filepath.Join("..", "..", "..", "test", "mixed", "kustomize", "overlays", "dev")
+			svc.Cluster = &console.ServiceDeploymentForAgent_Cluster{
+				ID:   "123",
+				Name: "test",
+			}
+			svc.Renderers = []*console.RendererFragment{{Path: dir, Type: console.RendererTypeAuto}}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(3))
+			sort.Slice(resp, func(i, j int) bool {
+				return resp[i].GetKind() < resp[j].GetKind()
+			})
+			Expect(resp[0].GetKind()).To(Equal("ConfigMap"))
+			Expect(strings.HasPrefix(resp[0].GetName(), "app-config")).Should(BeTrue())
+			Expect(resp[1].GetKind()).To(Equal("Deployment"))
+			Expect(resp[2].GetKind()).To(Equal("Secret"))
+			Expect(strings.HasPrefix(resp[2].GetName(), "credentials")).Should(BeTrue())
+		})
+
+	})
+})
+
+var _ = Describe("RAW and KUSTOMIZE and HELM renderers", Ordered, func() {
+	svc := &console.ServiceDeploymentForAgent{
+		Namespace:     "default",
+		Name:          "test",
+		Configuration: make([]*console.ServiceDeploymentForAgent_Configuration, 0),
+	}
+
+	r := gin.Default()
+	r.GET("/version", func(c *gin.Context) {
+		c.JSON(http.StatusOK, gin.H{
+			"major": "1",
+			"minor": "21",
+		})
+	})
+
+	srv := &http.Server{
+		Addr:    ":8080",
+		Handler: r,
+	}
+
+	BeforeAll(func() {
+		// Initializing the server in a goroutine so that
+		// it won't block the graceful shutdown handling below
+		go func() {
+			if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+				Expect(err).NotTo(HaveOccurred())
+			}
+		}()
+	})
+	AfterAll(func() {
+
+		// The context is used to inform the server it has 5 seconds to finish
+		// the request it is currently handling
+		ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
+		defer cancel()
+		if err := srv.Shutdown(ctx); err != nil {
+			log.Fatal("Server forced to shutdown: ", err)
+		}
+
+		log.Println("Server exiting")
+	})
+
+	Context("Render RAW and KUSTOMIZE and HELM template", func() {
+		const name = "nginx"
+		It("should successfully render the raw and kustomize templates", func() {
+			dir := filepath.Join("..", "..", "..", "test", "mixed")
+			dirRaw := filepath.Join("..", "..", "..", "test", "mixed", "raw")
+			dirKustomize := filepath.Join("..", "..", "..", "test", "mixed", "kustomize", "overlays", "dev")
+			dirHelm := filepath.Join("..", "..", "..", "test", "mixed", "helm", "yet-another-cloudwatch-exporter")
+			svc.Configuration = []*console.ServiceDeploymentForAgent_Configuration{
+				{
+					Name:  "name",
+					Value: name,
+				},
+			}
+			svc.Cluster = &console.ServiceDeploymentForAgent_Cluster{
+				ID:   "123",
+				Name: "test",
+			}
+			svc.Renderers = []*console.RendererFragment{{Path: dirRaw, Type: console.RendererTypeRaw}, {Path: dirKustomize, Type: console.RendererTypeKustomize}, {Path: dirHelm, Type: console.RendererTypeHelm}}
+			resp, err := Render(dir, svc, utilFactory)
+			Expect(err).NotTo(HaveOccurred())
+			Expect(len(resp)).To(Equal(5))
+			Expect(resp[0].GetName()).To(Equal(name))
+			sort.Slice(resp[1:4], func(i, j int) bool {
+				return resp[1+i].GetKind() < resp[1+j].GetKind()
+			})
+			Expect(resp[1].GetKind()).To(Equal("ConfigMap"))
+			Expect(strings.HasPrefix(resp[1].GetName(), "app-config")).Should(BeTrue())
+			Expect(resp[2].GetKind()).To(Equal("Deployment"))
+			Expect(resp[3].GetKind()).To(Equal("Secret"))
+			Expect(strings.HasPrefix(resp[3].GetName(), "credentials")).Should(BeTrue())
+			Expect(resp[4].GetKind()).To(Equal("ServiceMonitor"))
+			Expect(resp[4].GetName()).To(Equal("test"))
+		})
+
+	})
+})

test/mixed/helm/yet-another-cloudwatch-exporter/Chart.yaml

@@ -0,0 +1,7 @@
+apiVersion: v2
+name: yet-another-cloudwatch-exporter
+description: Yace - Yet Another CloudWatch Exporter
+type: application
+version: 0.1.0
+appVersion: "v0.61.2"
+

test/mixed/helm/yet-another-cloudwatch-exporter/templates/_helpers.tpl

@@ -0,0 +1,62 @@
+{{/*
+Expand the name of the chart.
+*/}}
+{{- define "yet-another-cloudwatch-exporter.name" -}}
+{{- default .Chart.Name .Values.nameOverride | trunc 63 | trimSuffix "-" }}
+{{- end }}
+
+{{/*
+Create a default fully qualified app name.
+We truncate at 63 chars because some Kubernetes name fields are limited to this (by the DNS naming spec).
+If release name contains chart name it will be used as a full name.
+*/}}
+{{- define "yet-another-cloudwatch-exporter.fullname" -}}
+{{- if .Values.fullnameOverride }}
+{{- .Values.fullnameOverride | trunc 63 | trimSuffix "-" }}
+{{- else }}
+{{- $name := default .Chart.Name .Values.nameOverride }}
+{{- if contains $name .Release.Name }}
+{{- .Release.Name | trunc 63 | trimSuffix "-" }}
+{{- else }}
+{{- printf "%s-%s" .Release.Name $name | trunc 63 | trimSuffix "-" }}
+{{- end }}
+{{- end }}
+{{- end }}
+
+{{/*
+Create chart name and version as used by the chart label.
+*/}}
+{{- define "yet-another-cloudwatch-exporter.chart" -}}
+{{- printf "%s-%s" .Chart.Name .Chart.Version | replace "+" "_" | trunc 63 | trimSuffix "-" }}
+{{- end }}
+
+{{/*
+Common labels
+*/}}
+{{- define "yet-another-cloudwatch-exporter.labels" -}}
+helm.sh/chart: {{ include "yet-another-cloudwatch-exporter.chart" . }}
+{{ include "yet-another-cloudwatch-exporter.selectorLabels" . }}
+{{- if .Chart.AppVersion }}
+app.kubernetes.io/version: {{ .Chart.AppVersion | quote }}
+{{- end }}
+app.kubernetes.io/managed-by: {{ .Release.Service }}
+{{- end }}
+
+{{/*
+Selector labels
+*/}}
+{{- define "yet-another-cloudwatch-exporter.selectorLabels" -}}
+app.kubernetes.io/name: {{ include "yet-another-cloudwatch-exporter.name" . }}
+app.kubernetes.io/instance: {{ .Release.Name }}
+{{- end }}
+
+{{/*
+Create the name of the service account to use
+*/}}
+{{- define "yet-another-cloudwatch-exporter.serviceAccountName" -}}
+{{- if .Values.serviceAccount.create }}
+{{- default (include "yet-another-cloudwatch-exporter.fullname" .) .Values.serviceAccount.name }}
+{{- else }}
+{{- default "default" .Values.serviceAccount.name }}
+{{- end }}
+{{- end }}

test/mixed/helm/yet-another-cloudwatch-exporter/templates/job.yaml

@@ -0,0 +1,16 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: pi
+  annotations:
+    "helm.sh/hook": pre-install
+    "helm.sh/hook-delete-policy": hook-succeeded, before-hook-creation
+spec:
+  template:
+    spec:
+      containers:
+        - name: pi
+          image: perl:5.34.0
+          command: ["perl",  "-Mbignum=bpi", "-wle", "print bpi(2000)"]
+      restartPolicy: Never
+  backoffLimit: 4

test/mixed/helm/yet-another-cloudwatch-exporter/templates/servicemonitor.yaml

@@ -0,0 +1,41 @@
+{{- if and ( .Capabilities.APIVersions.Has "monitoring.coreos.com/v1" ) ( .Values.serviceMonitor.enabled ) }}
+apiVersion: monitoring.coreos.com/v1
+kind: ServiceMonitor
+metadata:
+  name: test
+{{- if .Values.serviceMonitor.namespace }}
+  namespace: {{ .Values.serviceMonitor.namespace }}
+{{- end }}
+  labels:
+    {{- include "yet-another-cloudwatch-exporter.labels" . | nindent 4 }}
+    {{- with .Values.serviceMonitor.labels }}
+      {{- toYaml . | nindent 4 }}
+    {{- end }}
+spec:
+  endpoints:
+  - port: http
+{{- if .Values.serviceMonitor.interval }}
+    interval: {{ .Values.serviceMonitor.interval }}
+{{- end }}
+{{- if .Values.serviceMonitor.telemetryPath }}
+    path: {{ .Values.serviceMonitor.telemetryPath }}
+{{- end }}
+{{- if .Values.serviceMonitor.timeout }}
+    scrapeTimeout: {{ .Values.serviceMonitor.timeout }}
+{{- end }}
+{{- if .Values.serviceMonitor.relabelings }}
+    relabelings:
+{{ toYaml .Values.serviceMonitor.relabelings | indent 6 }}
+{{- end }}
+{{- if .Values.serviceMonitor.metricRelabelings }}
+    metricRelabelings:
+{{ toYaml .Values.serviceMonitor.metricRelabelings | indent 6 }}
+{{- end }}
+  jobLabel: {{ template "yet-another-cloudwatch-exporter.fullname" . }}
+  namespaceSelector:
+    matchNames:
+    - {{ .Release.Namespace }}
+  selector:
+    matchLabels:
+      {{- include "yet-another-cloudwatch-exporter.selectorLabels" . | nindent 6 }}
+{{- end }}

test/mixed/helm/yet-another-cloudwatch-exporter/values.yaml

@@ -0,0 +1,7 @@
+serviceMonitor:
+  # When set true then use a ServiceMonitor to configure scraping
+  enabled: true
+
+
+
+