feat: resolve imports from services

go.mod

@@ -28,7 +28,7 @@ require (
 	github.com/open-policy-agent/gatekeeper/v3 v3.17.1
 	github.com/orcaman/concurrent-map/v2 v2.0.1
 	github.com/pkg/errors v0.9.1
-	github.com/pluralsh/console/go/client v1.21.0
+	github.com/pluralsh/console/go/client v1.21.2
 	github.com/pluralsh/controller-reconcile-helper v0.1.0
 	github.com/pluralsh/gophoenix v0.1.3-0.20231201014135-dff1b4309e34
 	github.com/pluralsh/polly v0.1.10

go.sum

@@ -666,8 +666,8 @@ github.com/phayes/freeport v0.0.0-20220201140144-74d24b5ae9f5/go.mod h1:iIss55rK
 github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
 github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
-github.com/pluralsh/console/go/client v1.21.0 h1:l7gltTPY8gR4qhK0RV8WYBP3MdpwJe96AIclTti9Hz0=
-github.com/pluralsh/console/go/client v1.21.0/go.mod h1:lpoWASYsM9keNePS3dpFiEisUHEfObIVlSL3tzpKn8k=
+github.com/pluralsh/console/go/client v1.21.2 h1:bYbgporkQx8yDrKARF2tsKh4o15fwtT4yDLTkyPmi9M=
+github.com/pluralsh/console/go/client v1.21.2/go.mod h1:lpoWASYsM9keNePS3dpFiEisUHEfObIVlSL3tzpKn8k=
 github.com/pluralsh/controller-reconcile-helper v0.1.0 h1:BV3dYZFH5rn8ZvZjtpkACSv/GmLEtRftNQj/Y4ddHEo=
 github.com/pluralsh/controller-reconcile-helper v0.1.0/go.mod h1:RxAbvSB4/jkvx616krCdNQXPbpGJXW3J1L3rASxeFOA=
 github.com/pluralsh/gophoenix v0.1.3-0.20231201014135-dff1b4309e34 h1:ab2PN+6if/Aq3/sJM0AVdy1SYuMAnq4g20VaKhTm/Bw=

pkg/manifests/template/raw.go

@@ -32,6 +32,7 @@ func renderLiquid(input []byte, svc *console.GetServiceDeploymentForAgent_Servic
 		"configuration": configMap(svc),
 		"cluster":       clusterConfiguration(svc.Cluster),
 		"contexts":      contexts(svc),
+		"imports":       imports(svc),
 	}
 	return template.RenderLiquid(input, bindings)
 }

pkg/manifests/template/tpl.go

@@ -10,6 +10,7 @@ func renderTpl(input []byte, svc *console.GetServiceDeploymentForAgent_ServiceDe
 		"Configuration": configMap(svc),
 		"Cluster":       clusterConfiguration(svc.Cluster),
 		"Contexts":      contexts(svc),
+		"Imports":       imports(svc),
 	}
 
 	return template.RenderTpl(input, bindings)

pkg/manifests/template/utils.go

@@ -51,3 +51,14 @@ func contexts(svc *console.GetServiceDeploymentForAgent_ServiceDeployment) map[s
 	}
 	return res
 }
+
+func imports(svc *console.GetServiceDeploymentForAgent_ServiceDeployment) map[string]map[string]string {
+	res := map[string]map[string]string{}
+	for _, imp := range svc.Imports {
+		res[imp.Stack.Name] = map[string]string{}
+		for _, out := range imp.Outputs {
+			res[imp.Stack.Name][out.Name] = out.Value
+		}
+	}
+	return res
+}

pkg/manifests/template/utils_test.go

@@ -0,0 +1,59 @@
+package template
+
+import (
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+	console "github.com/pluralsh/console/go/client"
+	"github.com/samber/lo"
+)
+
+var _ = Describe("Kustomize template", func() {
+
+	svc := &console.GetServiceDeploymentForAgent_ServiceDeployment{
+		Namespace: "default",
+		Kustomize: &console.GetServiceDeploymentForAgent_ServiceDeployment_Kustomize{
+			Path: "",
+		},
+		Imports: []*console.GetServiceDeploymentForAgent_ServiceDeployment_Imports{
+			{
+				ID: "1",
+				Stack: &console.GetServiceDeploymentForAgent_ServiceDeployment_Imports_Stack{
+					ID:   lo.ToPtr("1"),
+					Name: "1",
+				},
+				Outputs: []*console.GetServiceDeploymentForAgent_ServiceDeployment_Imports_Outputs{
+					{
+						Name:  "ansible_instance_ids",
+						Value: "[\"i-05066719bbd2ea672\",\"i-0810e18d30b5cd564\",\"i-0c2a356e403cd67ec\"]",
+					},
+					{
+						Name:  "ansible_key_pair_name",
+						Value: "ansible-ssh-key",
+					},
+				},
+			},
+			{
+				ID: "2",
+				Stack: &console.GetServiceDeploymentForAgent_ServiceDeployment_Imports_Stack{
+					ID:   lo.ToPtr("2"),
+					Name: "2",
+				},
+				Outputs: []*console.GetServiceDeploymentForAgent_ServiceDeployment_Imports_Outputs{
+					{
+						Name:  "stacks_iam_role",
+						Value: "arn:aws:iam::312272277431:role/boot-test-plrl-stacks",
+					},
+				},
+			},
+		},
+	}
+	Context("Render imports", func() {
+		It("should successfully render the imports", func() {
+			resp := imports(svc)
+			Expect(len(resp)).To(Equal(2))
+			Expect(len(resp["1"])).To(Equal(2))
+			Expect(len(resp["2"])).To(Equal(1))
+		})
+
+	})
+})