SociDB.h

#pragma once

 
#include <soci/blob.h>
#include <soci/session.h>
 
#include <memory>
#ifdef __clang__
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wdeprecated"
#endif
 
#include <xrpl/core/JobQueue.h>
#include <xrpl/core/ServiceRegistry.h>
 
#define SOCI_USE_BOOST
 
#include <cstdint>
#include <string>
#include <vector>
 
namespace sqlite_api {
struct sqlite3;
}  // namespace sqlite_api
 
namespace xrpl {
 
class BasicConfig;

class DBConfig
{
    std::string connectionString_;
    explicit DBConfig(std::string dbPath);
 
public:
    DBConfig(BasicConfig const& config, std::string const& dbName);
    [[nodiscard]] std::string
    connectionString() const;
    void
    open(soci::session& s) const;
};

void
open(soci::session& s, BasicConfig const& config, std::string const& dbName);

void
open(soci::session& s, std::string const& beName, std::string const& connectionString);
 
std::uint32_t
getKBUsedAll(soci::session& s);
std::uint32_t
getKBUsedDB(soci::session& s);
 
void
convert(soci::blob& from, std::vector<std::uint8_t>& to);
void
convert(soci::blob& from, std::string& to);
void
convert(std::vector<std::uint8_t> const& from, soci::blob& to);
void
convert(std::string const& from, soci::blob& to);
 
class Checkpointer : public std::enable_shared_from_this<Checkpointer>
{
public:
    virtual std::uintptr_t
    id() const = 0;
    virtual ~Checkpointer() = default;
 
    virtual void
    schedule() = 0;
 
    virtual void
    checkpoint() = 0;
};

std::shared_ptr<Checkpointer>
makeCheckpointer(std::uintptr_t id, std::weak_ptr<soci::session>, JobQueue&, ServiceRegistry&);
 
}  // namespace xrpl
 
#ifdef __clang__
#pragma clang diagnostic pop
#endif