package edgetocloud

import (
	"testing"

	dsapi "edge-infra.dev/pkg/edge/datasync/apis/v1alpha1"
	"edge-infra.dev/pkg/k8s/testing/kmp"
	"edge-infra.dev/test/f2"
	"edge-infra.dev/test/f2/x/ktest"

	"gotest.tools/v3/assert"
	"gotest.tools/v3/assert/cmp"

	"sigs.k8s.io/controller-runtime/pkg/client"
)

func TestE2CResources(t *testing.T) {
	var k *ktest.K8s
	feature := f2.NewFeature("Messaging Resources Check").
		Setup("Initial setup", func(ctx f2.Context, t *testing.T) f2.Context {
			k = ktest.FromContextT(ctx, t)
			return ctx
		}).
		Test("Verify CouchDBPersistence in ready state", func(ctx f2.Context, t *testing.T) f2.Context {
			persistenceResources := dsapi.CouchDBPersistenceList{}
			err := k.Client.List(ctx, &persistenceResources, client.InNamespace(messagingNamespace))
			assert.NilError(t, err)
			assert.Check(t, cmp.Len(persistenceResources.Items, 1), "CouchDBPersistence be 1")

			for _, persistence := range persistenceResources.Items {
				persistence := persistence
				k.WaitOn(t, k.Check(&persistence, kmp.IsReady()))
			}
			return ctx
		}).
		Feature()
	f.Test(t, feature)
}