mirror of
https://github.com/argoproj/argo-cd.git
synced 2026-02-20 01:28:45 +01:00
535 lines
18 KiB
Go
535 lines
18 KiB
Go
package e2e
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
|
|
apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
|
|
"github.com/argoproj/argo-cd/v3/pkg/apis/application/v1alpha1"
|
|
. "github.com/argoproj/argo-cd/v3/test/e2e/fixture/applicationsets"
|
|
"github.com/argoproj/argo-cd/v3/test/e2e/fixture/applicationsets/utils"
|
|
|
|
"github.com/argoproj/argo-cd/v3/pkg/apis/application"
|
|
)
|
|
|
|
func TestListMatrixGenerator(t *testing.T) {
|
|
generateExpectedApp := func(cluster, name string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "argoproj.io/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s", cluster, name),
|
|
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("cluster1", "kustomize-guestbook"),
|
|
generateExpectedApp("cluster1", "helm-guestbook"),
|
|
|
|
generateExpectedApp("cluster2", "kustomize-guestbook"),
|
|
generateExpectedApp("cluster2", "helm-guestbook"),
|
|
}
|
|
|
|
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: "{{values.name}}-{{path.basename}}"},
|
|
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{
|
|
{
|
|
Matrix: &v1alpha1.MatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster1"}}`)},
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster2"}}`)},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).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().Then().Expect(ApplicationsDoNotExist(expectedAppsNewNamespace))
|
|
}
|
|
|
|
func TestClusterMatrixGenerator(t *testing.T) {
|
|
generateExpectedApp := func(cluster, name string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "argoproj.io/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s", cluster, name),
|
|
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"),
|
|
generateExpectedApp("cluster1", "helm-guestbook"),
|
|
|
|
generateExpectedApp("cluster2", "kustomize-guestbook"),
|
|
generateExpectedApp("cluster2", "helm-guestbook"),
|
|
}
|
|
|
|
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}}"},
|
|
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{
|
|
{
|
|
Matrix: &v1alpha1.MatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
Clusters: &v1alpha1.ClusterGenerator{
|
|
Selector: metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"argocd.argoproj.io/secret-type": "cluster",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).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().Then().Expect(ApplicationsDoNotExist(expectedAppsNewNamespace))
|
|
}
|
|
|
|
func TestMatrixTerminalMatrixGeneratorSelector(t *testing.T) {
|
|
generateExpectedApp := func(cluster, name string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "argoproj.io/v1alpha1",
|
|
},
|
|
ObjectMeta: metav1.ObjectMeta{
|
|
Name: fmt.Sprintf("%s-%s", cluster, name),
|
|
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("cluster1", "kustomize-guestbook"),
|
|
generateExpectedApp("cluster1", "helm-guestbook"),
|
|
}
|
|
expectedApps := []v1alpha1.Application{
|
|
generateExpectedApp("cluster2", "kustomize-guestbook"),
|
|
generateExpectedApp("cluster2", "helm-guestbook"),
|
|
}
|
|
|
|
Given(t).
|
|
// Create ApplicationSet with LabelSelector on an ApplicationSetTerminalGenerator
|
|
When().
|
|
Create(v1alpha1.ApplicationSet{
|
|
Spec: v1alpha1.ApplicationSetSpec{
|
|
Template: v1alpha1.ApplicationSetTemplate{
|
|
ApplicationSetTemplateMeta: v1alpha1.ApplicationSetTemplateMeta{Name: "{{values.name}}-{{path.basename}}"},
|
|
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{
|
|
{
|
|
Matrix: &v1alpha1.MatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetNestedGenerator{
|
|
{
|
|
Matrix: toAPIExtensionsJSON(t, &v1alpha1.NestedMatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetTerminalGenerator{
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster1"}}`)},
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster2"}}`)},
|
|
},
|
|
},
|
|
Selector: &metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"values.name": "cluster1",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
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(`{}`)},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
}).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].Matrix.Generators[0].Matrix = toAPIExtensionsJSON(t, &v1alpha1.NestedMatrixGenerator{
|
|
Generators: []v1alpha1.ApplicationSetTerminalGenerator{
|
|
{
|
|
List: &v1alpha1.ListGenerator{
|
|
Elements: []apiextensionsv1.JSON{
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster1"}}`)},
|
|
{Raw: []byte(`{"cluster": "my-cluster","url": "https://kubernetes.default.svc", "values": {"name": "cluster2"}}`)},
|
|
},
|
|
},
|
|
Selector: &metav1.LabelSelector{
|
|
MatchLabels: map[string]string{
|
|
"values.name": "cluster2",
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Git: &v1alpha1.GitGenerator{
|
|
RepoURL: "https://github.com/argoproj/argocd-example-apps.git",
|
|
Directories: []v1alpha1.GitDirectoryGeneratorItem{
|
|
{
|
|
Path: "*guestbook*",
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
})
|
|
}).Then().Expect(ApplicationsExist(expectedApps)).Expect(ApplicationsDoNotExist(excludedApps)).
|
|
When().
|
|
Delete().Then().Expect(ApplicationsDoNotExist(excludedApps)).Expect(ApplicationsDoNotExist(expectedApps))
|
|
}
|
|
|
|
func TestMatrixTerminalMergeGeneratorSelector(t *testing.T) {
|
|
generateExpectedApp := func(name, nameSuffix string) v1alpha1.Application {
|
|
return v1alpha1.Application{
|
|
TypeMeta: metav1.TypeMeta{
|
|
Kind: application.ApplicationKind,
|
|
APIVersion: "argoproj.io/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{
|
|
{
|
|
Matrix: &v1alpha1.MatrixGenerator{
|
|
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].Matrix.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().Then().Expect(ApplicationsDoNotExist(excludedApps)).Expect(ApplicationsDoNotExist(expectedApps))
|
|
}
|