Version 1.0.0

DataAggregator.sln

@@ -17,8 +17,6 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Collector.Te
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Registration.Tests", "tests\DataAggregator.Registration.Tests\DataAggregator.Registration.Tests.csproj", "{FB0B4F80-5801-407F-8425-54069C93DB60}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Integration.Tests", "tests\DataAggregator.Integration.Tests\DataAggregator.Integration.Tests.csproj", "{12FEEB75-A03A-4389-980B-6B735C550CAC}"
-EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{02EA681E-C7D8-13C7-8484-4AC65E1B71E8}"
 	ProjectSection(SolutionItems) = preProject
 		.editorconfig = .editorconfig
@@ -36,44 +34,130 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Collector.Sh
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Collector.OpenCNCapnProtoConnector", "src\DataAggregator.Collector.OpenCNCapnProtoConnector\DataAggregator.Collector.OpenCNCapnProtoConnector.csproj", "{2C10378E-0937-40E3-940E-F236F6E8B95B}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Processor", "src\DataAggregator.Processor\DataAggregator.Processor.csproj", "{039EC00D-5EDF-4C48-B449-29CFB6750232}"
+EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "processor", "processor", "{EB9A5576-3E00-4007-8C72-2235E0A1546D}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DataAggregator.Processor.Tests", "tests\DataAggregator.Processor.Tests\DataAggregator.Processor.Tests.csproj", "{EFE47FE6-F41E-CDD6-0991-472080AD88B0}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
+		Debug|x64 = Debug|x64
+		Debug|x86 = Debug|x86
 		Release|Any CPU = Release|Any CPU
+		Release|x64 = Release|x64
+		Release|x86 = Release|x86
 	EndGlobalSection
 	GlobalSection(ProjectConfigurationPlatforms) = postSolution
 		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|x64.ActiveCfg = Debug|x64
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|x64.Build.0 = Debug|x64
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|x86.ActiveCfg = Debug|x86
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Debug|x86.Build.0 = Debug|x86
 		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|Any CPU.Build.0 = Release|Any CPU
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|x64.ActiveCfg = Release|x64
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|x64.Build.0 = Release|x64
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|x86.ActiveCfg = Release|x86
+		{4DA834BA-134A-4F58-B6FF-FF0820FB9FA9}.Release|x86.Build.0 = Release|x86
 		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|x64.ActiveCfg = Debug|x64
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|x64.Build.0 = Debug|x64
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|x86.ActiveCfg = Debug|x86
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Debug|x86.Build.0 = Debug|x86
 		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|Any CPU.Build.0 = Release|Any CPU
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|x64.ActiveCfg = Release|x64
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|x64.Build.0 = Release|x64
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|x86.ActiveCfg = Release|x86
+		{54E71A40-291A-4FEB-9E13-1545172AF9EE}.Release|x86.Build.0 = Release|x86
 		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|x64.ActiveCfg = Debug|x64
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|x64.Build.0 = Debug|x64
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|x86.ActiveCfg = Debug|x86
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Debug|x86.Build.0 = Debug|x86
 		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|Any CPU.Build.0 = Release|Any CPU
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|x64.ActiveCfg = Release|x64
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|x64.Build.0 = Release|x64
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|x86.ActiveCfg = Release|x86
+		{E593EA7B-F713-4444-AE40-FDCEF462660A}.Release|x86.Build.0 = Release|x86
 		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|x64.ActiveCfg = Debug|x64
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|x64.Build.0 = Debug|x64
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|x86.ActiveCfg = Debug|x86
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Debug|x86.Build.0 = Debug|x86
 		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|Any CPU.Build.0 = Release|Any CPU
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|x64.ActiveCfg = Release|x64
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|x64.Build.0 = Release|x64
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|x86.ActiveCfg = Release|x86
+		{63D70F2C-9C7D-4397-8150-37F343949530}.Release|x86.Build.0 = Release|x86
 		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|x64.ActiveCfg = Debug|x64
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|x64.Build.0 = Debug|x64
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|x86.ActiveCfg = Debug|x86
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Debug|x86.Build.0 = Debug|x86
 		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|Any CPU.Build.0 = Release|Any CPU
