19 typedef std::pair<std::vector<unsigned char>, std::vector<unsigned char> >
KeyValPair;
34 std::unique_ptr<WalletDatabase> database =
MakeDatabase(file_path, options, status,
error);
35 if (!database)
return false;
38 std::string filename = berkeley_database.
Filename();
39 std::shared_ptr<BerkeleyEnvironment> env = berkeley_database.
env;
41 if (!env->Open(
error)) {
53 std::string newFilename =
strprintf(
"%s.%d.bak", filename, now);
55 int result = env->dbenv->dbrename(
nullptr, filename.c_str(),
nullptr,
56 newFilename.c_str(), DB_AUTO_COMMIT);
69 std::vector<KeyValPair> salvagedData;
71 std::stringstream strDump;
73 Db db(env->dbenv.get(), 0);
74 result = db.verify(newFilename.c_str(),
nullptr, &strDump, DB_SALVAGE | DB_AGGRESSIVE);
75 if (result == DB_VERIFY_BAD) {
76 warnings.push_back(
Untranslated(
"Salvage: Database salvage found errors, all data may not be recoverable."));
78 if (result != 0 && result != DB_VERIFY_BAD) {
92 while (!strDump.eof() && strLine !=
HEADER_END)
93 getline(strDump, strLine);
95 std::string keyHex, valueHex;
96 while (!strDump.eof() && keyHex !=
DATA_END) {
97 getline(strDump, keyHex);
101 getline(strDump, valueHex);
103 warnings.push_back(
Untranslated(
"Salvage: WARNING: Number of keys in data does not match number of values."));
112 warnings.push_back(
Untranslated(
"Salvage: WARNING: Unexpected end of file while reading salvage output."));
115 fSuccess = (result == 0);
118 if (salvagedData.empty())
124 std::unique_ptr<Db> pdbCopy = std::make_unique<Db>(env->dbenv.get(), 0);
125 int ret = pdbCopy->open(
nullptr,
137 DbTxn* ptxn = env->TxnBegin();
144 std::string strType, strErr;
156 warnings.push_back(
strprintf(
Untranslated(
"WARNING: WalletBatch::Recover skipping %s: %s"), strType, strErr));
159 Dbt datKey(row.first.data(), row.first.size());
160 Dbt datValue(row.second.data(), row.second.size());
161 int ret2 = pdbCopy->put(ptxn, &datKey, &datValue, DB_NOOVERWRITE);
Double ended buffer combining vector and stream-like interfaces.
Path class wrapper to block calls to the fs::path(std::string) implicit constructor and the fs::path:...
An instance of this class represents one database.
std::shared_ptr< BerkeleyEnvironment > env
Pointer to shared database environment.
std::string Filename() override
Return path to main database filename.
A CWallet maintains a set of transactions and balances, and provides the ability to create new transa...
RecursiveMutex cs_wallet
Main wallet lock.
static bool IsKeyType(const std::string &strType)
static const int CLIENT_VERSION
bitcoind-res.rc includes this file, but it cannot cope with real c++ code.
const std::string HDCHAIN
void ReadDatabaseArgs(const ArgsManager &args, DatabaseOptions &options)
std::unique_ptr< WalletDatabase > MakeDatabase(const fs::path &path, const DatabaseOptions &options, DatabaseStatus &status, bilingual_str &error)
std::pair< std::vector< unsigned char >, std::vector< unsigned char > > KeyValPair
static bool KeyFilter(const std::string &type)
static bool ReadKeyValue(CWallet *pwallet, DataStream &ssKey, CDataStream &ssValue, CWalletScanState &wss, std::string &strType, std::string &strErr, const KeyFilterFn &filter_fn=nullptr) EXCLUSIVE_LOCKS_REQUIRED(pwallet -> cs_wallet)
std::unique_ptr< WalletDatabase > CreateDummyWalletDatabase()
Return object for accessing dummy database with no read/write capabilities.
static const char * HEADER_END
static const char * DATA_END
bool RecoverDatabaseFile(const ArgsManager &args, const fs::path &file_path, bilingual_str &error, std::vector< bilingual_str > &warnings)
bool verify
Check data integrity on load.
std::optional< DatabaseFormat > require_format
bool error(const char *fmt, const Args &... args)
bilingual_str Untranslated(std::string original)
Mark a bilingual_str as untranslated.
std::vector< Byte > ParseHex(std::string_view str)
Parse the hex string into bytes (uint8_t or std::byte).