package test

import (
	"context"

	appsv1 "k8s.io/api/apps/v1"
	batchv1 "k8s.io/api/batch/v1"
	batchv1beta1 "k8s.io/api/batch/v1beta1"
	corev1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/client-go/dynamic"
	dynamicFake "k8s.io/client-go/dynamic/fake"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/kubernetes/fake"
)

// MockContainer creates a container object
func MockContainer(name string) corev1.Container {
	c := corev1.Container{
		Name: name,
	}
	return c
}

// MockPod creates a pod object.
func MockPod() corev1.Pod {
	c1 := MockContainer("test")
	p := corev1.Pod{
		Spec: corev1.PodSpec{
			Containers: []corev1.Container{
				c1,
			},
		},
	}
	return p
}

// MockNakedPod creates a pod object.
func MockNakedPod() corev1.Pod {
	return corev1.Pod{
		Spec: MockPod().Spec,
	}
}

// MockDeploy creates a Deployment object.
func MockDeploy() appsv1.Deployment {
	p := MockPod()
	d := appsv1.Deployment{
		Spec: appsv1.DeploymentSpec{
			Template: corev1.PodTemplateSpec{Spec: p.Spec},
		},
	}
	return d
}

// MockStatefulSet creates a StatefulSet object.
func MockStatefulSet() appsv1.StatefulSet {
	p := MockPod()
	s := appsv1.StatefulSet{
		Spec: appsv1.StatefulSetSpec{
			Template: corev1.PodTemplateSpec{Spec: p.Spec},
		},
	}
	return s
}

// MockDaemonSet creates a DaemonSet object.
func MockDaemonSet() appsv1.DaemonSet {
	p := MockPod()
	return appsv1.DaemonSet{
		Spec: appsv1.DaemonSetSpec{
			Template: corev1.PodTemplateSpec{Spec: p.Spec},
		},
	}
}

// MockJob creates a Job object.
func MockJob() batchv1.Job {
	p := MockPod()
	return batchv1.Job{
		Spec: batchv1.JobSpec{
			Template: corev1.PodTemplateSpec{Spec: p.Spec},
		},
	}
}

// MockCronJob creates a CronJob object.
func MockCronJob() batchv1beta1.CronJob {
	p := MockPod()
	return batchv1beta1.CronJob{
		Spec: batchv1beta1.CronJobSpec{
			JobTemplate: batchv1beta1.JobTemplateSpec{
				Spec: batchv1.JobSpec{
					Template: corev1.PodTemplateSpec{Spec: p.Spec},
				},
			},
		},
	}
}

// MockReplicationController creates a ReplicationController object.
func MockReplicationController() corev1.ReplicationController {
	p := MockPod()
	return corev1.ReplicationController{
		Spec: corev1.ReplicationControllerSpec{
			Template: &corev1.PodTemplateSpec{Spec: p.Spec},
		},
	}
}

// SetupTestAPI creates a test kube API struct.
func SetupTestAPI() (kubernetes.Interface, dynamic.Interface) {
	scheme := runtime.NewScheme()

	return fake.NewSimpleClientset(), dynamicFake.NewSimpleDynamicClient(scheme)
}

// SetupAddControllers creates mock controllers and adds them to the test clientset.
func SetupAddControllers(ctx context.Context, k kubernetes.Interface, namespace string) kubernetes.Interface {
	d1 := MockDeploy()
	if _, err := k.AppsV1().Deployments(namespace).Create(ctx, &d1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	s1 := MockStatefulSet()
	if _, err := k.AppsV1().StatefulSets(namespace).Create(ctx, &s1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	ds1 := MockDaemonSet()
	if _, err := k.AppsV1().DaemonSets(namespace).Create(ctx, &ds1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	j1 := MockJob()
	if _, err := k.BatchV1().Jobs(namespace).Create(ctx, &j1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	cj1 := MockCronJob()
	if _, err := k.BatchV1beta1().CronJobs(namespace).Create(ctx, &cj1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	rc1 := MockReplicationController()
	if _, err := k.CoreV1().ReplicationControllers(namespace).Create(ctx, &rc1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	p1 := MockNakedPod()
	if _, err := k.CoreV1().Pods(namespace).Create(ctx, &p1, metav1.CreateOptions{}); err != nil {
		panic(err)
	}

	return k
}