diff --git a/.gitignore b/.gitignore
index 69042ac4b2422c415cbe2c4fe07f2e83f6ec8b8f..821802ec224dcd6d94ab039356cbd8c14d508b30 100644
--- a/.gitignore
+++ b/.gitignore
@@ -11,7 +11,6 @@ ids/deployment/config/certificates/key_nm.pem
/ids/contrib/node_modules
/ids/replay_csv/mosaikrtu/dvcd/__pycache__
ids/contrib/development_configs/certificates/*
-ids/replay_csv/data/*
/ids/contrib/development_configs/SST/certificates
ids/implementation/ids_lib/__pycache__/
ids/implementation/ids_lib/config/__pycache__/
diff --git a/README.md b/README.md
index b78c5f8bf8bc369d02589d0f1295d1a88ac1db2d..57d8a2f173c65122b85a01e7c837f93f988ab1f2 100644
--- a/README.md
+++ b/README.md
@@ -27,6 +27,8 @@ To start the replay of CSV data, call the following in this repository:
`python replayDEMKit.py`
+**demkit_adaptions**: Adaptions made to DEMKit for logging of the demostreet scenario; more information see below.
+
## Implemented requirements
| Requirement Name | Description | Scope |
@@ -37,4 +39,12 @@ To start the replay of CSV data, call the following in this repository:
| S4 | Only power generating devices can feed power into the grid. | house-level/local |
| S5 | Battery dis-/charge rate does not exceed safe operational limit. | house-level/local |
| S6 | Only registered houses (or power generators) are feeding into the grid. | neighbourhood level |
-| S7 | Operator defined threshold of current in neighborhood is met for all meters. | neighbourhood level |
\ No newline at end of file
+| S7 | Operator defined threshold of current in neighborhood is met for all meters. | neighbourhood level |
+
+## Adaptations of DEMKit
+
+To implement a compatible CSV logging system for the IDS input files, we made specific adaptations rather than forking the entire [DEMKit repository](https://github.com/utwente-energy/demkit). Below, we provide the modified files:
+
+- **`device.py`**: Adds a call to our custom logging function. Place this file in `demkit/components/dev`.
+- **`mdi.py`**: Implements the custom logging functionality, storing the necessary data as CSV files in the workspace folder. Place this file in `demkit/components/util`.
+- **`manualMDI.py`**: Generates different types of attack files based on the base files created during the simulation. Place this file in `demkit/components/util`.
diff --git a/demkit_adaptions/device.py b/demkit_adaptions/device.py
new file mode 100644
index 0000000000000000000000000000000000000000..c7b6aa7ea4cea2a9a0dbb388ec751498b9162606
--- /dev/null
+++ b/demkit_adaptions/device.py
@@ -0,0 +1,172 @@
+# Copyright 2023 University of Twente
+
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+
+# http://www.apache.org/licenses/LICENSE-2.0
+
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+
+from core.entity import Entity
+from demkit.components.util.mdi import *
+
+import threading
+
+class Device(Entity):
+ def __init__(self, name, host):
+ Entity.__init__(self, name, host)
+
+ self.timeOffset = 0
+
+ if self.host != None:
+ self.timeOffset = host.timeOffset
+
+ self.devtype = "device"
+ self.type = "devices"
+
+ #state
+ self.totalConsumption = 0.0
+ self.commodities = ['ELECTRICITY']
+
+ #bindings
+ self.controller = None
+ self.flowMeter = None
+
+ self.plan = {}
+ self.consumption = {}
+
+ self.maxAgePlan = 900 # Used to prune plannings that are too old to be accurate
+ self.maxFuturePlan = 7*24*3600 # Used to prune a planning that is in the distant future
+ # Control
+ self.smartOperation = True # Indicates whether the device is being actively controlled. Can be used to disable control for e.g. cyber attacks or demonstrator simulations
+ self.strictComfort = True
+
+ self.lockPlanning = threading.Lock()
+ self.lockState = threading.Lock()
+
+ # Persistence
+ self.watchlist = ["consumption", "plan"]
+
+ self.csvData = []
+
+ def setPlan(self, plan):
+ self.lockPlanning.acquire()
+
+ for c in self.commodities:
+ self.plan[c] = list(plan[c])
+
+ self.lockPlanning.release()
+
+ def prunePlan(self):
+ self.lockPlanning.acquire()
+
+ for c in self.commodities:
+ run = True
+ while run and c in self.plan:
+ if len(self.plan[c]) >= 1:
+ if self.plan[c][0][0] <= self.host.time()-self.zGet(self.controller, "timeBase") or self.plan[c][0][0] < self.host.time()-self.maxAgePlan:
+ self.plan[c].pop(0)
+ elif self.maxFuturePlan is not None and self.plan[c][-1][0] > self.host.time()+self.maxFuturePlan:
+ self.plan[c].pop(-1)
+ else:
+ run = False
+ else:
+ run = False
+
+ self.lockPlanning.release()
+
+ def requestTickets(self, time):
+ self.ticketCallback.clear()
+ self.registerTicket(self.host.staticTicketPreTickDevs, 'preTick', register=False) # preTick
+ self.registerTicket(self.host.staticTicketTickDevs, 'timeTick', register=False) # timeTick
+
+ def preTick(self, time, deltatime=0):
+ Entity.preTick(self, time)
+
+ def timeTick(self, time, deltatime=0):
+ Entity.timeTick(self, time)
+
+ def postTick(self, time, deltatime=0):
+ Entity.postTick(self, time)
+
+ def startup(self):
+ if self.host != None:
+ self.host.addDevice(self)
+ Entity.startup(self)
+
+ def shutdown(self):
+ Entity.shutdown(self)
+
+ def logStats(self, time):
+ Entity.logStats(self, time)
+
+ def addMeter(self, meter):
+ self.flowMeter = meter # Used to obtain e.g. voltage measurements of the node and use these in the device
+
+ def getVoltage(self):
+ voltage = complex(0.0, 0.0)
+ if self.flowMeter != None:
+ voltage = self.zCall(self.flowMeter, "getVoltage")
+
+ return voltage
+
+ def getFrequency(self):
+ frequency = 50.0
+ if self.flowMeter != None:
+ frequency = self.zCall(self.flowMeter, "getFrequency")
+
+ return frequency
+
+ def logValue(self, measurement, value, time=None, deltatime=None):
+# tags = {'devtype':self.devtype, 'name':self.name}
+# values = {measurement:value}
+# self.host.logValue(self.type, tags, values, time)
+ interval = self.host.currentTime - self.host.startTime
+
+ #Modulo 15 used to output one data point every 15 simulated minutes
+ if interval % 15 == 0:
+ self.csvData.append([interval, self.devtype, measurement, str(value)])
+ data = self.type+",devtype="+self.devtype+",name="+self.name+" "+measurement+"="+str(value)
+ self.host.logValuePrepared(data, time, deltatime)
+
+ def logCsv(self):
+ storeMeterData(self.name, self.csvData)
+
+ def requestPlanning(self):
+ self.zCast(self.controller, "requestPlanning")
+
+ def triggerEvent(self, event):
+ if self.controller is not None:
+ self.zCast(self.controller, "triggerEvent", event)
+
+ def unPowered(self, commodity):
+ for c in self.commodities:
+ for c in self.commodities:
+ self.consumption[c] = complex(0.0, 0.0)
+
+ def getProperties(self):
+ # Get the properties of this device
+ self.lockState.acquire()
+
+ r = {}
+
+ # Populate the result dict
+ r['name'] = self.name
+ r['timeBase'] = self.timeBase
+ r['timeOffset'] = self.timeOffset
+ r['devtype'] = self.devtype
+
+ r['commodities'] = self.commodities
+ r['strictComfort'] = self.strictComfort
+
+ r['consumption'] = self.consumption
+
+ self.lockState.release()
+
+ return r
\ No newline at end of file
diff --git a/demkit_adaptions/manualMDI.py b/demkit_adaptions/manualMDI.py
new file mode 100644
index 0000000000000000000000000000000000000000..e38e3b14c1ecf5041b1fed902f6c0ca3434a13ad
--- /dev/null
+++ b/demkit_adaptions/manualMDI.py
@@ -0,0 +1,221 @@
+import csv
+import shutil
+
+path = "C:/Users/intruq/Desktop/Bachelorarbeit/DEMKit/workspace/example/data/"
+
+def makeCSVs():
+ joinCsv("CSV-House-1", ["SmartMeter-House-1", "Load-House-1", "WashingMachine-House-1", "Dishwasher-House-1", "ElectricVehicle-House-1", "Heatpump-House-1", "DomesticHotWaterControllerBoiler-House-1", "PV-House-1"])
+ joinCsv("CSV-House-4", ["SmartMeter-House-4", "Load-House-4", "WashingMachine-House-4", "ElectricVehicle-House-4"])
+ joinCsv("CSV-House-8", ["SmartMeter-House-8", "Load-House-8", "WashingMachine-House-8", "Dishwasher-House-8", "Battery-House-8", "Heatpump-House-8", "DomesticHotWaterControllerBoiler-House-8", "PV-House-8"])
+
+ shortenCSV("CSV-House-1")
+ shortenCSV("CSV-House-4")
+ shortenCSV("CSV-House-8")
+ feeder("")
+
+ att_scenario_1()
+ att_scenario_2()
+ att_scenario_3()
+ att_scenario_4()
+
+def att_scenario_1():
+ shutil.copy(path + "CSV-House-1-short.csv", path + "att_scenario_1/CSV-House-1.csv")
+ shutil.copy(path + "CSV-House-4-short.csv", path + "att_scenario_1/CSV-House-4.csv")
+ shutil.copy(path + "CSV-House-8-short.csv", path + "att_scenario_1/CSV-House-8.csv")
+ feeder("att_scenario_1/")
+
+def att_scenario_2():
+ as1_var_1()
+ as1_var_2()
+ as1_var_3()
+
+def att_scenario_3():
+ data1, data2 = readCsv("CSV-House-1-short"), readCsv("CSV-House-8-short")
+ for i in range(1, len(data1)):
+ if(i % 2 == 1):
+ data1[i][1] = float(data1[i][1]) - float(data1[i][4])
+ data2[i][1] = float(data2[i][1]) - float(data2[i][4])
+ data1[i][4] = 0
+ data2[i][4] = 0
+ else:
+ data1[i][4] = -11999
+ data2[i][4] = -11999
+ data1[i][1] = float(data1[i][1]) - 11999
+ data2[i][1] = float(data2[i][1]) - 11999
+ writeCsv("att_scenario_3/CSV-House-1", data1)
+ writeCsv("att_scenario_3/CSV-House-8", data2)
+ shutil.copy(path + "CSV-House-4-short.csv", path + "att_scenario_3/CSV-House-4.csv")
+ feeder("att_scenario_3/")
+
+def att_scenario_4():
+ data1 = readCsv("CSV-House-4-short")
+ for i in range(1, len(data1)):
+ data1[i][1] = float(data1[i][1]) + 1000
+ data1[i][3] = float(data1[i][3]) + 1000
+ writeCsv("att_scenario_4/CSV-House-4", data1)
+ shutil.copy(path + "CSV-House-1-short.csv", path + "att_scenario_4/CSV-House-1.csv")
+ shutil.copy(path + "CSV-House-8-short.csv", path + "att_scenario_4/CSV-House-8.csv")
+ shutil.copy(path + "att_scenario_1/CSV-Feeder.csv", path + "att_scenario_4/CSV-Feeder.csv")
+
+def as1_var_1():
+ data = readCsv("CSV-House-8-short")
+ for i in range(1, len(data)):
+ data[i][5] = 13000 # Max capacity of power line: 12000W
+ data[i][6] = 4000 # Max capacity of Medium ALPG battery: 4000Wh
+ writeCsv("att_scenario_2/var1/CSV-House-8", data)
+ shutil.copy(path + "CSV-House-1-short.csv", path + "att_scenario_2/var1/CSV-House-1.csv")
+ shutil.copy(path + "CSV-House-4-short.csv", path + "att_scenario_2/var1/CSV-House-4.csv")
+ feeder("att_scenario_2/var1/")
+
+def as1_var_2():
+ data = readCsv("CSV-House-8-short")
+ for i in range(1, len(data)):
+ if(i % 2 == 1):
+ data[i][6] = 5000 # Max capacity of Medium ALPG battery: 4000Wh
+ else:
+ data[i][6] = -1
+ writeCsv("att_scenario_2/var2/CSV-House-8", data)
+ shutil.copy(path + "CSV-House-1-short.csv", path + "att_scenario_2/var2/CSV-House-1.csv")
+ shutil.copy(path + "CSV-House-4-short.csv", path + "att_scenario_2/var2/CSV-House-4.csv")
+ feeder("att_scenario_2/var2/")
+
+def as1_var_3():
+ data = readCsv("CSV-House-8-short")
+ for i in range(1, len(data)):
+ data[i][5] = (-1) * float(data[i][5])
+ writeCsv("att_scenario_2/var3/CSV-House-8", data)
+ shutil.copy(path + "CSV-House-1-short.csv", path + "att_scenario_2/var3/CSV-House-1.csv")
+ shutil.copy(path + "CSV-House-4-short.csv", path + "att_scenario_2/var3/CSV-House-4.csv")
+ feeder("att_scenario_2/var3/")
+
+# Function collecting SmartMeter data and adding values to get combined input/output of all houses
+def feeder(folder: str):
+ data, sourceData = [["time", "W-power.real.c.ELECTRICITY"]], []
+ for m in ["CSV-House-1", "CSV-House-4", "CSV-House-8"]:
+ sourceData.append(readCsv(folder + m))
+ try:
+ maxTime = int(sourceData[0][-1][0])
+ except IndexError:
+ maxTime = 0
+ if maxTime > 0:
+ for i in range(1, (maxTime // 60) - 1):
+ time = sourceData[0][i][0]
+ sum_meters = 0
+ for j in range(3):
+ sum_meters += float(sourceData[j][i][1])
+ data.append([time, sum_meters])
+ writeCsv(folder + "CSV-Feeder", data)
+
+# Removes all columns not needed in the IDS for clarity
+def shortenCSV(source: str):
+ sourceData = readCsv(source)
+ headerIndices = [0]
+ columnCount = len(sourceData[0])
+
+ for i in range(columnCount):
+ header = sourceData[0][i]
+ if ("power.real.c.ELECTRICITY" in header) or ("energy.soc" in header):
+ headerIndices.append(i)
+
+ output = [[val for j, val in enumerate(row) if j in headerIndices] for row in sourceData]
+ writeCsv("att_scenario_1/" + source + "-short", output)
+
+# Joins CSVs from the fileNameList
+def joinCsv(fileName, fileNameList: list):
+ joinedData, sourceData, columnDepth, header = [], [], [], ["time"]
+
+ #Load all needed CSVs into one list
+ for source in fileNameList:
+ sourceData.append(readCsv(source))
+
+ columnDepth = calcListColumnDepth(sourceData)
+
+ maxTime = 0
+ for i in range(len(sourceData)):
+ try:
+ value = sourceData[i][-1][0]
+ except IndexError:
+ value = 0
+ if maxTime < int(value):
+ maxTime = int(value)
+
+ if maxTime > 0:
+ # Create header
+ for i in range(len(fileNameList)):
+ for j in range(1, columnDepth[i]):
+ header.append(fileNameList[i] + ": " + sourceData[i][0][j])
+ joinedData.append(header)
+
+ #Extracts data from CSVs row by row and adds them to output file
+ for i in range(1, (maxTime // 60) - 1):
+ #reinitialize row
+ time = sourceData[0][i][0]
+ row = [time]
+ for j in range(len(sourceData)):
+ try:
+ for k in range(1, columnDepth[j]):
+ row.append(sourceData[j][i][k])
+ except IndexError:
+ row.append(0)
+ joinedData.append(row)
+
+ writeCsv(fileName, joinedData)
+
+#Calculates how many measurements each input-CSV contains
+def calcListColumnDepth(data: list):
+ output = []
+
+ for i in range(len(data)):
+ try:
+ output.insert(i, len(data[i][0]))
+ except IndexError:
+ output.insert(i, 0)
+ return output
+
+# Input: CSV, Output: List
+def readCsv(fileName):
+ data = []
+
+ if not fileName.endswith('.csv'):
+ fileName += '.csv'
+
+ # Reading data from a CSV file
+ with open(path + fileName, mode='r', newline='') as file:
+ reader = csv.reader(file, delimiter=';')
+ for row in reader:
+ data.append(row)
+
+ return data
+
+# Input: List, Output: CSV
+def writeCsv(fileName, data: list):
+ if not fileName.endswith('.csv'):
+ fileName += '.csv'
+
+ # Writing data to a CSV file
+ with open(path + fileName, mode='w', newline='') as file:
+ writer = csv.writer(file, delimiter=';')
+ writer.writerows(data)
+
+def devLogCsv(fileName, data: list):
+ if len(data) > 0:
+ measurementCount = int(len(data) / 10080) #10080 is number of entries for one measurement type
+
+ dataSorted, header = [], []
+
+ #Header
+ header.append("time")
+ for i in range(measurementCount):
+ header.append(data[i][2])
+ dataSorted.append(header)
+
+ #Values
+ for i in range(10079):
+ row = [data[i * measurementCount][0]]
+ for j in range(measurementCount):
+ row.append(data[(i * measurementCount) + j][3])
+ dataSorted.append(row)
+
+ writeCsv(fileName, dataSorted)
+
+makeCSVs()
\ No newline at end of file
diff --git a/demkit_adaptions/mdi.py b/demkit_adaptions/mdi.py
new file mode 100644
index 0000000000000000000000000000000000000000..241d3f20e44d7fc300dcd3fd87addabeeb1bd7ee
--- /dev/null
+++ b/demkit_adaptions/mdi.py
@@ -0,0 +1,31 @@
+import csv
+
+def writeCsv(fileName, data: list):
+ if not fileName.endswith('.csv'):
+ fileName += '.csv'
+
+ # Writing data to a CSV file
+ with open("./data/" + fileName, mode='w', newline='') as file:
+ writer = csv.writer(file, delimiter=';')
+ writer.writerows(data)
+
+def storeMeterData(fileName, data: list):
+ if len(data) > 0:
+ measurementCount = int(len(data) / 10080) #10080 is number of entries for one measurement type
+
+ dataSorted, header = [], []
+
+ #Header
+ header.append("time")
+ for i in range(measurementCount):
+ header.append(data[i][2])
+ dataSorted.append(header)
+
+ #Values
+ for i in range(10079):
+ row = [data[i * measurementCount][0]]
+ for j in range(measurementCount):
+ row.append(data[(i * measurementCount) + j][3])
+ dataSorted.append(row)
+
+ writeCsv(fileName, dataSorted)
\ No newline at end of file
diff --git a/ids/replay_csv/data/Feeder.xml b/ids/replay_csv/data/Feeder.xml
new file mode 100644
index 0000000000000000000000000000000000000000..8721206c33c181834cd860763e17fe7fb3fbd083
--- /dev/null
+++ b/ids/replay_csv/data/Feeder.xml
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
+<DVCD label="Feeder">
+ <ip>0.0.0.0</ip>
+ <port>10504</port>
+ <identity>
+ <vendor name="UTwente 0" url="https://www.utwente.nl" />
+ <product name="PoorSecuritySubstation" code="PSS" model="PSS 1.0" />
+ <version major="0" minor="5" />
+ </identity>
+ <!-- Sensors -->
+ <reg type="hr" index="0" label="time" dt="64bit_float">0</reg><!-- Feeder: time -->
+ <reg type="hr" index="4" label="sensor_34" dt="64bit_float">0</reg><!-- Feeder: W-power.real.c.ELECTRICITY -->
+ <!-- Max Sensors -->
+ <reg type="hr" index="8" label="max_time" dt="64bit_float">0</reg>
+ <reg type="hr" index="12" label="max_c_34" dt="64bit_float">0</reg>
+ <code>mosaikrtu/conf/rtu_logic_good.py</code>
+</DVCD>
\ No newline at end of file
diff --git a/ids/replay_csv/data/House-1.xml b/ids/replay_csv/data/House-1.xml
new file mode 100644
index 0000000000000000000000000000000000000000..83d88a29631d2b17fe8601824753d68b2631a6bc
--- /dev/null
+++ b/ids/replay_csv/data/House-1.xml
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
+<DVCD label="House-1">
+ <ip>0.0.0.0</ip>
+ <port>10501</port>
+ <identity>
+ <vendor name="UTwente 0" url="https://www.utwente.nl" />
+ <product name="PoorSecuritySubstation" code="PSS" model="PSS 1.0" />
+ <version major="0" minor="5" />
+ </identity>
+ <!-- Sensors -->
+ <reg type="hr" index="0" label="time" dt="64bit_float">0</reg><!-- time -->
+ <reg type="hr" index="4" label="sensor_21" dt="64bit_float">0</reg><!-- SmartMeter-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="8" label="sensor_22" dt="64bit_float">0</reg><!-- Load-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="12" label="sensor_23" dt="64bit_float">0</reg><!-- WashingMachine-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="16" label="sensor_24" dt="64bit_float">0</reg><!-- Dishwasher-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="20" label="sensor_27" dt="64bit_float">0</reg><!-- ElectricVehicle-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="24" label="sensor_28" dt="64bit_float">0</reg><!-- ElectricVehicle-House-1: Wh-energy.soc -->
+ <reg type="hr" index="28" label="sensor_29" dt="64bit_float">0</reg><!-- Heatpump-House-1: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="32" label="sensor_30" dt="64bit_float">0</reg><!-- Heatpump-House-1: Wh-energy.soc -->
+ <reg type="hr" index="36" label="sensor_31" dt="64bit_float">0</reg><!-- DomesticHotWaterControllerBoiler-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="40" label="sensor_32" dt="64bit_float">0</reg><!-- DomesticHotWaterControllerBoiler-House-8: Wh-energy.soc -->
+ <reg type="hr" index="44" label="sensor_33" dt="64bit_float">0</reg><!-- PV-House-1: W-power.real.c.ELECTRICITY -->
+ <!-- Max Sensors -->
+ <reg type="hr" index="48" label="max_c_22" dt="64bit_float">0</reg>
+ <reg type="hr" index="52" label="max_c_23" dt="64bit_float">0</reg>
+ <reg type="hr" index="56" label="max_c_24" dt="64bit_float">0</reg>
+ <reg type="hr" index="60" label="max_c_27" dt="64bit_float">0</reg>
+ <reg type="hr" index="64" label="max_c_28" dt="64bit_float">0</reg>
+ <reg type="hr" index="68" label="max_c_29" dt="64bit_float">0</reg>
+ <reg type="hr" index="72" label="max_c_30" dt="64bit_float">0</reg>
+ <reg type="hr" index="76" label="max_c_31" dt="64bit_float">0</reg>
+ <reg type="hr" index="80" label="max_c_32" dt="64bit_float">0</reg>
+ <reg type="hr" index="84" label="max_c_33" dt="64bit_float">0</reg>
+ <reg type="hr" index="88" label="max_c_32" dt="64bit_float">0</reg>
+ <reg type="hr" index="92" label="max_c_33" dt="64bit_float">0</reg>
+ <code>mosaikrtu/conf/rtu_logic_good.py</code>
+</DVCD>
\ No newline at end of file
diff --git a/ids/replay_csv/data/House-4.xml b/ids/replay_csv/data/House-4.xml
new file mode 100644
index 0000000000000000000000000000000000000000..5a2f4d054181421ec58a57a5a6926323e9502976
--- /dev/null
+++ b/ids/replay_csv/data/House-4.xml
@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
+<DVCD label="House-4">
+ <ip>0.0.0.0</ip>
+ <port>10502</port>
+ <identity>
+ <vendor name="UTwente 0" url="https://www.utwente.nl" />
+ <product name="PoorSecuritySubstation" code="PSS" model="PSS 1.0" />
+ <version major="0" minor="5" />
+ </identity>
+ <!-- Sensors -->
+ <reg type="hr" index="0" label="time" dt="64bit_float">0</reg><!-- time -->
+ <reg type="hr" index="4" label="sensor_21" dt="64bit_float">0</reg><!-- SmartMeter-House-4: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="8" label="sensor_22" dt="64bit_float">0</reg><!-- Load-House-4: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="12" label="sensor_23" dt="64bit_float">0</reg><!-- WashingMachine-House-4: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="16" label="sensor_27" dt="64bit_float">0</reg><!-- ElectricVehicle-House-4: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="20" label="sensor_28" dt="64bit_float">0</reg><!-- ElectricVehicle-House-4: Wh-energy.soc -->
+ <!-- Max Sensors -->
+ <reg type="hr" index="24" label="max_c_22" dt="64bit_float">0</reg>
+ <reg type="hr" index="28" label="max_c_23" dt="64bit_float">0</reg>
+ <reg type="hr" index="32" label="max_c_27" dt="64bit_float">0</reg>
+ <reg type="hr" index="36" label="max_c_28" dt="64bit_float">0</reg>
+ <reg type="hr" index="40" label="max_c_28" dt="64bit_float">0</reg>
+ <reg type="hr" index="44" label="max_c_28" dt="64bit_float">0</reg>
+ <code>mosaikrtu/conf/rtu_logic_good.py</code>
+</DVCD>
\ No newline at end of file
diff --git a/ids/replay_csv/data/House-8.xml b/ids/replay_csv/data/House-8.xml
new file mode 100644
index 0000000000000000000000000000000000000000..319d2789c16c0927648d14912ff5935b05a3cfa5
--- /dev/null
+++ b/ids/replay_csv/data/House-8.xml
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no" ?>
+<DVCD label="House-8">
+ <ip>0.0.0.0</ip>
+ <port>10503</port>
+ <identity>
+ <vendor name="UTwente 0" url="https://www.utwente.nl" />
+ <product name="PoorSecuritySubstation" code="PSS" model="PSS 1.0" />
+ <version major="0" minor="5" />
+ </identity>
+ <!-- Sensors -->
+ <reg type="hr" index="0" label="time" dt="64bit_float">0</reg><!-- time -->
+ <reg type="hr" index="4" label="sensor_21" dt="64bit_float">0</reg><!-- SmartMeter-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="8" label="sensor_22" dt="64bit_float">0</reg><!-- Load-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="12" label="sensor_23" dt="64bit_float">0</reg><!-- WashingMachine-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="16" label="sensor_24" dt="64bit_float">0</reg><!-- Dishwasher-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="20" label="sensor_25" dt="64bit_float">0</reg><!-- Battery-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="24" label="sensor_26" dt="64bit_float">0</reg><!-- Battery-House-8: Wh-energy.soc -->
+ <reg type="hr" index="28" label="sensor_29" dt="64bit_float">0</reg><!-- Heatpump-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="32" label="sensor_30" dt="64bit_float">0</reg><!-- Heatpump-House-8: Wh-energy.soc -->
+ <reg type="hr" index="36" label="sensor_31" dt="64bit_float">0</reg><!-- DomesticHotWaterControllerBoiler-House-8: W-power.real.c.ELECTRICITY -->
+ <reg type="hr" index="40" label="sensor_32" dt="64bit_float">0</reg><!-- DomesticHotWaterControllerBoiler-House-8: Wh-energy.soc -->
+ <reg type="hr" index="44" label="sensor_33" dt="64bit_float">0</reg><!-- PV-House-8: W-power.real.c.ELECTRICITY -->
+ <!-- Max Sensors -->
+ <reg type="hr" index="48" label="max_c_22" dt="64bit_float">0</reg>
+ <reg type="hr" index="52" label="max_c_23" dt="64bit_float">0</reg>
+ <reg type="hr" index="56" label="max_c_24" dt="64bit_float">0</reg>
+ <reg type="hr" index="60" label="max_c_25" dt="64bit_float">0</reg>
+ <reg type="hr" index="64" label="max_c_26" dt="64bit_float">0</reg>
+ <reg type="hr" index="68" label="max_c_29" dt="64bit_float">0</reg>
+ <reg type="hr" index="72" label="max_c_30" dt="64bit_float">0</reg>
+ <reg type="hr" index="76" label="max_c_31" dt="64bit_float">0</reg>
+ <reg type="hr" index="80" label="max_c_32" dt="64bit_float">0</reg>
+ <reg type="hr" index="84" label="max_c_33" dt="64bit_float">0</reg>
+ <reg type="hr" index="88" label="max_c_21" dt="64bit_float">0</reg>
+ <reg type="hr" index="92" label="max_c_21" dt="64bit_float">0</reg>
+ <code>mosaikrtu/conf/rtu_logic_good.py</code>
+</DVCD>