-		{12FEEB75-A03A-4389-980B-6B735C550CAC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{12FEEB75-A03A-4389-980B-6B735C550CAC}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{12FEEB75-A03A-4389-980B-6B735C550CAC}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{12FEEB75-A03A-4389-980B-6B735C550CAC}.Release|Any CPU.Build.0 = Release|Any CPU
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|x64.ActiveCfg = Release|x64
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|x64.Build.0 = Release|x64
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|x86.ActiveCfg = Release|x86
+		{FB0B4F80-5801-407F-8425-54069C93DB60}.Release|x86.Build.0 = Release|x86
 		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|x64.ActiveCfg = Debug|x64
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|x64.Build.0 = Debug|x64
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|x86.ActiveCfg = Debug|x86
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Debug|x86.Build.0 = Debug|x86
 		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|Any CPU.Build.0 = Release|Any CPU
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|x64.ActiveCfg = Release|x64
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|x64.Build.0 = Release|x64
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|x86.ActiveCfg = Release|x86
+		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182}.Release|x86.Build.0 = Release|x86
 		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
 		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|x64.ActiveCfg = Debug|x64
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|x64.Build.0 = Debug|x64
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|x86.ActiveCfg = Debug|x86
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Debug|x86.Build.0 = Debug|x86
 		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|x64.ActiveCfg = Release|x64
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|x64.Build.0 = Release|x64
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|x86.ActiveCfg = Release|x86
+		{2C10378E-0937-40E3-940E-F236F6E8B95B}.Release|x86.Build.0 = Release|x86
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|x64.ActiveCfg = Debug|x64
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|x64.Build.0 = Debug|x64
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|x86.ActiveCfg = Debug|x86
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Debug|x86.Build.0 = Debug|x86
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|Any CPU.Build.0 = Release|Any CPU
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|x64.ActiveCfg = Release|x64
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|x64.Build.0 = Release|x64
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|x86.ActiveCfg = Release|x86
+		{039EC00D-5EDF-4C48-B449-29CFB6750232}.Release|x86.Build.0 = Release|x86
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|x64.ActiveCfg = Debug|x64
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|x64.Build.0 = Debug|x64
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|x86.ActiveCfg = Debug|x86
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Debug|x86.Build.0 = Debug|x86
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|Any CPU.Build.0 = Release|Any CPU
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|x64.ActiveCfg = Release|x64
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|x64.Build.0 = Release|x64
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|x86.ActiveCfg = Release|x86
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0}.Release|x86.Build.0 = Release|x86
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -84,12 +168,14 @@ Global
 		{E593EA7B-F713-4444-AE40-FDCEF462660A} = {AA521B32-6E75-46BD-ABDF-0450227A94C4}
 		{63D70F2C-9C7D-4397-8150-37F343949530} = {247EF7A2-1DFD-4B51-AC7D-0FD13827CAC2}
 		{FB0B4F80-5801-407F-8425-54069C93DB60} = {247EF7A2-1DFD-4B51-AC7D-0FD13827CAC2}
-		{12FEEB75-A03A-4389-980B-6B735C550CAC} = {247EF7A2-1DFD-4B51-AC7D-0FD13827CAC2}
 		{95F8787D-6FE2-4173-8450-6762EA6FAE1F} = {E1AD9667-4C40-4CAF-8096-5FA749EBB2B1}
 		{AA521B32-6E75-46BD-ABDF-0450227A94C4} = {E1AD9667-4C40-4CAF-8096-5FA749EBB2B1}
 		{F5250AC4-9CCC-432B-8725-DAC6AE01CCF0} = {95F8787D-6FE2-4173-8450-6762EA6FAE1F}
 		{4A5708E5-B5D1-4DA4-A2E4-323D3A21B182} = {95F8787D-6FE2-4173-8450-6762EA6FAE1F}
 		{2C10378E-0937-40E3-940E-F236F6E8B95B} = {F5250AC4-9CCC-432B-8725-DAC6AE01CCF0}
