From 5a59abb55d9e76f3095b903ea973138b1afdccf2 Mon Sep 17 00:00:00 2001 From: Matthis Holleville Date: Tue, 4 Apr 2023 22:59:26 +0200 Subject: [PATCH] feat: add tests for hpa analyzer Signed-off-by: Matthis Holleville --- pkg/analyzer/hpaAnalyzer_test.go | 205 +++++++++++++++++++++++++++++++ 1 file changed, 205 insertions(+) create mode 100644 pkg/analyzer/hpaAnalyzer_test.go diff --git a/pkg/analyzer/hpaAnalyzer_test.go b/pkg/analyzer/hpaAnalyzer_test.go new file mode 100644 index 0000000000..5ff60eb5a4 --- /dev/null +++ b/pkg/analyzer/hpaAnalyzer_test.go @@ -0,0 +1,205 @@ +package analyzer + +import ( + "context" + "strings" + "testing" + + "github.com/k8sgpt-ai/k8sgpt/pkg/kubernetes" + "github.com/magiconair/properties/assert" + appsv1 "k8s.io/api/apps/v1" + autoscalingv1 "k8s.io/api/autoscaling/v1" + metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" + "k8s.io/client-go/kubernetes/fake" +) + +func TestHPAAnalyzer(t *testing.T) { + clientset := fake.NewSimpleClientset( + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + }) + hpaAnalyzer := HpaAnalyzer{} + var analysisResults []Analysis + err := hpaAnalyzer.RunAnalysis(context.Background(), + &AnalysisConfiguration{ + Namespace: "default", + }, + &kubernetes.Client{ + Client: clientset, + }, nil, &analysisResults) + if err != nil { + t.Fatalf("unexpected error: %v", err) + } + assert.Equal(t, len(analysisResults), 1) +} + +func TestHPAAnalyzerWithMultipleHPA(t *testing.T) { + clientset := fake.NewSimpleClientset( + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + }, + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example-2", + Namespace: "default", + Annotations: map[string]string{}, + }, + }, + ) + hpaAnalyzer := HpaAnalyzer{} + var analysisResults []Analysis + err := hpaAnalyzer.RunAnalysis(context.Background(), + &AnalysisConfiguration{ + Namespace: "default", + }, + &kubernetes.Client{ + Client: clientset, + }, nil, &analysisResults) + if err != nil { + t.Fatalf("unexpected error: %v", err) + } + assert.Equal(t, len(analysisResults), 2) +} + +func TestHPAAnalyzerWithUnsuportedScaleTargetRef(t *testing.T) { + + clientset := fake.NewSimpleClientset( + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + Spec: autoscalingv1.HorizontalPodAutoscalerSpec{ + ScaleTargetRef: autoscalingv1.CrossVersionObjectReference{ + Kind: "unsuported", + }, + }, + }) + hpaAnalyzer := HpaAnalyzer{} + + var analysisResults []Analysis + err := hpaAnalyzer.RunAnalysis(context.Background(), + &AnalysisConfiguration{ + Namespace: "default", + }, + &kubernetes.Client{ + Client: clientset, + }, nil, &analysisResults) + if err != nil { + t.Fatalf("unexpected error: %v", err) + } + + var errorFound bool + for _, analysis := range analysisResults { + for _, err := range analysis.Error { + if strings.Contains(err, "does not possible option.") { + errorFound = true + break + } + } + if errorFound { + break + } + } + if !errorFound { + t.Error("expected error 'does not possible option.' not found in analysis results") + } +} + +func TestHPAAnalyzerWithUnexistentScaleTargetRef(t *testing.T) { + + clientset := fake.NewSimpleClientset( + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + Spec: autoscalingv1.HorizontalPodAutoscalerSpec{ + ScaleTargetRef: autoscalingv1.CrossVersionObjectReference{ + Kind: "Deployment", + Name: "unexistent", + }, + }, + }) + hpaAnalyzer := HpaAnalyzer{} + + var analysisResults []Analysis + err := hpaAnalyzer.RunAnalysis(context.Background(), + &AnalysisConfiguration{ + Namespace: "default", + }, + &kubernetes.Client{ + Client: clientset, + }, nil, &analysisResults) + if err != nil { + t.Fatalf("unexpected error: %v", err) + } + + var errorFound bool + for _, analysis := range analysisResults { + for _, err := range analysis.Error { + if strings.Contains(err, "does not exist.") { + errorFound = true + break + } + } + if errorFound { + break + } + } + if !errorFound { + t.Error("expected error 'does not exist.' not found in analysis results") + } +} + +func TestHPAAnalyzerWithExistingScaleTargetRef(t *testing.T) { + + clientset := fake.NewSimpleClientset( + &autoscalingv1.HorizontalPodAutoscaler{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + Spec: autoscalingv1.HorizontalPodAutoscalerSpec{ + ScaleTargetRef: autoscalingv1.CrossVersionObjectReference{ + Kind: "Deployment", + Name: "example", + }, + }, + }, + &appsv1.Deployment{ + ObjectMeta: metav1.ObjectMeta{ + Name: "example", + Namespace: "default", + Annotations: map[string]string{}, + }, + }, + ) + hpaAnalyzer := HpaAnalyzer{} + + var analysisResults []Analysis + err := hpaAnalyzer.RunAnalysis(context.Background(), + &AnalysisConfiguration{ + Namespace: "default", + }, + &kubernetes.Client{ + Client: clientset, + }, nil, &analysisResults) + if err != nil { + t.Fatalf("unexpected error: %v", err) + } + for _, analysis := range analysisResults { + assert.Equal(t, len(analysis.Error), 0) + } +}