Control: Add timer to update the default values

Co-authored-by: Lea Weiss <[email protected]>

Author: MiryamBenHaim

control/include/input.h

@@ -19,10 +19,12 @@ class Input {
     static void s_buildSensors(std::unordered_map<int, Sensor *> &sensors);
     // Function that builds the conditions according to the bson file
     static void s_buildConditions();
+    // Function to set the path to the BSON file - for using specific path for the tests
+    static void s_setPathBson();
 
 private:
     // Function that read the bson file
-    static bson_t *s_readData();
+    static bson_t *s_readData(string fileName);
     // Member that contains the bson file data
     static bson_t *document;
 };

control/include/sensor.h

@@ -6,7 +6,10 @@
 #include <map>
 #include <unordered_map>
 #include <set>
-#include <optional>
+#include <thread>
+#include <chrono>
+#include <atomic>
+#include <mutex>
 #include "operator_types.h"
 #include "global_properties.h"
 
@@ -21,6 +24,12 @@ class Sensor {
     PacketParser *parser;
     std::map<std::string, Field> fieldsMap;
 
+    // Variables for the timer functions
+    int timeForUpdate;
+    std::atomic<int> timerCounter; // Flag to indicate the remaining time in seconds
+    std::mutex mtx;
+    std::thread timerThread;
+
     // Contains the current values of various fields and a list of basic conditions associated with each field
     std::map<std::string, std::pair<FieldValue, std::vector<BasicCondition *>>> fields;
 
@@ -35,6 +44,13 @@ class Sensor {
 private:
     template <typename T>
     bool applyComparison(T a, T b, OperatorTypes op);
+
+    // Function that running until the timeout is reached and activate the update.
+    void delayedFunction();
+    // Function that activate or reset the timer
+    void startOrResetTimer();
+    // Function that update the fields to be the default values
+    void updateDefualtValues();
 };
 
 #endif  // _SENSOR_H_

control/src/input.cpp

@@ -193,10 +193,16 @@ void Input::s_buildConditions()
     GlobalProperties::controlLogger.logMessage(logger::LogLevel::INFO, "Conditions built successfully");
 }
 
+// Function to set the path to the BSON file - for using specific path for the tests.
+void Input::s_setPathBson()
+{ 
+    // Load the bson file into document
+    document = s_readData("../test/conditions.bson");
+}
+
 // Function that read the bson file
