PanoptesDatabase Class Reference

#include <database.hpp>

Public Member Functions
std::string	UpdateEntry (std::string key, std::string entry)
BOOL	AddEntry (std::string key, std::string entry)
std::string	GetEntry (std::string hash)
ERRORCODE	InitializeDatabase ()
	PanoptesDatabase ()

Detailed Description

Definition at line 7 of file database.hpp.

Constructor & Destructor Documentation

PanoptesDatabase()

PanoptesDatabase::PanoptesDatabase

(

)

Definition at line 68 of file database.cpp.

                                   {
    m_options.IncreaseParallelism();
    m_options.OptimizeLevelStyleCompaction();
    m_options.create_if_missing = true;
}

References m_options.

Member Function Documentation

AddEntry()

BOOL PanoptesDatabase::AddEntry	(	std::string	key,
		std::string	entry
	)

Definition at line 33 of file database.cpp.

                                                              {
    Status s = m_database->Put(WriteOptions(), key, entry);
    if (s.ok()) {
        return true;
    }
    else {
        return false;
    }
}

References m_database.

GetEntry()

std::string PanoptesDatabase::GetEntry

(

std::string

hash

)

Definition at line 43 of file database.cpp.

                                                   {
    std::string value;
    Status s = m_database->Get(ReadOptions(), hash, &value);
    return value;
}

References m_database.

Referenced by UpdateEntry().

InitializeDatabase()

ERRORCODE PanoptesDatabase::InitializeDatabase

(

)

Definition at line 23 of file database.cpp.

                                               {
    Status s = rocksdb::DB::Open(m_options, PANOPTES_DATABASE_PATH, &m_database);
    if (s.ok()) {
        return PANO_SUCCESS;
    }
    else {
        return DB_INITIALIZATION;
    }
}

References DB_INITIALIZATION, m_database, m_options, PANO_SUCCESS, and PANOPTES_DATABASE_PATH.

UpdateEntry()

std::string PanoptesDatabase::UpdateEntry	(	std::string	key,
		std::string	entry
	)

Definition at line 49 of file database.cpp.

                                                                      {
    std::string dbEntryStr = GetEntry(key);
    nlohmann::json dbEntry = nlohmann::json::parse(dbEntryStr);
    nlohmann::json entryToMerge = nlohmann::json::parse(entry);
    dbEntry.merge_patch(entryToMerge);
    std::string combinedEntry = dbEntry.dump();
    WriteBatch batch;
 
    batch.Delete(key);
    batch.Put(key, combinedEntry);
    Status s = m_database->Write(WriteOptions(), &batch);
    if (s.ok()) {
        return combinedEntry;
    }
    else {
        return "";
    }
}

References GetEntry(), and m_database.

---

The documentation for this class was generated from the following files:

• /home/runner/work/Panoptes/Panoptes/src/service/include/database.hpp
• /home/runner/work/Panoptes/Panoptes/src/service/src/database.cpp