+		{039EC00D-5EDF-4C48-B449-29CFB6750232} = {EB9A5576-3E00-4007-8C72-2235E0A1546D}
+		{EB9A5576-3E00-4007-8C72-2235E0A1546D} = {E1AD9667-4C40-4CAF-8096-5FA749EBB2B1}
+		{EFE47FE6-F41E-CDD6-0991-472080AD88B0} = {247EF7A2-1DFD-4B51-AC7D-0FD13827CAC2}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {9C8E6DBA-9F77-4FD0-9A1D-25150F7806FF}

docker/Dockerfile.Collector

@@ -0,0 +1,21 @@
+FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build
+WORKDIR /src
+
+COPY NuGet.config /NuGet.config
+COPY lib /lib
+
+COPY src/DataAggregator.Collector/*.csproj ./DataAggregator.Collector/
+COPY src/DataAggregator.Shared/*.csproj ./DataAggregator.Shared/
+COPY src/DataAggregator.Collector.OpenCNCapnProtoConnector/*.csproj ./DataAggregator.Collector.OpenCNCapnProtoConnector/
+
+RUN dotnet restore ./DataAggregator.Collector/DataAggregator.Collector.App.csproj --configfile /NuGet.config
+
+COPY src/ ./
+WORKDIR /src/DataAggregator.Collector
+RUN dotnet publish -c Release -o /app/publish --configfile /NuGet.config
+
+FROM mcr.microsoft.com/dotnet/aspnet:9.0
+RUN apt-get update && apt-get install -y curl && rm -rf /var/lib/apt/lists/*
+WORKDIR /app
+COPY --from=build /app/publish .
+ENTRYPOINT ["dotnet", "DataAggregator.Collector.App.dll"]

docker/Dockerfile.Processor

@@ -0,0 +1,17 @@
+FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build
+WORKDIR /src
+
+COPY src/DataAggregator.Processor/*.csproj ./DataAggregator.Processor/
+COPY src/DataAggregator.Shared/*.csproj ./DataAggregator.Shared/
+
+RUN dotnet restore ./DataAggregator.Processor/DataAggregator.Processor.csproj
+
+COPY src/ ./
+WORKDIR /src/DataAggregator.Processor
+RUN dotnet publish -c Release -o /app/publish
+
+FROM mcr.microsoft.com/dotnet/aspnet:9.0
+RUN apt-get update && apt-get install -y curl && rm -rf /var/lib/apt/lists/*
+WORKDIR /app
+COPY --from=build /app/publish .
+ENTRYPOINT ["dotnet", "DataAggregator.Processor.dll"]

docker/Dockerfile.Registration

@@ -0,0 +1,17 @@
+FROM mcr.microsoft.com/dotnet/sdk:9.0 AS build
+WORKDIR /src
+
+COPY src/DataAggregator.Registration/*.csproj ./DataAggregator.Registration/
+COPY src/DataAggregator.Shared/*.csproj ./DataAggregator.Shared/
+
+RUN dotnet restore ./DataAggregator.Registration/DataAggregator.Registration.csproj
+
+COPY src/ ./
+WORKDIR /src/DataAggregator.Registration
+RUN dotnet publish -c Release -o /app/publish
+
+FROM mcr.microsoft.com/dotnet/aspnet:9.0
+RUN apt-get update && apt-get install -y curl && rm -rf /var/lib/apt/lists/*
+WORKDIR /app
+COPY --from=build /app/publish .
+ENTRYPOINT ["dotnet", "DataAggregator.Registration.dll"]

env/docker-compose.yml

@@ -0,0 +1,54 @@
+services:
+        postgres:
+                image: postgres:15
+                environment:
+                        POSTGRES_DB: dataaggregator
+                        POSTGRES_USER: admin
+                        POSTGRES_PASSWORD: password123
+                ports:
+                        - "5432:5432"
+                volumes:
+                        - postgres_data:/var/lib/postgresql/data
+
+        influxdb:
+                image: influxdb:3-core
+                ports:
+                        - "8181:8181"
+                environment:
+                        INFLUXDB3_AUTH_TOKEN: YOUR-TOKEN
+                command:
+                        - influxdb3
+                        - serve
+                        - --node-id=node0
+                        - --object-store=file
+                        - --data-dir=/var/lib/influxdb3
+                volumes:
+                        - influx_data:/var/lib/influxdb3
+
+        influxdb-ui:
+                image: influxdata/influxdb3-ui:1.0.0
+                container_name: influxdb3-explorer
+                ports:
+                        - "8888:80"
+                environment:
+                        INFLUXDB_URL: http://influxdb:8181
+                command: [ "--mode=admin" ]
+                depends_on:
+                        - influxdb
+
+        grafana:
+                image: grafana/grafana:latest
+                container_name: grafana
+                ports:
+                        - "3001:3000"
+                environment:
+                        - GF_SECURITY_ADMIN_USER=admin
+                        - GF_SECURITY_ADMIN_PASSWORD=admin
+                volumes:
+                        - grafana_data:/var/lib/grafana
+                        - ./volumes/grafana/data:/data/
+
+volumes:
+        postgres_data:
+        influx_data:
+        grafana_data:

src/DataAggregator.Collector.OpenCNCapnProtoConnector/CapnProto/CapnProtoConfig.cs

@@ -14,9 +14,4 @@ public class CapnProtoConfig
     /// Gets or sets the server port.
     /// </summary>
     public int Port { get; set; } = 7001;
-
-    /// <summary>
-    /// Gets or sets the connection timeout in milliseconds.
-    /// </summary>
-    public int TimeoutMs { get; set; } = 5000;
 }

src/DataAggregator.Collector.Shared/Abstraction/CollectorService.cs

@@ -27,7 +27,7 @@ public class CollectorService(
 
     private readonly SemaphoreSlim _processingLock = new(1, 1);
     private readonly ConcurrentQueue<IMeasurementData> _dataQueue = new();
-    private readonly TimeSpan _flushInterval = TimeSpan.FromSeconds(1); // Flush every 1 second
+    private readonly TimeSpan _flushInterval = TimeSpan.FromMilliseconds(configuration.FlushIntervalMilliseconds); // Flush every 1 second
 
     private bool _isRunning;
     private CancellationTokenSource? _cancellationTokenSource;

src/DataAggregator.Collector.Shared/Abstraction/Configuration/CollectorConfiguration.cs

@@ -24,4 +24,9 @@ public class CollectorConfiguration
     /// Gets or sets the list of sensors configured for this collector.
     /// </summary>
     public List<SensorConfig> Sensors { get; set; } = [];
+
+    /// <summary>
+    /// Gets or sets the interval in milliseconds for flushing data to the time series database.
+    /// </summary>
+    public int FlushIntervalMilliseconds { get; set; } = 1000;
 }

src/DataAggregator.Collector.Shared/Abstraction/Configuration/SensorConfig.cs

@@ -25,7 +25,7 @@ public class SensorConfig
     /// <summary>
     /// Gets or sets the type of data this sensor produces.
     /// </summary>
-    public SensorDataType DataType { get; set; }
+    public SensorDataType DataType { get; set; } = SensorDataType.Undefined;
 
     /// <summary>
     /// Gets or sets additional metadata for the sensor.

src/DataAggregator.Collector.Shared/DataStorage/Influx/InfluxDbRepository.cs

@@ -79,8 +79,8 @@ private void InitializeClient()
         {
             Token = _config.Token,
             Host = _config.Endpoint,
-            Organization = "Dataggregator",
-            Database = "Dataggregator",
+            Organization = InfluxHelper.DatabaseName,
+            Database = InfluxHelper.DatabaseName,
         };
 
         _client = new InfluxDBClient(clientConfig);

src/DataAggregator.Collector.Shared/Models/IMeasurementData.cs

@@ -1,7 +1,5 @@
 namespace DataAggregator.Collector.Shared.Models;
 
-// TODO CJS -> Check if it's better to have a SensorConfig here and work with its datatype
-
 /// <summary>
 /// Interface for common measurement data operations regardless of the value type.
 /// </summary>