Merge branch 'master' into feat-fix-install-sh

not important but...

cmd/katenary/main.go

@@ -6,13 +6,13 @@ package main
 
 import (
 	"fmt"
+	"log"
 	"os"
 	"strings"
 
 	"katenary.io/internal/generator"
 	"katenary.io/internal/generator/katenaryfile"
 	"katenary.io/internal/generator/labels"
-	"katenary.io/internal/logger"
 	"katenary.io/internal/utils"
 
 	"github.com/compose-spec/compose-go/v2/cli"
@@ -28,7 +28,7 @@ func main() {
 	rootCmd := buildRootCmd()
 
 	if err := rootCmd.Execute(); err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 	}
 }
 

doc/docs/usage.md

@@ -97,8 +97,7 @@ Katenary transforms compose services this way:
 - environment variables will be stored inside a `ConfigMap`
 - image, tags, and ingresses configuration are also stored in `values.yaml` file
 - if named volumes are declared, Katenary create `PersistentVolumeClaims` - not enabled in values file
-- `depends_on` uses Kubernetes API by default to check if the service endpoint is ready. No port required.
+- `depends_on` needs that the pointed service declared a port. If not, you can use labels to inform Katenary
-  Use label `katenary.v3/depends-on: legacy` to use the old netcat method (requires port).
 
 For any other specific configuration, like binding local files as `ConfigMap`, bind variables, add values with
 documentation, etc. You'll need to use labels.
@@ -148,8 +147,10 @@ Katenary proposes a lot of labels to configure the helm chart generation, but so
 
 ### Work with Depends On?
 
-Katenary creates `initContainer` to wait for dependent services to be ready. By default, it uses the Kubernetes API
+Kubernetes does not provide service or pod starting detection from others pods. But Katenary will create `initContainer`
-to check if the service endpoint has ready addresses - no port required.
+to make you able to wait for a service to respond. But you'll probably need to adapt a bit the compose file.
+
+See this compose file:
 
 ```yaml
 version: "3"
@@ -166,7 +167,9 @@ services:
       MYSQL_ROOT_PASSWORD: foobar
 ```
 
-If you need the old netcat-based method (requires port), add the `katenary.v3/depends-on: legacy` label to the dependent service:
+In this case, `webapp` needs to know the `database` port because the `depends_on` points on it and Kubernetes has not
+(yet) solution to check the database startup. Katenary wants to create a `initContainer` to hit on the related service.
+So, instead of exposing the port in the compose definition, let's declare this to Katenary with labels:
 
 ```yaml
 version: "3"
@@ -176,15 +179,14 @@ services:
     image: php:8-apache
     depends_on:
       - database
-    labels:
-      katenary.v3/depends-on: legacy
 
   database:
     image: mariadb
     environment:
       MYSQL_ROOT_PASSWORD: foobar
-    ports:
+    labels:
-      - 3306:3306
+      katenary.v3/ports: |-
+        - 3306
 ```
 
 ### Declare ingresses

install.sh

@@ -49,7 +49,6 @@ fi
 
 # Where to download the binary
 TAG=$(curl -sLf https://repo.katenary.io/api/v1/repos/katenary/katenary/releases/latest 2>/dev/null | grep -Po '"tag_name":\s*"[^"]*"' | cut -d ":" -f2 | tr -d '"')
-TAG=${TAG#releases/}
 
 # use the right names for the OS and architecture
 if [ $ARCH = "x86_64" ]; then
@@ -58,7 +57,6 @@ fi
 
 BIN_URL="https://repo.katenary.io/api/packages/Katenary/generic/katenary/$TAG/katenary-$OS-$ARCH"
 
-
 echo
 echo "Downloading $BIN_URL"
 

internal/generator/chart.go

@@ -2,6 +2,7 @@ package generator
 
 import (
 	"fmt"
+	"log"
 	"maps"
 	"os"
 	"path/filepath"
@@ -330,12 +331,12 @@ func (chart *HelmChart) setSharedConf(service types.ServiceConfig, deployments m
 	}
 	fromservices, err := labelstructs.EnvFromFrom(service.Labels[labels.LabelEnvFrom])
 	if err != nil {
-		logger.Fatal("error unmarshaling env-from label:", err)
+		log.Fatal("error unmarshaling env-from label:", err)
 	}
 	// find the configmap in the chart templates
 	for _, fromservice := range fromservices {
 		if _, ok := chart.Templates[fromservice+".configmap.yaml"]; !ok {
-			logger.Warnf("configmap %s not found in chart templates", fromservice)
+			log.Printf("configmap %s not found in chart templates", fromservice)
 			continue
 		}
 		// find the corresponding target deployment
@@ -355,7 +356,7 @@ func (chart *HelmChart) setEnvironmentValuesFrom(service types.ServiceConfig, de
 	}
 	mapping, err := labelstructs.GetValueFrom(service.Labels[labels.LabelValuesFrom])
 	if err != nil {
-		logger.Fatal("error unmarshaling values-from label:", err)
+		log.Fatal("error unmarshaling values-from label:", err)
 	}
 
 	findDeployment := func(name string) *Deployment {
@@ -374,11 +375,11 @@ func (chart *HelmChart) setEnvironmentValuesFrom(service types.ServiceConfig, de
 		dep := findDeployment(depName[0])
 		target := findDeployment(service.Name)
 		if dep == nil || target == nil {
-			logger.Fatalf("deployment %s or %s not found", depName[0], service.Name)
+			log.Fatalf("deployment %s or %s not found", depName[0], service.Name)
 		}
 		container, index := utils.GetContainerByName(target.service.ContainerName, target.Spec.Template.Spec.Containers)
 		if container == nil {
-			logger.Fatalf("Container %s not found", target.GetName())
+			log.Fatalf("Container %s not found", target.GetName())
 		}
 		reourceName := fmt.Sprintf(`{{ include "%s.fullname" . }}-%s`, chart.Name, depName[0])
 		// add environment with from

internal/generator/configMap.go

@@ -2,6 +2,7 @@ package generator
 
 import (
 	"fmt"
+	"log"
 	"os"
 	"path/filepath"
 	"regexp"
@@ -68,7 +69,7 @@ func NewConfigMap(service types.ServiceConfig, appName string, forFile bool) *Co
 	// get the secrets from the labels
 	secrets, err := labelstructs.SecretsFrom(service.Labels[labels.LabelSecrets])
 	if err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 	}
 	// drop the secrets from the environment
 	for _, secret := range secrets {
@@ -94,7 +95,7 @@ func NewConfigMap(service types.ServiceConfig, appName string, forFile bool) *Co
 		if l, ok := service.Labels[labels.LabelMapEnv]; ok {
 			envmap, err := labelstructs.MapEnvFrom(l)
 			if err != nil {
-				logger.Fatal("Error parsing map-env", err)
+				log.Fatal("Error parsing map-env", err)
 			}
 			for key, value := range envmap {
 				cm.AddData(key, strings.ReplaceAll(value, "__APP__", appName))
@@ -144,7 +145,7 @@ func NewConfigMapFromDirectory(service types.ServiceConfig, appName, path string
 	path = filepath.Join(service.WorkingDir, path)
 	path = filepath.Clean(path)
 	if err := cm.AppendDir(path); err != nil {
-		logger.Fatal("Error adding files to configmap:", err)
+		log.Fatal("Error adding files to configmap:", err)
 	}
 	return cm
 }

internal/generator/converter.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
+	"log"
 	"os"
 	"os/exec"
 	"path/filepath"
@@ -109,19 +110,8 @@ func Convert(config ConvertOptions, dockerComposeFile ...string) error {
 
 	// the current working directory is the directory
 	currentDir, _ := os.Getwd()
-	// Filter to only existing files before chdir
-	var existingFiles []string
-	for _, f := range dockerComposeFile {
-		if _, err := os.Stat(f); err == nil {
-			existingFiles = append(existingFiles, f)
-		}
-	}
-	if len(existingFiles) == 0 && len(dockerComposeFile) > 0 {
-		return fmt.Errorf("no compose file found: %v", dockerComposeFile)
-	}
-
 	// go to the root of the project
-	if err := os.Chdir(filepath.Dir(existingFiles[0])); err != nil {
+	if err := os.Chdir(filepath.Dir(dockerComposeFile[0])); err != nil {
 		logger.Failure(err.Error())
 		return err
 	}
@@ -133,12 +123,12 @@ func Convert(config ConvertOptions, dockerComposeFile ...string) error {
 	}()
 
 	// repove the directory part of the docker-compose files
-	for i, f := range existingFiles {
+	for i, f := range dockerComposeFile {
-		existingFiles[i] = filepath.Base(f)
+		dockerComposeFile[i] = filepath.Base(f)
 	}
 
 	// parse the compose files
-	project, err := parser.Parse(config.Profiles, config.EnvFiles, existingFiles...)
+	project, err := parser.Parse(config.Profiles, config.EnvFiles, dockerComposeFile...)
 	if err != nil {
 		logger.Failure("Cannot parse compose files", err.Error())
 		return err
@@ -606,7 +596,7 @@ func callHelmUpdate(config ConvertOptions) {
 func removeNewlinesInsideBrackets(values []byte) []byte {
 	re, err := regexp.Compile(`(?s)\{\{(.*?)\}\}`)
 	if err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 	}
 	return re.ReplaceAllFunc(values, func(b []byte) []byte {
 		// get the first match
@@ -645,7 +635,7 @@ func writeContent(path string, content []byte) {
 	defer f.Close()
 	defer func() {
 		if _, err := f.Write(content); err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 	}()
 }

internal/generator/cronJob.go

@@ -1,11 +1,11 @@
 package generator
 
 import (
+	"log"
 	"strings"
 
 	"katenary.io/internal/generator/labels"
 	"katenary.io/internal/generator/labels/labelstructs"
-	"katenary.io/internal/logger"
 	"katenary.io/internal/utils"
 
 	"github.com/compose-spec/compose-go/v2/types"
@@ -33,7 +33,7 @@ func NewCronJob(service types.ServiceConfig, chart *HelmChart, appName string) (
 	}
 	mapping, err := labelstructs.CronJobFrom(labels)
 	if err != nil {
-		logger.Fatalf("Error parsing cronjob labels: %s", err)
+		log.Fatalf("Error parsing cronjob labels: %s", err)
 		return nil, nil
 	}
 

internal/generator/deployment.go

@@ -2,6 +2,7 @@ package generator
 
 import (
 	"fmt"
+	"log"
 	"os"
 	"path/filepath"
 	"regexp"
@@ -19,8 +20,6 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-const shCommand = "/bin/sh"
-
 var _ Yaml = (*Deployment)(nil)
 
 type mountPathConfig struct {
@@ -44,7 +43,6 @@ type Deployment struct {
 	isMainApp          bool                                    `yaml:"-"`
 	exchangesVolumes   map[string]*labelstructs.ExchangeVolume `yaml:"-"`
 	boundEnvVar        []string                                `yaml:"-"` // environement to remove
-	needsServiceAccount bool                                    `yaml:"-"`
 }
 
 // NewDeployment creates a new Deployment from a compose service. The appName is the name of the application taken from the project name.
@@ -168,7 +166,7 @@ func (d *Deployment) AddHealthCheck(service types.ServiceConfig, container *core
 	if v, ok := service.Labels[labels.LabelHealthCheck]; ok {
 		probes, err := labelstructs.ProbeFrom(v)
 		if err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 		container.LivenessProbe = probes.LivenessProbe
 		container.ReadinessProbe = probes.ReadinessProbe
@@ -203,7 +201,7 @@ func (d *Deployment) AddVolumes(service types.ServiceConfig, appName string) {
 	if v, ok := service.Labels[labels.LabelConfigMapFiles]; ok {
 		binds, err := labelstructs.ConfigMapFileFrom(v)
 		if err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 		for _, bind := range binds {
 			tobind[bind] = true
@@ -265,38 +263,26 @@ func (d *Deployment) BindFrom(service types.ServiceConfig, binded *Deployment) {
 
 // DependsOn adds a initContainer to the deployment that will wait for the service to be up.
 func (d *Deployment) DependsOn(to *Deployment, servicename string) error {
+	// Add a initContainer with busybox:latest using netcat to check if the service is up
+	// it will wait until the service responds to all ports
 	logger.Info("Adding dependency from ", d.service.Name, " to ", to.service.Name)
-
-	useLegacy := false
-	if label, ok := d.service.Labels[labels.LabelDependsOn]; ok {
-		useLegacy = strings.ToLower(label) == "legacy"
-	}
-
-	if useLegacy {
-		return d.dependsOnLegacy(to, servicename)
-	}
-
-	d.needsServiceAccount = true
-	return d.dependsOnK8sAPI(to)
-}
-
-func (d *Deployment) dependsOnLegacy(to *Deployment, servicename string) error {
 	for _, container := range to.Spec.Template.Spec.Containers {
 		commands := []string{}
 		if len(container.Ports) == 0 {
-			logger.Fatal("No ports found for service ",
+			logger.Warn("No ports found for service ",
 				servicename,
 				". You should declare a port in the service or use "+
 					labels.LabelPorts+
 					" label.",
 			)
+			os.Exit(1)
 		}
 		for _, port := range container.Ports {
 			command := fmt.Sprintf("until nc -z %s %d; do\n  sleep 1;\ndone", to.Name, port.ContainerPort)
 			commands = append(commands, command)
 		}
 
-		command := []string{shCommand, "-c", strings.Join(commands, "\n")}
+		command := []string{"/bin/sh", "-c", strings.Join(commands, "\n")}
 		d.Spec.Template.Spec.InitContainers = append(d.Spec.Template.Spec.InitContainers, corev1.Container{
 			Name:    "wait-for-" + to.service.Name,
 			Image:   "busybox:latest",
@@ -307,39 +293,6 @@ func (d *Deployment) dependsOnLegacy(to *Deployment, servicename string) error {
 	return nil
 }
 
-func (d *Deployment) dependsOnK8sAPI(to *Deployment) error {
-	script := `NAMESPACE=${NAMESPACE:-default}
-SERVICE=%s
-KUBERNETES_SERVICE_HOST=${KUBERNETES_SERVICE_HOST:-kubernetes.default.svc}
-KUBERNETES_SERVICE_PORT=${KUBERNETES_SERVICE_PORT:-443}
-
-until wget -q -O- --header="Authorization: Bearer $(cat /var/run/secrets/kubernetes.io/serviceaccount/token)" \
-  --cacert=/var/run/secrets/kubernetes.io/serviceaccount/ca.crt \
-  "https://${KUBERNETES_SERVICE_HOST}:${KUBERNETES_SERVICE_PORT}/api/v1/namespaces/${NAMESPACE}/endpoints/${SERVICE}" \
-  | grep -q '"ready":.*true'; do
-  sleep 2
-done`
-
-	command := []string{shCommand, "-c", fmt.Sprintf(script, to.Name)}
-	d.Spec.Template.Spec.InitContainers = append(d.Spec.Template.Spec.InitContainers, corev1.Container{
-		Name:    "wait-for-" + to.service.Name,
-		Image:   "busybox:latest",
-		Command: command,
-		Env: []corev1.EnvVar{
-			{
-				Name: "NAMESPACE",
-				ValueFrom: &corev1.EnvVarSource{
-					FieldRef: &corev1.ObjectFieldSelector{
-						FieldPath: "metadata.namespace",
-					},
-				},
-			},
-		},
-	})
-
-	return nil
-}
-
 // Filename returns the filename of the deployment.
 func (d *Deployment) Filename() string {
 	return d.service.Name + ".deployment.yaml"
@@ -358,7 +311,7 @@ func (d *Deployment) SetEnvFrom(service types.ServiceConfig, appName string, sam
 	defer func() {
 		c, index := d.BindMapFilesToContainer(service, secrets, appName)
 		if c == nil || index == -1 {
-			logger.Warn("Container not found for service ", service.Name)
+			log.Println("Container not found for service ", service.Name)
 			return
 		}
 		d.Spec.Template.Spec.Containers[index] = *c
@@ -367,7 +320,7 @@ func (d *Deployment) SetEnvFrom(service types.ServiceConfig, appName string, sam
 	// secrets from label
 	labelSecrets, err := labelstructs.SecretsFrom(service.Labels[labels.LabelSecrets])
 	if err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 	}
 
 	// values from label
@@ -382,7 +335,7 @@ func (d *Deployment) SetEnvFrom(service types.ServiceConfig, appName string, sam
 		_, ok := service.Environment[secret]
 		if !ok {
 			drop = append(drop, secret)
-			logger.Warn("Secret " + secret + " not found in service " + service.Name + " - skipped")
+			logger.Warn("Secret " + secret + " not found in service " + service.Name + " - skpped")
 			continue
 		}
 		secrets = append(secrets, secret)
@@ -399,7 +352,7 @@ func (d *Deployment) SetEnvFrom(service types.ServiceConfig, appName string, sam
 		val, ok := service.Environment[value]
 		if !ok {
 			drop = append(drop, value)
-			logger.Warn("Environment variable " + value + " not found in service " + service.Name + " - skipped")
+			logger.Warn("Environment variable " + value + " not found in service " + service.Name + " - skpped")
 			continue
 		}
 		if d.chart.Values[service.Name].(*Value).Environment == nil {
@@ -431,8 +384,8 @@ func (d *Deployment) BindMapFilesToContainer(service types.ServiceConfig, secret
 
 	if envSize > 0 {
 		if service.Name == "db" {
-			logger.Info("Service ", service.Name, " has environment variables")
+			log.Println("Service ", service.Name, " has environment variables")
-			logger.Info(service.Environment)
+			log.Println(service.Environment)
 		}
 		fromSources = append(fromSources, corev1.EnvFromSource{
 			ConfigMapRef: &corev1.ConfigMapEnvSource{
@@ -615,7 +568,7 @@ func (d *Deployment) Yaml() ([]byte, error) {
 		}
 
 		// manage serviceAccount, add condition to use the serviceAccount from values.yaml
-		if strings.Contains(line, "serviceAccountName:") && !d.needsServiceAccount {
+		if strings.Contains(line, "serviceAccountName:") {
 			spaces = strings.Repeat(" ", utils.CountStartingSpaces(line))
 			pre := spaces + `{{- if ne .Values.` + serviceName + `.serviceAccount "" }}`
 			post := spaces + "{{- end }}"
@@ -651,12 +604,6 @@ func (d *Deployment) Yaml() ([]byte, error) {
 	return []byte(strings.Join(content, "\n")), nil
 }
 
-func (d *Deployment) SetServiceAccountName() {
-	if d.needsServiceAccount {
-		d.Spec.Template.Spec.ServiceAccountName = utils.TplName(d.service.Name, d.chart.Name, "dependency")
-	}
-}
-
 func (d *Deployment) appendDirectoryToConfigMap(service types.ServiceConfig, appName string, volume types.ServiceVolumeConfig) {
 	pathnme := utils.PathToName(volume.Source)
 	if _, ok := d.configMaps[pathnme]; !ok {
@@ -668,7 +615,7 @@ func (d *Deployment) appendDirectoryToConfigMap(service types.ServiceConfig, app
 	// TODO: make it recursive to add all files in the directory and subdirectories
 	_, err := os.ReadDir(volume.Source)
 	if err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 	}
 	cm := NewConfigMapFromDirectory(service, appName, volume.Source)
 	d.configMaps[pathnme] = &ConfigMapMount{
@@ -713,7 +660,7 @@ func (d *Deployment) appendFileToConfigMap(service types.ServiceConfig, appName
 
 	}
 	if err := cm.AppendFile(volume.Source); err != nil {
-		logger.Fatal("Error adding file to configmap:", err)
+		log.Fatal("Error adding file to configmap:", err)
 	}
 }
 
@@ -774,7 +721,7 @@ func (d *Deployment) bindVolumes(volume types.ServiceVolumeConfig, tobind map[st
 		// Add volume to container
 		stat, err := os.Stat(volume.Source)
 		if err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 
 		if stat.IsDir() {

internal/generator/deployment_test.go

@@ -3,7 +3,6 @@ package generator
 import (
 	"fmt"
 	"os"
-	"slices"
 	"strings"
 	"testing"
 
@@ -12,7 +11,6 @@ import (
 	yaml3 "gopkg.in/yaml.v3"
 	v1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
-	rbacv1 "k8s.io/api/rbac/v1"
 	"sigs.k8s.io/yaml"
 )
 
@@ -144,86 +142,6 @@ services:
 	if len(dt.Spec.Template.Spec.InitContainers) != 1 {
 		t.Errorf("Expected 1 init container, got %d", len(dt.Spec.Template.Spec.InitContainers))
 	}
-
-	initContainer := dt.Spec.Template.Spec.InitContainers[0]
-	if !strings.Contains(initContainer.Image, "busybox") {
-		t.Errorf("Expected busybox image, got %s", initContainer.Image)
-	}
-
-	fullCommand := strings.Join(initContainer.Command, " ")
-	if !strings.Contains(fullCommand, "wget") {
-		t.Errorf("Expected wget command (K8s API method), got %s", fullCommand)
-	}
-
-	if !strings.Contains(fullCommand, "/api/v1/namespaces/") {
-		t.Errorf("Expected Kubernetes API call to /api/v1/namespaces/, got %s", fullCommand)
-	}
-
-	if !strings.Contains(fullCommand, "/endpoints/") {
-		t.Errorf("Expected Kubernetes API call to /endpoints/, got %s", fullCommand)
-	}
-
-	if len(initContainer.Env) == 0 {
-		t.Errorf("Expected environment variables to be set for namespace")
-	}
-
-	hasNamespace := false
-	for _, env := range initContainer.Env {
-		if env.Name == "NAMESPACE" && env.ValueFrom != nil && env.ValueFrom.FieldRef != nil {
-			if env.ValueFrom.FieldRef.FieldPath == "metadata.namespace" {
-				hasNamespace = true
-				break
-			}
-		}
-	}
-	if !hasNamespace {
-		t.Errorf("Expected NAMESPACE env var with metadata.namespace fieldRef")
-	}
-}
-
-func TestDependsOnLegacy(t *testing.T) {
-	composeFile := `
-services:
-    web:
-        image: nginx:1.29
-        ports:
-        - 80:80
-        depends_on:
-        - database
-        labels:
-            katenary.v3/depends-on: legacy
-
-    database:
-        image: mariadb:10.5
-        ports:
-        - 3306:3306
-`
-	tmpDir := setup(composeFile)
-	defer teardown(tmpDir)
-
-	currentDir, _ := os.Getwd()
-	os.Chdir(tmpDir)
-	defer os.Chdir(currentDir)
-
-	output := internalCompileTest(t, "-s", webTemplateOutput)
-	dt := v1.Deployment{}
-	if err := yaml.Unmarshal([]byte(output), &dt); err != nil {
-		t.Errorf(unmarshalError, err)
-	}
-
-	if len(dt.Spec.Template.Spec.InitContainers) != 1 {
-		t.Errorf("Expected 1 init container, got %d", len(dt.Spec.Template.Spec.InitContainers))
-	}
-
-	initContainer := dt.Spec.Template.Spec.InitContainers[0]
-	if !strings.Contains(initContainer.Image, "busybox") {
-		t.Errorf("Expected busybox image, got %s", initContainer.Image)
-	}
-
-	fullCommand := strings.Join(initContainer.Command, " ")
-	if !strings.Contains(fullCommand, "nc") {
-		t.Errorf("Expected nc (netcat) command for legacy method, got %s", fullCommand)
-	}
 }
 
 func TestHelmDependencies(t *testing.T) {
@@ -645,192 +563,3 @@ services:
 		t.Errorf("Expected command to be 'bar baz', got %s", strings.Join(command, " "))
 	}
 }
-
-func TestRestrictedRBACGeneration(t *testing.T) {
-	composeFile := `
-services:
-    web:
-        image: nginx:1.29
-        ports:
-        - 80:80
-        depends_on:
-        - database
-
-    database:
-        image: mariadb:10.5
-        ports:
-        - 3306:3306
-`
-	tmpDir := setup(composeFile)
-	defer teardown(tmpDir)
-
-	currentDir, _ := os.Getwd()
-	os.Chdir(tmpDir)
-	defer os.Chdir(currentDir)
-
-	rbacOutput := internalCompileTest(t, "-s", "templates/web/depends-on.rbac.yaml")
-
-	docs := strings.Split(rbacOutput, "---\n")
-
-	// Filter out empty documents and strip helm template comments
-	var filteredDocs []string
-	for _, doc := range docs {
-		if strings.TrimSpace(doc) != "" {
-			// Remove '# Source:' comment lines that helm template adds
-			lines := strings.Split(doc, "\n")
-			var contentLines []string
-			for _, line := range lines {
-				if !strings.HasPrefix(strings.TrimSpace(line), "# Source:") {
-					contentLines = append(contentLines, line)
-				}
-			}
-			filteredDocs = append(filteredDocs, strings.Join(contentLines, "\n"))
-		}
-	}
-
-	if len(filteredDocs) != 3 {
-		t.Fatalf("Expected 3 YAML documents in RBAC file, got %d (filtered from %d)", len(filteredDocs), len(docs))
-	}
-
-	var sa corev1.ServiceAccount
-	if err := yaml.Unmarshal([]byte(strings.TrimSpace(filteredDocs[0])), &sa); err != nil {
-		t.Errorf("Failed to unmarshal ServiceAccount: %v", err)
-	}
-	if sa.Kind != "ServiceAccount" {
-		t.Errorf("Expected Kind=ServiceAccount, got %s", sa.Kind)
-	}
-	if !strings.Contains(sa.Name, "web") {
-		t.Errorf("Expected ServiceAccount name to contain 'web', got %s", sa.Name)
-	}
-
-	var role rbacv1.Role
-	if err := yaml.Unmarshal([]byte(strings.TrimSpace(filteredDocs[1])), &role); err != nil {
-		t.Errorf("Failed to unmarshal Role: %v", err)
-	}
-	if role.Kind != "Role" {
-		t.Errorf("Expected Kind=Role, got %s", role.Kind)
-	}
-	if len(role.Rules) != 1 {
-		t.Errorf("Expected 1 rule in Role, got %d", len(role.Rules))
-	}
-
-	rule := role.Rules[0]
-	if !contains(rule.APIGroups, "") {
-		t.Error("Expected APIGroup to include core API ('')")
-	}
-	if !contains(rule.Resources, "endpoints") {
-		t.Errorf("Expected Resource to include 'endpoints', got %v", rule.Resources)
-	}
-
-	for _, res := range rule.Resources {
-		if res == "*" {
-			t.Error("Role should not have wildcard (*) resource permissions")
-		}
-	}
-	for _, verb := range rule.Verbs {
-		if verb == "*" {
-			t.Error("Role should not have wildcard (*) verb permissions")
-		}
-	}
-
-	var rb rbacv1.RoleBinding
-	if err := yaml.Unmarshal([]byte(strings.TrimSpace(filteredDocs[2])), &rb); err != nil {
-		t.Errorf("Failed to unmarshal RoleBinding: %v", err)
-	}
-	if rb.Kind != "RoleBinding" {
-		t.Errorf("Expected Kind=RoleBinding, got %s", rb.Kind)
-	}
-	if len(rb.Subjects) != 1 {
-		t.Errorf("Expected 1 subject in RoleBinding, got %d", len(rb.Subjects))
-	}
-	if rb.Subjects[0].Kind != "ServiceAccount" {
-		t.Errorf("Expected Subject Kind=ServiceAccount, got %s", rb.Subjects[0].Kind)
-	}
-
-	// Helm template renders the name, so check if it contains "web"
-	if !strings.Contains(rb.RoleRef.Name, "web") {
-		t.Errorf("Expected RoleRef Name to contain 'web', got %s", rb.RoleRef.Name)
-	}
-	if rb.RoleRef.Kind != "Role" {
-		t.Errorf("Expected RoleRef Kind=Role, got %s", rb.RoleRef.Kind)
-	}
-}
-
-func TestDeploymentReferencesServiceAccount(t *testing.T) {
-	composeFile := `
-services:
-    web:
-        image: nginx:1.29
-        ports:
-        - 80:80
-        depends_on:
-        - database
-
-    database:
-        image: mariadb:10.5
-        ports:
-        - 3306:3306
-`
-	tmpDir := setup(composeFile)
-	defer teardown(tmpDir)
-
-	currentDir, _ := os.Getwd()
-	os.Chdir(tmpDir)
-	defer os.Chdir(currentDir)
-
-	output := internalCompileTest(t, "-s", "templates/web/deployment.yaml")
-
-	var dt v1.Deployment
-	if err := yaml.Unmarshal([]byte(output), &dt); err != nil {
-		t.Errorf("Failed to unmarshal Deployment: %v", err)
-	}
-
-	serviceAccountName := dt.Spec.Template.Spec.ServiceAccountName
-	if !strings.Contains(serviceAccountName, "web") {
-		t.Errorf("Expected ServiceAccountName to contain 'web', got %s", serviceAccountName)
-	}
-
-	if len(dt.Spec.Template.Spec.InitContainers) == 0 {
-		t.Fatal("Expected at least one init container for depends_on")
-	}
-
-	initContainer := dt.Spec.Template.Spec.InitContainers[0]
-	if initContainer.Name != "wait-for-database" {
-		t.Errorf("Expected init container name 'wait-for-database', got %s", initContainer.Name)
-	}
-
-	fullCommand := strings.Join(initContainer.Command, " ")
-	if !strings.Contains(fullCommand, "wget") {
-		t.Error("Expected init container to use wget for K8s API calls")
-	}
-	if !strings.Contains(fullCommand, "/api/v1/namespaces/") {
-		t.Error("Expected init container to call /api/v1/namespaces/ endpoint")
-	}
-	if !strings.Contains(fullCommand, "/endpoints/") {
-		t.Error("Expected init container to access /endpoints/ resource")
-	}
-
-	hasNamespace := false
-	for _, env := range initContainer.Env {
-		if env.Name == "NAMESPACE" && env.ValueFrom != nil && env.ValueFrom.FieldRef != nil {
-			if env.ValueFrom.FieldRef.FieldPath == "metadata.namespace" {
-				hasNamespace = true
-				break
-			}
-		}
-	}
-	if !hasNamespace {
-		t.Error("Expected NAMESPACE env var with metadata.namespace fieldRef")
-	}
-
-	_, err := os.Stat("./chart/templates/web/depends-on.rbac.yaml")
-	if os.IsNotExist(err) {
-		t.Error("RBAC file depends-on.rbac.yaml should exist for service using depends_on with K8s API")
-	} else if err != nil {
-		t.Errorf("Unexpected error checking RBAC file: %v", err)
-	}
-}
-
-func contains(slice []string, item string) bool {
-	return slices.Contains(slice, item)
-}

internal/generator/extrafiles/readme.go

@@ -4,12 +4,12 @@ import (
 	"bytes"
 	_ "embed"
 	"fmt"
+	"log"
 	"sort"
 	"strings"
 	"text/template"
 
 	"gopkg.in/yaml.v3"
-	"katenary.io/internal/logger"
 )
 
 //go:embed readme.tpl
@@ -50,7 +50,7 @@ func ReadMeFile(charname, description string, values map[string]any) string {
 	vv := map[string]any{}
 	out, _ := yaml.Marshal(values)
 	if err := yaml.Unmarshal(out, &vv); err != nil {
-		logger.Warnf("Error parsing values: %s", err)
+		log.Printf("Error parsing values: %s", err)
 	}
 
 	result := make(map[string]string)

internal/generator/generator.go

@@ -3,6 +3,7 @@ package generator
 import (
 	"bytes"
 	"fmt"
+	"log"
 	"regexp"
 	"strings"
 
@@ -22,7 +23,7 @@ import (
 // The Generate function will create the HelmChart object this way:
 //
 //   - Detect the service port name or leave the port number if not found.
-//   - Create a deployment for each service that are not ingore.
+//   - Create a deployment for each service that are not ingnore.
 //   - Create a service and ingresses for each service that has ports and/or declared ingresses.
 //   - Create a PVC or Configmap volumes for each volume.
 //   - Create init containers for each service which has dependencies to other services.
@@ -134,12 +135,6 @@ func Generate(project *types.Project) (*HelmChart, error) {
 			}
 		}
 	}
-
-	// set ServiceAccountName for deployments that need it
-	for _, d := range deployments {
-		d.SetServiceAccountName()
-	}
-
 	for _, name := range drops {
 		delete(deployments, name)
 	}
@@ -148,14 +143,9 @@ func Generate(project *types.Project) (*HelmChart, error) {
 		chart.setEnvironmentValuesFrom(s, deployments)
 	}
 
-	// generate RBAC resources for services that need K8s API access (non-legacy depends_on)
-	if err := chart.generateRBAC(deployments); err != nil {
-		logger.Fatalf("error generating RBAC: %s", err)
-	}
-
 	// generate configmaps with environment variables
 	if err := chart.generateConfigMapsAndSecrets(project); err != nil {
-		logger.Fatalf("error generating configmaps and secrets: %s", err)
+		log.Fatalf("error generating configmaps and secrets: %s", err)
 	}
 
 	// if the env-from label is set, we need to add the env vars from the configmap
@@ -290,7 +280,7 @@ func addStaticVolumes(deployments map[string]*Deployment, service types.ServiceC
 	var d *Deployment
 	var ok bool
 	if d, ok = deployments[service.Name]; !ok {
-		logger.Warnf("service %s not found in deployments", service.Name)
+		log.Printf("service %s not found in deployments", service.Name)
 		return
 	}
 
@@ -302,7 +292,7 @@ func addStaticVolumes(deployments map[string]*Deployment, service types.ServiceC
 		var y []byte
 		var err error
 		if y, err = config.configMap.Yaml(); err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 
 		// add the configmap to the chart
@@ -444,65 +434,13 @@ func samePodVolume(service types.ServiceConfig, v types.ServiceVolumeConfig, dep
 	// check if it has the same volume
 	for _, tv := range target.Spec.Template.Spec.Volumes {
 		if tv.Name == v.Source {
-			logger.Warnf("found same pod volume %s in deployment %s and %s", tv.Name, service.Name, targetDeployment)
+			log.Printf("found same pod volume %s in deployment %s and %s", tv.Name, service.Name, targetDeployment)
 			return true
 		}
 	}
 	return false
 }
 
-// generateRBAC creates RBAC resources (ServiceAccount, Role, RoleBinding) for services that need K8s API access.
-// A service needs RBAC if it has non-legacy depends_on relationships.
-func (chart *HelmChart) generateRBAC(deployments map[string]*Deployment) error {
-	serviceMap := make(map[string]bool)
-
-	for _, d := range deployments {
-		if !d.needsServiceAccount {
-			continue
-		}
-
-		sa := NewServiceAccount(*d.service, chart.Name)
-		role := NewRestrictedRole(*d.service, chart.Name)
-		rb := NewRestrictedRoleBinding(*d.service, chart.Name)
-
-		var buf bytes.Buffer
-
-		saYaml, err := yaml.Marshal(sa.ServiceAccount)
-		if err != nil {
-			return fmt.Errorf("error marshaling ServiceAccount for %s: %w", d.service.Name, err)
-		}
-		buf.Write(saYaml)
-		buf.WriteString("---\n")
-
-		roleYaml, err := yaml.Marshal(role.Role)
-		if err != nil {
-			return fmt.Errorf("error marshaling Role for %s: %w", d.service.Name, err)
-		}
-		buf.Write(roleYaml)
-		buf.WriteString("---\n")
-
-		rbYaml, err := yaml.Marshal(rb.RoleBinding)
-		if err != nil {
-			return fmt.Errorf("error marshaling RoleBinding for %s: %w", d.service.Name, err)
-		}
-		buf.Write(rbYaml)
-
-		filename := d.service.Name + "/depends-on.rbac.yaml"
-		chart.Templates[filename] = &ChartTemplate{
-			Content:     buf.Bytes(),
-			Servicename: d.service.Name,
-		}
-
-		serviceMap[d.service.Name] = true
-	}
-
-	for svcName := range serviceMap {
-		logger.Log(logger.IconPackage, "Creating RBAC", svcName)
-	}
-
-	return nil
-}
-
 func fixContainerNames(project *types.Project) {
 	// fix container names to be unique
 	for i, service := range project.Services {

internal/generator/ingress.go

@@ -1,11 +1,11 @@
 package generator
 
 import (
+	"log"
 	"strings"
 
 	"katenary.io/internal/generator/labels"
 	"katenary.io/internal/generator/labels/labelstructs"
-	"katenary.io/internal/logger"
 	"katenary.io/internal/utils"
 
 	"github.com/compose-spec/compose-go/v2/types"
@@ -36,7 +36,7 @@ func NewIngress(service types.ServiceConfig, Chart *HelmChart) *Ingress {
 
 	mapping, err := labelstructs.IngressFrom(label)
 	if err != nil {
-		logger.Fatalf("Failed to parse ingress label: %s\n", err)
+		log.Fatalf("Failed to parse ingress label: %s\n", err)
 	}
 	if mapping.Hostname == "" {
 		mapping.Hostname = service.Name + ".tld"

internal/generator/katenaryfile/main.go

@@ -3,6 +3,7 @@ package katenaryfile
 import (
 	"bytes"
 	"encoding/json"
+	"log"
 	"os"
 	"reflect"
 	"strings"
@@ -66,7 +67,7 @@ func OverrideWithConfig(project *types.Project) {
 		return
 	}
 	if err := yaml.NewDecoder(fp).Decode(&services); err != nil {
-		logger.Fatal(err)
+		log.Fatal(err)
 		return
 	}
 	for _, p := range project.Services {
@@ -78,7 +79,7 @@ func OverrideWithConfig(project *types.Project) {
 			}
 			err := getLabelContent(o, &s, labelName)
 			if err != nil {
-				logger.Fatal(err)
+				log.Fatal(err)
 			}
 			project.Services[name] = s
 		}
@@ -112,7 +113,7 @@ func getLabelContent(o any, service *types.ServiceConfig, labelName string) erro
 
 	c, err := yaml.Marshal(o)
 	if err != nil {
-		logger.Failure(err.Error())
+		log.Println(err)
 		return err
 	}
 	val := strings.TrimSpace(string(c))
@@ -120,7 +121,7 @@ func getLabelContent(o any, service *types.ServiceConfig, labelName string) erro
 		// special case, values must be set from some defaults
 		ing, err := labelstructs.IngressFrom(val)
 		if err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 			return err
 		}
 		c, err := yaml.Marshal(ing)

internal/generator/labels/katenaryLabels.go

@@ -4,13 +4,13 @@ import (
 	"bytes"
 	_ "embed"
 	"fmt"
+	"log"
 	"regexp"
 	"sort"
 	"strings"
 	"text/tabwriter"
 	"text/template"
 
-	"katenary.io/internal/logger"
 	"katenary.io/internal/utils"
 
 	"sigs.k8s.io/yaml"
@@ -36,7 +36,6 @@ const (
 	LabelEnvFrom        Label = KatenaryLabelPrefix + "/env-from"
 	LabelExchangeVolume Label = KatenaryLabelPrefix + "/exchange-volumes"
 	LabelValuesFrom     Label = KatenaryLabelPrefix + "/values-from"
-	LabelDependsOn      Label = KatenaryLabelPrefix + "/depends-on"
 )
 
 var (
@@ -135,7 +134,7 @@ func GetLabelHelpFor(labelname string, asMarkdown bool) string {
 		KatenaryPrefix: KatenaryLabelPrefix,
 	})
 	if err != nil {
-		logger.Fatalf("Error executing template: %v", err)
+		log.Fatalf("Error executing template: %v", err)
 	}
 	help.Long = buf.String()
 	buf.Reset()
@@ -146,7 +145,7 @@ func GetLabelHelpFor(labelname string, asMarkdown bool) string {
 		KatenaryPrefix: KatenaryLabelPrefix,
 	})
 	if err != nil {
-		logger.Fatalf("Error executing template: %v", err)
+		log.Fatalf("Error executing template: %v", err)
 	}
 	help.Example = buf.String()
 	buf.Reset()
@@ -161,7 +160,7 @@ func GetLabelHelpFor(labelname string, asMarkdown bool) string {
 		KatenaryPrefix: KatenaryLabelPrefix,
 	})
 	if err != nil {
-		logger.Fatalf("Error executing template: %v", err)
+		log.Fatalf("Error executing template: %v", err)
 	}
 
 	return buf.String()

internal/generator/labels/katenaryLabelsDoc.yaml

@@ -355,25 +355,4 @@
           DB_USER: database.MARIADB_USER
           DB_PASSWORD: database.MARIADB_PASSWORD
 
-"depends-on":
-  short: "Method to check if a service is ready (for depends_on)."
-  long: |-
-    When a service uses `depends_on`, Katenary creates an initContainer to wait
-    for the dependent service to be ready.
-
-    By default, Katenary uses the Kubernetes API to check if the service endpoint
-    has ready addresses. This method does not require the service to expose a port.
-
-    Set this label to `legacy` to use the old netcat method that requires a port
-    to be defined for the dependent service.
-  example: |-
-    web:
-      image: nginx
-      depends_on:
-        - database
-      labels:
-        # Use legacy netcat method (requires port)
-        {{ .KatenaryPrefix }}/depends-on: legacy
-  type: "string"
-
 # vim: ft=gotmpl.yaml

internal/generator/labels/labelstructs/probes.go

@@ -2,10 +2,10 @@ package labelstructs
 
 import (
 	"encoding/json"
+	"log"
 
 	"gopkg.in/yaml.v3"
 	corev1 "k8s.io/api/core/v1"
-	"katenary.io/internal/logger"
 )
 
 type HealthCheck struct {
@@ -24,13 +24,13 @@ func ProbeFrom(data string) (*HealthCheck, error) {
 	if livenessProbe, ok := tmp["livenessProbe"]; ok {
 		livenessProbeBytes, err := json.Marshal(livenessProbe)
 		if err != nil {
-			logger.Warnf("Error marshalling livenessProbe: %v", err)
+			log.Printf("Error marshalling livenessProbe: %v", err)
 			return nil, err
 		}
 		livenessProbe := &corev1.Probe{}
 		err = json.Unmarshal(livenessProbeBytes, livenessProbe)
 		if err != nil {
-			logger.Warnf("Error unmarshalling livenessProbe: %v", err)
+			log.Printf("Error unmarshalling livenessProbe: %v", err)
 			return nil, err
 		}
 		mapping.LivenessProbe = livenessProbe
@@ -39,13 +39,13 @@ func ProbeFrom(data string) (*HealthCheck, error) {
 	if readinessProbe, ok := tmp["readinessProbe"]; ok {
 		readinessProbeBytes, err := json.Marshal(readinessProbe)
 		if err != nil {
-			logger.Warnf("Error marshalling readinessProbe: %v", err)
+			log.Printf("Error marshalling readinessProbe: %v", err)
 			return nil, err
 		}
 		readinessProbe := &corev1.Probe{}
 		err = json.Unmarshal(readinessProbeBytes, readinessProbe)
 		if err != nil {
-			logger.Warnf("Error unmarshalling readinessProbe: %v", err)
+			log.Printf("Error unmarshalling readinessProbe: %v", err)
 			return nil, err
 		}
 		mapping.ReadinessProbe = readinessProbe

internal/generator/rbac.go

@@ -32,7 +32,7 @@ func NewRBAC(service types.ServiceConfig, appName string) *RBAC {
 				APIVersion: "rbac.authorization.k8s.io/v1",
 			},
 			ObjectMeta: metav1.ObjectMeta{
-				Name:        utils.TplName(service.Name, appName, "dependency"),
+				Name:        utils.TplName(service.Name, appName),
 				Labels:      GetLabels(service.Name, appName),
 				Annotations: Annotations,
 			},
@@ -128,79 +128,6 @@ func (r *Role) Yaml() ([]byte, error) {
 	}
 }
 
-// NewServiceAccount creates a new ServiceAccount from a compose service.
-func NewServiceAccount(service types.ServiceConfig, appName string) *ServiceAccount {
-	return &ServiceAccount{
-		ServiceAccount: &corev1.ServiceAccount{
-			TypeMeta: metav1.TypeMeta{
-				Kind:       "ServiceAccount",
-				APIVersion: "v1",
-			},
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        utils.TplName(service.Name, appName),
-				Labels:      GetLabels(service.Name, appName),
-				Annotations: Annotations,
-			},
-		},
-		service: &service,
-	}
-}
-
-// NewRestrictedRole creates a Role with minimal permissions for init containers.
-func NewRestrictedRole(service types.ServiceConfig, appName string) *Role {
-	return &Role{
-		Role: &rbacv1.Role{
-			TypeMeta: metav1.TypeMeta{
-				Kind:       "Role",
-				APIVersion: "rbac.authorization.k8s.io/v1",
-			},
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        utils.TplName(service.Name, appName, "dependency"),
-				Labels:      GetLabels(service.Name, appName),
-				Annotations: Annotations,
-			},
-			Rules: []rbacv1.PolicyRule{
-				{
-					APIGroups: []string{""},
-					Resources: []string{"endpoints"},
-					Verbs:     []string{"get", "list", "watch"},
-				},
-			},
-		},
-		service: &service,
-	}
-}
-
-// NewRestrictedRoleBinding creates a RoleBinding that binds the restricted role to the ServiceAccount.
-func NewRestrictedRoleBinding(service types.ServiceConfig, appName string) *RoleBinding {
-	return &RoleBinding{
-		RoleBinding: &rbacv1.RoleBinding{
-			TypeMeta: metav1.TypeMeta{
-				Kind:       "RoleBinding",
-				APIVersion: "rbac.authorization.k8s.io/v1",
-			},
-			ObjectMeta: metav1.ObjectMeta{
-				Name:        utils.TplName(service.Name, appName, "dependency"),
-				Labels:      GetLabels(service.Name, appName),
-				Annotations: Annotations,
-			},
-			Subjects: []rbacv1.Subject{
-				{
-					Kind:      "ServiceAccount",
-					Name:      utils.TplName(service.Name, appName, "dependency"),
-					Namespace: "{{ .Release.Namespace }}",
-				},
-			},
-			RoleRef: rbacv1.RoleRef{
-				Kind:     "Role",
-				Name:     utils.TplName(service.Name, appName, "dependency"),
-				APIGroup: "rbac.authorization.k8s.io",
-			},
-		},
-		service: &service,
-	}
-}
-
 // ServiceAccount is a kubernetes ServiceAccount.
 type ServiceAccount struct {
 	*corev1.ServiceAccount

internal/generator/tools_test.go

@@ -1,11 +1,11 @@
 package generator
 
 import (
+	"log"
 	"os"
 	"os/exec"
 	"testing"
 
-	"katenary.io/internal/logger"
 	"katenary.io/internal/parser"
 )
 
@@ -23,7 +23,7 @@ func setup(content string) string {
 
 func teardown(tmpDir string) {
 	// remove the temporary directory
-	logger.Info("Removing temporary directory: ", tmpDir)
+	log.Println("Removing temporary directory: ", tmpDir)
 	if err := os.RemoveAll(tmpDir); err != nil {
 		panic(err)
 	}
@@ -59,7 +59,7 @@ func compileTest(t *testing.T, force bool, options ...string) string {
 		ChartVersion: chartVersion,
 	}
 	if err := Convert(convertOptions, "compose.yml"); err != nil {
-		logger.Warnf("Failed to convert: %s", err)
+		log.Printf("Failed to convert: %s", err)
 		return err.Error()
 	}
 

internal/logger/logger.go

@@ -1,11 +1,6 @@
 // Package logger provides simple logging functions with icons and colors.
 package logger
 
-import (
-	"fmt"
-	"os"
-)
-
 // Icon is a unicode icon
 type Icon string
 
@@ -27,91 +22,30 @@ const (
 
 const reset = "\033[0m"
 
-// Print prints a message without icon.
-func Print(msg ...any) {
-	fmt.Print(msg...)
-}
-
-// Printf prints a formatted message without icon.
-func Printf(format string, msg ...any) {
-	fmt.Printf(format, msg...)
-}
-
 // Info prints an informational message.
 func Info(msg ...any) {
 	message("", IconInfo, msg...)
 }
 
-// Infof prints a formatted informational message.
-func Infof(format string, msg ...any) {
-	message("", IconInfo, fmt.Sprintf(format, msg...))
-}
-
 // Warn prints a warning message.
 func Warn(msg ...any) {
 	orange := "\033[38;5;214m"
 	message(orange, IconWarning, msg...)
 }
 
-// Warnf prints a formatted warning message.
-func Warnf(format string, msg ...any) {
-	orange := "\033[38;5;214m"
-	message(orange, IconWarning, fmt.Sprintf(format, msg...))
-}
-
 // Success prints a success message.
 func Success(msg ...any) {
 	green := "\033[38;5;34m"
 	message(green, IconSuccess, msg...)
 }
 
-// Successf prints a formatted success message.
-func Successf(format string, msg ...any) {
-	green := "\033[38;5;34m"
-	message(green, IconSuccess, fmt.Sprintf(format, msg...))
-}
-
 // Failure prints a failure message.
 func Failure(msg ...any) {
 	red := "\033[38;5;196m"
 	message(red, IconFailure, msg...)
 }
 
-// Failuref prints a formatted failure message.
-func Failuref(format string, msg ...any) {
-	red := "\033[38;5;196m"
-	message(red, IconFailure, fmt.Sprintf(format, msg...))
-}
-
 // Log prints a message with a custom icon.
 func Log(icon Icon, msg ...any) {
 	message("", icon, msg...)
 }
-
-// Logf prints a formatted message with a custom icon.
-func Logf(icon Icon, format string, msg ...any) {
-	message("", icon, fmt.Sprintf(format, msg...))
-}
-
-func fatal(red string, icon Icon, msg ...any) {
-	fmt.Print(icon, " ", red)
-	fmt.Print(msg...)
-	fmt.Println(reset)
-	os.Exit(1)
-}
-
-func fatalf(red string, icon Icon, format string, msg ...any) {
-	fatal(red, icon, fmt.Sprintf(format, msg...))
-}
-
-// Fatal prints a fatal error message and exits with code 1.
-func Fatal(msg ...any) {
-	red := "\033[38;5;196m"
-	fatal(red, IconFailure, msg...)
-}
-
-// Fatalf prints a fatal error message with formatting and exits with code 1.
-func Fatalf(format string, msg ...any) {
-	red := "\033[38;5;196m"
-	fatalf(red, IconFailure, format, msg...)
-}

internal/logger/logger_test.go

@@ -1,79 +0,0 @@
-package logger
-
-import (
-	"testing"
-)
-
-func TestIcons(t *testing.T) {
-	tests := []struct {
-		name     string
-		got      Icon
-		expected Icon
-	}{
-		{"IconSuccess", IconSuccess, "✅"},
-		{"IconFailure", IconFailure, "❌"},
-		{"IconWarning", IconWarning, "❕"},
-		{"IconNote", IconNote, "📝"},
-		{"IconWorld", IconWorld, "🌐"},
-		{"IconPlug", IconPlug, "🔌"},
-		{"IconPackage", IconPackage, "📦"},
-		{"IconCabinet", IconCabinet, "🗄️"},
-		{"IconInfo", IconInfo, "🔵"},
-		{"IconSecret", IconSecret, "🔒"},
-		{"IconConfig", IconConfig, "🔧"},
-		{"IconDependency", IconDependency, "🔗"},
-	}
-
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			if tt.got != tt.expected {
-				t.Errorf("got %q, want %q", tt.got, tt.expected)
-			}
-		})
-	}
-}
-
-func TestInfo(t *testing.T) {
-	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("Info panicked: %v", r)
-		}
-	}()
-	Info("test message")
-}
-
-func TestWarn(t *testing.T) {
-	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("Warn panicked: %v", r)
-		}
-	}()
-	Warn("test warning")
-}
-
-func TestSuccess(t *testing.T) {
-	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("Success panicked: %v", r)
-		}
-	}()
-	Success("test success")
-}
-
-func TestFailure(t *testing.T) {
-	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("Failure panicked: %v", r)
-		}
-	}()
-	Failure("test failure")
-}
-
-func TestLog(t *testing.T) {
-	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("Log panicked: %v", r)
-		}
-	}()
-	Log(IconInfo, "test log")
-}

internal/parser/main.go

@@ -3,11 +3,11 @@ package parser
 
 import (
 	"context"
+	"log"
 	"path/filepath"
 
 	"github.com/compose-spec/compose-go/v2/cli"
 	"github.com/compose-spec/compose-go/v2/types"
-	"katenary.io/internal/logger"
 )
 
 func init() {
@@ -37,25 +37,20 @@ func Parse(profiles []string, envFiles []string, dockerComposeFile ...string) (*
 		var err error
 		envFiles[i], err = filepath.Abs(envFiles[i])
 		if err != nil {
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 	}
 
-	opts := []cli.ProjectOptionsFn{
+	options, err := cli.NewProjectOptions(nil,
 		cli.WithProfiles(profiles),
 		cli.WithInterpolation(true),
+		cli.WithDefaultConfigPath,
 		cli.WithEnvFiles(envFiles...),
 		cli.WithOsEnv,
 		cli.WithDotEnv,
 		cli.WithNormalization(true),
 		cli.WithResolvedPaths(false),
-	}
+	)
-
-	if len(dockerComposeFile) == 0 {
-		opts = append(opts, cli.WithDefaultConfigPath)
-	}
-
-	options, err := cli.NewProjectOptions(dockerComposeFile, opts...)
 	if err != nil {
 		return nil, err
 	}

internal/parser/main_test.go

@@ -1,11 +1,10 @@
 package parser
 
 import (
+	"log"
 	"os"
 	"path/filepath"
 	"testing"
-
-	"katenary.io/internal/logger"
 )
 
 const composeFile = `
@@ -28,7 +27,7 @@ func setupTest() (string, error) {
 func tearDownTest(tmpDir string) {
 	if tmpDir != "" {
 		if err := os.RemoveAll(tmpDir); err != nil {
-			logger.Fatalf("Failed to remove temporary directory %s: %s", tmpDir, err.Error())
+			log.Fatalf("Failed to remove temporary directory %s: %s", tmpDir, err.Error())
 		}
 	}
 }

internal/utils/utils.go

@@ -3,6 +3,7 @@ package utils
 import (
 	"bytes"
 	"fmt"
+	"log"
 	"path/filepath"
 	"strings"
 
@@ -132,8 +133,8 @@ func GetValuesFromLabel(service types.ServiceConfig, LabelValues string) map[str
 		labelContent := []any{}
 		err := yaml.Unmarshal([]byte(v), &labelContent)
 		if err != nil {
-			logger.Warnf("Error parsing label %s: %s", v, err)
+			log.Printf("Error parsing label %s: %s", v, err)
-			logger.Fatal(err)
+			log.Fatal(err)
 		}
 
 		for _, value := range labelContent {
@@ -149,7 +150,7 @@ func GetValuesFromLabel(service types.ServiceConfig, LabelValues string) map[str
 					descriptions[k.(string)] = &EnvConfig{Service: service, Description: v.(string)}
 				}
 			default:
-				logger.Fatalf("Unknown type in label: %s %T", LabelValues, value)
+				log.Fatalf("Unknown type in label: %s %T", LabelValues, value)
 			}
 		}
 	}
@@ -170,7 +171,7 @@ func Confirm(question string, icon ...logger.Icon) bool {
 	}
 	var response string
 	if _, err := fmt.Scanln(&response); err != nil {
-		logger.Fatalf("Error parsing response: %s", err.Error())
+		log.Fatalf("Error parsing response: %s", err.Error())
 	}
 	return strings.ToLower(response) == "y"
 }