mirror of
https://github.com/hanzoai/deploy.git
synced 2026-10-07 08:44:50 +00:00
zeekayandHanzo Dev
1ab6e799c1
go.mod still declared `module github.com/hanzoai/deploy` after the repo was renamed. A Go module path is not cosmetic — it is the resolvable location. So `go get github.com/hanzoai/cd` could not work, and anything importing this module had to spell a name that no longer exists at that address. The build log of v3.6.0 is where it surfaced: the compiler was still emitting github.com/hanzoai/deploy/cmd/cd/commands. 3541 import paths across 690 .go, 19 .proto, 4 .yaml, 3 .sh, 2 .mod, Procfile and Makefile. Plus the 62 ghcr.io/hanzoai/deploy image references, moved to ghcr.io/hanzoai/cd to match hanzo.yml's build target — a distinct string from the module path, replaced separately so neither could clobber the other. go mod tidy clean, CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build ./... clean. Co-authored-by: Hanzo Dev <[email protected]>
428 lines
14 KiB
Go
428 lines
14 KiB
Go
package e2e
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
"testing"
|
|
|
|
apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
|
|
"github.com/hanzoai/cd/pkg/apis/application/v1alpha1"
|
|
. "github.com/hanzoai/cd/test/e2e/fixture/applicationsets"
|
|
"github.com/hanzoai/cd/test/e2e/fixture/applicationsets/utils"
|
|
|
|
"github.com/hanzoai/cd/pkg/apis/application"
|
|
)
|
|
|
|
func TestListMergeGenerator(t *testing.T) {
|
|
generateExpectedApp := func(name, nameSuffix string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "apps.hanzo.ai/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s", name, nameSuffix),
|
|
Namespace: utils.TestNamespace(),
|
|
Finalizers: []string{v1alpha1.ResourcesFinalizerName},
|
|
},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: name,
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Server: "https://kubernetes.default.svc",
|
|
Namespace: name,
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
expectedApps := []v1alpha1.Application{
|
|
generateExpectedApp("kustomize-guestbook", "1"),
|
|
generateExpectedApp("helm-guestbook", "2"),
|
|
}
|
|
|
|
var expectedAppsNewNamespace []v1alpha1.Application
|
|
var expectedAppsNewMetadata []v1alpha1.Application
|
|
|
|
Given(t).
|
|
// Create a ClusterGenerator-based ApplicationSet
|
|
When().
|
|
Create(v1alpha1.ApplicationSet{
|
|
Spec: v1alpha1.ApplicationSetSpec{
|
|
Template: v1alpha1.ApplicationSetTemplate{
|
|
ApplicationSetTemplateMeta: v1alpha1.ApplicationSetTemplateMeta{Name: "{{path.basename}}-{{name-suffix}}"},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: "{{path}}",
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Server: "https://kubernetes.default.svc",
|
|
Namespace: "{{path.basename}}",
|
|
},
|
|
},
|
|
},
|
|
Generators: []v1alpha1.ApplicationSetGenerator{
|
|
{
|
|
Merge: &v1alpha1.MergeGenerator{
|
|
MergeKeys: []string{"path.basename"},
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"path.basename": "kustomize-guestbook", "name-suffix": "1"}`)},
|
|
{Raw: []byte(`{"path.basename": "helm-guestbook", "name-suffix": "2"}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).Then().Expect(ApplicationsExist(expectedApps)).
|
|
|
|
// Update the ApplicationSet template namespace, and verify it updates the Applications
|
|
When().
|
|
And(func() {
|
|
for _, expectedApp := range expectedApps {
|
|
newExpectedApp := expectedApp.DeepCopy()
|
|
newExpectedApp.Spec.Destination.Namespace = "guestbook2"
|
|
expectedAppsNewNamespace = append(expectedAppsNewNamespace, *newExpectedApp)
|
|
}
|
|
}).
|
|
Update(func(appset *v1alpha1.ApplicationSet) {
|
|
appset.Spec.Template.Spec.Destination.Namespace = "guestbook2"
|
|
}).Then().Expect(ApplicationsExist(expectedAppsNewNamespace)).
|
|
|
|
// Update the metadata fields in the appset template, and make sure it propagates to the apps
|
|
When().
|
|
And(func() {
|
|
for _, expectedApp := range expectedAppsNewNamespace {
|
|
expectedAppNewMetadata := expectedApp.DeepCopy()
|
|
expectedAppNewMetadata.ObjectMeta.Annotations = map[string]string{"annotation-key": "annotation-value"}
|
|
expectedAppNewMetadata.ObjectMeta.Labels = map[string]string{"label-key": "label-value"}
|
|
expectedAppsNewMetadata = append(expectedAppsNewMetadata, *expectedAppNewMetadata)
|
|
}
|
|
}).
|
|
Update(func(appset *v1alpha1.ApplicationSet) {
|
|
appset.Spec.Template.Annotations = map[string]string{"annotation-key": "annotation-value"}
|
|
appset.Spec.Template.Labels = map[string]string{"label-key": "label-value"}
|
|
}).Then().Expect(ApplicationsExist(expectedAppsNewMetadata)).
|
|
|
|
// Delete the ApplicationSet, and verify it deletes the Applications
|
|
When().
|
|
Delete(metav1.DeletePropagationForeground).Then().Expect(ApplicationsDoNotExist(expectedAppsNewNamespace))
|
|
}
|
|
|
|
func TestClusterMergeGenerator(t *testing.T) {
|
|
generateExpectedApp := func(cluster, name, nameSuffix string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "apps.hanzo.ai/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s-%s", cluster, name, nameSuffix),
|
|
Namespace: utils.TestNamespace(),
|
|
Finalizers: []string{v1alpha1.ResourcesFinalizerName},
|
|
},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: name,
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Name: cluster,
|
|
Namespace: name,
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
expectedApps := []v1alpha1.Application{
|
|
generateExpectedApp("cluster1", "kustomize-guestbook", "1"),
|
|
generateExpectedApp("cluster1", "helm-guestbook", "0"),
|
|
|
|
generateExpectedApp("cluster2", "kustomize-guestbook", "0"),
|
|
generateExpectedApp("cluster2", "helm-guestbook", "2"),
|
|
}
|
|
|
|
var expectedAppsNewNamespace []v1alpha1.Application
|
|
var expectedAppsNewMetadata []v1alpha1.Application
|
|
|
|
Given(t).
|
|
// Create a ClusterGenerator-based ApplicationSet
|
|
When().
|
|
CreateClusterSecret("my-secret", "cluster1", "https://kubernetes.default.svc").
|
|
CreateClusterSecret("my-secret2", "cluster2", "https://kubernetes.default.svc").
|
|
Create(v1alpha1.ApplicationSet{
|
|
Spec: v1alpha1.ApplicationSetSpec{
|
|
Template: v1alpha1.ApplicationSetTemplate{
|
|
ApplicationSetTemplateMeta: v1alpha1.ApplicationSetTemplateMeta{Name: "{{name}}-{{path.basename}}-{{values.name-suffix}}"},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: "{{path}}",
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Name: "{{name}}",
|
|
Namespace: "{{path.basename}}",
|
|
},
|
|
},
|
|
},
|
|
Generators: []v1alpha1.ApplicationSetGenerator{
|
|
{
|
|
Merge: &v1alpha1.MergeGenerator{
|
|
MergeKeys: []string{"name", "path.basename"},
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
Matrix: toAPIExtensionsJSON(t, &v1alpha1.NestedMatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetTerminalGenerator{
|
|
{
|
|
Clusters: &v1alpha1.ClusterGenerator{
|
|
Selector: metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"cd.hanzo.ai/secret-type": "cluster",
|
|
},
|
|
},
|
|
Values: map[string]string{
|
|
"name-suffix": "0",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}),
|
|
},
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"name": "cluster1", "path.basename": "kustomize-guestbook", "values": {"name-suffix": "1"}}`)},
|
|
{Raw: []byte(`{"name": "cluster2", "path.basename": "helm-guestbook", "values": {"name-suffix": "2"}}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).Then().Expect(ApplicationsExist(expectedApps)).
|
|
|
|
// Update the ApplicationSet template namespace, and verify it updates the Applications
|
|
When().
|
|
And(func() {
|
|
for _, expectedApp := range expectedApps {
|
|
newExpectedApp := expectedApp.DeepCopy()
|
|
newExpectedApp.Spec.Destination.Namespace = "guestbook2"
|
|
expectedAppsNewNamespace = append(expectedAppsNewNamespace, *newExpectedApp)
|
|
}
|
|
}).
|
|
Update(func(appset *v1alpha1.ApplicationSet) {
|
|
appset.Spec.Template.Spec.Destination.Namespace = "guestbook2"
|
|
}).Then().Expect(ApplicationsExist(expectedAppsNewNamespace)).
|
|
|
|
// Update the metadata fields in the appset template, and make sure it propagates to the apps
|
|
When().
|
|
And(func() {
|
|
for _, expectedApp := range expectedAppsNewNamespace {
|
|
expectedAppNewMetadata := expectedApp.DeepCopy()
|
|
expectedAppNewMetadata.ObjectMeta.Annotations = map[string]string{"annotation-key": "annotation-value"}
|
|
expectedAppNewMetadata.ObjectMeta.Labels = map[string]string{"label-key": "label-value"}
|
|
expectedAppsNewMetadata = append(expectedAppsNewMetadata, *expectedAppNewMetadata)
|
|
}
|
|
}).
|
|
Update(func(appset *v1alpha1.ApplicationSet) {
|
|
appset.Spec.Template.Annotations = map[string]string{"annotation-key": "annotation-value"}
|
|
appset.Spec.Template.Labels = map[string]string{"label-key": "label-value"}
|
|
}).Then().Expect(ApplicationsExist(expectedAppsNewMetadata)).
|
|
|
|
// Delete the ApplicationSet, and verify it deletes the Applications
|
|
When().
|
|
Delete(metav1.DeletePropagationForeground).Then().Expect(ApplicationsDoNotExist(expectedAppsNewNamespace))
|
|
}
|
|
|
|
func TestMergeTerminalMergeGeneratorSelector(t *testing.T) {
|
|
generateExpectedApp := func(name, nameSuffix string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "apps.hanzo.ai/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s", name, nameSuffix),
|
|
Namespace: utils.TestNamespace(),
|
|
Finalizers: []string{v1alpha1.ResourcesFinalizerName},
|
|
},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: name,
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Server: "https://kubernetes.default.svc",
|
|
Namespace: name,
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
excludedApps := []v1alpha1.Application{
|
|
generateExpectedApp("kustomize-guestbook", "1"),
|
|
}
|
|
expectedApps := []v1alpha1.Application{
|
|
generateExpectedApp("helm-guestbook", "2"),
|
|
}
|
|
|
|
Given(t).
|
|
// Create ApplicationSet with LabelSelector on an ApplicationSetTerminalGenerator
|
|
When().
|
|
Create(v1alpha1.ApplicationSet{
|
|
Spec: v1alpha1.ApplicationSetSpec{
|
|
Template: v1alpha1.ApplicationSetTemplate{
|
|
ApplicationSetTemplateMeta: v1alpha1.ApplicationSetTemplateMeta{Name: "{{path.basename}}-{{name-suffix}}"},
|
|
Spec: v1alpha1.ApplicationSpec{
|
|
Project: "default",
|
|
Source: &v1alpha1.ApplicationSource{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
TargetRevision: "HEAD",
|
|
Path: "{{path}}",
|
|
},
|
|
Destination: v1alpha1.ApplicationDestination{
|
|
Server: "https://kubernetes.default.svc",
|
|
Namespace: "{{path.basename}}",
|
|
},
|
|
},
|
|
},
|
|
Generators: []v1alpha1.ApplicationSetGenerator{
|
|
{
|
|
Merge: &v1alpha1.MergeGenerator{
|
|
MergeKeys: []string{"path.basename"},
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
Merge: toAPIExtensionsJSON(t, &v1alpha1.NestedMergeGenerator{
|
|
MergeKeys: []string{"path.basename"},
|
|
Generators: []v1alpha1.ApplicationSetTerminalGenerator{
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
Selector: &metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"path.basename": "kustomize-guestbook",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"path.basename": "kustomize-guestbook", "name-suffix": "1"}`)},
|
|
{Raw: []byte(`{"path.basename": "helm-guestbook", "name-suffix": "2"}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}),
|
|
},
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).Then().Expect(ApplicationsExist(excludedApps)).Expect(ApplicationsDoNotExist(expectedApps)).
|
|
|
|
// Update the ApplicationSetTerminalGenerator LabelSelector, and verify the Applications are deleted and created
|
|
When().
|
|
Update(func(appset *v1alpha1.ApplicationSet) {
|
|
appset.Spec.Generators[0].Merge.Generators[0].Merge = toAPIExtensionsJSON(t, &v1alpha1.NestedMergeGenerator{
|
|
MergeKeys: []string{"path.basename"},
|
|
Generators: []v1alpha1.ApplicationSetTerminalGenerator{
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
Selector: &metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"path.basename": "helm-guestbook",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"path.basename": "kustomize-guestbook", "name-suffix": "1"}`)},
|
|
{Raw: []byte(`{"path.basename": "helm-guestbook", "name-suffix": "2"}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
})
|
|
}).Then().Expect(ApplicationsExist(expectedApps)).Expect(ApplicationsDoNotExist(excludedApps)).
|
|
When().
|
|
Delete(metav1.DeletePropagationForeground).Then().Expect(ApplicationsDoNotExist(excludedApps)).Expect(ApplicationsDoNotExist(expectedApps))
|
|
}
|
|
|
|
func toAPIExtensionsJSON(t *testing.T, g any) *apiextensionsv1.JSON {
|
|
t.Helper()
|
|
resVal, err := json.Marshal(g)
|
|
if err != nil {
|
|
t.Error("unable to unmarshal json", g)
|
|
return nil
|
|
}
|
|
|
|
res := &apiextensionsv1.JSON{Raw: resVal}
|
|
|
|
return res
|
|
}
|