package builder

import (
	"context"
	"encoding/base64"
	"fmt"
	"strings"

	"github.com/aws/aws-sdk-go-v2/service/cloudformation/types"

	"github.com/tidwall/gjson"

	gfn "github.com/weaveworks/eksctl/pkg/goformation/cloudformation"
	gfncfn "github.com/weaveworks/eksctl/pkg/goformation/cloudformation/cloudformation"
	gfnec2 "github.com/weaveworks/eksctl/pkg/goformation/cloudformation/ec2"
	gfneks "github.com/weaveworks/eksctl/pkg/goformation/cloudformation/eks"
	gfnt "github.com/weaveworks/eksctl/pkg/goformation/cloudformation/types"

	api "github.com/weaveworks/eksctl/pkg/apis/eksctl.io/v1alpha5"
	"github.com/weaveworks/eksctl/pkg/awsapi"
	"github.com/weaveworks/eksctl/pkg/cfn/outputs"
)

// ClusterResourceSet stores the resource information of the cluster
type ClusterResourceSet struct {
	rs             *resourceSet
	spec           *api.ClusterConfig
	ec2API         awsapi.EC2
	region         string
	vpcResourceSet VPCResourceSet
	securityGroups *gfnt.Value
	stsAPI         awsapi.STS
}

// NewClusterResourceSet returns a resource set for the new cluster.
func NewClusterResourceSet(ec2API awsapi.EC2, stsAPI awsapi.STS, region string, spec *api.ClusterConfig, existingStack *gjson.Result, extendForOutposts bool) *ClusterResourceSet {
	var usesExistingVPC bool
	if existingStack != nil {
		unsetExistingResources(existingStack, spec)
		usesExistingVPC = !existingStack.Get(cfnVPCResource).Exists()
	} else {
		usesExistingVPC = spec.VPC.ID != ""
	}

	var (
		vpcResourceSet VPCResourceSet
		rs             = newResourceSet()
	)

	switch {
	case usesExistingVPC:
		vpcResourceSet = NewExistingVPCResourceSet(rs, spec, ec2API)
	case spec.IPv6Enabled():
		vpcResourceSet = NewIPv6VPCResourceSet(rs, spec, ec2API)
	default:
		vpcResourceSet = NewIPv4VPCResourceSet(rs, spec, ec2API, extendForOutposts)
	}

	return &ClusterResourceSet{
		rs:             rs,
		spec:           spec,
		ec2API:         ec2API,
		stsAPI:         stsAPI,
		region:         region,
		vpcResourceSet: vpcResourceSet,
	}
}

// AddAllResources adds all the information about the cluster to the resource set
func (c *ClusterResourceSet) AddAllResources(ctx context.Context) error {
	if err := c.spec.HasSufficientSubnets(); err != nil {
		return err
	}

	vpcID, subnetDetails, err := c.vpcResourceSet.CreateTemplate(ctx)
	if err != nil {
		return fmt.Errorf("error adding VPC resources: %w", err)
	}

	clusterSG, err := c.addResourcesForSecurityGroups(vpcID)
	if err != nil {
		return fmt.Errorf("error adding security group resources: %w", err)
	}

	if privateCluster := c.spec.PrivateCluster; privateCluster.Enabled && !privateCluster.SkipEndpointCreation {
		vpcEndpointResourceSet := NewVPCEndpointResourceSet(c.ec2API, c.region, c.rs, c.spec, vpcID, subnetDetails.Private, clusterSG.ClusterSharedNode)

		if err := vpcEndpointResourceSet.AddResources(ctx); err != nil {
			return fmt.Errorf("error adding resources for VPC endpoints: %w", err)
		}
	}

	c.addResourcesForIAM()
	if err := c.addResourcesForControlPlane(subnetDetails); err != nil {
		return err
	}
	if c.spec.HasRemoteNetworkingConfigured() {
		c.addAccessEntryForRemoteNodes()
	}

	if len(c.spec.FargateProfiles) > 0 {
		c.addResourcesForFargate()
	}

	c.rs.defineOutput(outputs.ClusterStackName, gfnt.RefStackName, false, func(v string) error {
		if c.spec.Status == nil {
			c.spec.Status = &api.ClusterStatus{}
		}
		c.spec.Status.StackName = v
		return nil
	})

	c.Template().Mappings[servicePrincipalPartitionMapName] = api.Partitions.ServicePrincipalPartitionMappings()

	c.rs.template.Description = fmt.Sprintf(
		"%s (dedicated VPC: %v, dedicated IAM: %v) %s",
		clusterTemplateDescription,
		c.spec.VPC.ID == "",
		c.rs.withIAM,
		templateDescriptionSuffix,
	)

	return nil
}

