package kube

import (
	"context"
	"fmt"
	"time"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/types"
	"sigs.k8s.io/controller-runtime/pkg/client"
)

func Create(ctx context.Context, client client.Client, obj client.Object, wait bool) error {
	if err := client.Create(ctx, obj); err != nil {
		return err
	}
	if wait {
		if err := WaitUntilCreated(ctx, client, obj, 10, time.Millisecond*50); err != nil {
			return err
		}
	}
	return nil
}

func SetOwnerRef(ctx context.Context, client client.Client, obj client.Object, owner client.Object) client.Object {
	apiVersion := fmt.Sprintf("%s/%s", owner.GetObjectKind().GroupVersionKind().Group, owner.GetObjectKind().GroupVersionKind().Version)
	ownerReference := []metav1.OwnerReference{
		{
			APIVersion: apiVersion,
			Kind:       owner.GetObjectKind().GroupVersionKind().GroupKind().Kind,
			Name:       owner.GetName(),
			UID:        owner.GetUID(),
		},
	}
	obj.SetOwnerReferences(ownerReference)
	return obj
}

func WaitUntilCreated(ctx context.Context, client client.Client, obj client.Object, attemps int, timeout time.Duration) error {
	if err := client.Get(ctx, types.NamespacedName{
		Namespace: obj.GetNamespace(),
		Name:      obj.GetName(),
	}, obj); err != nil {
		if attemps > 0 {
			time.Sleep(timeout)
			if err := WaitUntilCreated(ctx, client, obj, attemps-1, timeout); err != nil {
				return err
			}
		} else {
			return err
		}
	}
	return nil
}

func Delete(ctx context.Context, client client.Client, obj client.Object, wait bool) error {
	if err := client.Delete(ctx, obj); err != nil {
		return err
	}
	return nil
}