Thykof/mod 1170 handle wrong response from a miner

.gitignore

@@ -200,6 +200,7 @@ bt_venv/
 ENV/
 env.bak/
 venv.bak/
+bt_venv
 
 # Spyder project settings
 .spyderproject

simulation/validator/forward.py

@@ -31,6 +31,7 @@
 from simulation.validator.miner_data_handler import MinerDataHandler
 from simulation.validator.moving_average import compute_weighted_averages
 from simulation.validator.price_data_provider import PriceDataProvider
+from simulation.validator.response_validation import validate_responses
 from simulation.validator.reward import get_rewards
 
 
@@ -249,7 +250,7 @@ async def _query_available_miners_and_save_responses(
 
     miner_predictions = {}
     for i, response in enumerate(responses):
-        if response is None or len(response) == 0:
+        if validate_responses(response, simulation_input) is False:
             continue
         miner_id = miner_uids[i]
         miner_predictions[miner_id] = response

simulation/validator/response_validation.py

@@ -0,0 +1,48 @@
+import json
+from datetime import datetime, timedelta
+
+
+from simulation.simulation_input import SimulationInput
+
+
+def validate_responses(response, simulation_input: SimulationInput) -> bool:
+    """
+    Validate responses from miners.
+
+    Return False if response is incorrect.
+    """
+    if response is None or len(response) == 0:
+        return False
+
+    # assuming `response` is in json
+    response = json.loads(response)
+
+    # check the number of paths
+    if len(response) != simulation_input.num_simulations:
+        return False
+
+    for path in response:
+        # check the number of time points
+        if (
+            len(path)
+            != simulation_input.time_length // simulation_input.time_increment
+        ):
+            return False
+
+        # check the start time
+        if path[0]["time"] != simulation_input.start_time:
+            return False
+
+        for i in range(1, len(path)):
+            # check the time increment
+            i_minus_one_time = datetime.fromisoformat(path[i - 1]["time"])
+            i_time = datetime.fromisoformat(path[i]["time"])
+            expected_delta = timedelta(seconds=simulation_input.time_increment)
+            if i_time - i_minus_one_time != expected_delta:
+                return False
+
+            # check the price format
+            if not isinstance(path[i]["price"], (int, float)):
+                return False
+
+    return True