ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add RPC commands data_delete, data_fetch, and data_store.

Browse Source
This commit is contained in:
Arthur Britto
2012-06-07 12:37:58 -07:00
parent 232f7f2dbb
commit 04b9581652
6 changed files with 142 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/DBInit.cpp
View File

@@ -58,6 +58,12 @@ const char *WalletDBInit[] = {
Dh1024 TEXT \
);",
// Local persistence of the RPC client
"CREATE TABLE RPCData ( \
Key TEXT PRIMARY Key, \
Value TEXT \
);",
// Miscellaneous persistent information
// Integer: 1 : Used to simplify SQL.
// ScoreUpdated: when scores was last updated.

77
src/RPCServer.cpp
View File

@@ -827,6 +827,76 @@ Json::Value RPCServer::doCreditSet(Json::Value& params)
}
}
// data_delete <key>
Json::Value RPCServer::doDataDelete(Json::Value& params)
{
if (params.size() != 1)
{
return JSONRPCError(400, "invalid params");
}
std::string strKey = params[0u].asString();
Json::Value ret = Json::Value(Json::objectValue);
if (theApp->getWallet().dataDelete(strKey))
{
ret["key"] = strKey;
}
else
{
ret = JSONRPCError(500, "internal error");
}
return ret;
}
// data_fetch <key>
Json::Value RPCServer::doDataFetch(Json::Value& params)
{
if (params.size() != 1)
{
return JSONRPCError(400, "invalid params");
}
std::string strKey = params[0u].asString();
std::string strValue;
Json::Value ret = Json::Value(Json::objectValue);
ret["key"] = strKey;
if (theApp->getWallet().dataFetch(strKey, strValue))
ret["value"] = strValue;
return ret;
}
// data_store <key> <value>
Json::Value RPCServer::doDataStore(Json::Value& params)
{
if (params.size() != 2)
{
return JSONRPCError(400, "invalid params");
}
std::string strKey = params[0u].asString();
std::string strValue = params[1u].asString();
Json::Value ret = Json::Value(Json::objectValue);
if (theApp->getWallet().dataStore(strKey, strValue))
{
ret["key"] = strKey;
ret["value"] = strValue;
}
else
{
ret = JSONRPCError(500, "internal error");
}
return ret;
}
// nickname_info <nickname>
// Note: Nicknames are not automatically looked up by commands as they are advisory and can be changed.
Json::Value RPCServer::doNicknameInfo(Json::Value& params)
@@ -1336,7 +1406,7 @@ Json::Value RPCServer::doTx(Json::Value& params)
return txn->getJson(true);
}
return "not implemented";
return JSONRPCError(501, "not implemented");
}
// ledger
@@ -1352,7 +1422,7 @@ Json::Value RPCServer::doLedger(Json::Value& params)
return ret;
}
return "not implemented";
return JSONRPCError(501, "not implemented");
}
// unl_add <domain>|<node_public> [<comment>]
@@ -2006,6 +2076,9 @@ Json::Value RPCServer::doCommand(const std::string& command, Json::Value& params
if (command == "account_wallet_set") return doAccountWalletSet(params);
if (command == "connect") return doConnect(params);
if (command == "credit_set") return doCreditSet(params);
if (command == "data_delete") return doDataDelete(params);
if (command == "data_fetch") return doDataFetch(params);
if (command == "data_store") return doDataStore(params);
if (command == "nickname_info") return doNicknameInfo(params);
if (command == "nickname_set") return doNicknameSet(params);
if (command == "password_fund") return doPasswordFund(params);

3
src/RPCServer.h
View File

@@ -55,6 +55,9 @@ private:
Json::Value doAccountWalletSet(Json::Value &params);
Json::Value doConnect(Json::Value& params);
Json::Value doCreditSet(Json::Value& params);
Json::Value doDataDelete(Json::Value& params);
Json::Value doDataFetch(Json::Value& params);
Json::Value doDataStore(Json::Value& params);
Json::Value doLedger(Json::Value& params);
Json::Value doNicknameInfo(Json::Value& params);
Json::Value doNicknameSet(Json::Value& params);

51
src/Wallet.cpp
View File

@@ -43,7 +43,7 @@ bool Wallet::nodeIdentityLoad()
ScopedLock sl(theApp->getWalletDB()->getDBLock());
bool bSuccess = false;
if(db->executeSQL("SELECT * FROM NodeIdentity;") && db->startIterRows())
if (db->executeSQL("SELECT * FROM NodeIdentity;") && db->startIterRows())
{
std::string strPublicKey, strPrivateKey;
@@ -112,6 +112,55 @@ bool Wallet::nodeIdentityCreate() {
return true;
}
bool Wallet::dataDelete(const std::string& strKey)
{
Database* db = theApp->getWalletDB()->getDB();
ScopedLock sl(theApp->getWalletDB()->getDBLock());
return db->executeSQL(str(boost::format("DELETE FROM RPCData WHERE Key=%s;")
% db->escape(strKey)));
}
bool Wallet::dataFetch(const std::string& strKey, std::string& strValue)
{
Database* db = theApp->getWalletDB()->getDB();
ScopedLock sl(theApp->getWalletDB()->getDBLock());
bool bSuccess = false;
if (db->executeSQL(str(boost::format("SELECT Value FROM RPCData WHERE Key=%s;")
% db->escape(strKey))) && db->startIterRows())
{
std::string strPublicKey, strPrivateKey;
db->getStr("Value", strValue);
db->endIterRows();
bSuccess = true;
}
return bSuccess;
}
bool Wallet::dataStore(const std::string& strKey, const std::string& strValue)
{
Database* db = theApp->getWalletDB()->getDB();
ScopedLock sl(theApp->getWalletDB()->getDBLock());
bool bSuccess = false;
return (db->executeSQL(str(boost::format("REPLACE INTO RPCData (Key, Value) VALUES (%s,%s);")
% db->escape(strKey)
% db->escape(strValue)
)));
return bSuccess;
}
bool Wallet::unitTest()
{
// Create 100 keys for each of 1,000 families and ensure all keys match

5
src/Wallet.h
View File

@@ -50,6 +50,11 @@ public:
DH* getDh512() { return DHparams_dup(mDh512); }
DH* getDh1024() { return DHparams_dup(mDh1024); }
// Local persistence of RPC clients
bool dataDelete(const std::string& strKey);
bool dataFetch(const std::string& strKey, std::string& strValue);
bool dataStore(const std::string& strKey, const std::string& strValue);
static bool unitTest();
};

3
src/main.cpp
View File

@@ -45,6 +45,9 @@ void printHelp(const po::options_description& desc)
cout << " account_wallet_set <seed> <paying_account> [<wallet_hash>]" << endl;
cout << " connect <ip> [<port>]" << endl;
cout << " credit_set <seed> <paying_account> <destination_account> <limit_amount> <currency> [<account_rate>]" << endl;
cout << " data_delete <key>" << endl;
cout << " data_fetch <key>" << endl;
cout << " data_store <key> <value>" << endl;
cout << " ledger" << endl;
cout << " nickname_info <nickname>" << endl;
cout << " nickname_set <seed> <paying_account> <nickname> [<offer_minimum>] [<authorization>]" << endl;