change lib

add fallback for addresses
[TASK] add no-respondd
2019-01-20 02:12:47 +01:00 · 2019-01-20 01:00:50 +01:00 · 2019-01-19 21:37:27 +01:00
61 changed files with 381 additions and 889 deletions
--- a/.gitignore
+++ b/.gitignore
@ -25,4 +25,3 @@ _testmain.go
 webroot
 /config.toml
 /vendor
-/bin
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@ -6,7 +6,7 @@ stages:
 before_script:
  - curl https://raw.githubusercontent.com/golang/dep/master/install.sh | sh
  - mkdir -p /go/src/github.com/FreifunkBremen/
-  - cp -R /builds/freifunkbremen/yanic /go/src/github.com/FreifunkBremen/yanic
+  - cp -R /builds/FreifunkBremen/yanic /go/src/github.com/FreifunkBremen/yanic
  - cd /go/src/github.com/FreifunkBremen/yanic
  - dep ensure

@ -14,13 +14,9 @@ build-my-project:
  stage: build
  script:
    - go install -ldflags "-X github.com/FreifunkBremen/yanic/cmd.VERSION=`git -C $GOPATH/src/github.com/FreifunkBremen/yanic rev-parse HEAD`" github.com/FreifunkBremen/yanic
-    - mkdir /builds/freifunkbremen/yanic/bin/
-    - cp /go/bin/yanic /builds/freifunkbremen/yanic/bin/yanic
  artifacts:
    paths:
-      - bin/yanic
-      - config_example.toml
-      - config-respondd_example.toml
+      - /go/bin/yanic

 test-my-project:
  stage: test
@ -28,7 +24,6 @@ test-my-project:
    - ./.circleci/check-gofmt
    - ./.circleci/check-testfiles
    - go test $(go list ./... | grep -v /vendor/) -v -coverprofile .testCoverage.txt
-    - go tool cover -func=.testCoverage.txt

 test-race-my-project:
  stage: test
--- a/Gopkg.lock
+++ b/Gopkg.lock
@ -2,28 +2,12 @@


 [[projects]]
-  digest = "1:af6e785bedb62fc2abb81977c58a7a44e5cf9f7e41b8d3c8dd4d872edea0ce08"
+  digest = "1:0803645e1f57fb5271a6edc7570b9ea59bac2e5de67957075a43f3d74c8dbd97"
  name = "github.com/NYTimes/gziphandler"
  packages = ["."]
  pruneopts = "UT"
-  revision = "dd0439581c7657cb652dfe5c71d7d48baf39541d"
-  version = "v1.1.1"
-
-[[projects]]
-  digest = "1:616fe3fc0d5eb7b89324dc5e47aef8cf05f3b0aed0bfe908e62516da4c638647"
-  name = "github.com/bdlm/log"
-  packages = ["."]
-  pruneopts = "UT"
-  revision = "b8b76dd35f1d7fdf6a49497c8ac22e6554efffed"
-  version = "v0.1.18"
-
-[[projects]]
-  branch = "master"
-  digest = "1:9da00d14e7f20473d129be028aa99a2f47859aed17e58cd24c5108df76ad3959"
-  name = "github.com/bdlm/std"
-  packages = ["logger"]
-  pruneopts = "UT"
-  revision = "fd3b596111c78b7d14f1e1308ebdb1153013f1a8"
+  revision = "2600fb119af974220d3916a5916d6e31176aac1b"
+  version = "v1.0.1"

 [[projects]]
  digest = "1:ffe9824d294da03b391f44e1ae8281281b4afc1bdaa9588c9097785e3af10cec"
@ -49,17 +33,35 @@
  revision = "76626ae9c91c4f2a10f34cad8ce83ea42c93bb75"
  version = "v1.0"

+[[projects]]
+  digest = "1:e0123d1a40d588fb2d5f98188927826ed5ddfa1d50e759596a6c774f71b81358"
+  name = "github.com/influxdata/influxdb"
+  packages = ["pkg/escape"]
+  pruneopts = "UT"
+  revision = "698dbc789aff13c2678357a6b93ff73dd7136571"
+  version = "v1.7.3"
+
 [[projects]]
  branch = "master"
-  digest = "1:50708c8fc92aec981df5c446581cf9f90ba9e2a5692118e0ce75d4534aaa14a2"
+  digest = "1:22a9593272bc74ef4c513e176608eeed2dee7e8bd7542bae40369cb62d907a3b"
  name = "github.com/influxdata/influxdb1-client"
  packages = [
    "models",
-    "pkg/escape",
    "v2",
  ]
  pruneopts = "UT"
-  revision = "8ff2fc3824fcb533795f9a2f233275f0bb18d6c5"
+  revision = "e237d47d0fc87c8ba2b7c98c349cdceca9c37e27"
+
+[[projects]]
+  branch = "master"
+  digest = "1:ac6b73796941a7ab33ec69fc32f9886a6e7506998f822e3d5205377aee77284a"
+  name = "github.com/influxdata/platform"
+  packages = [
+    "models",
+    "pkg/escape",
+  ]
+  pruneopts = "UT"
+  revision = "98469bf07613ffae6f025893761c1e7a5e96e4aa"

 [[projects]]
  digest = "1:b56c589214f01a5601e0821387db484617392d0042f26234bf2da853a2f498a1"
@ -80,14 +82,6 @@
  revision = "e6f5723bf2a66af014955e0888881314cf294129"
  version = "v0.1.1"

-[[projects]]
-  digest = "1:36cfc0b6facbc68c92a4d55f32eff22b872a899ab75c384ac24a08dd33bc1380"
-  name = "github.com/paulmach/go.geojson"
-  packages = ["."]
-  pruneopts = "UT"
-  revision = "a5c451da2d9c67c590ae6be92565b67698286a1a"
-  version = "v1.4"
-
 [[projects]]
  digest = "1:cf31692c14422fa27c83a05292eb5cbe0fb2775972e8f1f8446a71549bd8980b"
  name = "github.com/pkg/errors"
@ -105,12 +99,12 @@
  version = "v1.0.0"

 [[projects]]
-  digest = "1:22799aea8fe96dd5693abdd1eaa14b1b29e3eafbdc7733fa155b3cb556c8a7ae"
+  digest = "1:645cabccbb4fa8aab25a956cbcbdf6a6845ca736b2c64e197ca7cbb9d210b939"
  name = "github.com/spf13/cobra"
  packages = ["."]
  pruneopts = "UT"
-  revision = "67fc4837d267bc9bfd6e47f77783fcc3dffc68de"
-  version = "v0.0.4"
+  revision = "ef82de70bb3f60c65fb8eebacbb2d122ef517385"
+  version = "v0.0.3"

 [[projects]]
  digest = "1:c1b1102241e7f645bc8e0c22ae352e8f0dc6484b6cb4d132fa9f24174e0119e2"
@ -128,37 +122,15 @@
  revision = "ffdc059bfe9ce6a4e144ba849dbedead332c6053"
  version = "v1.3.0"

