log_database.h

Go to the documentation of this file.

 
#ifndef MANTIS_LOG_DATABASE_H
#define MANTIS_LOG_DATABASE_H
 
#include <string>
#include <memory>
#include <thread>
#include <atomic>
#include <condition_variable>
#include <mutex>
#include <nlohmann/json.hpp>
 
namespace soci {
    class session;
}
 
namespace mb {
    using json = nlohmann::json;
 
    class LogDatabase {
    public:
        LogDatabase();
 
        ~LogDatabase();
 
        bool init(const std::string& data_dir = "");
 
        bool insertLog(const std::string& level, const std::string& origin, const std::string& message, 
                       const std::string& details, const json& data = json::object());
 
        json getLogs(int page = 1, int page_size = 50,
                     const std::string& level_filter = "",
                     const std::string& search_filter = "",
                     const std::string& start_date = "",
                     const std::string& end_date = "",
                     const std::string& sort_by = "timestamp",
                     const std::string& sort_order = "desc");
    private:
        void shutdown();
 
        void createTable() const;
 
        void cleanupThread();
 
        void deleteOldLogs(int days = 5);
 
        static std::string buildMinLogWhereCondition(const std::string& level);
 
        std::string m_dataDir;
        std::unique_ptr<soci::session> m_session;
        std::thread m_cleanupThread;
        std::atomic<bool> m_running;
        std::condition_variable m_cv;
        std::mutex m_dbMutexLock;
 
        inline static const std::vector<std::string> m_logLevels{ "critical", "warn", "info", "debug", "trace"};
    };
}
 
#endif // MANTIS_LOG_DATABASE_H