-bson_t *Input::s_readData()
+bson_t *Input::s_readData(string fileName)
 {
-    string fileName = "../conditions.bson";
     ifstream file(fileName, ios::binary);
     if (file.is_open()) {
         // Get the file size
@@ -234,4 +240,4 @@ bson_t *Input::s_readData()
 }
 
 // Load the bson file into document
-bson_t *Input::document = s_readData();
+bson_t *Input::document = s_readData("../conditions.bson");

control/src/operator_node.cpp

@@ -9,8 +9,6 @@ void OperatorNode::updateTree()
     // Update the status of the current node
     this->updateStatus();
 
-    // TODO: Check what would happen if the root was true and we got to it with true
-
     // Check if the status changed
     if (prevStatus != this->status) {
         // Go over all the parents and update them

control/src/sensor.cpp

@@ -1,11 +1,56 @@
 #include "sensor.h"
 using namespace std;
 
+// Function that running until the timeout is reached and activate the update.
+void Sensor::delayedFunction()
+{
+    while (timerCounter > 0) {
+        this_thread::sleep_for(chrono::milliseconds(1000)); // Sleep for 1 second
+        timerCounter.fetch_sub(1); // Atomically decrement the timer
+        cout << "Time left: " << timerCounter.load() << " seconds" << endl;
+    }
+    updateDefualtValues();
+}
+
+// Function that activate or reset the timer
+void Sensor::startOrResetTimer()
+{
+    lock_guard<mutex> lock(mtx);
+    if (timerCounter == 0) {
+        // Timer is not active, set the timer to 10 seconds and start it
+        timerCounter = timeForUpdate;
+        cout << "Starting new timer..." << endl;
+        timerThread = thread(&Sensor::delayedFunction, this);
+        timerThread.detach(); // Detach the thread so it can run independently
+    }
+    else {
+        // Timer is already running, just reset it to 10 seconds
+        timerCounter = timeForUpdate;
+        cout << "Timer is active, resetting to 10 seconds..." << endl;
+    }
+}
+
+// Function that update the fields to be the default values
+void Sensor::updateDefualtValues()
+{
+    for (auto field : fieldsMap) {
+        updateTrueRoots(field.second.name, field.second.defaultValue, parser->getFieldType(field.second.type));
+    }
+    
+    // TODO: check if the default value have to send a message
+    GlobalProperties &instanceGP = GlobalProperties::getInstance();
+    for (int cId : instanceGP.trueConditions)
+        instanceGP.conditions[cId]->activateActions();
+}
+
 // C-tor initializes the id member variable.
 Sensor::Sensor(int id, string name, string jsonFilePath) : id(id), name(name)
 {
+    timeForUpdate = 10;
+    timerCounter = 0;
+
     parser = new PacketParser(jsonFilePath);
-    std::vector<Field> tempFields = parser->getFields();
+    vector<Field> tempFields = parser->getFields();
 
     for (auto field : tempFields) {
         if (field.type == "bit_field") 
@@ -22,11 +67,12 @@ Sensor::Sensor(int id, string name, string jsonFilePath) : id(id), name(name)
 
 void Sensor::handleMessage(void *msg)
 {
+    startOrResetTimer(); // Starts the timer
+
     parser->setBuffer(msg);
 
     for (auto field : fieldsMap) {
         string fieldName = field.first;
-        GlobalProperties::controlLogger.logMessage(logger::LogLevel::DEBUG, "Processing field: " + fieldName);
 
         updateTrueRoots(fieldName, parser->getFieldValue(fieldName),
                         parser->getFieldType(field.second.type));
@@ -36,6 +82,8 @@ void Sensor::handleMessage(void *msg)
 //Updates the condition status according to the received field and returns the  list of the full conditions whose root is true
 void Sensor::updateTrueRoots(string field, FieldValue value, FieldType type)
 {
+    GlobalProperties::controlLogger.logMessage(logger::LogLevel::DEBUG, "Processing field: " + field);
+
     // Update the field value in the sensor
     this->fields[field].first = value;
 

control/test/sensors_data/camera.json

@@ -6,17 +6,20 @@
                 {
                     "name": "MessageType",
                     "size": 1,
-                    "type": "unsigned_int"
+                    "type": "unsigned_int",
+                    "defaultValue": 1
                 },
                 {
                     "name": "Level",
                     "size": 3,
-                    "type": "unsigned_int"
+                    "type": "unsigned_int",
+                    "defaultValue": 1
                 },
                 {
                     "name": "ObjectType",
                     "size": 4,
-                    "type": "unsigned_int"
+                    "type": "unsigned_int",
+                    "defaultValue": 1
                 }
             ],
             "name": "AlertDetails",
@@ -26,17 +29,20 @@
         {
             "name": "ObjectDistance",
             "size": 32,
-            "type": "float_fixed"
+            "type": "float_fixed",
+            "defaultValue": 100.0
         },
         {
             "name": "CarSpeed",
             "size": 32,
-            "type": "unsigned_int"
+            "type": "unsigned_int",
+            "defaultValue": 100
         },
         {
             "name": "ObjectSpeed",
             "size": 32,
-            "type": "unsigned_int"
+            "type": "unsigned_int",
+            "defaultValue": 100
         }
     ]
 }

control/test/sensors_data/communication.json

@@ -4,17 +4,20 @@
         {
             "size": 32,
             "type": "signed_int",
-            "name": "Status"
+            "name": "Status",
+            "defaultValue": 100
         },
         {
             "size": 32,
             "type": "signed_int",
-            "name": "Code"
+            "name": "Code",
+            "defaultValue": 100
         },
         {
             "size": 32,
             "type": "signed_int",
-            "name": "Flags"
+            "name": "Flags",
+            "defaultValue": 100
         }
     ]
 }

control/test/sensors_data/speed.json

@@ -4,17 +4,20 @@
         {
             "size": 8,
             "type": "boolean",
-            "name": "Status"
+            "name": "Status",
+            "defaultValue": true
         },
         {
             "size": 64,
             "type": "char_array",
-            "name": "Msg"
+            "name": "Msg",
+            "defaultValue": "average current speed"
         },
         {
             "size": 32,
             "type": "signed_int",
-            "name": "Speed"
+            "name": "Speed",
+            "defaultValue": 100
         }
     ]
 }

control/test/sensors_data/tirePressure.json

@@ -4,12 +4,14 @@
         {
             "size": 32,
             "type": "float_fixed",
-            "name": "Temperature"
+            "name": "Temperature",
+            "defaultValue": 100
         },
         {
             "size": 32,
             "type": "float_fixed",
-            "name": "Pressure"
+            "name": "Pressure",
+            "defaultValue": 80
         }
     ]
 }

control/test/test_simple_build.cpp

@@ -118,6 +118,7 @@ TEST(OrAndCondition, ComplexConditionTest)
 
 int main(int argc, char **argv)
 {
+    Input::s_setPathBson();
     ::testing::InitGoogleTest(&argc, argv);
     return RUN_ALL_TESTS();
 }