//go:build e2e

package harness

import (
	"github.com/mulgadc/spinifex/spinifex/foundation/messaging/nats"
	"bytes"
	"os"
	"path/filepath"
	"strings"
	"testing"

	"github.com/mulgadc/spinifex/spinifex/bootstrap/config"
	handlers_eks "github.com/mulgadc/spinifex/spinifex/handlers/eks"
	"github.com/nats-io/nats.go/jetstream"
	"github.com/spf13/viper"
)

// ControlPlaneMgmtIP resolves the EKS control-plane VM's br-mgmt address, read
// directly from the NATS KV record. Tests reach the apiserver via the published
// cluster endpoint; this is the out-of-band path to the VM itself.
func ControlPlaneMgmtIP(t *testing.T, env *Env, accountID, clusterName string) string {
	t.Helper()
	host, token, ca := natsConn(t, env)
	nc, err := natsmsg.ConnectNATS(host, token, ca)
	if err != nil {
		t.Fatalf("connect NATS %s: %v", host, err)
	}
	defer nc.Close()

	js, err := jetstream.New(nc)
	if err != nil {
		t.Fatalf("jetstream: %v", err)
	}
	kv, err := js.KeyValue(t.Context(), handlers_eks.AccountBucketName(accountID))
	if err != nil {
		t.Fatalf("open EKS account KV for %s: %v", accountID, err)
	}
	meta, err := handlers_eks.GetClusterMeta(t.Context(), kv, clusterName)
	if err != nil {
		t.Fatalf("get cluster meta %s: %v", clusterName, err)
	}
	if meta.ControlPlaneMgmtIP == "" {
		t.Fatalf("cluster %s has no ControlPlaneMgmtIP recorded", clusterName)
	}
	t.Logf("control-plane mgmt IP: %s", meta.ControlPlaneMgmtIP)
	return meta.ControlPlaneMgmtIP
}

// natsConn resolves NATS host/token/CA. SPINIFEX_NATS_* env vars win; otherwise
// reads from spinifex.toml.
func natsConn(t *testing.T, env *Env) (host, token, ca string) {
	t.Helper()
	host = os.Getenv("SPINIFEX_NATS_URL")
	token = os.Getenv("SPINIFEX_NATS_TOKEN")
	ca = os.Getenv("SPINIFEX_NATS_CA")
	if host != "" {
		return dialableNATSHost(host), token, ca
	}

	cfgPath := filepath.Join(env.ConfigDir, "spinifex.toml")
	cc, err := loadClusterConfig(cfgPath)
	if err != nil {
		t.Fatalf("load %s for NATS settings: %v", cfgPath, err)
	}
	node := nodeConfig(cc)
	if node == nil {
		t.Fatalf("no node stanza with a NATS host in %s", cfgPath)
	}
	return dialableNATSHost(node.NATS.Host), node.NATS.ACL.Token, node.NATS.CACert
}

// loadClusterConfig reads spinifex.toml via a private viper instance with no
// AutomaticEnv, so the harness's own SPINIFEX_* vars (the multinode workflow
// exports SPINIFEX_NODES) cannot shadow the [nodes.*] table and blank the parse.
func loadClusterConfig(path string) (*config.ClusterConfig, error) {
	v := viper.New()
	v.SetConfigFile(path)
	v.SetConfigType("toml")
	if err := v.ReadInConfig(); err != nil {
		return nil, err
	}
	return unmarshalClusterConfig(v)
}

func loadClusterConfigBytes(data []byte) (*config.ClusterConfig, error) {
	v := viper.New()
	v.SetConfigType("toml")
	if err := v.ReadConfig(bytes.NewReader(data)); err != nil {
		return nil, err
	}
	return unmarshalClusterConfig(v)
}

func unmarshalClusterConfig(v *viper.Viper) (*config.ClusterConfig, error) {
	var cc config.ClusterConfig
	if err := v.Unmarshal(&cc); err != nil {
		return nil, err
	}
	// Mirror config.LoadConfig's legacy fallback: a cluster upgraded from an
	// older release may still carry internal_suffix rather than
	// services_domain, and this harness has to see the same value the daemon
	// resolved rather than silently disagreeing with it.
	if cc.AWS.ServicesDomain == "" {
		if legacy := strings.TrimSpace(v.GetString("aws.internal_suffix")); legacy != "" {
			cc.AWS.ServicesDomain = legacy
		}
	}
	return &cc, nil
}

// dialableNATSHost rewrites a wildcard bind address to loopback. NATS.Host is a
// bind address (commonly 0.0.0.0:4222); the TLS serving cert SANs the loopback
// and real node IPs but not 0.0.0.0, so dial 127.0.0.1 instead.
func dialableNATSHost(host string) string {
	return strings.Replace(host, "0.0.0.0", "127.0.0.1", 1)
}

// nodeConfig returns the local node's Config (cc.Node), falling back to the
// first node carrying a NATS host.
func nodeConfig(cc *config.ClusterConfig) *config.Config {
	if cc == nil {
		return nil
	}
	if n, ok := cc.Nodes[cc.Node]; ok && n.NATS.Host != "" {
		return &n
	}
	for _, n := range cc.Nodes {
		if n.NATS.Host != "" {
			return &n
		}
	}
	return nil
}