Drop TObject2Json in favour of nodejs extenstion (#106)

* Make TObject2Json a library

* Drop TObject2Json

* Add retrieveJson method to database interface

* Update docs

Author: awegrzyn

Framework/CMakeLists.txt

@@ -35,18 +35,8 @@ set(
   include/QualityControl/InfrastructureGenerator.h
 )
 
-set(
-  SRCS_TOBJECT2JSON
-  src/tobject2json/TObject2Json.cxx
-  src/tobject2json/TObject2JsonServer.cxx
-  src/tobject2json/TObject2JsonWorker.cxx
-  src/tobject2json/TObject2JsonBackendFactory.cxx
-  src/tobject2json/TObject2JsonCcdb.cxx
-)
-
 if(ENABLE_MYSQL)
   list(APPEND SRCS src/MySqlDatabase.cxx)
-  list(APPEND SRCS_TOBJECT2JSON src/tobject2json/TObject2JsonMySql.cxx)
 endif()
 
 # Produce the final Version.h using template Version.h.in and substituting variables. We don't want to polute our source
@@ -168,10 +158,6 @@ foreach(i RANGE ${count})
   target_link_libraries(${name} PRIVATE QualityControl)
 endforeach()
 
-# tobject2json
-add_executable(tobject2json ${SRCS_TOBJECT2JSON})
-target_link_libraries(tobject2json PRIVATE QualityControl ZeroMQ::ZeroMQ $<$<BOOL:${ENABLE_MYSQL}>:MySQL::MySQL>)
-
 # ---- Gui ----
 
 set(DATADUMP "")
@@ -243,7 +229,7 @@ unset(isSystemDir)
 
 # Install library and binaries
 install(
-  TARGETS QualityControl ${EXE_NAMES} tobject2json ${DATADUMP}
+  TARGETS QualityControl ${EXE_NAMES} ${DATADUMP}
   EXPORT QualityControlTargets
   LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR}
   ARCHIVE DESTINATION ${CMAKE_INSTALL_LIBDIR}

Framework/include/QualityControl/CcdbDatabase.h

@@ -61,6 +61,7 @@ class CcdbDatabase : public DatabaseInterface
   void connect(const std::unordered_map<std::string, std::string>& config) override;
   void store(std::shared_ptr<o2::quality_control::core::MonitorObject> mo) override;
   core::MonitorObject* retrieve(std::string taskName, std::string objectName) override;
+  std::string retrieveJson(std::string taskName, std::string objectName) override;
   void disconnect() override;
   void prepareTaskDataContainer(std::string taskName) override;
   std::vector<std::string> getListOfTasksWithPublications() override;

Framework/include/QualityControl/DatabaseInterface.h

@@ -60,6 +60,11 @@ class DatabaseInterface
    * TODO evaluate whether we should have a method to retrieve a list of objects (optimization)
    */
   virtual o2::quality_control::core::MonitorObject* retrieve(std::string taskName, std::string objectName) = 0;
+
+  /**
+   * Returns JSON encoded object
+   */
+  virtual std::string retrieveJson(std::string taskName, std::string objectName) = 0;
   virtual void disconnect() = 0;
   /**
    * \brief Prepare the container, such as a table in a relational database, that will contain the MonitorObject's for

Framework/include/QualityControl/MySqlDatabase.h

@@ -34,6 +34,7 @@ class MySqlDatabase : public DatabaseInterface
   void connect(const std::unordered_map& config) override;
   void store(std::shared_ptr<o2::quality_control::core::MonitorObject> mo) override;
   o2::quality_control::core::MonitorObject* retrieve(std::string taskName, std::string objectName) override;
+  std::string retrieveJson(std::string taskName, std::string objectName) override;
   void disconnect() override;
   std::vector<std::string> getPublishedObjectNames(std::string taskName) override;
   std::vector<std::string> getListOfTasksWithPublications() override;

Framework/src/CcdbDatabase.cxx

@@ -18,6 +18,7 @@
 #include <boost/algorithm/string.hpp>
 #include <chrono>
 #include <sstream>
+#include "TBufferJSON.h"
 
 using namespace std::chrono;
 using namespace AliceO2::Common;
@@ -82,6 +83,18 @@ core::MonitorObject* CcdbDatabase::retrieve(std::string taskName, std::string ob
   return dynamic_cast<core::MonitorObject*>(object);
 }
 
+std::string CcdbDatabase::retrieveJson(std::string taskName, std::string objectName)
+{
+  std::unique_ptr<core::MonitorObject> monitor(retrieve(taskName, objectName));
+  if (monitor == nullptr) {
+    return std::string();
+  }
+  std::unique_ptr<TObject> obj(monitor->getObject());
+  monitor->setIsOwner(false);
+  TString json = TBufferJSON::ConvertToJSON(obj.get());
+  return json.Data();
+}
+
 void CcdbDatabase::disconnect()
 {
   /* we're done with libcurl, so clean it up */

Framework/src/MySqlDatabase.cxx

@@ -10,6 +10,7 @@
 #include "TMySQLResult.h"
 #include "TMySQLRow.h"
 #include "TMySQLStatement.h"
+#include "TBufferJSON.h"
 // O2
 #include "Common/Exceptions.h"
 // QC
@@ -207,6 +208,18 @@ o2::quality_control::core::MonitorObject* MySqlDatabase::retrieve(std::string ta
   return mo;
 }
 
+std::string MySqlDatabase::retrieveJson(std::string taskName, std::string objectName)
+{
+  std::unique_ptr<o2::quality_control::core::MonitorObject> monitor(retrieve(taskName, objectName));
+  if (monitor == nullptr) {
+    return std::string();
+  }
+  std::unique_ptr<TObject> obj(monitor->getObject());
+  monitor->setIsOwner(false);
+  TString json = TBufferJSON::ConvertToJSON(obj.get());
+  return json.Data();
+}
+
 void MySqlDatabase::disconnect()
 {
   storeQueue();