test: integration test for argo rollouts

Author: ivanstanev

snyk-monitor-cluster-permissions.yaml

@@ -54,6 +54,14 @@ rules:
   - get
   - list
   - watch
+- apiGroups:
+  - argoproj.io
+  resources:
+  - rollouts
+  verbs:
+  - get
+  - list
+  - watch
 ---
 kind: ServiceAccount
 apiVersion: v1

snyk-monitor-namespaced-permissions.yaml

@@ -46,6 +46,14 @@ rules:
   - get
   - list
   - watch
+- apiGroups:
+  - argoproj.io
+  resources:
+  - rollouts
+  verbs:
+  - get
+  - list
+  - watch
 ---
 kind: ServiceAccount
 apiVersion: v1

test/fixtures/argo-rollout.yaml

@@ -0,0 +1,33 @@
+apiVersion: argoproj.io/v1alpha1
+kind: Rollout
+metadata:
+  name: argo-rollout
+  namespace: services
+spec:
+  replicas: 1
+  strategy:
+    canary:
+      steps:
+        - setWeight: 100
+  revisionHistoryLimit: 1
+  selector:
+    matchLabels:
+      app: rollouts-demo
+  template:
+    metadata:
+      labels:
+        app: rollouts-demo
+    spec:
+      imagePullSecrets:
+        - name: docker-io
+      containers:
+        - name: rollouts-demo
+          image: argoproj/rollouts-demo:blue
+          ports:
+            - name: http
+              containerPort: 8080
+              protocol: TCP
+          resources:
+            requests:
+              memory: 32Mi
+              cpu: 5m

test/integration/kubernetes.spec.ts

@@ -55,6 +55,7 @@ let cronJobV1Supported = true;
 let cronJobV1Beta1Supported = true;
 // Next we apply some sample workloads
 test('deploy sample workloads', async () => {
+  const argoNamespace = 'argo-rollouts';
   const servicesNamespace = 'services';
   const someImageWithSha =
     'docker.io/library/alpine@sha256:7746df395af22f04212cd25a92c1d6dbc5a06a0ca9579a229ef43008d4d1302a';
@@ -81,6 +82,15 @@ test('deploy sample workloads', async () => {
       someImageWithSha,
       servicesNamespace,
     ),
+    kubectl
+      .createNamespace(argoNamespace)
+      .then(() =>
+        kubectl.applyK8sYaml(
+          'https://github.com/argoproj/argo-rollouts/releases/latest/download/install.yaml',
+          argoNamespace,
+        ),
+      )
+      .then(() => kubectl.applyK8sYaml('./test/fixtures/argo-rollout.yaml')),
   ]);
 });
 
@@ -176,6 +186,11 @@ test('snyk-monitor sends data to kubernetes-upstream', async () => {
           workload.name === 'consul' &&
           workload.type === WorkloadKind.Deployment,
       ) !== undefined &&
+      workloads.find(
+        (workload) =>
+          workload.name === 'argo-rollout' &&
+          workload.type === WorkloadKind.ArgoRollout,
+      ) !== undefined &&
       // only one of the cronjob versions needs to be valid
       (cronJobValidator(workloads) || cronJobV1Beta1Validator(workloads))
     );

test/setup/platforms/aks.ts

@@ -69,6 +69,7 @@ export async function loadImageInCluster(
 export async function clean(): Promise<void> {
   await Promise.all([
     kubectl.deleteNamespace('services'),
+    kubectl.deleteNamespace('argo-rollouts'),
     kubectl.deleteNamespace('snyk-monitor'),
   ]);
 }

test/setup/platforms/eks.ts

@@ -72,6 +72,7 @@ export async function loadImageInCluster(
 export async function clean(): Promise<void> {
   await Promise.all([
     kubectl.deleteNamespace('services'),
+    kubectl.deleteNamespace('argo-rollouts'),
     kubectl.deleteNamespace('snyk-monitor'),
   ]);
 }

test/setup/platforms/openshift4.ts

@@ -142,6 +142,7 @@ export async function clean(): Promise<void> {
       .deleteResource('clusterrole', 'snyk-monitor', 'default')
       .catch(() => undefined),
     kubectl.deleteNamespace('services').catch(() => undefined),
+    kubectl.deleteNamespace('argo-rollouts').catch(() => undefined),
     kubectl.deleteNamespace('snyk-monitor').catch(() => undefined),
   ]);
 }