package metrics

import (
	"github.com/opencost/opencost/core/pkg/clustercache"
	"github.com/prometheus/client_golang/prometheus"
	dto "github.com/prometheus/client_model/go"
	v1 "k8s.io/api/core/v1"
)

//--------------------------------------------------------------------------
//  KubePVCollector
//--------------------------------------------------------------------------

// KubePVCollector is a prometheus collector that generates PV metrics
type KubePVCollector struct {
	KubeClusterCache clustercache.ClusterCache
	metricsConfig    MetricsConfig
}

// Describe sends the super-set of all possible descriptors of metrics
// collected by this Collector.
func (kpvcb KubePVCollector) Describe(ch chan<- *prometheus.Desc) {
	disabledMetrics := kpvcb.metricsConfig.GetDisabledMetricsMap()

	if _, disabled := disabledMetrics["kube_persistentvolume_capacity_bytes"]; !disabled {
		ch <- prometheus.NewDesc("kube_persistentvolume_capacity_bytes", "The pv storage capacity in bytes", []string{}, nil)
	}
	if _, disabled := disabledMetrics["kube_persistentvolume_status_phase"]; !disabled {
		ch <- prometheus.NewDesc("kube_persistentvolume_status_phase", "The phase indicates if a volume is available, bound to a claim, or released by a claim.", []string{}, nil)
	}
	if _, disabled := disabledMetrics["kubecost_pv_info"]; !disabled {
		ch <- prometheus.NewDesc("kubecost_pv_info", "The pv information", []string{}, nil)
	}
}

// Collect is called by the Prometheus registry when collecting metrics.
func (kpvcb KubePVCollector) Collect(ch chan<- prometheus.Metric) {
	pvs := kpvcb.KubeClusterCache.GetAllPersistentVolumes()
	disabledMetrics := kpvcb.metricsConfig.GetDisabledMetricsMap()

	for _, pv := range pvs {
		pvUID := string(pv.UID)

		if _, disabled := disabledMetrics["kube_persistentvolume_status_phase"]; !disabled {
			phase := pv.Status.Phase
			if phase != "" {
				phases := []struct {
					v bool
					n string
				}{
					{phase == v1.VolumePending, string(v1.VolumePending)},
					{phase == v1.VolumeAvailable, string(v1.VolumeAvailable)},
					{phase == v1.VolumeBound, string(v1.VolumeBound)},
					{phase == v1.VolumeReleased, string(v1.VolumeReleased)},
					{phase == v1.VolumeFailed, string(v1.VolumeFailed)},
				}

				for _, p := range phases {
					ch <- newKubePVStatusPhaseMetric("kube_persistentvolume_status_phase", pv.Name, pvUID, p.n, boolFloat64(p.v))
				}
			}
		}

		if _, disabled := disabledMetrics["kube_persistentvolume_capacity_bytes"]; !disabled {
			storage := pv.Spec.Capacity[v1.ResourceStorage]
			m := newKubePVCapacityBytesMetric("kube_persistentvolume_capacity_bytes", pv.Name, pvUID, float64(storage.Value()))
			ch <- m
		}

		if _, disabled := disabledMetrics["kubecost_pv_info"]; !disabled {
			storageClass := pv.Spec.StorageClassName
			providerID := pv.Name
			// if a more accurate provider ID is available, use that
			if pv.Spec.CSI != nil && pv.Spec.CSI.VolumeHandle != "" {
				providerID = pv.Spec.CSI.VolumeHandle
			}
			m := newKubecostPVInfoMetric("kubecost_pv_info", pv.Name, pvUID, storageClass, providerID, float64(1))
			ch <- m
		}
	}
}

//--------------------------------------------------------------------------
//  KubePVCapacityBytesMetric
//--------------------------------------------------------------------------

// KubePVCapacityBytesMetric is a prometheus.Metric
type KubePVCapacityBytesMetric struct {
	fqName string
	help   string
	pv     string
	value  float64
	uid    string
}

// Creates a new KubePVCapacityBytesMetric, implementation of prometheus.Metric
func newKubePVCapacityBytesMetric(fqname, pv, uid string, value float64) KubePVCapacityBytesMetric {
	return KubePVCapacityBytesMetric{
		fqName: fqname,
		help:   "kube_persistentvolume_capacity_bytes pv storage capacity in bytes",
		pv:     pv,
		value:  value,
		uid:    uid,
	}
}

// Desc returns the descriptor for the Metric. This method idempotently
// returns the same descriptor throughout the lifetime of the Metric.
func (kpcrr KubePVCapacityBytesMetric) Desc() *prometheus.Desc {
	l := prometheus.Labels{
		"persistentvolume": kpcrr.pv,
		"uid":              kpcrr.uid,
	}
	return prometheus.NewDesc(kpcrr.fqName, kpcrr.help, []string{}, l)
}

