// +build runit

package exporter

import (
	"github.com/prometheus/client_golang/prometheus"
	"github.com/soundcloud/go-runit/runit"
)

type runitCollector struct {
	name         string
	config       config
	state        prometheus.Gauge
	stateDesired prometheus.Gauge
	stateNormal  prometheus.Gauge
}

func init() {
	collectorFactories = append(collectorFactories, NewRunitCollector)
}

func NewRunitCollector(config config, registry prometheus.Registry) (Collector, error) {
	c := runitCollector{
		name:         "runit_collector",
		config:       config,
		state:        prometheus.NewGauge(),
		stateDesired: prometheus.NewGauge(),
		stateNormal:  prometheus.NewGauge(),
	}

	registry.Register(
		"node_service_state",
		"node_exporter: state of runit service.",
		prometheus.NilLabels,
		c.state,
	)

	registry.Register(
		"node_service_desired_state",
		"node_exporter: desired state of runit service.",
		prometheus.NilLabels,
		c.stateDesired,
	)

	registry.Register(
		"node_service_normal_state",
		"node_exporter: normal state of runit service.",
		prometheus.NilLabels,
		c.stateNormal,
	)

	return &c, nil
}

func (c *runitCollector) Name() string { return c.name }

func (c *runitCollector) Update() (updates int, err error) {
	services, err := runit.GetServices("/etc/service")
	if err != nil {
		return 0, err
	}

	for _, service := range services {
		status, err := service.Status()
		if err != nil {
			debug(c.Name(), "Couldn't get status for %s: %s, skipping...", service.Name, err)
			continue
		}

		debug(c.Name(), "%s is %d on pid %d for %d seconds", service.Name, status.State, status.Pid, status.Duration)
		labels := map[string]string{
			"service": service.Name,
		}

		c.state.Set(labels, float64(status.State))
		c.stateDesired.Set(labels, float64(status.Want))
		if status.NormallyUp {
			c.stateNormal.Set(labels, 1)
		} else {
			c.stateNormal.Set(labels, 1)
		}
		updates += 3
	}

	return updates, err
}