refactor: add lux

Author: CumpsD

docker-compose.yml

@@ -9,7 +9,7 @@ services:
       Features__SendToInflux: 'true'
       KnxSender__Endpoint: http://functional-living-knx-sender:9001
       InfluxDb__Endpoint: http://functional-living-influx:9999
-      InfluxDb_Token: ODWCQ0YnLUPb9Gw321z5ONnzoBSHpthbsdve3QLAxbPGl5ytcK0gMK9XjiAnmy5c7Iq0nIF3YDNyqTL0hVrn2A==
+      InfluxDb__Token: JBU-kgjsFW2q9lKmklFgHaVSHs8kp1nff6iMUxg_Xuj-KeuuY2Dc2LFDfJ5HDDvbvWqQeSEeb5c62Flr9X6QVA==
       InfluxDb__Bucket: functional-living
       InfluxDb__Organisation: cumps
       InfluxDb__LogLevel: None
@@ -95,6 +95,7 @@ services:
 
 volumes:
   influxdb:
+    name: functional-living-influx
 
 # docker exec -it influxdb /bin/bash
 # influx setup

src/FunctionalLiving/Knx/KnxCommandHandlerModule.cs

@@ -109,10 +109,13 @@ public KnxCommandHandlerModule(
                             value);
 
                         if (sendToInflux.FeatureEnabled)
-                            WriteTemperature(
+                            Write(
                                 influxWrite,
-                                description,
-                                functionalTemp);
+                                new Temperature
+                                {
+                                    Location = description,
+                                    Value = functionalTemp
+                                });
                     }
                     else if (LightStrength.TryGetValue(groupAddress, out description))
                     {
@@ -125,6 +128,15 @@ public KnxCommandHandlerModule(
                             "LUX",
                             description,
                             value);
+
+                        if (sendToInflux.FeatureEnabled)
+                            Write(
+                                influxWrite,
+                                new Lux
+                                {
+                                    Location = description,
+                                    Value = functionalLightStrength
+                                });
                     }
                     else if (Times.TryGetValue(groupAddress, out description))
                     {
@@ -201,23 +213,15 @@ private static void Log(
                 value);
         }
 
-        private static void WriteTemperature(
+        private static void Write<T>(
             Func<WriteApi> writeApi,
-            string location,
-            double value)
+            T measurement)
         {
-            var temperature = new Temperature
-            {
-                Location = location,
-                Value = value,
-                Time = DateTime.UtcNow
-            };
-
             using (var writeClient = writeApi())
             {
                 writeClient.WriteMeasurement(
                     WritePrecision.Ns,
-                    temperature);
+                    measurement);
 
                 writeClient.Flush();
             }

src/FunctionalLiving/Measurements/Lux.cs

@@ -0,0 +1,18 @@
+namespace FunctionalLiving.Measurements
+{
+    using System;
+    using InfluxDB.Client.Core;
+
+    [Measurement("lux")]
+    public class Lux
+    {
+        [Column("location", IsTag = true)]
+        public string Location { get; set; }
+
+        [Column("value")]
+        public double Value { get; set; }
+
+        [Column(IsTimestamp = true)]
+        public DateTime Time { get; set; } = DateTime.UtcNow;
+    }
+}

src/FunctionalLiving/Measurements/Temperature.cs

@@ -13,6 +13,6 @@ public class Temperature
         public double Value { get; set; }
 
         [Column(IsTimestamp = true)]
-        public DateTime Time;
+        public DateTime Time { get; set; } = DateTime.UtcNow;
     }
 }