package graphite

import (
	"time"

	"github.com/FreifunkBremen/yanic/runtime"
	"github.com/fgrosse/graphigo"
)

// PruneNode implementation of database
func (c *Connection) PruneNodes(deleteAfter time.Duration) {
	// we can't really delete nodes from graphite remotely :(
}

// InsertNode implementation of database
func (c *Connection) InsertNode(node *runtime.Node) {
	var fields []graphigo.Metric

	stats := node.Statistics

	nodeinfo := node.Nodeinfo

	if nodeinfo == nil {
		return
	}

	node_prefix := MeasurementNode + `.` + stats.NodeID + `.` + replaceInvalidChars(nodeinfo.Hostname)

	addField := func(name string, value interface{}) {
		fields = append(fields, graphigo.Metric{Name: node_prefix + "." + name, Value: value})
	}

	if neighbours := node.Neighbours; neighbours != nil {
		vpn := 0
		if meshvpn := stats.MeshVPN; meshvpn != nil {
			for _, group := range meshvpn.Groups {
				for _, link := range group.Peers {
					if link != nil && link.Established > 1 {
						vpn++
					}
				}
			}
		}
		addField("neighbours.vpn", vpn)
		// protocol: Batman Advance
		batadv := 0
		for _, batadvNeighbours := range neighbours.Batadv {
			batadv += len(batadvNeighbours.Neighbours)
		}
		addField("neighbours.batadv", batadv)

		// protocol: LLDP
		lldp := 0
		for _, lldpNeighbours := range neighbours.LLDP {
			lldp += len(lldpNeighbours)
		}
		addField("neighbours.lldp", lldp)

		// total is the sum of all protocols
		addField("neighbours.total", batadv+lldp)
	}

	if t := stats.Traffic.Rx; t != nil {
		addField("traffic.rx.bytes", int64(t.Bytes))
		addField("traffic.rx.packets", t.Packets)
	}
	if t := stats.Traffic.Tx; t != nil {
		addField("traffic.tx.bytes", int64(t.Bytes))
		addField("traffic.tx.packets", t.Packets)
		addField("traffic.tx.dropped", t.Dropped)
	}
	if t := stats.Traffic.Forward; t != nil {
		addField("traffic.forward.bytes", int64(t.Bytes))
		addField("traffic.forward.packets", t.Packets)
	}
	if t := stats.Traffic.MgmtRx; t != nil {
		addField("traffic.mgmt_rx.bytes", int64(t.Bytes))
		addField("traffic.mgmt_rx.packets", t.Packets)
	}
	if t := stats.Traffic.MgmtTx; t != nil {
		addField("traffic.mgmt_tx.bytes", int64(t.Bytes))
		addField("traffic.mgmt_tx.packets", t.Packets)
	}

	for _, airtime := range stats.Wireless {
		suffix := airtime.FrequencyName()
		addField("airtime"+suffix+".chan_util", airtime.ChanUtil)
		addField("airtime"+suffix+".rx_util", airtime.RxUtil)
		addField("airtime"+suffix+".tx_util", airtime.TxUtil)
		addField("airtime"+suffix+".noise", airtime.Noise)
		addField("airtime"+suffix+".frequency", airtime.Frequency)
	}

	addField("load", stats.LoadAverage)
	addField("nproc", nodeinfo.Hardware.Nproc)
	addField("time.up", int64(stats.Uptime))
	addField("time.idle", int64(stats.Idletime))
	addField("proc.running", stats.Processes.Running)
	addField("clients.wifi", stats.Clients.Wifi)
	addField("clients.wifi24", stats.Clients.Wifi24)
	addField("clients.wifi5", stats.Clients.Wifi5)
	addField("clients.total", stats.Clients.Total)
	addField("memory.buffers", stats.Memory.Buffers)
	addField("memory.cached", stats.Memory.Cached)
	addField("memory.free", stats.Memory.Free)
	addField("memory.total", stats.Memory.Total)

	c.addPoint(fields)
}