func (c *ClusterResourceSet) addResourcesForSecurityGroups(vpcID *gfnt.Value) (*clusterSecurityGroup, error) {
	var refControlPlaneSG, refClusterSharedNodeSG *gfnt.Value

	if sg := c.spec.VPC.SecurityGroup; sg != "" {
		refControlPlaneSG = gfnt.NewString(sg)
		c.securityGroups = gfnt.NewStringSlice(sg)
	} else if securityGroupIDs := c.spec.VPC.ControlPlaneSecurityGroupIDs; len(securityGroupIDs) > 0 {
		refControlPlaneSG = gfnt.NewString(securityGroupIDs[0])
		c.securityGroups = gfnt.NewStringSlice(securityGroupIDs...)
	} else {
		refControlPlaneSG = c.newResource(cfnControlPlaneSGResource, &gfnec2.SecurityGroup{
			GroupDescription: gfnt.NewString("Communication between the control plane and worker nodegroups"),
			VpcId:            vpcID,
		})

		if c.spec.HasRemoteNetworkingConfigured() {
			for i, remoteNetworkCIDR := range c.spec.RemoteNetworkConfig.ToRemoteNetworksPool() {
				c.newResource(fmt.Sprintf("IngressControlPlaneRemoteNetworks%d", i), &gfnec2.SecurityGroupIngress{
					GroupId:     refControlPlaneSG,
					CidrIp:      gfnt.NewString(remoteNetworkCIDR),
					Description: gfnt.NewString(fmt.Sprintf("Allow nodes/pods from remote network (%s) to communicate to controlplane", remoteNetworkCIDR)),
					IpProtocol:  gfnt.NewString("tcp"),
					FromPort:    sgPortHTTPS,
					ToPort:      sgPortHTTPS,
				})
			}
		}

		if len(c.spec.VPC.ExtraCIDRs) > 0 {
			for i, cidr := range c.spec.VPC.ExtraCIDRs {
				c.newResource(fmt.Sprintf("IngressControlPlaneExtraCIDR%d", i), &gfnec2.SecurityGroupIngress{
					GroupId:     refControlPlaneSG,
					CidrIp:      gfnt.NewString(cidr),
					Description: gfnt.NewString(fmt.Sprintf("Allow Extra CIDR %d (%s) to communicate to controlplane", i, cidr)),
					IpProtocol:  gfnt.NewString("tcp"),
					FromPort:    sgPortHTTPS,
					ToPort:      sgPortHTTPS,
				})
			}
		}

		if len(c.spec.VPC.ExtraIPv6CIDRs) > 0 {
			for i, cidr := range c.spec.VPC.ExtraIPv6CIDRs {
				c.newResource(fmt.Sprintf("IngressControlPlaneExtraIPv6CIDR%d", i), &gfnec2.SecurityGroupIngress{
					GroupId:     refControlPlaneSG,
					CidrIpv6:    gfnt.NewString(cidr),
					Description: gfnt.NewString(fmt.Sprintf("Allow Extra IPv6 CIDR %d (%s) to communicate to controlplane", i, cidr)),
					IpProtocol:  gfnt.NewString("tcp"),
					FromPort:    sgPortHTTPS,
					ToPort:      sgPortHTTPS,
				})
			}
		}
		c.securityGroups = gfnt.NewSlice(refControlPlaneSG)
	}

	if c.spec.VPC.SharedNodeSecurityGroup == "" {
		// Create the security group with conditional tags
		sharedNodeSG := &gfnec2.SecurityGroup{
			GroupDescription: gfnt.NewString("Communication between all nodes in the cluster"),
			VpcId:            vpcID,
		}

		// Add karpenter.sh/discovery tags if both conditions are met:
		// 1. Karpenter is enabled (karpenter.version is specified)
		// 2. User has specified karpenter.sh/discovery in metadata.tags
		errorHandler := NewSecurityGroupErrorHandler(c.spec.Metadata.Name)

		hasKarpenter := c.isKarpenterEnabled()
		hasDiscoveryTag := c.hasKarpenterDiscoveryMetadataTag()
		var discoveryValue string
		if hasDiscoveryTag && c.spec.Metadata != nil && c.spec.Metadata.Tags != nil {
			discoveryValue = c.spec.Metadata.Tags["karpenter.sh/discovery"]
		}

		// Validate prerequisites and handle errors appropriately
		if err := errorHandler.ValidateTaggingPrerequisites(hasKarpenter, hasDiscoveryTag, discoveryValue); err != nil {
			return nil, errorHandler.WrapConfigurationError(err)
		}

		if hasKarpenter && hasDiscoveryTag {
			tags, err := c.generateKarpenterDiscoveryTagsWithValidation()
			if err != nil {
				return nil, errorHandler.WrapTemplateGenerationError("generate security group tags", err)
			}
			sharedNodeSG.Tags = tags
			errorHandler.LogSuccessfulTagging("karpenter.sh/discovery", discoveryValue)
		}

		refClusterSharedNodeSG = c.newResource(cfnSharedNodeSGResource, sharedNodeSG)
		c.newResource("IngressInterNodeGroupSG", &gfnec2.SecurityGroupIngress{
			GroupId:               refClusterSharedNodeSG,
			SourceSecurityGroupId: refClusterSharedNodeSG,
			Description:           gfnt.NewString("Allow nodes to communicate with each other (all ports)"),
			IpProtocol:            gfnt.NewString("-1"),
			FromPort:              sgPortZero,
			ToPort:                sgMaxNodePort,
		})
	} else {
		refClusterSharedNodeSG = gfnt.NewString(c.spec.VPC.SharedNodeSecurityGroup)
	}

	if api.IsEnabled(c.spec.VPC.ManageSharedNodeSecurityGroupRules) {
		// To enable communication between both managed and unmanaged nodegroups, this allows ingress traffic from
		// the default cluster security group ID that EKS creates by default
		// EKS attaches this to Managed Nodegroups by default, but we need to handle this for unmanaged nodegroups
		c.newResource(cfnIngressClusterToNodeSGResource, &gfnec2.SecurityGroupIngress{
			GroupId:               refClusterSharedNodeSG,
			SourceSecurityGroupId: gfnt.MakeFnGetAttString("ControlPlane", outputs.ClusterDefaultSecurityGroup),
			Description:           gfnt.NewString("Allow managed and unmanaged nodes to communicate with each other (all ports)"),
			IpProtocol:            gfnt.NewString("-1"),
			FromPort:              sgPortZero,
			ToPort:                sgMaxNodePort,
		})
		if c.spec.IsControlPlaneOnOutposts() && c.spec.IsFullyPrivate() {
			if subnets := c.spec.VPC.Subnets; subnets != nil && subnets.Private != nil {
				for az, subnet := range subnets.Private {
					c.newResource(fmt.Sprintf("IngressPrivateSubnet%s", formatAZ(az)), &gfnec2.SecurityGroupIngress{
						GroupId:     refClusterSharedNodeSG,
						CidrIp:      gfnt.NewString(subnet.CIDR.String()),
						Description: gfnt.NewString("Allow private subnets to communicate with VPC endpoints"),
						IpProtocol:  gfnt.NewString("tcp"),
						FromPort:    sgPortHTTPS,
						ToPort:      sgPortHTTPS,
					})
				}
			}

		}
		c.newResource("IngressNodeToDefaultClusterSG", &gfnec2.SecurityGroupIngress{
			GroupId:               gfnt.MakeFnGetAttString("ControlPlane", outputs.ClusterDefaultSecurityGroup),
			SourceSecurityGroupId: refClusterSharedNodeSG,
			Description:           gfnt.NewString("Allow unmanaged nodes to communicate with control plane (all ports)"),
			IpProtocol:            gfnt.NewString("-1"),
			FromPort:              sgPortZero,
			ToPort:                sgMaxNodePort,
		})
	}

	if c.spec.VPC == nil {
		c.spec.VPC = &api.ClusterVPC{}
	}
	c.rs.defineOutput(outputs.ClusterSecurityGroup, refControlPlaneSG, true, func(v string) error {
		c.spec.VPC.SecurityGroup = v
		return nil
	})
	c.rs.defineOutput(outputs.ClusterSharedNodeSecurityGroup, refClusterSharedNodeSG, true, func(v string) error {
		c.spec.VPC.SharedNodeSecurityGroup = v
		return nil
	})

	return &clusterSecurityGroup{
		ControlPlane:      refControlPlaneSG,
		ClusterSharedNode: refClusterSharedNodeSG,
	}, nil
}

// RenderJSON returns the rendered JSON
func (c *ClusterResourceSet) RenderJSON() ([]byte, error) {
	errorHandler := NewSecurityGroupErrorHandler(c.spec.Metadata.Name)

	jsonBytes, err := c.rs.renderJSON()
	if err != nil {
		return nil, errorHandler.WrapTemplateGenerationError("render CloudFormation template", err)
	}

	return jsonBytes, nil
}

// Template returns the CloudFormation template
func (c *ClusterResourceSet) Template() gfn.Template {
	return *c.rs.template
}

// GetAllOutputs collects all outputs of the cluster
func (c *ClusterResourceSet) GetAllOutputs(stack types.Stack) error {
	return c.rs.GetAllOutputs(stack)
}

// HasManagedNodesSG reports whether the stack has the security group required for communication between
// managed and unmanaged nodegroups
func HasManagedNodesSG(stackResources *gjson.Result) bool {
	return stackResources.Get(cfnIngressClusterToNodeSGResource).Exists()
}

// unsetExistingResources unsets fields for CloudFormation resources that were created by eksctl (and not user-supplied)
// in order to trigger execution of code that relies on these fields
func unsetExistingResources(existingStack *gjson.Result, clusterConfig *api.ClusterConfig) {
	controlPlaneSG := existingStack.Get(cfnControlPlaneSGResource)
	if controlPlaneSG.Exists() {
		clusterConfig.VPC.SecurityGroup = ""
	}
	sharedNodeSG := existingStack.Get(cfnSharedNodeSGResource)
	if sharedNodeSG.Exists() {
		clusterConfig.VPC.SharedNodeSecurityGroup = ""
	}
}

func (c *ClusterResourceSet) newResource(name string, resource gfn.Resource) *gfnt.Value {
	return c.rs.newResource(name, resource)
}

func (c *ClusterResourceSet) addResourcesForControlPlane(subnetDetails *SubnetDetails) error {
	clusterVPC := &gfneks.Cluster_ResourcesVpcConfig{
		EndpointPublicAccess:  gfnt.NewBoolean(*c.spec.VPC.ClusterEndpoints.PublicAccess),
		EndpointPrivateAccess: gfnt.NewBoolean(*c.spec.VPC.ClusterEndpoints.PrivateAccess),
		SecurityGroupIds:      c.securityGroups,
		PublicAccessCidrs:     gfnt.NewStringSlice(c.spec.VPC.PublicAccessCIDRs...),
	}
	if subnetIDs := c.spec.VPC.ControlPlaneSubnetIDs; len(subnetIDs) > 0 {
		clusterVPC.SubnetIds = gfnt.NewStringSlice(subnetIDs...)
	} else {
		clusterVPC.SubnetIds = gfnt.NewSlice(subnetDetails.ControlPlaneSubnetRefs()...)
	}

	serviceRoleARN := gfnt.MakeFnGetAttString("ServiceRole", "Arn")
	if api.IsSetAndNonEmptyString(c.spec.IAM.ServiceRoleARN) {
		serviceRoleARN = gfnt.NewString(*c.spec.IAM.ServiceRoleARN)
	}

	var encryptionConfigs []gfneks.Cluster_EncryptionConfig
	if c.spec.SecretsEncryption != nil && c.spec.SecretsEncryption.KeyARN != "" {
		encryptionConfigs = []gfneks.Cluster_EncryptionConfig{
			{
				Resources: gfnt.NewSlice(gfnt.NewString("secrets")),
				Provider: &gfneks.Cluster_Provider{
					KeyArn: gfnt.NewString(c.spec.SecretsEncryption.KeyARN),
				},
			},
		}
	}

	var upgradePolicy *gfneks.Cluster_UpgradePolicy
	if c.spec.UpgradePolicy != nil {
		if c.spec.UpgradePolicy.SupportType != "" {
			upgradePolicy = &gfneks.Cluster_UpgradePolicy{
				SupportType: gfnt.NewString(c.spec.UpgradePolicy.SupportType),
			}
		}
	}

	cluster := gfneks.Cluster{
		EncryptionConfig:           encryptionConfigs,
		Logging:                    makeClusterLogging(c.spec),
		Name:                       gfnt.NewString(c.spec.Metadata.Name),
		ResourcesVpcConfig:         clusterVPC,
		RoleArn:                    serviceRoleARN,
		BootstrapSelfManagedAddons: gfnt.NewBoolean(false),
		UpgradePolicy:              upgradePolicy,
		AccessConfig: &gfneks.Cluster_AccessConfig{
			AuthenticationMode:                      gfnt.NewString(string(c.spec.AccessConfig.AuthenticationMode)),
			BootstrapClusterCreatorAdminPermissions: gfnt.NewBoolean(!api.IsDisabled(c.spec.AccessConfig.BootstrapClusterCreatorAdminPermissions)),
		},
		Tags:    makeCFNTags(c.spec),
		Version: gfnt.NewString(c.spec.Metadata.Version),
	}

	if cc := c.spec.AutoModeConfig; cc != nil && api.IsEnabled(cc.Enabled) {
		computeConfig := &gfneks.Cluster_ComputeConfig{
			Enabled: gfnt.NewBoolean(true),
		}
		cluster.ComputeConfig = computeConfig
		if cc.NodeRoleARN.IsZero() {
			if cc.HasNodePools() {
				autoModeRefs, err := AddAutoModeResources(c.rs.template, cc.PermissionsBoundaryARN)
				if err != nil {
					return fmt.Errorf("error building cluster compute roles: %w", err)
				}
				computeConfig.NodeRoleArn = autoModeRefs.NodeRole
				c.rs.withIAM = true
			}
		} else {
			computeConfig.NodeRoleArn = gfnt.NewString(cc.NodeRoleARN.String())
		}
		if cc.HasNodePools() {
			computeConfig.NodePools = gfnt.NewStringSlice(*cc.NodePools...)
		}

		cluster.KubernetesNetworkConfig = &gfneks.Cluster_KubernetesNetworkConfig{
			ElasticLoadBalancing: &gfneks.Cluster_ElasticLoadBalancing{
				Enabled: gfnt.NewBoolean(true),
			},
		}
		cluster.StorageConfig = &gfneks.Cluster_StorageConfig{
			BlockStorage: &gfneks.Cluster_BlockStorage{
				Enabled: gfnt.NewBoolean(true),
			},
		}
	}

	if c.spec.IsControlPlaneOnOutposts() {
		cluster.OutpostConfig = &gfneks.Cluster_OutpostConfig{
			OutpostArns:              gfnt.NewStringSlice(c.spec.Outpost.ControlPlaneOutpostARN),
			ControlPlaneInstanceType: gfnt.NewString(c.spec.Outpost.ControlPlaneInstanceType),
		}
		if c.spec.Outpost.HasPlacementGroup() {
			cluster.OutpostConfig.ControlPlanePlacement = &gfneks.Cluster_ControlPlanePlacement{
				GroupName: gfnt.NewString(c.spec.Outpost.ControlPlanePlacement.GroupName),
			}
		}
	}

	kubernetesNetworkConfig := cluster.KubernetesNetworkConfig
	if kubernetesNetworkConfig == nil {
		kubernetesNetworkConfig = &gfneks.Cluster_KubernetesNetworkConfig{}
	}
	if knc := c.spec.KubernetesNetworkConfig; knc != nil {
		if knc.ServiceIPv4CIDR != "" {
			kubernetesNetworkConfig.ServiceIpv4Cidr = gfnt.NewString(knc.ServiceIPv4CIDR)
		}
		ipFamily := knc.IPFamily
		if ipFamily == "" {
			ipFamily = api.IPV4Family
		}
		kubernetesNetworkConfig.IpFamily = gfnt.NewString(strings.ToLower(ipFamily))
	}
	cluster.KubernetesNetworkConfig = kubernetesNetworkConfig
	if c.spec.ZonalShiftConfig != nil && api.IsEnabled(c.spec.ZonalShiftConfig.Enabled) {
		cluster.ZonalShiftConfig = &gfneks.Cluster_ZonalShiftConfig{
			Enabled: gfnt.NewBoolean(true),
		}
	}
	if c.spec.ControlPlaneScalingConfig != nil && c.spec.ControlPlaneScalingConfig.Tier != nil {
		cluster.ControlPlaneScalingConfig = &gfneks.Cluster_ControlPlaneScalingConfig{
			Tier: gfnt.NewString(*c.spec.ControlPlaneScalingConfig.Tier),
		}
	}

	if c.spec.HasRemoteNetworkingConfigured() {
		cluster.RemoteNetworkConfig = &gfneks.Cluster_RemoteNetworkConfig{}
		for _, remoteNetwork := range c.spec.RemoteNetworkConfig.RemotePodNetworks {
			cluster.RemoteNetworkConfig.RemotePodNetworks = append(cluster.RemoteNetworkConfig.RemotePodNetworks, gfneks.Cluster_RemotePodNetwork{
				Cidrs: gfnt.NewStringSlice(remoteNetwork.CIDRs...),
			})
		}
		for _, remoteNetwork := range c.spec.RemoteNetworkConfig.RemoteNodeNetworks {
			cluster.RemoteNetworkConfig.RemoteNodeNetworks = append(cluster.RemoteNetworkConfig.RemoteNodeNetworks, gfneks.Cluster_RemoteNodeNetwork{
				Cidrs: gfnt.NewStringSlice(remoteNetwork.CIDRs...),
			})
		}
	}

	if c.spec.IsCustomEksEndpoint() {
		err := addBetaResources(c.stsAPI, c.spec.Metadata.Name, c.rs.template, &cluster)
		if err != nil {
			return fmt.Errorf("unable to add beta resources: %w", err)
		}
	} else {
		c.newResource("ControlPlane", &cluster)
	}

	if c.spec.Status == nil {
		c.spec.Status = &api.ClusterStatus{}
	}

	c.rs.defineOutputFromAtt(outputs.ClusterCertificateAuthorityData, "ControlPlane", "CertificateAuthorityData", false, func(v string) error {
		caData, err := base64.StdEncoding.DecodeString(v)
		if err != nil {
			return fmt.Errorf("decoding certificate authority data: %w", err)
		}
		c.spec.Status.CertificateAuthorityData = caData
		return nil
	})
	c.rs.defineOutputFromAtt(outputs.ClusterEndpoint, "ControlPlane", "Endpoint", true, func(v string) error {
		c.spec.Status.Endpoint = v
		return nil
	})
	c.rs.defineOutputFromAtt(outputs.ClusterARN, "ControlPlane", "Arn", true, func(v string) error {
		c.spec.Status.ARN = v
		return nil
	})

	// This exports the cluster security group ID that EKS creates by default. To enable communication between both
	// managed and unmanaged nodegroups, they must share a security group.
	// EKS attaches this to Managed Nodegroups by default, but we need to add this for unmanaged nodegroups.
	// This exported value is imported in the CloudFormation resource for unmanaged nodegroups
	c.rs.defineOutputFromAtt(outputs.ClusterDefaultSecurityGroup, "ControlPlane", "ClusterSecurityGroupId",
		true, func(s string) error {
			return nil
		})
	return nil
}

func (c *ClusterResourceSet) addAccessEntryForRemoteNodes() {
	getRemoteNodesRoleName := func() string {
		switch strings.ToLower(*c.spec.RemoteNetworkConfig.IAM.Provider) {
		case api.SSMProvider:
			return SSMRole
		case api.IRAProvider:
			return IRARole
		default:
			// Validations should ensure this is never reached
			return ""
		}
	}
	c.newResource("RemoteNodesAccessEntry", &gfneks.AccessEntry{
		PrincipalArn:               gfnt.MakeFnGetAttString(getRemoteNodesRoleName(), "Arn"),
		ClusterName:                gfnt.NewString(c.spec.Metadata.Name),
		Type:                       gfnt.NewString(string(api.AccessEntryTypeHybridLinux)),
		AWSCloudFormationDependsOn: []string{"ControlPlane"},
	})
}

func makeCFNTags(clusterConfig *api.ClusterConfig) []gfncfn.Tag {
	var tags []gfncfn.Tag
	for k, v := range clusterConfig.Metadata.Tags {
		tags = append(tags, gfncfn.Tag{
			Key:   gfnt.NewString(k),
			Value: gfnt.NewString(v),
		})
	}
	return tags
}

func (c *ClusterResourceSet) addResourcesForFargate() {
	_ = addResourcesForFargate(c.rs, c.spec)
}

