Dissolve a few lines for fun.
This commit is contained in:
parent
5ad874f6f4
commit
08cfb35dd3
|
|
@ -83,24 +83,19 @@ func GetConfig(configFile string) (Config, error) {
|
||||||
func (c *Config) PollUnifiController(infdb influx.Client, unifi *unidev.AuthedReq) {
|
func (c *Config) PollUnifiController(infdb influx.Client, unifi *unidev.AuthedReq) {
|
||||||
ticker := time.NewTicker(c.Interval.value)
|
ticker := time.NewTicker(c.Interval.value)
|
||||||
for range ticker.C {
|
for range ticker.C {
|
||||||
clients, err := unifi.GetUnifiClientAssets()
|
var clients, devices []unidev.Asset
|
||||||
if err != nil {
|
var bp influx.BatchPoints
|
||||||
|
var err error
|
||||||
|
if clients, err = unifi.GetUnifiClientAssets(); err != nil {
|
||||||
log.Println("unifi.GetUnifiClientsAssets():", err)
|
log.Println("unifi.GetUnifiClientsAssets():", err)
|
||||||
continue
|
} else if devices, err = unifi.GetUnifiDeviceAssets(); err != nil {
|
||||||
}
|
|
||||||
devices, err := unifi.GetUnifiDeviceAssets()
|
|
||||||
if err != nil {
|
|
||||||
log.Println("unifi.GetUnifiDeviceAssets():", err)
|
log.Println("unifi.GetUnifiDeviceAssets():", err)
|
||||||
continue
|
} else if bp, err = influx.NewBatchPoints(influx.BatchPointsConfig{Database: c.InfluxDB}); err != nil {
|
||||||
}
|
|
||||||
bp, err := influx.NewBatchPoints(influx.BatchPointsConfig{
|
|
||||||
Database: c.InfluxDB,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
log.Println("influx.NewBatchPoints:", err)
|
log.Println("influx.NewBatchPoints:", err)
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, asset := range append(clients, devices...) {
|
for _, asset := range append(clients, devices...) {
|
||||||
if pt, errr := asset.Points(); errr != nil {
|
if pt, errr := asset.Points(); errr != nil {
|
||||||
log.Println("asset.Points():", errr)
|
log.Println("asset.Points():", errr)
|
||||||
|
|
@ -108,7 +103,6 @@ func (c *Config) PollUnifiController(infdb influx.Client, unifi *unidev.AuthedRe
|
||||||
bp.AddPoints(pt)
|
bp.AddPoints(pt)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if err = infdb.Write(bp); err != nil {
|
if err = infdb.Write(bp); err != nil {
|
||||||
log.Println("infdb.Write(bp):", err)
|
log.Println("infdb.Write(bp):", err)
|
||||||
continue
|
continue
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue