//go:build integration

package integration

import (
	"path/filepath"
	"testing"

	"github.com/mulgadc/spinifex/spinifex/bootstrap/config"
	acmdomain "github.com/mulgadc/spinifex/spinifex/domains/acm"
	handlers_ecs "github.com/mulgadc/spinifex/spinifex/handlers/ecs"
	handlers_eks "github.com/mulgadc/spinifex/spinifex/handlers/eks"
	handlers_elbv2 "github.com/mulgadc/spinifex/spinifex/handlers/elbv2"
	handlers_iam "github.com/mulgadc/spinifex/spinifex/handlers/iam"
	handlers_rds "github.com/mulgadc/spinifex/spinifex/handlers/rds"
	"github.com/stretchr/testify/require"
)

// StartServiceDaemonLite subscribes the real ACM, ECS, EKS, ELBv2 and RDS
// services to their "<service>.<Method>" subjects. ECS and RDS run without
// their provisioning dependencies, so checks that need them do not run.
func StartServiceDaemonLite(t *testing.T, gw *Gateway) {
	t.Helper()
	nc := gw.NATSConn
	cfg := &config.Config{AZ: testAZ, Region: testRegion}
	masterKey, err := handlers_iam.GenerateMasterKey()
	require.NoError(t, err)

	acm, err := acmdomain.NewACMServiceImplWithNATS(t.Context(), cfg, nc, masterKey)
	require.NoError(t, err, "construct ACM service")
	// Without a tenant CA no mode can issue, so every RequestCertificate would
	// be refused. The generated requests name example.com domains.
	caDir := t.TempDir()
	acm.TenantCA, err = acmdomain.LoadOrCreateTenantCA(filepath.Join(caDir, "ca.pem"), filepath.Join(caDir, "ca.key"), []string{"example.com"})
	require.NoError(t, err, "create ACM tenant CA")
	subscribeServiceMethods(t, nc, "acm", acm)

	elbv2, err := handlers_elbv2.NewELBv2ServiceImplWithNATS(cfg, nc, masterKey)
	require.NoError(t, err, "construct ELBv2 service")
	t.Cleanup(elbv2.Close)
	subscribeServiceMethods(t, nc, "elbv2", elbv2)

	eks, err := handlers_eks.NewEKSServiceImpl(handlers_eks.EKSServiceDeps{
		Config: cfg, NATSConn: nc, MasterKey: masterKey, Region: testRegion, HolderID: "integration-test-node",
	})
	require.NoError(t, err, "construct EKS service")
	t.Cleanup(eks.Shutdown)
	subscribeServiceMethods(t, nc, "eks", eks)

	subscribeServiceMethods(t, nc, "ecs", handlers_ecs.NewService(nc, testRegion, ""))
	subscribeServiceMethods(t, nc, "rds", handlers_rds.NewService(nc, testRegion))
}