MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-25 23:14:13 +01:00
Code Issues Releases Wiki Activity

modules/federation/federation: Split feds version request / response.

Browse source
This commit is contained in:
Jason Volk 2018-04-30 05:43:56 -07:00
parent bc5ab4a1b1
commit ec4453404e
1 changed files with 39 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

67
modules/federation/federation.cc
View file

@ -16,29 +16,36 @@ IRCD_MODULE
"Federation :General Library and Utils"
};
extern "C" void
feds__version(const m::room::id &room_id, std::ostream &out)
namespace ircd::m::feds
{
struct req
:m::v1::version
struct version;
}
struct ircd::m::feds::version
:m::v1::version
{
char origin[256];
char buf[16_KiB];
version(const string_view &origin)
:m::v1::version{[&]
{
char origin[256];
char buf[16_KiB];
m::v1::version::opts opts;
opts.dynamic = false;
opts.remote = string_view{this->origin, strlcpy(this->origin, origin)};
return m::v1::version{mutable_buffer{buf}, std::move(opts)};
}()}
{}
req(const string_view &origin)
:m::v1::version{[&]
{
m::v1::version::opts opts;
opts.dynamic = false;
opts.remote = string_view{this->origin, strlcpy(this->origin, origin)};
return m::v1::version{mutable_buffer{buf}, std::move(opts)};
}()}
{}
};
version(const version &) = delete;
version &operator=(const version &) = delete;
};
std::list<req> reqs;
const m::room::origins origins{room_id};
origins.for_each([&out, &reqs]
std::list<m::feds::version>
feds__version(const m::room::id &room_id)
{
std::list<m::feds::version> reqs;
m::room::origins{room_id}.for_each([&reqs]
(const string_view &origin)
{
const auto emsg
@ -46,23 +53,27 @@ feds__version(const m::room::id &room_id, std::ostream &out)
ircd::server::errmsg(origin)
};
if(emsg)
{
out << "! " << origin << " " << emsg << std::endl;
return;
}
try
if(!emsg) try
{
reqs.emplace_back(origin);
}
catch(const std::exception &e)
catch(const std::exception &)
{
out << "! " << origin << " " << e.what() << std::endl;
return;
}
});
return std::move(reqs);
}
extern "C" void
feds__version(const m::room::id &room_id, std::ostream &out)
{
auto reqs
{
feds__version(room_id)
};
auto all
{
ctx::when_all(begin(reqs), end(reqs))