package encryption

import (
	"context"

	"edge-infra.dev/test/f2"

	_ "embed"
	"os"
	"testing"

	"k8s.io/apimachinery/pkg/runtime"

	utilruntime "k8s.io/apimachinery/pkg/util/runtime"

	clientgoscheme "k8s.io/client-go/kubernetes/scheme"

	ctrl "sigs.k8s.io/controller-runtime"

	dsapi "edge-infra.dev/pkg/edge/datasync/apis/v1alpha1"
	"edge-infra.dev/pkg/k8s/runtime/controller"
	"edge-infra.dev/pkg/lib/fog"
	"edge-infra.dev/test/f2/x/ktest"
	"edge-infra.dev/test/f2/x/ktest/envtest"
)

const (
	DefaultChannelName = "test"
	DefaultWorkload    = "podinfo"
)

var (
	f f2.Framework
	//go:embed testdata/tlog.json
	tlog []byte

	//go:embed testdata/podinfo_config_values.yaml
	configValues []byte
)

func TestMain(m *testing.M) {
	ctrl.SetLogger(fog.New().WithName("encryption_e2e_test"))

	f = f2.New(context.Background(),
		f2.WithExtensions(
			//bslauth.New(),
			ktest.New(
				ktest.WithCtrlManager(createManager),
				ktest.WithEnvtestOptions(
					// Do not install any CRD into cluster
					envtest.WithoutCRDs(),
				),
				ktest.SkipNamespaceCreation(),
			),
		),
	).WithLabel("dsds", "true")
	os.Exit(f.Run(m))
}

func createManager(opts ...controller.Option) (ctrl.Manager, error) {
	mgrCfg, mgrOpts := controller.ProcessOptions(opts...)
	mgrOpts.Scheme = createScheme()
	return ctrl.NewManager(mgrCfg, mgrOpts)
}

func createScheme() *runtime.Scheme {
	scheme := runtime.NewScheme()
	utilruntime.Must(clientgoscheme.AddToScheme(scheme))
	utilruntime.Must(dsapi.AddToScheme(scheme))
	return scheme
}