mirror of
https://github.com/matrix-construct/construct
synced 2024-11-19 08:21:09 +01:00
modules/federation/make_leave: Upgrade to json::stack; use m::room:: interfaces.
This commit is contained in:
parent
fd6c2fb2aa
commit
0c6845253d
1 changed files with 71 additions and 34 deletions
|
@ -85,57 +85,94 @@ get__make_leave(client &client,
|
||||||
membership
|
membership
|
||||||
};
|
};
|
||||||
|
|
||||||
int64_t depth;
|
const unique_buffer<mutable_buffer> buf
|
||||||
m::id::event::buf prev_event_id;
|
|
||||||
std::tie(prev_event_id, depth, std::ignore) = m::top(room_id);
|
|
||||||
|
|
||||||
const m::event::fetch evf
|
|
||||||
{
|
{
|
||||||
prev_event_id, std::nothrow
|
8_KiB
|
||||||
};
|
};
|
||||||
|
|
||||||
const auto &auth_events
|
json::stack out{buf};
|
||||||
|
json::stack::object top{out};
|
||||||
|
json::stack::object event
|
||||||
{
|
{
|
||||||
json::get<"auth_events"_>(evf)?
|
top, "event"
|
||||||
json::get<"auth_events"_>(evf) : json::array{"[]"}
|
|
||||||
};
|
};
|
||||||
|
|
||||||
const json::value prev[]
|
|
||||||
{
|
{
|
||||||
{ string_view{prev_event_id} },
|
const m::room::auth auth{room};
|
||||||
{ json::get<"hashes"_>(evf) }
|
json::stack::array auth_events
|
||||||
|
{
|
||||||
|
event, "auth_events"
|
||||||
};
|
};
|
||||||
|
|
||||||
const json::value prevs[]
|
static const string_view types[]
|
||||||
{
|
{
|
||||||
{ prev, 2 }
|
"m.room.create",
|
||||||
|
"m.room.join_rules",
|
||||||
|
"m.room.power_levels",
|
||||||
|
"m.room.member",
|
||||||
};
|
};
|
||||||
|
|
||||||
thread_local char bufs[96_KiB];
|
auth.make_refs(auth_events, types, user_id);
|
||||||
mutable_buffer buf{bufs};
|
}
|
||||||
|
|
||||||
json::iov content, event, wrapper;
|
json::stack::member
|
||||||
const json::iov::push push[]
|
|
||||||
{
|
{
|
||||||
{ event, { "origin", request.origin }},
|
event, "content", R"({"membership":"leave"})"
|
||||||
{ event, { "origin_server_ts", time<milliseconds>() }},
|
|
||||||
{ event, { "room_id", room_id }},
|
|
||||||
{ event, { "type", "m.room.member" }},
|
|
||||||
{ event, { "sender", user_id }},
|
|
||||||
{ event, { "state_key", user_id }},
|
|
||||||
{ event, { "depth", depth + 1 }},
|
|
||||||
{ event, { "membership", "leave" }},
|
|
||||||
{ content, { "membership", "leave" }},
|
|
||||||
{ event, { "auth_events", auth_events }},
|
|
||||||
{ event, { "prev_state", "[]" }},
|
|
||||||
{ event, { "prev_events", { prevs, 1 } }},
|
|
||||||
{ event, { "content", stringify(buf, content) }},
|
|
||||||
{ wrapper, { "event", stringify(buf, event) }},
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "depth", json::value(m::depth(room) + 1L)
|
||||||
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "origin", request.origin
|
||||||
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "origin_server_ts", json::value(time<milliseconds>())
|
||||||
|
};
|
||||||
|
|
||||||
|
{
|
||||||
|
const m::room::head head{room};
|
||||||
|
json::stack::array prev_events
|
||||||
|
{
|
||||||
|
event, "prev_events"
|
||||||
|
};
|
||||||
|
|
||||||
|
head.make_refs(prev_events, 32, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "room_id", room.room_id
|
||||||
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "sender", user_id
|
||||||
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "state_key", user_id
|
||||||
|
};
|
||||||
|
|
||||||
|
json::stack::member
|
||||||
|
{
|
||||||
|
event, "type", "m.room.member"
|
||||||
|
};
|
||||||
|
|
||||||
|
event.~object();
|
||||||
|
top.~object();
|
||||||
return resource::response
|
return resource::response
|
||||||
{
|
{
|
||||||
client, wrapper
|
client, json::object
|
||||||
|
{
|
||||||
|
out.completed()
|
||||||
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue