package functions

import "fmt"

type Volume struct {
	Secret                *string                `yaml:"secret,omitempty" jsonschema:"oneof_required=secret"`
	ConfigMap             *string                `yaml:"configMap,omitempty" jsonschema:"oneof_required=configmap"`
	PersistentVolumeClaim *PersistentVolumeClaim `yaml:"persistentVolumeClaim,omitempty" jsonschema:"oneof_required=persistentVolumeClaim"`
	EmptyDir              *EmptyDir              `yaml:"emptyDir,omitempty" jsonschema:"oneof_required=emptyDir"`
	Path                  *string                `yaml:"path,omitempty"`
}

type PersistentVolumeClaim struct {
	// claimName is the name of a PersistentVolumeClaim in the same namespace as the pod using this volume.
	// More info: https://kubernetes.io/docs/concepts/storage/persistent-volumes#persistentvolumeclaims
	ClaimName *string `yaml:"claimName,omitempty"`
	// readOnly Will force the ReadOnly setting in VolumeMounts.
	// Default false.
	ReadOnly bool `yaml:"readOnly,omitempty"`
}

const (
	StorageMediumDefault = ""       // use whatever the default is for the node, assume anything we don't explicitly handle is this
	StorageMediumMemory  = "Memory" // use memory (e.g. tmpfs on linux)
)

type EmptyDir struct {
	// medium represents what type of storage medium should back this directory.
	// The default is "" which means to use the node's default medium.
	// Must be an empty string (default) or Memory.
	// More info: https://kubernetes.io/docs/concepts/storage/volumes#emptydir
	Medium string `yaml:"medium,omitempty"`
	// sizeLimit is the total amount of local storage required for this EmptyDir volume.
	// The size limit is also applicable for memory medium.
	// The maximum usage on memory medium EmptyDir would be the minimum value between
	// the SizeLimit specified here and the sum of memory limits of all containers in a pod.
	// The default is nil which means that the limit is undefined.
	// More info: http://kubernetes.io/docs/user-guide/volumes#emptydir
	SizeLimit *string `yaml:"sizeLimit,omitempty"`
}

func (v Volume) String() string {
	var result string
	if v.ConfigMap != nil {
		result = fmt.Sprintf("ConfigMap \"%s\"", *v.ConfigMap)
	} else if v.Secret != nil {
		result = fmt.Sprintf("Secret \"%s\"", *v.Secret)
	} else if v.PersistentVolumeClaim != nil {
		result = "PersistentVolumeClaim"
		if v.PersistentVolumeClaim.ClaimName != nil {
			result += fmt.Sprintf(" \"%s\"", *v.PersistentVolumeClaim.ClaimName)
		}
	} else if v.EmptyDir != nil {
		result = "EmptyDir"
		if v.EmptyDir.Medium == StorageMediumMemory {
			result += " in memory"
		}
		if v.EmptyDir.SizeLimit != nil {
			result += fmt.Sprintf(" with size limit \"%s\"", *v.EmptyDir.SizeLimit)
		}
	} else {
		result = "No volume type"
	}

	if v.Path != nil {
		result += fmt.Sprintf(" at path: \"%s\"", *v.Path)
	}
	return result
}

// validateVolumes checks that input Volumes are correct and contain all necessary fields.
// Returns array of error messages, empty if no errors are found
//
// Allowed settings:
//   - secret: example-secret                              # mount Secret as Volume
//     path: /etc/secret-volume
//   - configMap: example-configMap                        # mount ConfigMap as Volume
//     path: /etc/configMap-volume
//   - persistentVolumeClaim: { claimName: example-pvc }   # mount PersistentVolumeClaim as Volume
//     path: /etc/secret-volume
//   - emptyDir: {}                                         # mount EmptyDir as Volume
//     path: /etc/configMap-volume
func validateVolumes(volumes []Volume) (errors []string) {

	for i, vol := range volumes {
		numVolumes := 0
		if vol.Secret != nil {
			numVolumes++
		}

		if vol.ConfigMap != nil {
			numVolumes++
		}

		if vol.PersistentVolumeClaim != nil {
			numVolumes++
			if vol.PersistentVolumeClaim.ClaimName == nil {
				errors = append(errors, fmt.Sprintf("volume entry #%d (%s) is missing claim name", i, vol))
			}
		}

		if vol.EmptyDir != nil {
			numVolumes++
			if vol.EmptyDir.Medium != StorageMediumDefault && vol.EmptyDir.Medium != StorageMediumMemory {
				errors = append(errors, fmt.Sprintf("volume entry #%d (%s) has invalid storage medium (%s)", i, vol, vol.EmptyDir.Medium))
			}
		}

		if numVolumes == 0 {
			errors = append(errors, fmt.Sprintf("volume entry #%d (%s) is missing a volume type", i, vol))
		} else if numVolumes > 1 {
			errors = append(errors, fmt.Sprintf("volume entry #%d (%s) may not specify more than one volume type", i, vol))
		}

		if vol.Path == nil {
			errors = append(errors, fmt.Sprintf("volume entry #%d (%s) is missing path field", i, vol))
		}
	}

	return
}