MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-07-05 10:08:36 +02:00
Code Issues Releases Wiki Activity

modules/console: Add fed head command.

Browse source
This commit is contained in:
Jason Volk 2018-03-06 06:43:32 -08:00
parent 37753a9648
commit 1a65c1ed47
1 changed files with 46 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
modules/s_console.cc
View file

@ -1505,6 +1505,7 @@ static bool console_cmd__fed__version(const string_view &line);
static bool console_cmd__fed__query(const string_view &line);
static bool console_cmd__fed__event(const string_view &line);
static bool console_cmd__fed__state(const string_view &line);
static bool console_cmd__fed__head(const string_view &line);
bool
console_cmd__fed(const string_view &line)
@ -1528,6 +1529,9 @@ console_cmd__fed(const string_view &line)
case hash("state"):
return console_cmd__fed__state(args);
case hash("head"):
return console_cmd__fed__head(args);
default:
throw bad_command{};
}
@ -1535,6 +1539,48 @@ console_cmd__fed(const string_view &line)
return true;
}
bool
console_cmd__fed__head(const string_view &line)
{
const m::room::id &room_id
{
token(line, ' ', 0)
};
const net::hostport remote
{
token(line, ' ', 1)
};
thread_local char buf[16_KiB];
m::v1::make_join request
{
room_id, m::me.user_id, buf
};
if(request.wait(seconds(5)) == ctx::future_status::timeout)
throw http::error{http::REQUEST_TIMEOUT};
request.get();
const json::object proto
{
request.in.content
};
const json::array prev_events
{
proto.at({"event", "prev_events"})
};
for(const json::array &prev_event : prev_events)
{
const string_view &id{prev_event.at(0)};
out << id << " :" << string_view{prev_event.at(1)} << std::endl;
}
return true;
}
bool
console_cmd__fed__state(const string_view &line)
{