// Write encodes the Metric into a "Metric" Protocol Buffer data
// transmission object.
func (kpcrr KubePVCapacityBytesMetric) Write(m *dto.Metric) error {
	m.Gauge = &dto.Gauge{
		Value: &kpcrr.value,
	}

	m.Label = []*dto.LabelPair{
		{
			Name:  toStringPtr("persistentvolume"),
			Value: &kpcrr.pv,
		},
		{
			Name:  toStringPtr("uid"),
			Value: &kpcrr.uid,
		},
	}
	return nil
}

//--------------------------------------------------------------------------
//  KubePVStatusPhaseMetric
//--------------------------------------------------------------------------

// KubePVStatusPhaseMetric is a prometheus.Metric
type KubePVStatusPhaseMetric struct {
	fqName string
	help   string
	pv     string
	phase  string
	value  float64
	uid    string
}

// Creates a new KubePVStatusPhaseMetric, implementation of prometheus.Metric
func newKubePVStatusPhaseMetric(fqname, pv, uid, phase string, value float64) KubePVStatusPhaseMetric {
	return KubePVStatusPhaseMetric{
		fqName: fqname,
		help:   "kube_persistentvolume_status_phase pv status phase",
		pv:     pv,
		phase:  phase,
		value:  value,
		uid:    uid,
	}
}

// Desc returns the descriptor for the Metric. This method idempotently
// returns the same descriptor throughout the lifetime of the Metric.
func (kpcrr KubePVStatusPhaseMetric) Desc() *prometheus.Desc {
	l := prometheus.Labels{
		"persistentvolume": kpcrr.pv,
		"phase":            kpcrr.phase,
		"uid":              kpcrr.uid,
	}
	return prometheus.NewDesc(kpcrr.fqName, kpcrr.help, []string{}, l)
}

// Write encodes the Metric into a "Metric" Protocol Buffer data
// transmission object.
func (kpcrr KubePVStatusPhaseMetric) Write(m *dto.Metric) error {
	m.Gauge = &dto.Gauge{
		Value: &kpcrr.value,
	}

	m.Label = []*dto.LabelPair{
		{
			Name:  toStringPtr("persistentvolume"),
			Value: &kpcrr.pv,
		},
		{
			Name:  toStringPtr("phase"),
			Value: &kpcrr.phase,
		},
		{
			Name:  toStringPtr("uid"),
			Value: &kpcrr.uid,
		},
	}
	return nil
}

// --------------------------------------------------------------------------
//
//	KubecostPVInfoMetric
//
// --------------------------------------------------------------------------
// KubecostPVInfoMetric is a prometheus.Metric
type KubecostPVInfoMetric struct {
	fqName       string
	help         string
	pv           string
	storageClass string
	value        float64
	providerId   string
	uid          string
}

// Creates a new newKubecostPVInfoMetric, implementation of prometheus.Metric
func newKubecostPVInfoMetric(fqname, pv, uid, storageClass, providerID string, value float64) KubecostPVInfoMetric {
	return KubecostPVInfoMetric{
		fqName:       fqname,
		help:         "kubecost_pv_info pv info",
		pv:           pv,
		storageClass: storageClass,
		value:        value,
		providerId:   providerID,
		uid:          uid,
	}
}

// Desc returns the descriptor for the Metric. This method idempotently
// returns the same descriptor throughout the lifetime of the Metric.
func (kpvim KubecostPVInfoMetric) Desc() *prometheus.Desc {
	l := prometheus.Labels{
		"persistentvolume": kpvim.pv,
		"storageclass":     kpvim.storageClass,
		"provider_id":      kpvim.providerId,
		"uid":              kpvim.uid,
	}
	return prometheus.NewDesc(kpvim.fqName, kpvim.help, []string{}, l)
}

// Write encodes the Metric into a "Metric" Protocol Buffer data
// transmission object.
func (kpvim KubecostPVInfoMetric) Write(m *dto.Metric) error {
	m.Gauge = &dto.Gauge{
		Value: &kpvim.value,
	}

	m.Label = []*dto.LabelPair{
		{
			Name:  toStringPtr("persistentvolume"),
			Value: &kpvim.pv,
		},
		{
			Name:  toStringPtr("storageclass"),
			Value: &kpvim.storageClass,
		},
		{
			Name:  toStringPtr("provider_id"),
			Value: &kpvim.providerId,
		},
		{
			Name:  toStringPtr("uid"),
			Value: &kpvim.uid,
		},
	}
	return nil
}