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

ircd:Ⓜ️:txn: Elaborate the txn generation stack.

Browse source
This commit is contained in:
Jason Volk 2018-04-06 21:46:20 -07:00
parent cfbe032af5
commit ccf9e993dd
2 changed files with 71 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
include/ircd/m/txn.h
View file

@ -29,8 +29,14 @@ struct ircd::m::txn
>
{
using array = vector_view<const json::value>;
using closure = std::function<void (json::iov &)>;
static string_view create_id(const mutable_buffer &out, const string_view &txn);
static std::string create(const array &pdu, const array &edu, const array &pdu_failure = {});
static void create(const closure &, const array &pdu, const array &edu = {}, const array &pdu_failure = {});
static string_view create(const mutable_buffer &, const array &pdu, const array &edu = {}, const array &pdu_failure = {});
static std::string create(const array &pdu, const array &edu = {}, const array &pdu_failure = {});
static size_t serialized(const array &pdu, const array &edu = {}, const array &pdu_failure = {});
using super_type::tuple;
using super_type::operator=;

68
ircd/m/m.cc
View file

@ -1486,10 +1486,73 @@ ircd::m::exists(const id::room_alias &room_alias,
// m/txn.h
//
/// Returns the serial size of the JSON this txn would consume. Note: this
/// creates a json::iov involving a timestamp to figure out the total size
/// of the txn. When the user creates the actual txn a different timestamp
/// is created which may be a different size. Consider using the lower-level
/// create(closure) or add some pad to be sure.
///
size_t
ircd::m::txn::serialized(const array &pdu,
const array &edu,
const array &pdu_failure)
{
size_t ret;
const auto closure{[&ret]
(const json::iov &iov)
{
ret = json::serialized(iov);
}};
create(closure, pdu, edu, pdu_failure);
return ret;
}
/// Stringifies a txn from the inputs into the returned std::string
///
std::string
ircd::m::txn::create(const array &pdu,
const array &edu,
const array &pdu_failure)
{
std::string ret;
const auto closure{[&ret]
(const json::iov &iov)
{
ret = json::strung(iov);
}};
create(closure, pdu, edu, pdu_failure);
return ret;
}
/// Stringifies a txn from the inputs into the buffer
///
ircd::string_view
ircd::m::txn::create(const mutable_buffer &buf,
const array &pdu,
const array &edu,
const array &pdu_failure)
{
string_view ret;
const auto closure{[&buf, &ret]
(const json::iov &iov)
{
ret = json::stringify(mutable_buffer{buf}, iov);
}};
create(closure, pdu, edu, pdu_failure);
return ret;
}
/// Forms a txn from the inputs into a json::iov and presents that iov
/// to the user's closure.
///
void
ircd::m::txn::create(const closure &closure,
const array &pdu,
const array &edu,
const array &pdu_failure)
{
using ircd::size;
@ -1524,10 +1587,7 @@ ircd::m::txn::create(const array &pdu,
}
};
return json::strung
{
iov
};
closure(iov);
}
ircd::string_view