fix(database/influxdb*): add type to link

FreifunkBremen · Jul 19, 2024 · 29bc461 · 29bc461
1 parent f854410
commit 29bc461
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/database/influxdb/link.go b/database/influxdb/link.go
@@ -14,6 +14,7 @@ func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) {
 	tags.SetString("source.addr", link.SourceAddress)
 	tags.SetString("target.id", link.TargetID)
 	tags.SetString("target.addr", link.TargetAddress)
+	tags.SetString("type", link.Type.String())
 	if link.SourceHostname != "" {
 		tags.SetString("source.hostname", link.SourceHostname)
 	}

diff --git a/database/influxdb/node_test.go b/database/influxdb/node_test.go
@@ -187,6 +187,7 @@ func TestToInflux(t *testing.T) {
 		"source.addr": "a-interface-mac",
 		"target.id":   "foobar",
 		"target.addr": "BAFF1E5",
+		"type":        "vpn",
 	}, tags)
 	assert.EqualValues(80, fields["tq"])
 

diff --git a/database/influxdb2/link.go b/database/influxdb2/link.go
@@ -19,7 +19,8 @@ func (conn *Connection) InsertLink(link *runtime.Link, t time.Time) {
 		AddTag("source.id", link.SourceID).
 		AddTag("source.addr", link.SourceAddress).
 		AddTag("target.id", link.TargetID).
-		AddTag("target.addr", link.TargetAddress)
+		AddTag("target.addr", link.TargetAddress).
+		AddTag("type", link.Type.String())
 	if link.SourceHostname != "" {
 		p.AddTag("source.hostname", link.SourceHostname)
 	}