From c1e8badaecce4db7bc8b7d4784af0bb44ecd8a84 Mon Sep 17 00:00:00 2001
From: andig <cpuidle@gmx.de>
Date: Sun, 25 Apr 2021 09:46:13 +0200
Subject: [PATCH] InfluxDB: add vehicle tag (#889)

---
 server/influxdb.go | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/server/influxdb.go b/server/influxdb.go
index eb683e2f8..6e733708a 100644
--- a/server/influxdb.go
+++ b/server/influxdb.go
@@ -83,8 +83,19 @@ func (m *Influx) Run(loadPoints []core.LoadPointAPI, in <-chan util.Param) {
 		}
 	}()
 
+	// track active vehicle per loadpoint
+	vehicles := make(map[int]string)
+
 	// add points to batch for async writing
 	for param := range in {
+		// vehicle name
+		if param.LoadPoint != nil {
+			if name, ok := param.Val.(string); ok && param.Key == "socTitle" {
+				vehicles[*param.LoadPoint] = name
+				continue
+			}
+		}
+
 		if !m.supportedType(param) {
 			continue
 		}
@@ -92,6 +103,7 @@ func (m *Influx) Run(loadPoints []core.LoadPointAPI, in <-chan util.Param) {
 		tags := map[string]string{}
 		if param.LoadPoint != nil {
 			tags["loadpoint"] = loadPoints[*param.LoadPoint].Name()
+			tags["vehicle"] = vehicles[*param.LoadPoint]
 		}
 
 		fields := map[string]interface{}{}