feat: support chart

cmd/README.md

@@ -10,7 +10,8 @@ Before running commands, configure your system using environment variables. You
 |-----------------------|----------------------------|----------------------------|
 | `database.url`        | `DATABASE.URL`             | `mem://` or `mongodb://`   |
 | `database.name`       | `DATABASE.NAME`            | -                          |
+| `collection.charts`   | `COLLECTION.CHARTS`        | `charts`                   |
 | `collection.nodes`    | `COLLECTION.NODES`         | `nodes`                    |
 | `collection.secrets`  | `COLLECTION.SECRETS`       | `secrets`                  |
 
-If using [MongoDB](https://www.mongodb.com/), ensure that [Change Streams](https://www.mongodb.com/docs/manual/changeStreams/) are enabled so that the engine can track changes to node specifications. To utilize Change Streams, set up a [Replica Set](https://www.mongodb.com/docs/manual/replication/#std-label-replication).
+If using [MongoDB](https://www.mongodb.com/), ensure that [Change Streams](https://www.mongodb.com/docs/manual/changeStreams/) are enabled so that the engine can track changes to resources. To utilize Change Streams, set up a [Replica Set](https://www.mongodb.com/docs/manual/replication/#std-label-replication).

cmd/README_kr.md

@@ -10,7 +10,8 @@
 |----------------------|--------------------------|----------------------------|
 | `database.url`       | `DATABASE.URL`           | `mem://` 또는 `mongodb://` |
 | `database.name`      | `DATABASE.NAME`          | -                          |
+| `collection.charts`  | `COLLECTION.CHARTS`      | `charts`                   |
 | `collection.nodes`   | `COLLECTION.NODES`       | `nodes`                    |
 | `collection.secrets` | `COLLECTION.SECRETS`     | `secrets`                  |
 
-[MongoDB](https://www.mongodb.com/)를 사용할 경우, 엔진이 노드 명세의 변경을 추적할 수 있도록 [변경 스트림](https://www.mongodb.com/docs/manual/changeStreams/)을 활성화해야 합니다. 변경 스트림을 이용하려면 [복제본 세트](https://www.mongodb.com/ko-kr/docs/manual/replication/#std-label-replication)를 설정하세요.
+[MongoDB](https://www.mongodb.com/)를 사용할 경우, 엔진이 리소스의 변경을 추적할 수 있도록 [변경 스트림](https://www.mongodb.com/docs/manual/changeStreams/)을 활성화해야 합니다. 변경 스트림을 이용하려면 [복제본 세트](https://www.mongodb.com/ko-kr/docs/manual/replication/#std-label-replication)를 설정하세요.

cmd/pkg/cli/apply.go

@@ -2,6 +2,7 @@
 
 import (
 	"github.com/siyul-park/uniflow/cmd/pkg/resource"
+	"github.com/siyul-park/uniflow/pkg/chart"
 	resourcebase "github.com/siyul-park/uniflow/pkg/resource"
 	"github.com/siyul-park/uniflow/pkg/secret"
 	"github.com/siyul-park/uniflow/pkg/spec"
@@ -11,6 +12,7 @@
 
 // ApplyConfig represents the configuration for the apply command.
 type ApplyConfig struct {
+	ChartStore  chart.Store
 	SpecStore   spec.Store
 	SecretStore secret.Store
 	FS          afero.Fs
@@ -22,7 +24,7 @@
 		Use:       "apply",
 		Short:     "Apply resources to the specified namespace",
 		Args:      cobra.MatchAll(cobra.ExactArgs(1), cobra.OnlyValidArgs),
-		ValidArgs: []string{argNodes, argSecrets},
+		ValidArgs: []string{argCharts, argNodes, argSecrets},
 		RunE:      runApplyCommand(config),
 	}
 
@@ -55,6 +57,42 @@
 		writer := resource.NewWriter(cmd.OutOrStdout())
 
 		switch args[0] {
+		case argCharts:
+			var charts []*chart.Chart
+			if err := reader.Read(&charts); err != nil {
+				return err
+			}
+
+			for _, scrt := range charts {
+				if scrt.GetNamespace() == "" {
+					scrt.SetNamespace(namespace)
+				}
+			}
+
+			ok, err := config.ChartStore.Load(ctx, charts...)
+			if err != nil {
+				return err
+			}
+
+			var inserts []*chart.Chart
+			var updates []*chart.Chart
+			for _, chrt := range charts {
+				if match := resourcebase.Match(chrt, ok...); len(match) > 0 {
+					chrt.SetID(match[0].GetID())
+					updates = append(updates, chrt)
+				} else {
+					inserts = append(inserts, chrt)
+				}
+			}
+
+			if _, err := config.ChartStore.Store(ctx, inserts...); err != nil {
+				return err
+			}
+			if _, err := config.ChartStore.Swap(ctx, updates...); err != nil {
+				return err
+			}
+
+			return writer.Write(charts)
 		case argNodes:
 			var specs []spec.Spec
 			if err := reader.Read(&specs); err != nil {
@@ -97,9 +135,9 @@
 				return err
 			}
 
-			for _, sec := range secrets {
-				if sec.GetNamespace() == "" {
-					sec.SetNamespace(namespace)
+			for _, scrt := range secrets {
+				if scrt.GetNamespace() == "" {
+					scrt.SetNamespace(namespace)
 				}
 			}
 
@@ -110,12 +148,12 @@
 
 			var inserts []*secret.Secret
 			var updates []*secret.Secret
-			for _, sec := range secrets {
-				if match := resourcebase.Match(sec, ok...); len(match) > 0 {
-					sec.SetID(match[0].GetID())
-					updates = append(updates, sec)
+			for _, scrt := range secrets {
+				if match := resourcebase.Match(scrt, ok...); len(match) > 0 {
+					scrt.SetID(match[0].GetID())
+					updates = append(updates, scrt)
 				} else {
-					inserts = append(inserts, sec)
+					inserts = append(inserts, scrt)
 				}
 			}
 
@@ -128,7 +166,6 @@
 
 			return writer.Write(secrets)
 		}
-
 		return nil
 	}
 }