[OMON-662] Store SOR timestamp in InfluxDB as soon as run starts (#317)

Author: awegrzyn

CMakeLists.txt

@@ -31,7 +31,7 @@ endif()
 
 # Define project
 project(Monitoring
-  VERSION 3.15.4
+  VERSION 3.15.5
   DESCRIPTION "O2 Monitoring library"
   LANGUAGES CXX
 )

examples/12-KafkaToInfluxDb.cxx

@@ -48,12 +48,13 @@ int main(int argc, char* argv[])
         if (stateChange.envinfo().state().empty()) {
           continue;
         }
-        std::cout << stateChange.envinfo().environmentid() << "/" << stateChange.envinfo().runnumber() << "  " << change.first << " SOR: " <<stateChange.envinfo().enterstatetimestamp() << " EOR: " << stateChange.timestamp() << std::endl;
         auto metric = Metric{"run_times"};
         if (change.first.find("leave") != std::string::npos) {
-          metric.addValue(stateChange.envinfo().enterstatetimestamp(), "sor").addValue(stateChange.timestamp(), "eor");
+          metric.addValue(stateChange.timestamp(), "eor");
+          std::cout << stateChange.envinfo().environmentid() << "/" << stateChange.envinfo().runnumber() << "  " << change.first << " EOR: " << stateChange.timestamp() << std::endl;
         } else {
-          metric.addValue(stateChange.envinfo().runtype(), "type");
+          metric.addValue(stateChange.envinfo().runtype(), "type").addValue(stateChange.envinfo().enterstatetimestamp(), "sor");
+          std::cout << stateChange.envinfo().environmentid() << "/" << stateChange.envinfo().runnumber() << "  " << change.first << " SOR: " <<stateChange.envinfo().enterstatetimestamp() << std::endl;
         }
         int run = stateChange.envinfo().runnumber();
         if (run > 1) {