Ralph Wessel
e148094c81
Added numerous Send argument classes: - ConversionResult (incomplete) - SendError - SendObject - SendViaBrowserArgs (incomplete) Send method looks up model card and account details, constructs send arguments AccountDatabase can find an account by ID or server URL Added DetachedMemoryStore
142 lines
4.8 KiB
C++
142 lines
4.8 KiB
C++
#include "Connector/Database/ModelCardDatabase.h"
|
|
|
|
#include "Active/Database/Storage/Storage.h"
|
|
#include "Active/Serialise/JSON/JSONTransport.h"
|
|
#include "Connector/Record/Model/CardMover.h"
|
|
#include "Speckle/Database/Identity/RecordID.h"
|
|
#include "Speckle/Database/Storage/DocumentStore/DocumentStoreEngine.h"
|
|
|
|
#include <array>
|
|
|
|
using namespace active::container;
|
|
using namespace active::database;
|
|
using namespace active::event;
|
|
using namespace active::serialise;
|
|
using namespace active::serialise::json;
|
|
using namespace connector::database;
|
|
using namespace connector::record;
|
|
using namespace speckle::database;
|
|
using namespace speckle::utility;
|
|
|
|
namespace connector::database {
|
|
|
|
///ModelCard database engine declaration
|
|
class ModelCardDatabase::Engine : public DocumentStoreEngine<ModelCard, CardMover, JSONTransport, RecordID> {
|
|
using base = DocumentStoreEngine<ModelCard, CardMover, JSONTransport, RecordID>;
|
|
using base::base;
|
|
};
|
|
|
|
///ModelCard database storage declaration
|
|
class ModelCardDatabase::Store : public Storage<ModelCard, JSONTransport,
|
|
RecordID, RecordID, RecordID, RecordID> {
|
|
using base = Storage<ModelCard, JSONTransport,
|
|
RecordID, RecordID, RecordID, RecordID>;
|
|
using base::base;
|
|
};
|
|
|
|
}
|
|
|
|
namespace {
|
|
|
|
///The document storage identifier for model cards
|
|
const char* modelCardDBaseName = "connector::database::ModelModelCardDatabase";
|
|
///The document storage identifier for model cards
|
|
const char* modelCardTableName = "models";
|
|
|
|
}
|
|
|
|
/*--------------------------------------------------------------------
|
|
Constructor
|
|
--------------------------------------------------------------------*/
|
|
ModelCardDatabase::ModelCardDatabase() {
|
|
m_engine = std::make_shared<Engine>(modelCardDBaseName,
|
|
//Schema
|
|
DBaseSchema{active::utility::String{modelCardDBaseName},
|
|
//Tables
|
|
{
|
|
//Model card table
|
|
{
|
|
modelCardTableName, 0, 0, {} //The table specifics aren't relevant in this context
|
|
}
|
|
}
|
|
}
|
|
);
|
|
m_store = std::make_shared<Store>(m_engine);
|
|
} //ModelCardDatabase::ModelCardDatabase
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Destructor
|
|
--------------------------------------------------------------------*/
|
|
ModelCardDatabase::~ModelCardDatabase() {}
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Get a specified card from the database
|
|
|
|
return: The requested card (nullptr on failure)
|
|
--------------------------------------------------------------------*/
|
|
ModelCard::Unique ModelCardDatabase::getCard(const speckle::utility::String& cardID) const {
|
|
return m_store->getObject(cardID);
|
|
} //ModelCardDatabase::getCard
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Get all model cards
|
|
|
|
return: All the cards
|
|
--------------------------------------------------------------------*/
|
|
Vector<ModelCard> ModelCardDatabase::getCards() const {
|
|
return m_store->getObjects();
|
|
} //ModelCardDatabase::getCards
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Write a card to storage
|
|
|
|
card: The card to write
|
|
--------------------------------------------------------------------*/
|
|
void ModelCardDatabase::write(const ModelCard& card) const {
|
|
m_store->write(card);
|
|
} //ModelCardDatabase::write
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Erase a card
|
|
|
|
cardID: The ID of the card to erase
|
|
--------------------------------------------------------------------*/
|
|
void ModelCardDatabase::erase(const String& cardID) const {
|
|
m_store->erase(cardID);
|
|
} //ModelCardDatabase::erase
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Get the unique ID of the engine storage
|
|
|
|
return: The databas unique ID
|
|
--------------------------------------------------------------------*/
|
|
RecordID ModelCardDatabase::getStoreID() const {
|
|
return m_engine->getUniqueID();
|
|
} //ModelCardDatabase::getStoreID
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Get a serialisation wrapper for the database
|
|
|
|
return: A database wrapper
|
|
--------------------------------------------------------------------*/
|
|
std::unique_ptr<Cargo> ModelCardDatabase::wrapper() const {
|
|
return m_store->wrapper();
|
|
} //ModelCardDatabase::wrapper
|
|
|
|
|
|
/*--------------------------------------------------------------------
|
|
Get the database subscription (the content is document-based, and must react to document operations)
|
|
|
|
return: The database subscription (add weakly to publisher)
|
|
--------------------------------------------------------------------*/
|
|
std::shared_ptr<active::event::Subscriber> ModelCardDatabase::getSubscription() {
|
|
return std::dynamic_pointer_cast<Subscriber>(m_engine);
|
|
} //ModelCardDatabase::getSubscription
|