-[[projects]]
-  branch = "master"
-  digest = "1:bbe51412d9915d64ffaa96b51d409e070665efc5194fcf145c4a27d4133107a4"
-  name = "golang.org/x/crypto"
-  packages = ["ssh/terminal"]
-  pruneopts = "UT"
-  revision = "22d7a77e9e5f409e934ed268692e56707cd169e5"
-
-[[projects]]
-  branch = "master"
-  digest = "1:160e165ef13917405d1ebfde865cb9c292b8635f83655e3932662d5586d300ee"
-  name = "golang.org/x/sys"
-  packages = [
-    "unix",
-    "windows",
-  ]
-  pruneopts = "UT"
-  revision = "c432e742b0af385916e013f6a34e9e73d139cf82"
-
 [solve-meta]
  analyzer-name = "dep"
  analyzer-version = 1
  input-imports = [
    "github.com/NYTimes/gziphandler",
-    "github.com/bdlm/log",
-    "github.com/bdlm/std/logger",
    "github.com/fgrosse/graphigo",
    "github.com/influxdata/influxdb1-client/models",
    "github.com/influxdata/influxdb1-client/v2",
    "github.com/naoina/toml",
-    "github.com/paulmach/go.geojson",
    "github.com/pkg/errors",
    "github.com/spf13/cobra",
    "github.com/stretchr/testify/assert",
--- a/INSTALL.md
+++ b/INSTALL.md
@ -5,7 +5,7 @@
 ### Install
 ```sh
 cd /usr/local/
-wget https://dl.google.com/go/go1.13.1.linux-amd64.tar.gz -O go-release-linux-amd64.tar.gz
+wget https://storage.googleapis.com/golang/go1.9.1.linux-amd64.tar.gz -O go-release-linux-amd64.tar.gz
 tar xvf go-release-linux-amd64.tar.gz
 rm go-release-linux-amd64.tar.gz
 ```
@ -25,6 +25,12 @@ As root:
 go get -v -u github.com/FreifunkBremen/yanic
 ```

+### allow to ping
+only needed if config has `nodes.ping_count` > 0
+```sh
+sudo setcap cap_net_raw=+ep  /opt/go/bin/yanic
+```
+
 #### Work with other databases
 If you like to use another database solution than influxdb, Pull Requests are
 welcome. Just fork this project and create another subpackage within the folder
@ -62,15 +68,7 @@ the same directory as the `dataPath`. Change the path in the section
 ```sh
 cp /opt/go/src/github.com/FreifunkBremen/yanic/contrib/init/linux-systemd/yanic.service /lib/systemd/system/yanic.service
 systemctl daemon-reload
-```
-
-Before start, you should configure yanic by the file `/etc/yanic.conf`:
-```sh
 systemctl start yanic
-```
-
-Enable to start on boot:
-```sh
 systemctl enable yanic
 ```

--- a/README.md
+++ b/README.md
@ -19,25 +19,25 @@ Yet another node info collector
 * Provide a little webserver for a standalone installation with a meshviewer

 ## How it works
-In the first step Yanic sends a multicast message to the group `ff05::2:1001` and port `1001`.
+
+In the first step Yanic sends a multicast message to the group `ff02:0:0:0:0:0:2:1001` and port `1001`.
 Recently seen nodes that does not reply are requested via a unicast message.

 ## Documentation
 Take a look at the [git](https://github.com/FreifunkBremen/yanic/blob/master/SUMMARY.md) or [Gitbook](https://freifunkbremen.gitbooks.io/yanic/content/)

-# Installation
-Take a look into the Documentation (see above) or for Quick Overview in [INSTALL.md](INSTALL.md).
-
-If you like Docker you may want to take a look [here](https://github.com/christf/docker-yanic).

 ## Configuration
 Read comments in [config_example.toml](config_example.toml) for more information.

 ## Running
+
 Yanic provides several commands:

 ### Usage
+
 Run Yanic without any arguments to get the usage information:
+
 ```
 Usage:
  yanic [command]
@ -49,72 +49,58 @@ Available Commands:
  serve       Runs the yanic server

 Flags:
-  -h, --help              help for yanic
-      --loglevel uint32   Show log message starting at level (default 40)
-      --timestamps        Enables timestamps for log output
+  -h, --help         help for yanic
+      --timestamps   Enables timestamps for log output

 Use "yanic [command] --help" for more information about a command.
 ```

 #### Serve
-Runs the yanic server
+
 ```
 Usage:
  yanic serve [flags]

 Examples:
-yanic serve --config /etc/yanic.toml
+  yanic serve --config /etc/yanic.toml

 Flags:
  -c, --config string   Path to configuration file (default "config.toml")
  -h, --help            help for serve
-
-Global Flags:
-      --loglevel uint32   Show log message starting at level (default 40)
-      --timestamps        Enables timestamps for log output
-```
-
-#### Query
-Sends a query on the interface to the destination and waits for a response
-```
-Usage:
-  yanic query <interfaces> <destination> [flags]
-
-Examples:
-yanic query "eth0,wlan0" "fe80::eade:27ff:dead:beef"
-
-Flags:
-  -h, --help        help for query
-      --ip string   ip address which is used for sending (optional - without definition used the link-local address)
-      --port int    define a port to listen (if not set or set to 0 the kernel will use a random free port at its own)
-      --wait int    Seconds to wait for a response (default 1)
-
-Global Flags:
-      --loglevel uint32   Show log message starting at level (default 40)
-      --timestamps        Enables timestamps for log output
 ```

 #### Import
-Imports global statistics from the given RRD files (ffmap-backend).
+
 ```
 Usage:
-  yanic import <file.rrd> <site> <domain> [flags]
+  yanic import <file.rrd> [flags]

 Examples:
-yanic import --config /etc/yanic.toml olddata.rrd global global
+  yanic import --config /etc/yanic.toml olddata.rrd

 Flags:
  -c, --config string   Path to configuration file (default "config.toml")
  -h, --help            help for import
-
-Global Flags:
-      --loglevel uint32   Show log message starting at level (default 40)
-      --timestamps        Enables timestamps for log output
 ```


+#### Query
+
+```
+Usage:
+  yanic query <interface> <destination> [flags]
+
+Examples:
+  yanic query wlan0 "fe80::eade:27ff:dead:beef"
+
+Flags:
+  -h, --help       help for query
+      --wait int   Seconds to wait for a response (default 1)
+```
+

 ## Communities using Yanic
+
 * **Freifunk Bremen** uses InfluxDB, [Grafana](https://grafana.bremen.freifunk.net), and [Meshviewer](https://map.bremen.freifunk.net) with a patch to show state-version of `nodes.json`. 
 * **Freifunk Nord** uses [hopglass](https://github.com/hopglass/hopglass) (commit 587740a) as frontend:  https://mesh.freifunknord.de/
 * **Freifunk Kiel** uses [Meshviewer](https://github.com/ffrgb/meshviewer/) as frontend: https://map.freifunk.in-kiel.de/
@ -122,6 +108,7 @@ Global Flags:
 Do you know someone else using Yanic? Create a [pull request](https://github.com/FreifunkBremen/yanic/issues/new?template=community.md&title=Mention+community+$name)!

 ## Related projects
+
 Collecting data from respondd:
 * [HopGlass Server](https://github.com/plumpudding/hopglass-server) written in Node.js

@ -131,4 +118,5 @@ Respondd for servers:


 ## License
+
 This software is licensed under the terms of the [AGPL v3 License](LICENSE).
--- a/cmd/config_test.go
+++ b/cmd/config_test.go
@ -25,7 +25,7 @@ func TestReadConfig(t *testing.T) {
 	assert.Contains(config.Respondd.Sites["ffhb"].Domains, "city")

 	// Test output plugins
-	assert.Len(config.Nodes.Output, 4)
+	assert.Len(config.Nodes.Output, 3)
 	outputs := config.Nodes.Output["meshviewer"].([]interface{})
 	assert.Len(outputs, 1)
 	meshviewer := outputs[0]
--- a/config_example.toml
+++ b/config_example.toml
@ -1,6 +1,6 @@
 # This is the config file for Yanic written in "Tom's Obvious, Minimal Language."
 # syntax: https://github.com/toml-lang/toml
-# (if you need something multiple times, checkout out the [[array of table]] section)
+# (if you need somethink multiple times, checkout out the [[array of table]] section)

 # Send respondd request to update information
 [respondd]
@ -23,14 +23,14 @@ domains            = ["city"]
 # name of interface on which this collector is running
 ifname = "br-ffhb"
 # ip address which is used for sending
-# (optional - without definition used a address of ifname - preferred link local)
+# (optional - without definition used a address of ifname)
 ip_address = "fd2f:5119:f2d::5"
 # disable sending multicast respondd request
 # (for receiving only respondd packages e.g. database respondd)
 #send_no_request = false
 # multicast address to destination of respondd
-# (optional - without definition used default ff05::2:1001)
-#multicast_address = "ff02::2:1001"
+# (optional - without definition used batman default ff02::2:1001)
+multicast_address = "ff05::2:1001"
 # define a port to listen
 # if not set or set to 0 the kernel will use a random free port at its own
 #port = 10001
@ -55,6 +55,12 @@ save_interval = "5s"
 # Set node to offline if not seen within this period
 offline_after = "10m"

+## Verify if node is really down by ping last seen address of node
+# send x pings to verify if node is offline (for disable set count < 1)
+ping_count = 3
+# timeout of sending ping to a node
+ping_timeout = "1s"
+

 ## [[nodes.output.example]]
 # Each output format has its own config block and needs to be enabled by adding:
@ -93,11 +99,6 @@ offline_after = "10m"
 #longitude_max = 39.72


-# outputs all nodes as points into nodes.geojson
-[[nodes.output.geojson]]
-enable   = true
-path = "/var/www/html/meshviewer/data/nodes.geojson"
-
 # definition for the new more compressed meshviewer.json
 [[nodes.output.meshviewer-ffrgb]]
 enable   = true
--- a/data/nodeinfo.go
+++ b/data/nodeinfo.go
@ -1,7 +1,7 @@
 package data

-// Nodeinfo struct
-type Nodeinfo struct {
+// NodeInfo struct
+type NodeInfo struct {
 	NodeID   string    `json:"node_id"`
 	Network  Network   `json:"network"`
 	Owner    *Owner    `json:"owner"`
--- a/data/response.go
+++ b/data/response.go
@ -3,6 +3,6 @@ package data
 // ResponseData struct
 type ResponseData struct {
 	Neighbours *Neighbours `json:"neighbours"`
-	Nodeinfo   *Nodeinfo   `json:"nodeinfo"`
+	NodeInfo   *NodeInfo   `json:"nodeinfo"`
 	Statistics *Statistics `json:"statistics"`
 }
--- a/database/graphite/global.go
+++ b/database/graphite/global.go
@ -36,6 +36,7 @@ func (c *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time, s
 func GlobalStatsFields(name string, stats *runtime.GlobalStats) []graphigo.Metric {
 	return []graphigo.Metric{
 		{Name: name + ".nodes", Value: stats.Nodes},
+		{Name: name + ".nodes.no_respondd", Value: stats.NodesNoRespondd},
 		{Name: name + ".gateways", Value: stats.Gateways},
 		{Name: name + ".clients.total", Value: stats.Clients},
 		{Name: name + ".clients.wifi", Value: stats.ClientsWifi},
--- a/database/graphite/node.go
+++ b/database/graphite/node.go
@ -30,36 +30,25 @@ func (c *Connection) InsertNode(node *runtime.Node) {
 		fields = append(fields, graphigo.Metric{Name: node_prefix + "." + name, Value: value})
 	}

-	vpnInterfaces := make(map[string]bool)
-	for _, mIface := range nodeinfo.Network.Mesh {
-		for _, tunnel := range mIface.Interfaces.Tunnel {
-			vpnInterfaces[tunnel] = true
-		}
-	}
-
 	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 mac, batadvNeighbours := range neighbours.Batadv {
+		for _, batadvNeighbours := range neighbours.Batadv {
 			batadv += len(batadvNeighbours.Neighbours)
-			if _, ok := vpnInterfaces[mac]; ok {
-				vpn += len(batadvNeighbours.Neighbours)
-			}
 		}
 		addField("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)
-			}
-		}
-		addField("neighbours.babel", babel)
-
 		// protocol: LLDP
 		lldp := 0
 		for _, lldpNeighbours := range neighbours.LLDP {
@ -67,10 +56,8 @@ func (c *Connection) InsertNode(node *runtime.Node) {
 		}
 		addField("neighbours.lldp", lldp)

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

 	if t := stats.Traffic.Rx; t != nil {
--- a/database/influxdb/global.go
+++ b/database/influxdb/global.go
@ -42,12 +42,13 @@ func (conn *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time
 // GlobalStatsFields returns fields for InfluxDB
 func GlobalStatsFields(stats *runtime.GlobalStats) map[string]interface{} {
 	return map[string]interface{}{
-		"nodes":          stats.Nodes,
-		"gateways":       stats.Gateways,
-		"clients.total":  stats.Clients,
-		"clients.wifi":   stats.ClientsWifi,
-		"clients.wifi24": stats.ClientsWifi24,
-		"clients.wifi5":  stats.ClientsWifi5,
+		"nodes":             stats.Nodes,
+		"nodes.no_respondd": stats.NodesNoRespondd,
+		"gateways":          stats.Gateways,
+		"clients.total":     stats.Clients,
+		"clients.wifi":      stats.ClientsWifi,
+		"clients.wifi24":    stats.ClientsWifi24,
+		"clients.wifi5":     stats.ClientsWifi5,
 	}
 }

--- a/database/influxdb/global_test.go
+++ b/database/influxdb/global_test.go
@ -124,7 +124,7 @@ func createTestNodes() *runtime.Nodes {
 				Total: 23,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "abcdef012345",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -146,7 +146,7 @@ func createTestNodes() *runtime.Nodes {
 				Total: 2,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "112233445566",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -156,7 +156,7 @@ func createTestNodes() *runtime.Nodes {

 	nodes.AddNode(&runtime.Node{
 		Online: true,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "0xdeadbeef0x",
 			VPN:    true,
 			Hardware: data.Hardware{
--- a/database/influxdb/node.go
+++ b/database/influxdb/node.go
@ -48,15 +48,7 @@ func (conn *Connection) InsertNode(node *runtime.Node) {
 		"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)
@ -83,30 +75,28 @@ func (conn *Connection) InsertNode(node *runtime.Node) {
 		}

 	}
+
 	if neighbours := node.Neighbours; neighbours != nil {
 		// VPN Neighbours are Neighbours but includet in one protocol
 		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++
+					}
+				}
+			}
+		}
+		fields["neighbours.vpn"] = vpn

 		// protocol: Batman Advance
 		batadv := 0
-		for mac, batadvNeighbours := range neighbours.Batadv {
+		for _, 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 {
@ -114,11 +104,8 @@ func (conn *Connection) InsertNode(node *runtime.Node) {
 		}
 		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
+		fields["neighbours.total"] = batadv + lldp
 	}
 	if procstat := stats.ProcStats; procstat != nil {
 		fields["stat.cpu.user"] = procstat.CPU.User
--- a/database/influxdb/node_test.go
+++ b/database/influxdb/node_test.go
@ -39,8 +39,20 @@ func TestToInflux(t *testing.T) {
 				MgmtTx:  &data.Traffic{Packets: 2327},
 				MgmtRx:  &data.Traffic{Bytes: 2331},
 			},
+			MeshVPN: &data.MeshVPN{
+				Groups: map[string]*data.MeshVPNPeerGroup{
+					"ffhb": {
+						Peers: map[string]*data.MeshVPNPeerLink{
+							"vpn01": {Established: 3},
+							"vpn02": {},
+							"trash": nil,
+							"vpn03": {Established: 0},
+						},
+					},
+				},
+			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "deadbeef",
 			Owner: &data.Owner{
 				Contact: "nobody",
@ -55,17 +67,6 @@ func TestToInflux(t *testing.T) {
 			},
 			Network: data.Network{
 				Mac: "DEADMAC",
-				Mesh: map[string]*data.NetworkInterface{
-					"bat0": {
-						Interfaces: struct {
-							Wireless []string `json:"wireless,omitempty"`
-							Other    []string `json:"other,omitempty"`
-							Tunnel   []string `json:"tunnel,omitempty"`
-						}{
-							Tunnel: []string{"a-interface-mac", "fe80::1"},
-						},
-					},
-				},
 			},
 			Software: data.Software{
 				Autoupdater: struct {
@ -80,7 +81,7 @@ func TestToInflux(t *testing.T) {
 		Neighbours: &data.Neighbours{
 			NodeID: "deadbeef",
 			Batadv: map[string]data.BatadvNeighbours{
-				"a-interface-mac": {
+				"a-interface": {
 					Neighbours: map[string]data.BatmanLink{
 						"BAFF1E5": {
 							Tq: 204,
@ -88,24 +89,14 @@ func TestToInflux(t *testing.T) {
 					},
 				},
 			},
-			Babel: map[string]data.BabelNeighbours{
-				"wg-01": {
-					LinkLocalAddress: "fe80::1",
-					Neighbours: map[string]data.BabelLink{
-						"fe80::2": {
-							Cost: 0,
-						},
-					},
-				},
-			},
 			LLDP: map[string]data.LLDPNeighbours{
-				"b-interface-mac": {},
+				"b-interface": {},
 			},
 		},
 	}

 	neighbour := &runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "foobar",
 			Network: data.Network{
 				Mac: "BAFF1E5",
@ -126,7 +117,7 @@ func TestToInflux(t *testing.T) {

 	// do not add a empty statistics of a node
 	droppednode := &runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "notfound",
 			Network: data.Network{
 				Mac: "instats",
@ -153,10 +144,9 @@ func TestToInflux(t *testing.T) {
 	assert.EqualValues("city", tags["domain"])
 	assert.EqualValues(0.5, fields["load"])
 	assert.EqualValues(0, fields["neighbours.lldp"])
-	assert.EqualValues(1, fields["neighbours.babel"])
 	assert.EqualValues(1, fields["neighbours.batadv"])
-	assert.EqualValues(2, fields["neighbours.vpn"])
-	assert.EqualValues(2, fields["neighbours.total"])
+	assert.EqualValues(1, fields["neighbours.vpn"])
+	assert.EqualValues(1, fields["neighbours.total"])

 	assert.EqualValues(uint32(3), fields["wireless.txpower24"])
 	assert.EqualValues(uint32(5500), fields["airtime11a.frequency"])
@ -175,7 +165,7 @@ func TestToInflux(t *testing.T) {
 	assert.EqualValues("link", nPoint.Name())
 	assert.EqualValues(map[string]string{
 		"source.id":   "deadbeef",
-		"source.addr": "a-interface-mac",
+		"source.addr": "a-interface",
 		"target.id":   "foobar",
 		"target.addr": "BAFF1E5",
 	}, tags)
--- a/database/logging/file.go
+++ b/database/logging/file.go
@ -50,7 +50,7 @@ func (conn *Connection) InsertLink(link *runtime.Link, time time.Time) {
 }

 func (conn *Connection) InsertGlobals(stats *runtime.GlobalStats, time time.Time, site string, domain string) {
-	conn.log("InsertGlobals: [", time.String(), "] site: ", site, " domain: ", domain, ", nodes: ", stats.Nodes, ", clients: ", stats.Clients, " models: ", len(stats.Models))
+	conn.log("InsertGlobals: [", time.String(), "] site: ", site, " domain: ", domain, ", nodes: ", stats.Nodes, " (no respondd: ", stats.NodesNoRespondd, "), clients: ", stats.Clients, " models: ", len(stats.Models))
 }

 func (conn *Connection) PruneNodes(deleteAfter time.Duration) {
--- a/database/respondd/main.go
+++ b/database/respondd/main.go
@ -51,7 +51,7 @@ func Connect(configuration map[string]interface{}) (database.Connection, error)

 func (conn *Connection) InsertNode(node *runtime.Node) {
 	res := &data.ResponseData{
-		Nodeinfo:   node.Nodeinfo,
+		NodeInfo:   node.Nodeinfo,
 		Statistics: node.Statistics,
 		Neighbours: node.Neighbours,
 	}
--- a/database/respondd/main_test.go
+++ b/database/respondd/main_test.go
@ -25,7 +25,7 @@ func TestStart(t *testing.T) {
 	assert.NoError(err)

 	conn.InsertNode(&runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID:   "73deadbeaf13",
 			Hostname: "inject-test",
 			Network: data.Network{
--- a/docs/docs_configuration.md
+++ b/docs/docs_configuration.md
@ -52,7 +52,7 @@ synchronize      = "1m"
 {% method %}
 How often send request per respondd.

-It will send UDP packets with multicast address `ff05::2:1001` and port `1001`.
+It will send UDP packets with multicast address `ff02::2:1001` and port `1001`.
 If a node does not answer after the half time, it will request with the last know address under the port `1001`.
 {% sample lang="toml" %}
 ```toml
@ -110,7 +110,7 @@ ifname              = "br-ffhb"
 {% method %}
 ip address is the own address which is used for sending.
 If not set or set with empty string it will take an address of ifname.
-(It prefers the link local address, so at babel mesh-network it should be configurated)
+(If `multicast_address` is not set the link local address otherwise a global unicast address)
 {% sample lang="toml" %}
 ```toml
 ip_address          = "fe80::..."
@ -130,8 +130,8 @@ send_no_request     = true
 ### multicast_address
 {% method %}
 Multicast address to destination of respondd.
-If not set or set with empty string it will take the batman default multicast address `ff05::2:1001`
-(Needed to set for legacy `ff02::2:1001`)
+If not set or set with empty string it will take the batman default multicast address `ff02::2:1001`
+(Needed in babel for a mesh-network wide routeable multicast addreess `ff05::2:1001`)
 {% sample lang="toml" %}
 ```toml
 multicast_address    = "ff02::2:1001"
@ -203,6 +203,8 @@ state_path     = "/var/lib/yanic/state.json"
 prune_after    = "7d"
 save_interval  = "5s"
 offline_after  = "10m"
+ping_count = 3
+ping_timeout = "1s"
 ```
 {% endmethod %}

@ -246,6 +248,26 @@ offline_after = "10m"
 ```
 {% endmethod %}

+### ping_count
+{% method %}
+Verify if node is really down by ping last seen address of node
+send x pings to verify if node is offline (for disable set count < 1)
+{% sample lang="toml" %}
+```toml
+ping_count = 3
+```
+{% endmethod %}
+
+
+### ping_timeout
+{% method %}
+Timeout of sending ping to a node
+{% sample lang="toml" %}
+```toml
+ping_timeout = "1s"
+```
+{% endmethod %}
+

 ## [[nodes.output.example]]
 {% method %}
@ -387,32 +409,6 @@ longitude_max = 39.72



-## [[nodes.output.geojson]]
-{% method %}
-The geojson output produces a geojson file which contains the location data of all monitored nodes to be used to visualize the location of the nodes.
-It is optimized to be used with [UMap](https://github.com/umap-project/umap) but should work with other tools as well.
-
-Here is a public demo provided by Freifunk Muenchen: http://u.osmfr.org/m/328494/
-{% sample lang="toml" %}
-```toml
-[[nodes.output.geojson]]
-enable   = true
-path = "/var/www/html/meshviewer/data/nodes.geojson"
-```
-{% endmethod %}
-
-
-### path
-{% method %}
-The path, where to store nodes.geojson
-{% sample lang="toml" %}
-```toml
-path     = "/var/www/html/meshviewer/data/nodes.geojson"
-```
-{% endmethod %}
-
-
-
 ## [[nodes.output.meshviewer-ffrgb]]
 {% method %}
 The new json file format for the [meshviewer](https://github.com/ffrgb/meshviewer) developed in Regensburg.
@ -521,21 +517,6 @@ path     = "/var/www/html/meshviewer/data/nodelist.json"
 ```
 {% endmethod %}

-## [[nodes.output.raw]]
-{% method %}
-This output takes the respondd response as sent by the node and includes it in a JSON document.
-{% endmethod %}
-
-
-### path
-{% method %}
-The path, where to store raw.json
-{% sample lang="toml" %}
-```toml
-path     = "/var/www/html/meshviewer/data/raw.json"
-```
-{% endmethod %}
-


 ## [database]
--- a/docs/docs_install.md
+++ b/docs/docs_install.md
@ -5,13 +5,14 @@
 ### Install
 ```sh
 cd /usr/local/
-wget https://dl.google.com/go/go1.13.1.linux-amd64.tar.gz -O go-release-linux-amd64.tar.gz
+wget https://storage.googleapis.com/golang/go1.9.1.linux-amd64.tar.gz -O go-release-linux-amd64.tar.gz
 tar xvf go-release-linux-amd64.tar.gz
 rm go-release-linux-amd64.tar.gz
 ```

 ### Configure go
 Add these lines in your root shell startup file (e.g. `/root/.bashrc`):
+
 ```sh
 export GOPATH=/opt/go
 export PATH=$PATH:/usr/local/go/bin:$GOPATH/bin
@ -25,6 +26,12 @@ As root:
 go get -v -u github.com/FreifunkBremen/yanic
 ```

+### allow to ping
+only needed if config has `nodes.ping_count` > 0
+```sh
+sudo setcap cap_net_raw=+ep  /opt/go/bin/yanic
+```
+
 ### Install

 ```sh
@ -33,12 +40,14 @@ systemctl daemon-reload
 ```

 Before start, you should configure yanic by the file `/etc/yanic.conf`:
-```sh
+
+```
 systemctl start yanic
 ```

 Enable to start on boot:
-```sh
+
+```
 systemctl enable yanic
 ```

--- a/docs/home_about.md
+++ b/docs/home_about.md
@ -7,7 +7,7 @@ A little overview of yanic in connection with other software:

 It sends the `gluon-neighbour-info` request and collects the answers.

-It will send UDP packets with multicast address `ff05:0:0:0:0:0:2:1001` and port `1001`.
+It will send UDP packets with multicast address `ff02:0:0:0:0:0:2:1001` and port `1001`.

 If a node does not answer, it will request with the last know address under the port `1001`.

--- a/main.go
+++ b/main.go
@ -9,9 +9,9 @@ import (
 	"github.com/FreifunkBremen/yanic/cmd"
 )

-type hook struct{}
+type Hook struct{}

-func (h *hook) Fire(entry *log.Entry) error {
+func (hook *Hook) Fire(entry *log.Entry) error {
 	switch entry.Level {
 	case log.PanicLevel:
 		entry.Logger.Out = os.Stderr
@ -31,12 +31,12 @@ func (h *hook) Fire(entry *log.Entry) error {
 	return nil
 }

-func (h *hook) Levels() []stdLogger.Level {
+func (hook *Hook) Levels() []stdLogger.Level {
 	return log.AllLevels
 }

 func main() {
-	log.AddHook(&hook{})
+	log.AddHook(&Hook{})

 	cmd.Execute()
 }
--- a/output/all/main.go
+++ b/output/all/main.go
@ -1,9 +1,7 @@
 package all

 import (
-	_ "github.com/FreifunkBremen/yanic/output/geojson"
 	_ "github.com/FreifunkBremen/yanic/output/meshviewer"
 	_ "github.com/FreifunkBremen/yanic/output/meshviewer-ffrgb"
 	_ "github.com/FreifunkBremen/yanic/output/nodelist"
-	_ "github.com/FreifunkBremen/yanic/output/raw"
 )
--- a/output/filter/blacklist/blacklist_test.go
+++ b/output/filter/blacklist/blacklist_test.go
@ -23,7 +23,7 @@ func TestFilterBlacklist(t *testing.T) {
 	assert.NoError(err)

 	// keep node without nodeid
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{}})
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{}})
 	assert.NotNil(n)

 	// tests with blacklist
@ -31,11 +31,11 @@ func TestFilterBlacklist(t *testing.T) {
 	assert.NoError(err)

 	// blacklist contains node with nodeid -> drop it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{NodeID: "a"}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{NodeID: "a"}})
 	assert.Nil(n)

 	// blacklist does not contains node without nodeid -> keep it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{}})
 	assert.NotNil(n)

 	n = filter.Apply(&runtime.Node{})
--- a/output/filter/domainappendsite/domainappendsite.go
+++ b/output/filter/domainappendsite/domainappendsite.go
@ -29,7 +29,7 @@ func (config *domainAppendSite) Apply(node *runtime.Node) *runtime.Node {
 			Lastseen:   node.Lastseen,
 			Online:     node.Online,
 			Statistics: node.Statistics,
-			Nodeinfo: &data.Nodeinfo{
+			Nodeinfo: &data.NodeInfo{
 				NodeID:  nodeinfo.NodeID,
 				Network: nodeinfo.Network,
 				System: data.System{
--- a/output/filter/domainappendsite/domainappendsite_test.go
+++ b/output/filter/domainappendsite/domainappendsite_test.go
@ -17,7 +17,7 @@ func TestFilter(t *testing.T) {

 	// delete owner by configuration
 	filter, _ = build(true)
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		System: data.System{
 			SiteCode:   "ffhb",
 			DomainCode: "city",
@ -30,7 +30,7 @@ func TestFilter(t *testing.T) {

 	// keep owner configuration
 	filter, _ = build(false)
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		System: data.System{
 			SiteCode:   "ffhb",
 			DomainCode: "city",
--- a/output/filter/domainassite/domainassite.go
+++ b/output/filter/domainassite/domainassite.go
@ -29,7 +29,7 @@ func (config *domainAsSite) Apply(node *runtime.Node) *runtime.Node {
 			Lastseen:   node.Lastseen,
 			Online:     node.Online,
 			Statistics: node.Statistics,
-			Nodeinfo: &data.Nodeinfo{
+			Nodeinfo: &data.NodeInfo{
 				NodeID:  nodeinfo.NodeID,
 				Network: nodeinfo.Network,
 				System: data.System{
--- a/output/filter/domainassite/domainassite_test.go
+++ b/output/filter/domainassite/domainassite_test.go
@ -17,7 +17,7 @@ func TestFilter(t *testing.T) {

 	// delete owner by configuration
 	filter, _ = build(true)
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		System: data.System{
 			SiteCode:   "ffhb",
 			DomainCode: "city",
@ -30,7 +30,7 @@ func TestFilter(t *testing.T) {

 	// keep owner configuration
 	filter, _ = build(false)
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		System: data.System{
 			SiteCode:   "ffhb",
 			DomainCode: "city",
--- a/output/filter/filter_test.go
+++ b/output/filter/filter_test.go
@ -68,7 +68,7 @@ func TestFilter(t *testing.T) {
 	nodes := &runtime.Nodes{
 		List: map[string]*runtime.Node{
 			"a": {
-				Nodeinfo: &data.Nodeinfo{NodeID: "a"},
+				Nodeinfo: &data.NodeInfo{NodeID: "a"},
 			},
 		},
 	}
@ -83,7 +83,7 @@ func TestFilter(t *testing.T) {
 	nodes = &runtime.Nodes{
 		List: map[string]*runtime.Node{
 			"a": {
-				Nodeinfo: &data.Nodeinfo{NodeID: "a"},
+				Nodeinfo: &data.NodeInfo{NodeID: "a"},
 			},
 		},
 	}
--- a/output/filter/haslocation/haslocation_test.go
+++ b/output/filter/haslocation/haslocation_test.go
@ -20,13 +20,13 @@ func TestFilterHasLocation(t *testing.T) {
 	assert.NoError(err)

 	// node has location (with 0,0) -> keep it
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{},
 	}})
 	assert.NotNil(n)

 	// node without location has no location -> drop it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{}})
 	assert.Nil(n)

 	// node without nodeinfo has no location -> drop it
@ -38,13 +38,13 @@ func TestFilterHasLocation(t *testing.T) {
 	assert.NoError(err)

 	// node has location (with 0,0) -> drop it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{},
 	}})
 	assert.Nil(n)

 	// node without location has no location -> keep it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{}})
 	assert.NotNil(n)

 	// node without nodeinfo has no location -> keep it
--- a/output/filter/inarea/inarea_test.go
+++ b/output/filter/inarea/inarea_test.go
@ -18,7 +18,7 @@ func TestFilterInArea(t *testing.T) {
 		"longitude_max": 12.0,
 	})

-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{Latitude: 4.0, Longitude: 11.0},
 	}})
 	assert.NotNil(n)
@ -28,35 +28,35 @@ func TestFilterInArea(t *testing.T) {
 	assert.NotNil(n)

 	// keep without location -> use has_location for it
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{}})
 	assert.NotNil(n)

 	// zeros not in area (0, 0)
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{},
 	}})
 	assert.Nil(n)

 	// in area
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{Latitude: 4.0, Longitude: 11.0},
 	}})
 	assert.NotNil(n)

 	// over max longitude -> dropped
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{Latitude: 4.0, Longitude: 13.0},
 	}})
 	assert.Nil(n)

 	// over max latitude -> dropped
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{Latitude: 6.0, Longitude: 11.0},
 	}})
 	assert.Nil(n)

 	// lower then mix latitde -> dropped
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Location: &data.Location{Latitude: 1.0, Longitude: 2.0},
 	}})
 	assert.Nil(n)
--- a/output/filter/noowner/noowner.go
+++ b/output/filter/noowner/noowner.go
@ -29,7 +29,7 @@ func (no *noowner) Apply(node *runtime.Node) *runtime.Node {
 			Lastseen:   node.Lastseen,
 			Online:     node.Online,
 			Statistics: node.Statistics,
-			Nodeinfo: &data.Nodeinfo{
+			Nodeinfo: &data.NodeInfo{
 				NodeID:   nodeinfo.NodeID,
 				Network:  nodeinfo.Network,
 				System:   nodeinfo.System,
--- a/output/filter/noowner/noowner_test.go
+++ b/output/filter/noowner/noowner_test.go
@ -17,7 +17,7 @@ func TestFilter(t *testing.T) {

 	// delete owner by configuration
 	filter, _ = build(true)
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Owner: &data.Owner{
 			Contact: "blub",
 		},
@ -28,7 +28,7 @@ func TestFilter(t *testing.T) {

 	// keep owner configuration
 	filter, _ = build(false)
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{
 		Owner: &data.Owner{
 			Contact: "blub",
 		},
--- a/output/filter/site/site_test.go
+++ b/output/filter/site/site_test.go
@ -22,11 +22,11 @@ func TestFilterSite(t *testing.T) {
 	assert.NoError(err)

 	// wronge node
-	n := filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{System: data.System{SiteCode: "ffxx"}}})
+	n := filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{System: data.System{SiteCode: "ffxx"}}})
 	assert.Nil(n)

 	// right node
-	n = filter.Apply(&runtime.Node{Nodeinfo: &data.Nodeinfo{System: data.System{SiteCode: "ffhb"}}})
+	n = filter.Apply(&runtime.Node{Nodeinfo: &data.NodeInfo{System: data.System{SiteCode: "ffhb"}}})
 	assert.NotNil(n)

 	// node without data -> wrong node
--- a/output/geojson/geojson.go
+++ b/output/geojson/geojson.go
@ -1,89 +0,0 @@
-package geojson
-
-import (
-	"strconv"
-	"strings"
-
-	"github.com/FreifunkBremen/yanic/runtime"
-	"github.com/paulmach/go.geojson"
-)
-
-const (
-	POINT_UMAP_CLASS         = "Circle"
-	POINT_UMAP_ONLINE_COLOR  = "Green"
-	POINT_UMAP_OFFLINE_COLOR = "Red"
-)
-
-func newNodePoint(n *runtime.Node) (point *geojson.Feature) {
-	nodeinfo := n.Nodeinfo
-	location := nodeinfo.Location
-	point = geojson.NewPointFeature([]float64{
-		location.Longitude,
-		location.Latitude,
-	})
-	point.Properties["id"] = nodeinfo.NodeID
-	point.Properties["name"] = nodeinfo.Hostname
-
-	point.Properties["online"] = n.Online
-	var description strings.Builder
-	if n.Online {
-		description.WriteString("Online\n")
-		if statistics := n.Statistics; statistics != nil {
-			point.Properties["clients"] = statistics.Clients.Total
-			description.WriteString("Clients: " + strconv.Itoa(int(statistics.Clients.Total)) + "\n")
-		}
-	} else {
-		description.WriteString("Offline\n")
-	}
-	if nodeinfo.Hardware.Model != "" {
-		point.Properties["model"] = nodeinfo.Hardware.Model
-		description.WriteString("Model: " + nodeinfo.Hardware.Model + "\n")
-	}
-	if fw := nodeinfo.Software.Firmware; fw.Release != "" {
-		point.Properties["firmware"] = fw.Release
-		description.WriteString("Firmware: " + fw.Release + "\n")
-	}
-	if nodeinfo.System.SiteCode != "" {
-		point.Properties["site"] = nodeinfo.System.SiteCode
-		description.WriteString("Site: " + nodeinfo.System.SiteCode + "\n")
-	}
-	if nodeinfo.System.DomainCode != "" {
-		point.Properties["domain"] = nodeinfo.System.DomainCode
-		description.WriteString("Domain: " + nodeinfo.System.DomainCode + "\n")
-	}
-	if owner := nodeinfo.Owner; owner != nil && owner.Contact != "" {
-		point.Properties["contact"] = owner.Contact
-		description.WriteString("Contact: " + owner.Contact + "\n")
-	}
-
-	point.Properties["description"] = description.String()
-	point.Properties["_umap_options"] = getUMapOptions(n)
-	return
-}
-
-func getUMapOptions(n *runtime.Node) map[string]string {
-	result := map[string]string{
-		"iconClass": POINT_UMAP_CLASS,
-	}
-	if n.Online {
-		result["color"] = POINT_UMAP_ONLINE_COLOR
-	} else {
-		result["color"] = POINT_UMAP_OFFLINE_COLOR
-	}
-	return result
-}
-
-func transform(nodes *runtime.Nodes) *geojson.FeatureCollection {
-	nodelist := geojson.NewFeatureCollection()
-
-	for _, n := range nodes.List {
-		if n.Nodeinfo == nil || n.Nodeinfo.Location == nil {
-			continue
-		}
-		point := newNodePoint(n)
-		if point != nil {
-			nodelist.Features = append(nodelist.Features, point)
-		}
-	}
-	return nodelist
-}
--- a/output/geojson/geojson_test.go
+++ b/output/geojson/geojson_test.go
@ -1,129 +0,0 @@
-package geojson
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-
-	"github.com/FreifunkBremen/yanic/data"
-	"github.com/FreifunkBremen/yanic/runtime"
-)
-
-const (
-	testNodeDescription string = "Online\nClients: 42\nModel: TP-Link 841\n" +
-		"Site: mysite\nDomain: domain_42\n"
-)
-
-func TestTransform(t *testing.T) {
-	testNodes := createTestNodes()
-	nodes := transform(testNodes)
-
-	assert := assert.New(t)
-	assert.Len(testNodes.List, 4)
-	assert.Len(nodes.Features, 3)
-
-	node := testNodes.List["abcdef012425"]
-
-	umap := getUMapOptions(node)
-	assert.Len(umap, 2)
-
-	nodePoint := newNodePoint(node)
-	assert.Equal(
-		"abcdef012425",
-		nodePoint.Properties["id"],
-	)
-	assert.Equal(
-		"TP-Link 841",
-		nodePoint.Properties["model"],
-	)
-	assert.Equal(
-		uint32(42),
-		nodePoint.Properties["clients"],
-	)
-	assert.Equal(
-		testNodeDescription,
-		nodePoint.Properties["description"],
-	)
-}
-
-func createTestNodes() *runtime.Nodes {
-	nodes := runtime.NewNodes(&runtime.NodesConfig{})
-
-	nodes.AddNode(&runtime.Node{
-		Online: true,
-		Statistics: &data.Statistics{
-			Clients: data.Clients{
-				Total: 42,
-			},
-		},
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "abcdef012425",
-			Hardware: data.Hardware{
-				Model: "TP-Link 841",
-			},
-			Location: &data.Location{
-				Latitude:  24,
-				Longitude: 2,
-			},
-			System: data.System{
-				SiteCode:   "mysite",
-				DomainCode: "domain_42",
-			},
-		},
-	})
-
-	nodeData := &runtime.Node{
-		Online: true,
-		Statistics: &data.Statistics{
-			Clients: data.Clients{
-				Total: 23,
-			},
-		},
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "abcdef012345",
-			Hardware: data.Hardware{
-				Model: "TP-Link 842",
-			},
-			System: data.System{
-				SiteCode:   "mysite",
-				DomainCode: "domain_42",
-			},
-		},
-	}
-	nodeData.Nodeinfo.Software.Firmware.Release = "2019.1~exp42"
-	nodes.AddNode(nodeData)
-
-	nodes.AddNode(&runtime.Node{
-		Statistics: &data.Statistics{
-			Clients: data.Clients{
-				Total: 2,
-			},
-		},
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "112233445566",
-			Hardware: data.Hardware{
-				Model: "TP-Link 843",
-			},
-			Location: &data.Location{
-				Latitude:  23,
-				Longitude: 2,
-			},
-		},
-	})
-
-	nodes.AddNode(&runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "0xdeadbeef0x",
-			VPN:    true,
-			Hardware: data.Hardware{
-				Model: "Xeon Multi-Core",
-			},
-			Location: &data.Location{
-				Latitude:  23,
-				Longitude: 22,
-			},
-		},
-	})
-
-	return nodes
-}
--- a/output/geojson/output.go
+++ b/output/geojson/output.go
@ -1,46 +0,0 @@
-package geojson
-
-import (
-	"errors"
-
-	"github.com/FreifunkBremen/yanic/output"
-	"github.com/FreifunkBremen/yanic/runtime"
-)
-
-type Output struct {
-	output.Output
-	path string
-}
-
-type Config map[string]interface{}
-
-func (c Config) Path() string {
-	if path, ok := c["path"]; ok {
-		return path.(string)
-	}
-	return ""
-}
-
-func init() {
-	output.RegisterAdapter("geojson", Register)
-}
-
-func Register(configuration map[string]interface{}) (output.Output, error) {
-	var config Config
-	config = configuration
-
-	if path := config.Path(); path != "" {
-		return &Output{
-			path: path,
-		}, nil
-	}
-	return nil, errors.New("no path given")
-
-}
-
-func (o *Output) Save(nodes *runtime.Nodes) {
-	nodes.RLock()
-	defer nodes.RUnlock()
-
-	runtime.SaveJSON(transform(nodes), o.path)
-}
--- a/output/geojson/output_test.go
+++ b/output/geojson/output_test.go
@ -1,28 +0,0 @@
-package geojson
-
-import (
-	"os"
-	"testing"
-
-	"github.com/FreifunkBremen/yanic/runtime"
-	"github.com/stretchr/testify/assert"
-)
-
-func TestOutput(t *testing.T) {
-	assert := assert.New(t)
-
-	out, err := Register(map[string]interface{}{})
-	assert.Error(err)
-	assert.Nil(out)
-
-	out, err = Register(map[string]interface{}{
-		"path": "/tmp/nodes.geojson",
-	})
-	os.Remove("/tmp/nodes.geojson")
-	assert.NoError(err)
-	assert.NotNil(out)
-
-	out.Save(&runtime.Nodes{})
-	_, err = os.Stat("/tmp/nodes.geojson")
-	assert.NoError(err)
-}
--- a/output/meshviewer-ffrgb/meshviewer_test.go
+++ b/output/meshviewer-ffrgb/meshviewer_test.go
@ -14,7 +14,7 @@ func TestTransform(t *testing.T) {
 	nodes := runtime.NewNodes(&runtime.NodesConfig{})
 	nodes.AddNode(&runtime.Node{
 		Online: true,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "node_a",
 			Network: data.Network{
 				Mac: "node:a:mac",
@ -51,7 +51,7 @@ func TestTransform(t *testing.T) {
 	})
 	nodes.AddNode(&runtime.Node{
 		Online: true,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "node_c",
 			Network: data.Network{
 				Mac: "node:c:mac",
@ -69,7 +69,7 @@ func TestTransform(t *testing.T) {
 			},
 		},
 		Neighbours: &data.Neighbours{
-			NodeID: "node_c",
+			NodeID: "node_b",
 			Batadv: map[string]data.BatadvNeighbours{
 				"node:c:mac:lan": {
 					Neighbours: map[string]data.BatmanLink{
@ -81,7 +81,7 @@ func TestTransform(t *testing.T) {
 	})
 	nodes.AddNode(&runtime.Node{
 		Online: true,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "node_b",
 			Network: data.Network{
 				Mac: "node:b:mac",
@ -117,7 +117,7 @@ func TestTransform(t *testing.T) {
 	})
 	nodes.AddNode(&runtime.Node{
 		Online: false,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "node_d",
 			Network: data.Network{
 				Mac: "node:d:mac",
--- a/output/meshviewer-ffrgb/struct_test.go
+++ b/output/meshviewer-ffrgb/struct_test.go
@ -12,7 +12,7 @@ func TestRegister(t *testing.T) {
 	assert := assert.New(t)
 	nodes := runtime.NewNodes(&runtime.NodesConfig{})
 	node := NewNode(nodes, &runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			Owner: &data.Owner{
 				Contact: "whoami",
 			},
@ -26,7 +26,7 @@ func TestRegister(t *testing.T) {
 	assert.Len(node.Addresses, 1)

 	node = NewNode(nodes, &runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			Owner: &data.Owner{
 				Contact: "whoami",
 			},
--- a/output/meshviewer/graph_test.go
+++ b/output/meshviewer/graph_test.go
@ -12,7 +12,7 @@ import (
 )

 type TestNode struct {
-	Nodeinfo   *data.Nodeinfo   `json:"nodeinfo"`
+	Nodeinfo   *data.NodeInfo   `json:"nodeinfo"`
 	Neighbours *data.Neighbours `json:"neighbours"`
 }

@ -38,7 +38,7 @@ func testGetNodesByFile(files ...string) *runtime.Nodes {
 	for _, file := range files {
 		node := testGetNodeByFile(file)
 		nodes.Update(file, &data.ResponseData{
-			Nodeinfo:   node.Nodeinfo,
+			NodeInfo:   node.Nodeinfo,
 			Neighbours: node.Neighbours,
 		})
 	}
--- a/output/meshviewer/node.go
+++ b/output/meshviewer/node.go
@ -11,7 +11,7 @@ type Node struct {
 	Lastseen   jsontime.Time    `json:"lastseen"`
 	Flags      Flags            `json:"flags"`
 	Statistics *Statistics      `json:"statistics"`
-	Nodeinfo   *data.Nodeinfo   `json:"nodeinfo"`
+	Nodeinfo   *data.NodeInfo   `json:"nodeinfo"`
 	Neighbours *data.Neighbours `json:"-"`
 }

--- a/output/meshviewer/nodes_test.go
+++ b/output/meshviewer/nodes_test.go
@ -31,7 +31,7 @@ func createTestNodes() *runtime.Nodes {
 				Total: 23,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "abcdef012345",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -52,7 +52,7 @@ func createTestNodes() *runtime.Nodes {
 				Free:  8,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "112233445566",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -61,7 +61,7 @@ func createTestNodes() *runtime.Nodes {
 	})

 	nodes.AddNode(&runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "0xdeadbeef0x",
 			VPN:    true,
 			Hardware: data.Hardware{
--- a/output/nodelist/nodelist_test.go
+++ b/output/nodelist/nodelist_test.go
@ -25,7 +25,7 @@ func createTestNodes() *runtime.Nodes {
 				Total: 23,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "abcdef012345",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -41,7 +41,7 @@ func createTestNodes() *runtime.Nodes {
 				Total: 2,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "112233445566",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -54,7 +54,7 @@ func createTestNodes() *runtime.Nodes {
 	})

 	nodes.AddNode(&runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "0xdeadbeef0x",
 			VPN:    true,
 			Hardware: data.Hardware{
--- a/output/raw/output.go
+++ b/output/raw/output.go
@ -1,46 +0,0 @@
-package raw
-
-import (
-	"errors"
-
-	"github.com/FreifunkBremen/yanic/output"
-	"github.com/FreifunkBremen/yanic/runtime"
-)
-
-type Output struct {
-	output.Output
-	path string
-}
-
-type Config map[string]interface{}
-
-func (c Config) Path() string {
-	if path, ok := c["path"]; ok {
-		return path.(string)
-	}
-	return ""
-}
-
-func init() {
-	output.RegisterAdapter("raw", Register)
-}
-
-func Register(configuration map[string]interface{}) (output.Output, error) {
-	var config Config
-	config = configuration
-
-	if path := config.Path(); path != "" {
-		return &Output{
-			path: path,
-		}, nil
-	}
-	return nil, errors.New("no path given")
-
-}
-
-func (o *Output) Save(nodes *runtime.Nodes) {
-	nodes.RLock()
-	defer nodes.RUnlock()
-
-	runtime.SaveJSON(transform(nodes), o.path)
-}
--- a/output/raw/output_test.go
+++ b/output/raw/output_test.go
@ -1,28 +0,0 @@
-package raw
-
-import (
-	"os"
-	"testing"
-
-	"github.com/FreifunkBremen/yanic/runtime"
-	"github.com/stretchr/testify/assert"
-)
-
-func TestOutput(t *testing.T) {
-	assert := assert.New(t)
-
-	out, err := Register(map[string]interface{}{})
-	assert.Error(err)
-	assert.Nil(out)
-
-	out, err = Register(map[string]interface{}{
-		"path": "/tmp/raw.json",
-	})
-	os.Remove("/tmp/raw.json")
-	assert.NoError(err)
-	assert.NotNil(out)
-
-	out.Save(&runtime.Nodes{})
-	_, err = os.Stat("/tmp/raw.json")
-	assert.NoError(err)
-}
--- a/output/raw/raw.go
+++ b/output/raw/raw.go
@ -1,45 +0,0 @@
-package raw
-
-import (
-	"github.com/FreifunkBremen/yanic/data"
-	"github.com/FreifunkBremen/yanic/lib/jsontime"
-	"github.com/FreifunkBremen/yanic/runtime"
-)
-
-// Node struct
-type RawNode struct {
-	Firstseen  jsontime.Time    `json:"firstseen"`
-	Lastseen   jsontime.Time    `json:"lastseen"`
-	Online     bool             `json:"online"`
-	Statistics *data.Statistics `json:"statistics"`
-	Nodeinfo   *data.Nodeinfo   `json:"nodeinfo"`
-	Neighbours *data.Neighbours `json:"neighbours"`
-}
-
-type NodeList struct {
-	Version   string        `json:"version"`
-	Timestamp jsontime.Time `json:"updated_at"` // Timestamp of the generation
-	List      []*RawNode    `json:"nodes"`
-}
-
-func transform(nodes *runtime.Nodes) *NodeList {
-	nodelist := &NodeList{
-		Version:   "1.0.0",
-		Timestamp: jsontime.Now(),
-	}
-
-	for _, nodeOrigin := range nodes.List {
-		if nodeOrigin != nil {
-			node := &RawNode{
-				Firstseen:  nodeOrigin.Firstseen,
-				Lastseen:   nodeOrigin.Lastseen,
-				Online:     nodeOrigin.Online,
-				Statistics: nodeOrigin.Statistics,
-				Nodeinfo:   nodeOrigin.Nodeinfo,
-				Neighbours: nodeOrigin.Neighbours,
-			}
-			nodelist.List = append(nodelist.List, node)
-		}
-	}
-	return nodelist
-}
--- a/output/raw/raw_test.go
+++ b/output/raw/raw_test.go
@ -1,67 +0,0 @@
-package raw
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-
-	"github.com/FreifunkBremen/yanic/data"
-	"github.com/FreifunkBremen/yanic/runtime"
-)
-
-func TestTransform(t *testing.T) {
-	nodes := transform(createTestNodes())
-
-	assert := assert.New(t)
-	assert.Len(nodes.List, 3)
-}
-
-func createTestNodes() *runtime.Nodes {
-	nodes := runtime.NewNodes(&runtime.NodesConfig{})
-
-	nodeData := &runtime.Node{
-		Statistics: &data.Statistics{
-			Clients: data.Clients{
-				Total: 23,
-			},
-		},
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "abcdef012345",
-			Hardware: data.Hardware{
-				Model: "TP-Link 841",
-			},
-		},
-	}
-	nodeData.Nodeinfo.Software.Firmware.Release = "2016.1.6+entenhausen1"
-	nodes.AddNode(nodeData)
-
-	nodes.AddNode(&runtime.Node{
-		Statistics: &data.Statistics{
-			Clients: data.Clients{
-				Total: 2,
-			},
-		},
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "112233445566",
-			Hardware: data.Hardware{
-				Model: "TP-Link 841",
-			},
-			Location: &data.Location{
-				Latitude:  23,
-				Longitude: 2,
-			},
-		},
-	})
-
-	nodes.AddNode(&runtime.Node{
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "0xdeadbeef0x",
-			VPN:    true,
-			Hardware: data.Hardware{
-				Model: "Xeon Multi-Core",
-			},
-		},
-	})
-
-	return nodes
-}
--- a/respond/collector.go
+++ b/respond/collector.go
@ -66,7 +66,7 @@ func (coll *Collector) listenUDP(iface InterfaceConfig) {
 	if iface.IPAddress != "" {
 		addr = net.ParseIP(iface.IPAddress)
 	} else {
-		addr, err = getUnicastAddr(iface.InterfaceName)
+		addr, err = getUnicastAddr(iface.InterfaceName, iface.MulticastAddress == "")
 		if err != nil {
 			log.WithField("iface", iface.InterfaceName).Panic(err)
 		}
@ -99,7 +99,7 @@ func (coll *Collector) listenUDP(iface InterfaceConfig) {
 }

 // Returns a unicast address of given interface (linklocal or global unicast address)
-func getUnicastAddr(ifname string) (net.IP, error) {
+func getUnicastAddr(ifname string, linklocal bool) (net.IP, error) {
 	iface, err := net.InterfaceByName(ifname)
 	if err != nil {
 		return nil, err
@ -116,7 +116,7 @@ func getUnicastAddr(ifname string) (net.IP, error) {
 		if !ok {
 			continue
 		}
-		if (ip == nil && ipnet.IP.IsGlobalUnicast()) || ipnet.IP.IsLinkLocalUnicast() {
+		if (!linklocal && ipnet.IP.IsGlobalUnicast()) || (linklocal && ipnet.IP.IsLinkLocalUnicast()) {
 			ip = ipnet.IP
 		}
 	}
@ -260,7 +260,7 @@ func (res *Response) parse() (*data.ResponseData, error) {
 func (coll *Collector) saveResponse(addr *net.UDPAddr, res *data.ResponseData) {
 	// Search for NodeID
 	var nodeID string
-	if val := res.Nodeinfo; val != nil {
+	if val := res.NodeInfo; val != nil {
 		nodeID = val.NodeID
 	} else if val := res.Neighbours; val != nil {
 		nodeID = val.NodeID
@ -284,8 +284,8 @@ func (coll *Collector) saveResponse(addr *net.UDPAddr, res *data.ResponseData) {
 	if res.Neighbours != nil && res.Neighbours.NodeID != nodeID {
 		res.Neighbours = nil
 	}
-	if res.Nodeinfo != nil && res.Nodeinfo.NodeID != nodeID {
-		res.Nodeinfo = nil
+	if res.NodeInfo != nil && res.NodeInfo.NodeID != nodeID {
+		res.NodeInfo = nil
 	}

 	// Process the data and update IP address
--- a/respond/collector_test.go
+++ b/respond/collector_test.go
@ -39,5 +39,5 @@ func TestParse(t *testing.T) {
 	assert.NoError(err)
 	assert.NotNil(data)

-	assert.Equal("f81a67a5e9c1", data.Nodeinfo.NodeID)
+	assert.Equal("f81a67a5e9c1", data.NodeInfo.NodeID)
 }
--- a/respond/respond.go
+++ b/respond/respond.go
@ -6,7 +6,7 @@ import (

 const (
 	// default multicast group used by announced
-	multicastAddressDefault = "ff05:0:0:0:0:0:2:1001"
+	multicastAddressDefault = "ff02:0:0:0:0:0:2:1001"

 	// default udp port used by announced
 	port = 1001
--- a/runtime/node.go
+++ b/runtime/node.go
@ -13,8 +13,9 @@ type Node struct {
 	Firstseen  jsontime.Time    `json:"firstseen"`
 	Lastseen   jsontime.Time    `json:"lastseen"`
 	Online     bool             `json:"online"`
+	NoRespondd bool             `json:"no_respondd"`
 	Statistics *data.Statistics `json:"statistics"`
-	Nodeinfo   *data.Nodeinfo   `json:"nodeinfo"`
+	Nodeinfo   *data.NodeInfo   `json:"nodeinfo"`
 	Neighbours *data.Neighbours `json:"-"`
 }

--- a/runtime/node_test.go
+++ b/runtime/node_test.go
@ -13,7 +13,7 @@ func TestNode(t *testing.T) {
 	node := &Node{}
 	assert.False(node.IsGateway())

-	node.Nodeinfo = &data.Nodeinfo{}
+	node.Nodeinfo = &data.NodeInfo{}
 	assert.False(node.IsGateway())

 	node.Nodeinfo.VPN = true
--- a/runtime/nodes.go
+++ b/runtime/nodes.go
@ -7,6 +7,7 @@ import (
 	"time"

 	"github.com/bdlm/log"
+	ping "github.com/digineo/go-ping"

 	"github.com/FreifunkBremen/yanic/data"
 	"github.com/FreifunkBremen/yanic/lib/jsontime"
@ -17,6 +18,7 @@ type Nodes struct {
 	List          map[string]*Node  `json:"nodes"` // the current nodemap, indexed by node ID
 	ifaceToNodeID map[string]string // mapping from MAC address to NodeID
 	config        *NodesConfig
+	pinger          *ping.Pinger
 	sync.RWMutex
 }

@ -27,6 +29,11 @@ func NewNodes(config *NodesConfig) *Nodes {
 		ifaceToNodeID: make(map[string]string),
 		config:        config,
 	}
+	p, err := ping.New("", "::")
+	if err != nil {
+		log.Warnf("ping bind failed: %s", err)
+	}
+	nodes.pinger = p

 	if config.StatePath != "" {
 		nodes.load()
@ -64,8 +71,8 @@ func (nodes *Nodes) Update(nodeID string, res *data.ResponseData) *Node {
 		}
 		nodes.List[nodeID] = node
 	}
-	if res.Nodeinfo != nil {
-		nodes.readIfaces(res.Nodeinfo)
+	if res.NodeInfo != nil {
+		nodes.readIfaces(res.NodeInfo)
 	}
 	nodes.Unlock()

@ -80,9 +87,10 @@ func (nodes *Nodes) Update(nodeID string, res *data.ResponseData) *Node {
 	// Update fields
 	node.Lastseen = now
 	node.Online = true
-	node.Neighbours = res.Neighbours
-	node.Nodeinfo = res.Nodeinfo
+	node.Nodeinfo = res.NodeInfo
 	node.Statistics = res.Statistics
+	node.Neighbours = res.Neighbours
+	node.NoRespondd = false

 	return node
 }
@ -170,19 +178,33 @@ func (nodes *Nodes) expire() {
 	nodes.Lock()
 	defer nodes.Unlock()

+	wg := sync.WaitGroup{}
+
 	for id, node := range nodes.List {
 		if node.Lastseen.Before(pruneAfter) {
 			// expire
 			delete(nodes.List, id)
 		} else if node.Lastseen.Before(offlineAfter) {
 			// set to offline
-			node.Online = false
+			wg.Add(1)
+			go func(node *Node) {
+				defer wg.Done()
+				if nodes.config.PingCount > 0 && nodes.ping(node) {
+					node.Online = true
+					node.NoRespondd = true
+				} else {
+					node.Online = false
+					node.NoRespondd = false
+				}
+			}(node)
 		}
 	}
+	wg.Wait()
+	log.WithField("nodes", "expire").Info("end")
 }

 // adds the nodes interface addresses to the internal map
-func (nodes *Nodes) readIfaces(nodeinfo *data.Nodeinfo) {
+func (nodes *Nodes) readIfaces(nodeinfo *data.NodeInfo) {
 	nodeID := nodeinfo.NodeID
 	network := nodeinfo.Network

@ -240,6 +262,7 @@ func (nodes *Nodes) save() {

 	// serialize nodes
 	SaveJSON(nodes, nodes.config.StatePath)
+	log.WithField("nodes", "save").Info("end")
 }

 // SaveJSON to path
--- a/runtime/nodes_config.go
+++ b/runtime/nodes_config.go
@ -7,5 +7,7 @@ type NodesConfig struct {
 	SaveInterval duration.Duration `toml:"save_interval"` // Save nodes periodically
 	OfflineAfter duration.Duration `toml:"offline_after"` // Set node to offline if not seen within this period
 	PruneAfter   duration.Duration `toml:"prune_after"`   // Remove nodes after n days of inactivity
+	PingCount    int               `toml:"ping_count"`    // send x pings to verify if node is offline (for disable count < 1)
+	PingTimeout  duration.Duration `toml:"ping_timeout"`  // timeout of sending ping to a node
 	Output       map[string]interface{}
 }
--- a/runtime/nodes_ping.go
+++ b/runtime/nodes_ping.go
@ -0,0 +1,39 @@
+package runtime
+
+import (
+	"net"
+
+	"github.com/bdlm/log"
+)
+
+func (nodes *Nodes) ping(node *Node) bool {
+	logNode := log.WithField("node_id", "unknown")
+	if node.Nodeinfo != nil {
+		logNode = logNode.WithField("node_id", node.Nodeinfo.NodeID)
+	}
+	var addr *net.IPAddr
+	if node.Address != nil {
+		addr = &net.IPAddr{IP:node.Address.IP, Zone: node.Address.Zone}
+	} else {
+		logNode.Debug("error no address found")
+		if node.Nodeinfo != nil {
+			for _, addrMaybeString := range node.Nodeinfo.Network.Addresses {
+				if len(addrMaybeString) >= 5 && addrMaybeString[:5] != "fe80:" {
+					addrMaybe, err := net.ResolveIPAddr("ip6", addrMaybeString)
+					if err == nil {
+						addr = addrMaybe
+					}
+				}
+			}
+		}
+	}
+
+	logAddr := logNode.WithField("addr", addr.String())
+
+	_, err := nodes.pinger.PingAttempts(addr, nodes.config.PingTimeout.Duration, nodes.config.PingCount)
+
+	logAddr.WithFields(map[string]interface{}{
+		"success": err == nil,
+	}).Debug("pong")
+	return err == nil
+}
--- a/runtime/nodes_ping_test.go
+++ b/runtime/nodes_ping_test.go
@ -0,0 +1,44 @@
+package runtime
+
+import (
+	"net"
+	"testing"
+	"time"
+
+	"github.com/bdlm/log"
+	"github.com/stretchr/testify/assert"
+
+	"github.com/FreifunkBremen/yanic/data"
+)
+
+func TestPing(t *testing.T) {
+	log.SetLevel(log.DebugLevel)
+
+	assert := assert.New(t)
+	config := &NodesConfig{
+		PingCount: 1,
+	}
+	config.OfflineAfter.Duration = time.Minute * 10
+	// to get default (100%) path of testing
+	// config.PruneAfter.Duration = time.Hour * 24 * 6
+	nodes := &Nodes{
+		config:        config,
+		List:          make(map[string]*Node),
+		ifaceToNodeID: make(map[string]string),
+	}
+
+	node := nodes.Update("expire", &data.ResponseData{NodeInfo: &data.NodeInfo{
+		NodeID:  "nodeID-Lola",
+		Network: data.Network{Addresses: []string{"fe80::1", "fd2f::1"}},
+	}})
+	// get fallback
+	assert.False(nodes.ping(node))
+
+	node.Address = &net.UDPAddr{Zone: "bat0"}
+	// error during ping
+	assert.False(nodes.ping(node))
+
+	node.Address.IP = net.ParseIP("fe80::1")
+	// error during ping
+	assert.False(nodes.ping(node))
+}
--- a/runtime/nodes_test.go
+++ b/runtime/nodes_test.go
@ -55,8 +55,8 @@ func TestLoadAndSave(t *testing.T) {
 	// not autoload without StatePath
 	NewNodes(config)

-	// Test unmarshalable
-	config.StatePath = "testdata/nodes-broken.json"
+	// Test unmarshalable /dev/null - autolead with StatePath
+	config.StatePath = "/dev/null"
 	nodes := NewNodes(config)
 	// Test unopen able
 	config.StatePath = "/root/nodes.json"
@ -71,8 +71,8 @@ func TestLoadAndSave(t *testing.T) {
 	os.Remove(tmpfile.Name())

 	assert.Panics(func() {
-		SaveJSON(nodes, "/proc/a")
-		// "open /proc/a.tmp: permission denied",
+		SaveJSON(nodes, "/dev/null")
+		// "open /dev/null.tmp: permission denied",
 	})

 	tmpfile, _ = ioutil.TempFile("/tmp", "nodes")
@ -102,7 +102,7 @@ func TestUpdateNodes(t *testing.T) {
 				&data.WirelessAirtime{},
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{},
+		NodeInfo: &data.NodeInfo{},
 	}
 	nodes.Update("abcdef012345", res)

@ -146,10 +146,10 @@ func TestAddNode(t *testing.T) {
 	nodes.AddNode(&Node{})
 	assert.Len(nodes.List, 0)

-	nodes.AddNode(&Node{Nodeinfo: &data.Nodeinfo{}})
+	nodes.AddNode(&Node{Nodeinfo: &data.NodeInfo{}})
 	assert.Len(nodes.List, 0)

-	nodes.AddNode(&Node{Nodeinfo: &data.Nodeinfo{NodeID: "blub"}})
+	nodes.AddNode(&Node{Nodeinfo: &data.NodeInfo{NodeID: "blub"}})
 	assert.Len(nodes.List, 1)
 }

@ -162,52 +162,18 @@ func TestLinksNodes(t *testing.T) {
 	}
 	assert.Len(nodes.List, 0)

-	nodes.Update("f4f26dd7a300", &data.ResponseData{
-		Nodeinfo: &data.Nodeinfo{
-			NodeID: "f4f26dd7a300",
-			Network: data.Network{
-				Mac: "f4:f2:6d:d7:a3:00",
-			},
-		},
-	})
 	nodes.Update("f4f26dd7a30a", &data.ResponseData{
-		Nodeinfo: &data.Nodeinfo{
+		NodeInfo: &data.NodeInfo{
 			NodeID: "f4f26dd7a30a",
 			Network: data.Network{
 				Mac: "f4:f2:6d:d7:a3:0a",
 			},
 		},
-		Neighbours: &data.Neighbours{
-			NodeID: "f4f26dd7a30a",
-			Babel: map[string]data.BabelNeighbours{
-				"vx_mesh_lan": {
-					LinkLocalAddress: "fe80::2",
-					Neighbours: map[string]data.BabelLink{
-						"fe80::1337": {
-							Cost: 26214,
-						},
-					},
-				},
-			},
-		},
 	})

 	nodes.Update("f4f26dd7a30b", &data.ResponseData{
-		Nodeinfo: &data.Nodeinfo{
+		NodeInfo: &data.NodeInfo{
 			NodeID: "f4f26dd7a30b",
-			Network: data.Network{
-				Mesh: map[string]*data.NetworkInterface{
-					"babel": {
-						Interfaces: struct {
-							Wireless []string `json:"wireless,omitempty"`
-							Other    []string `json:"other,omitempty"`
-							Tunnel   []string `json:"tunnel,omitempty"`
-						}{
-							Other: []string{"fe80::1337"},
-						},
-					},
-				},
-			},
 		},
 		Neighbours: &data.Neighbours{
 			NodeID: "f4f26dd7a30b",
@ -223,35 +189,21 @@ func TestLinksNodes(t *testing.T) {
 		},
 	})

-	// no neighbours nodeid
-	node := nodes.List["f4f26dd7a300"]
+	node := nodes.List["f4f26dd7a30a"]
 	assert.NotNil(node)
 	links := nodes.NodeLinks(node)
 	assert.Len(links, 0)

-	// babel link
-	node = nodes.List["f4f26dd7a30a"]
-	assert.NotNil(node)
-	links = nodes.NodeLinks(node)
-	assert.Len(links, 1)
-	link := links[0]
-	assert.Equal("f4f26dd7a30a", link.SourceID)
-	assert.Equal("fe80::2", link.SourceAddress)
-	assert.Equal("f4f26dd7a30b", link.TargetID)
-	assert.Equal("fe80::1337", link.TargetAddress)
-	assert.Equal(float32(0.6), link.TQ)
-
-	// batman link
 	node = nodes.List["f4f26dd7a30b"]
 	assert.NotNil(node)
 	links = nodes.NodeLinks(node)
 	assert.Len(links, 1)
-	link = links[0]
-	assert.Equal("f4f26dd7a30b", link.SourceID)
-	assert.Equal("f4:f2:6d:d7:a3:0b", link.SourceAddress)
-	assert.Equal("f4f26dd7a30a", link.TargetID)
-	assert.Equal("f4:f2:6d:d7:a3:0a", link.TargetAddress)
-	assert.Equal(float32(0.8), link.TQ)
+	link := links[0]
+	assert.Equal(link.SourceID, "f4f26dd7a30b")
+	assert.Equal(link.SourceAddress, "f4:f2:6d:d7:a3:0b")
+	assert.Equal(link.TargetID, "f4f26dd7a30a")
+	assert.Equal(link.TargetAddress, "f4:f2:6d:d7:a3:0a")
+	assert.Equal(link.TQ, float32(0.8))

 	nodeid := nodes.GetNodeIDbyAddress("f4:f2:6d:d7:a3:0a")
 	assert.Equal("f4f26dd7a30a", nodeid)
--- a/runtime/stats.go
+++ b/runtime/stats.go
@ -11,12 +11,13 @@ type CounterMap map[string]uint32

 // GlobalStats struct
 type GlobalStats struct {
-	Clients       uint32
-	ClientsWifi   uint32
-	ClientsWifi24 uint32
-	ClientsWifi5  uint32
-	Gateways      uint32
-	Nodes         uint32
+	Clients         uint32
+	ClientsWifi     uint32
+	ClientsWifi24   uint32
+	ClientsWifi5    uint32
+	Gateways        uint32
+	Nodes           uint32
+	NodesNoRespondd uint32

 	Firmwares   CounterMap
 	Models      CounterMap
@ -81,6 +82,9 @@ func (s *GlobalStats) Add(node *Node) {
 		s.ClientsWifi5 += stats.Clients.Wifi5
 		s.ClientsWifi += stats.Clients.Wifi
 	}
+	if node.NoRespondd {
+		s.NodesNoRespondd++
+	}
 	if node.IsGateway() {
 		s.Gateways++
 	}
--- a/runtime/stats_test.go
+++ b/runtime/stats_test.go
@ -22,6 +22,7 @@ func TestGlobalStats(t *testing.T) {
 	//check GLOBAL_SITE stats
 	assert.EqualValues(1, stats[GLOBAL_SITE][GLOBAL_DOMAIN].Gateways)
 	assert.EqualValues(3, stats[GLOBAL_SITE][GLOBAL_DOMAIN].Nodes)
+	assert.EqualValues(1, stats[GLOBAL_SITE][GLOBAL_DOMAIN].NodesNoRespondd)
 	assert.EqualValues(25, stats[GLOBAL_SITE][GLOBAL_DOMAIN].Clients)

 	// check models
@ -84,7 +85,7 @@ func createTestNodes() *Nodes {
 				Total: 23,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "abcdef012345",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -98,13 +99,14 @@ func createTestNodes() *Nodes {
 	nodes.AddNode(nodeData)

 	nodes.AddNode(&Node{
-		Online: true,
+		Online:     true,
+		NoRespondd: true,
 		Statistics: &data.Statistics{
 			Clients: data.Clients{
 				Total: 2,
 			},
 		},
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "112233445566",
 			Hardware: data.Hardware{
 				Model: "TP-Link 841",
@ -123,7 +125,7 @@ func createTestNodes() *Nodes {

 	nodes.AddNode(&Node{
 		Online: true,
-		Nodeinfo: &data.Nodeinfo{
+		Nodeinfo: &data.NodeInfo{
 			NodeID: "0xdeadbeef0x",
 			VPN:    true,
 			Hardware: data.Hardware{
--- a/runtime/testdata/nodes-broken.json
+++ b/runtime/testdata/nodes-broken.json
@ -1,4 +0,0 @@
-{
-	// make it invalid by this comment
-	"affe": 3
-}
Author	SHA1	Message	Date
Martin/Geno	9b6e9eb300	change lib	2019-01-20 02:12:47 +01:00
Martin/Geno	8b75fb1b04	add fallback for addresses	2019-01-20 01:00:50 +01:00
Martin/Geno	521af9429a	[TASK] add no-respondd	2019-01-19 21:37:27 +01:00