yanic/database/influxdb/node.go

package influxdb

import (
	"fmt"
	"log"
	"strconv"
	"strings"
	"time"

	models "github.com/influxdata/influxdb1-client/models"
	client "github.com/influxdata/influxdb1-client/v2"

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

// PruneNodes prunes historical per-node data
func (conn *Connection) PruneNodes(deleteAfter time.Duration) {
	for _, measurement := range []string{MeasurementNode, MeasurementLink} {
		query := fmt.Sprintf("delete from %s where time < now() - %ds", measurement, deleteAfter/time.Second)
		if _, err := conn.client.Query(client.NewQuery(query, conn.config.Database(), "m")); err != nil {
			log.Println(err)
		}
	}

}

// InsertNode stores statistics and neighbours in the database
func (conn *Connection) InsertNode(node *runtime.Node) {
	stats := node.Statistics
	time := node.Lastseen.GetTime()

	if stats == nil || stats.NodeID == "" {
		return
	}

	tags := models.Tags{}
	tags.SetString("nodeid", stats.NodeID)

	fields := models.Fields{
		"load":             stats.LoadAverage,
		"time.up":          int64(stats.Uptime),
		"time.idle":        int64(stats.Idletime),
		"proc.running":     stats.Processes.Running,
		"clients.wifi":     stats.Clients.Wifi,
		"clients.wifi24":   stats.Clients.Wifi24,
		"clients.wifi5":    stats.Clients.Wifi5,
		"clients.owe":      stats.Clients.OWE,
		"clients.owe24":    stats.Clients.OWE24,
		"clients.owe5":     stats.Clients.OWE5,
		"clients.total":    stats.Clients.Total,
		"memory.buffers":   stats.Memory.Buffers,
		"memory.cached":    stats.Memory.Cached,
		"memory.free":      stats.Memory.Free,
		"memory.total":     stats.Memory.Total,
		"memory.available": stats.Memory.Available,
	}

	vpnInterfaces := make(map[string]bool)

	if nodeinfo := node.Nodeinfo; nodeinfo != nil {
		for _, mIface := range nodeinfo.Network.Mesh {
			for _, tunnel := range mIface.Interfaces.Tunnel {
				vpnInterfaces[tunnel] = true
			}
		}

		tags.SetString("hostname", nodeinfo.Hostname)
		if nodeinfo.System.SiteCode != "" {
			tags.SetString("site", nodeinfo.System.SiteCode)
		}
		if nodeinfo.System.DomainCode != "" {
			tags.SetString("domain", nodeinfo.System.DomainCode)
		}
		if owner := nodeinfo.Owner; owner != nil {
			tags.SetString("owner", owner.Contact)
		}
		if wireless := nodeinfo.Wireless; wireless != nil {
			fields["wireless.txpower24"] = wireless.TxPower24
			fields["wireless.txpower5"] = wireless.TxPower5
		}
		// Hardware
		tags.SetString("model", nodeinfo.Hardware.Model)
		fields["nproc"] = nodeinfo.Hardware.Nproc
		if nodeinfo.Software.Firmware != nil {
			tags.SetString("firmware_base", nodeinfo.Software.Firmware.Base)
			tags.SetString("firmware_release", nodeinfo.Software.Firmware.Release)
		}
		if nodeinfo.Software.Autoupdater != nil && nodeinfo.Software.Autoupdater.Enabled {
			tags.SetString("autoupdater", nodeinfo.Software.Autoupdater.Branch)
		} else {
			tags.SetString("autoupdater", runtime.DISABLED_AUTOUPDATER)
		}

	}
	if neighbours := node.Neighbours; neighbours != nil {
		// VPN Neighbours are Neighbours but includet in one protocol
		vpn := 0

		// protocol: Batman Advance
		batadv := 0
		for mac, batadvNeighbours := range neighbours.Batadv {
			batadv += len(batadvNeighbours.Neighbours)
			if _, ok := vpnInterfaces[mac]; ok {
				vpn += len(batadvNeighbours.Neighbours)
			}
		}
		fields["neighbours.batadv"] = batadv

		// protocol: Babel
		babel := 0
		for _, babelNeighbours := range neighbours.Babel {
			babel += len(babelNeighbours.Neighbours)
			if _, ok := vpnInterfaces[babelNeighbours.LinkLocalAddress]; ok {
				vpn += len(babelNeighbours.Neighbours)
			}
		}
		fields["neighbours.babel"] = babel

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

		// vpn  wait for babel
		fields["neighbours.vpn"] = vpn

		// total is the sum of all protocols
		fields["neighbours.total"] = batadv + babel + lldp
	}
	if procstat := stats.ProcStats; procstat != nil {
		fields["stat.cpu.user"] = procstat.CPU.User
		fields["stat.cpu.nice"] = procstat.CPU.Nice
		fields["stat.cpu.system"] = procstat.CPU.System
		fields["stat.cpu.idle"] = procstat.CPU.Idle
		fields["stat.cpu.iowait"] = procstat.CPU.IOWait
		fields["stat.cpu.irq"] = procstat.CPU.IRQ
		fields["stat.cpu.softirq"] = procstat.CPU.SoftIRQ
		fields["stat.intr"] = procstat.Intr
		fields["stat.ctxt"] = procstat.ContextSwitches
		fields["stat.softirq"] = procstat.SoftIRQ
		fields["stat.processes"] = procstat.Processes
	}

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

	for _, airtime := range stats.Wireless {
		suffix := airtime.FrequencyName()
		fields["airtime"+suffix+".chan_util"] = airtime.ChanUtil
		fields["airtime"+suffix+".rx_util"] = airtime.RxUtil
		fields["airtime"+suffix+".tx_util"] = airtime.TxUtil
		fields["airtime"+suffix+".noise"] = airtime.Noise
		fields["airtime"+suffix+".frequency"] = airtime.Frequency
		tags.SetString("frequency"+suffix, strconv.Itoa(int(airtime.Frequency)))
	}
	// Add selected gateway mac as tag
	tags.SetString("gateway", strings.ReplaceAll(stats.GatewayIPv4, ":", ""))
	tags.SetString("gateway6", strings.ReplaceAll(stats.GatewayIPv6, ":", ""))
	conn.addPoint(MeasurementNode, tags, fields, time)

	// Add DHCP statistics
	if dhcp := stats.DHCP; dhcp != nil {
		fields := models.Fields{
			"decline":  dhcp.Decline,
			"offer":    dhcp.Offer,
			"ack":      dhcp.Ack,
			"nak":      dhcp.Nak,
			"request":  dhcp.Request,
			"discover": dhcp.Discover,
			"inform":   dhcp.Inform,
			"release":  dhcp.Release,

			"leases.allocated": dhcp.LeasesAllocated,
			"leases.pruned":    dhcp.LeasesPruned,
		}

		// Tags
		tags.SetString("nodeid", stats.NodeID)
		if nodeinfo := node.Nodeinfo; nodeinfo != nil {
			tags.SetString("hostname", nodeinfo.Hostname)
		}

		conn.addPoint(MeasurementDHCP, tags, fields, time)
	}
}