// shouldAddKarpenterDiscoveryTags checks if both conditions are met for adding karpenter.sh/discovery tags:
// 1. Karpenter is enabled in cluster config (karpenter.version is specified)
// 2. User has specified karpenter.sh/discovery in metadata.tags
func (c *ClusterResourceSet) shouldAddKarpenterDiscoveryTags() bool {
	return c.isKarpenterEnabled() && c.hasKarpenterDiscoveryMetadataTag()
}

// isKarpenterEnabled checks if Karpenter is enabled in the cluster configuration
func (c *ClusterResourceSet) isKarpenterEnabled() bool {
	return c.spec.Karpenter != nil && c.spec.Karpenter.Version != ""
}

// hasKarpenterDiscoveryMetadataTag checks if karpenter.sh/discovery tag exists in metadata.tags
func (c *ClusterResourceSet) hasKarpenterDiscoveryMetadataTag() bool {
	if c.spec.Metadata == nil || c.spec.Metadata.Tags == nil {
		return false
	}
	_, exists := c.spec.Metadata.Tags["karpenter.sh/discovery"]
	return exists
}

// generateKarpenterDiscoveryTags creates the karpenter.sh/discovery tag using the value from metadata.tags
func (c *ClusterResourceSet) generateKarpenterDiscoveryTags() []gfncfn.Tag {
	if c.spec.Metadata == nil || c.spec.Metadata.Tags == nil {
		return nil
	}

	discoveryValue, exists := c.spec.Metadata.Tags["karpenter.sh/discovery"]
	if !exists {
		return nil
	}

	return []gfncfn.Tag{
		{
			Key:   gfnt.NewString("karpenter.sh/discovery"),
			Value: gfnt.NewString(discoveryValue),
		},
	}
}

// generateKarpenterDiscoveryTagsWithValidation creates the karpenter.sh/discovery tag with comprehensive validation
func (c *ClusterResourceSet) generateKarpenterDiscoveryTagsWithValidation() ([]gfncfn.Tag, error) {
	if c.spec.Metadata == nil {
		return nil, fmt.Errorf("cluster metadata is nil")
	}

	if c.spec.Metadata.Tags == nil {
		return nil, fmt.Errorf("cluster metadata tags are nil")
	}

	discoveryValue, exists := c.spec.Metadata.Tags["karpenter.sh/discovery"]
	if !exists {
		return nil, fmt.Errorf("karpenter.sh/discovery tag not found in metadata.tags")
	}

	if discoveryValue == "" {
		return nil, fmt.Errorf("karpenter.sh/discovery tag value cannot be empty")
	}

	// Validate tag value format - AWS tag values have specific constraints
	if len(discoveryValue) > 256 {
		return nil, fmt.Errorf("karpenter.sh/discovery tag value exceeds maximum length of 256 characters")
	}

	return []gfncfn.Tag{
		{
			Key:   gfnt.NewString("karpenter.sh/discovery"),
			Value: gfnt.NewString(discoveryValue),
		},
	}, nil
}
