database_handler_common.hpp

// SPDX-License-Identifier: Apache-2.0
// Copyright 2020 - 2023 Pionix GmbH and Contributors to EVerest
 
#pragma once
 
#include <memory>
#include <string>
#include <vector>
 
#include <ocpp/common/database/database_connection.hpp>
#include <ocpp/common/database/database_exceptions.hpp>
#include <ocpp/common/types.hpp>
 
namespace ocpp::common {
 
struct DBTransactionMessage {
    json json_message;
    std::string message_type;
    int32_t message_attempts;
    DateTime timestamp;
    std::string unique_id;
};
 
class DatabaseHandlerCommon {
protected:
    std::unique_ptr<DatabaseConnectionInterface> database;
    const fs::path sql_migration_files_path;
    const uint32_t target_schema_version;
 
    virtual void init_sql() = 0;
 
public:
    explicit DatabaseHandlerCommon(std::unique_ptr<DatabaseConnectionInterface> database,
                                   const fs::path& sql_migration_files_path, uint32_t target_schema_version) noexcept;
 
    ~DatabaseHandlerCommon() = default;
 
    void open_connection();
 
    void close_connection();
 
    virtual std::vector<DBTransactionMessage>
    get_message_queue_messages(const QueueType queue_type = QueueType::Transaction);
 
    virtual void insert_message_queue_message(const DBTransactionMessage& message,
                                              const QueueType queue_type = QueueType::Transaction);
 
    virtual void remove_message_queue_message(const std::string& unique_id,
                                              const QueueType queue_type = QueueType::Transaction);
 
    virtual void clear_message_queue(const QueueType queue_type = QueueType::Transaction);
};
 
} // namespace ocpp::common