MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-29 10:12:39 +01:00
Code Issues Releases Wiki Activity

modules/console: Add cmd to iterate event_id txns from seq num w/ limit.

Browse source
This commit is contained in:
Jason Volk 2018-03-22 21:24:43 -07:00
parent 83bdb7161c
commit 635e09c80e
1 changed files with 53 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

53
modules/console.cc
View file

@ -324,6 +324,7 @@ console_cmd__mod_reload(const string_view &line)
//
static bool console_cmd__db_list(const string_view &line);
static bool console_cmd__db_txns(const string_view &line);
static bool console_cmd__db_checkpoint(const string_view &line);
static bool console_cmd__db_prop(const string_view &line);
@ -343,6 +344,9 @@ console_cmd__db(const string_view &line)
case hash("checkpoint"):
return console_cmd__db_checkpoint(args);
case hash("txns"):
return console_cmd__db_txns(args);
default:
case hash("list"):
return console_cmd__db_list(args);
@ -365,6 +369,55 @@ console_cmd__db_prop(const string_view &line)
return true;
}
bool
console_cmd__db_txns(const string_view &line)
try
{
const auto dbname
{
token(line, ' ', 0)
};
if(dbname != "events")
throw error
{
"Sorry, this command is specific to the events db for now."
};
const auto seqnum
{
lex_cast<uint64_t>(token(line, ' ', 1, "0"))
};
auto limit
{
lex_cast<size_t>(token(line, ' ', 2, "32"))
};
auto &database
{
*db::database::dbs.at(dbname)
};
for_each(database, seqnum, db::seq_closure_bool{[&limit]
(db::txn &txn, const uint64_t &seqnum) -> bool
{
if(txn.has(db::op::SET, "event_id"))
out << std::setw(12) << std::right << seqnum << " : "
<< std::get<db::delta::KEY>(txn.get(db::op::SET, "event_id"))
<< std::endl;
return --limit;
}});
return true;
}
catch(const std::out_of_range &e)
{
out << "No open database by that name" << std::endl;
return true;
}
bool
console_cmd__db_checkpoint(const string_view &line)
try