Rename Wallet to LocalCredentials

2025-12-06 17:27:52 +00:00 · 2013-06-15 18:01:38 -07:00
parent 8aab3645cb
commit 8a6ce5de68
19 changed files with 123 additions and 126 deletions
--- a/src/cpp/ripple/ripple_LocalCredentials.cpp
+++ b/src/cpp/ripple/ripple_LocalCredentials.cpp
@@ -0,0 +1,165 @@
+
+LocalCredentials::LocalCredentials () : mDh512 (NULL), mDh1024 (NULL), mLedger (0)
+{
+    ;
+}
+
+void LocalCredentials::start ()
+{
+    // We need our node identity before we begin networking.
+    // - Allows others to identify if they have connected multiple times.
+    // - Determines our CAS routing and responsibilities.
+    // - This is not our validation identity.
+    if (!nodeIdentityLoad ())
+    {
+        nodeIdentityCreate ();
+
+        if (!nodeIdentityLoad ())
+            throw std::runtime_error ("unable to retrieve new node identity.");
+    }
+
+    if (!theConfig.QUIET)
+        std::cerr << "NodeIdentity: " << mNodePublicKey.humanNodePublic () << std::endl;
+
+    theApp->getUNL ().start ();
+}
+
+// Retrieve network identity.
+bool LocalCredentials::nodeIdentityLoad ()
+{
+
+    Database*   db = theApp->getWalletDB ()->getDB ();
+    ScopedLock  sl (theApp->getWalletDB ()->getDBLock ());
+    bool        bSuccess    = false;
+
+    if (db->executeSQL ("SELECT * FROM NodeIdentity;") && db->startIterRows ())
+    {
+        std::string strPublicKey, strPrivateKey;
+
+        db->getStr ("PublicKey", strPublicKey);
+        db->getStr ("PrivateKey", strPrivateKey);
+
+        mNodePublicKey.setNodePublic (strPublicKey);
+        mNodePrivateKey.setNodePrivate (strPrivateKey);
+
+        mDh512  = DH_der_load (db->getStrBinary ("Dh512"));
+        mDh1024 = DH_der_load (db->getStrBinary ("Dh1024"));
+
+        db->endIterRows ();
+        bSuccess    = true;
+    }
+
+    if (theConfig.NODE_PUB.isValid () && theConfig.NODE_PRIV.isValid ())
+    {
+        mNodePublicKey = theConfig.NODE_PUB;
+        mNodePrivateKey = theConfig.NODE_PRIV;
+    }
+
+    return bSuccess;
+}
+
+// Create and store a network identity.
+bool LocalCredentials::nodeIdentityCreate ()
+{
+    if (!theConfig.QUIET)
+        std::cerr << "NodeIdentity: Creating." << std::endl;
+
+    //
+    // Generate the public and private key
+    //
+    RippleAddress   naSeed          = RippleAddress::createSeedRandom ();
+    RippleAddress   naNodePublic    = RippleAddress::createNodePublic (naSeed);
+    RippleAddress   naNodePrivate   = RippleAddress::createNodePrivate (naSeed);
+
+    // Make new key.
+
+#ifdef CREATE_NEW_DH_PARAMS
+    std::string     strDh512        = DH_der_gen (512);
+#else
+    static const unsigned char dh512Param[] =
+    {
+        0x30, 0x46, 0x02, 0x41, 0x00, 0x98, 0x15, 0xd2, 0xd0, 0x08, 0x32, 0xda,
+        0xaa, 0xac, 0xc4, 0x71, 0xa3, 0x1b, 0x11, 0xf0, 0x6c, 0x62, 0xb2, 0x35,
+        0x8a, 0x10, 0x92, 0xc6, 0x0a, 0xa3, 0x84, 0x7e, 0xaf, 0x17, 0x29, 0x0b,
+        0x70, 0xef, 0x07, 0x4f, 0xfc, 0x9d, 0x6d, 0x87, 0x99, 0x19, 0x09, 0x5b,
+        0x6e, 0xdb, 0x57, 0x72, 0x4a, 0x7e, 0xcd, 0xaf, 0xbd, 0x3a, 0x97, 0x55,
+        0x51, 0x77, 0x5a, 0x34, 0x7c, 0xe8, 0xc5, 0x71, 0x63, 0x02, 0x01, 0x02
+    };
+    std::string     strDh512 (reinterpret_cast<const char*> (dh512Param), sizeof (dh512Param));
+#endif
+
+
+#if 1
+    std::string     strDh1024       = strDh512;             // For testing and most cases 512 is fine.
+#else
+    std::string     strDh1024       = DH_der_gen (1024);
+#endif
+
+    //
+    // Store the node information
+    //
+    Database* db    = theApp->getWalletDB ()->getDB ();
+
+    ScopedLock sl (theApp->getWalletDB ()->getDBLock ());
+    db->executeSQL (str (boost::format ("INSERT INTO NodeIdentity (PublicKey,PrivateKey,Dh512,Dh1024) VALUES ('%s','%s',%s,%s);")
+                         % naNodePublic.humanNodePublic ()
+                         % naNodePrivate.humanNodePrivate ()
+                         % sqlEscape (strDh512)
+                         % sqlEscape (strDh1024)));
+    // XXX Check error result.
+
+    if (!theConfig.QUIET)
+        std::cerr << "NodeIdentity: Created." << std::endl;
+
+    return true;
+}
+
+bool LocalCredentials::dataDelete (const std::string& strKey)
+{
+    Database* db    = theApp->getRpcDB ()->getDB ();
+
+    ScopedLock sl (theApp->getRpcDB ()->getDBLock ());
+
+    return db->executeSQL (str (boost::format ("DELETE FROM RPCData WHERE Key=%s;")
+                                % sqlEscape (strKey)));
+}
+
+bool LocalCredentials::dataFetch (const std::string& strKey, std::string& strValue)
+{
+    Database* db    = theApp->getRpcDB ()->getDB ();
+
+    ScopedLock sl (theApp->getRpcDB ()->getDBLock ());
+
+    bool        bSuccess    = false;
+
+    if (db->executeSQL (str (boost::format ("SELECT Value FROM RPCData WHERE Key=%s;")
+                             % sqlEscape (strKey))) && db->startIterRows ())
+    {
+        Blob vucData    = db->getBinary ("Value");
+        strValue.assign (vucData.begin (), vucData.end ());
+
+        db->endIterRows ();
+
+        bSuccess    = true;
+    }
+
+    return bSuccess;
+}
+
+bool LocalCredentials::dataStore (const std::string& strKey, const std::string& strValue)
+{
+    Database* db    = theApp->getRpcDB ()->getDB ();
+
+    ScopedLock sl (theApp->getRpcDB ()->getDBLock ());
+
+    bool        bSuccess    = false;
+
+    return (db->executeSQL (str (boost::format ("REPLACE INTO RPCData (Key, Value) VALUES (%s,%s);")
+                                 % sqlEscape (strKey)
+                                 % sqlEscape (strValue)
+                                )));
+
+    return bSuccess;
+}
+
+// vim:ts=4