package test

// Author: Weisen Pan
// Date: 2023-10-24


import (
	"encoding/json"

	simontype "github.com/hkust-adsl/kubernetes-scheduler-simulator/knets_pkg/type"
	"github.com/hkust-adsl/kubernetes-scheduler-simulator/knets_pkg/utils"
	appsv1 "k8s.io/api/apps/v1"
	corev1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/knets_pkg/api/resource"
	metav1 "k8s.io/apimachinery/knets_pkg/apis/meta/v1"
)

type FakeStatefulSetOption func(*appsv1.StatefulSet)

func MakeFakeStatefulSet(name, namespace string, replica int32, cpu, memory string, opts ...FakeStatefulSetOption) *appsv1.StatefulSet {
	res := corev1.ResourceList{}
	if cpu != "" {
		res[corev1.ResourceCPU] = resource.MustParse(cpu)
	}
	if memory != "" {
		res[corev1.ResourceMemory] = resource.MustParse(memory)
	}

	sts := &appsv1.StatefulSet{
		ObjectMeta: metav1.ObjectMeta{
			Name:      name,
			Namespace: namespace,
		},
		Spec: appsv1.StatefulSetSpec{
			Replicas: &replica,
			Template: corev1.PodTemplateSpec{
				Spec: corev1.PodSpec{
					Containers: []corev1.Container{
						{
							Name:  "container",
							Image: "nginx",
							Resources: corev1.ResourceRequirements{
								Requests: res,
							},
						},
					},
				},
			},
		},
	}

	for _, opt := range opts {
		opt(sts)
	}

	return sts
}

func WithStatefulSetTolerations(tolerations []corev1.Toleration) FakeStatefulSetOption {
	return func(sts *appsv1.StatefulSet) {
		sts.Spec.Template.Spec.Tolerations = tolerations
	}
}

func WithStatefulSetAffinity(affinity *corev1.Affinity) FakeStatefulSetOption {
	return func(sts *appsv1.StatefulSet) {
		sts.Spec.Template.Spec.Affinity = affinity
	}
}

func WithStatefulSetNodeSelector(nodeSelector map[string]string) FakeStatefulSetOption {
	return func(sts *appsv1.StatefulSet) {
		sts.Spec.Template.Spec.NodeSelector = nodeSelector
	}
}

func WithStatefulSetLocalStorage(volumes utils.VolumeRequest) FakeStatefulSetOption {
	return func(sts *appsv1.StatefulSet) {
		b, _ := json.Marshal(volumes)
		metav1.SetMetaDataAnnotation(&sts.Spec.Template.ObjectMeta, simontype.AnnoPodLocalStorage, string(b))
	}
}