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

modules/federation/make_join: Upgrade to json::stack; use m::room:: interfaces.

Browse source
This commit is contained in:
Jason Volk 2019-04-17 06:52:09 -07:00
parent 4f45571526
commit fd6c2fb2aa
1 changed files with 63 additions and 47 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

110
modules/federation/make_join.cc
View file

@ -72,91 +72,107 @@ get__make_join(client &client,
room_id room_id
}; };
if(!exists(room))
throw m::NOT_FOUND
{
"Room %s is not known here.",
string_view{room_id}
};
if(!room.visible(user_id)) if(!room.visible(user_id))
throw m::ACCESS_DENIED throw m::ACCESS_DENIED
{ {
"You are not permitted to view the room at this event." "You are not permitted to view the room at this event."
}; };
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 json::value prev[] json::stack out{buf};
json::stack::object top{out};
json::stack::object event
{ {
{ string_view{prev_event_id} }, top, "event"
{ json::get<"hashes"_>(evf) }
}; };
const json::value prevs[]
{ {
{ prev, 2 } const m::room::auth auth{room};
json::stack::array auth_events
{
event, "auth_events"
};
static const string_view types[]
{
"m.room.create",
"m.room.join_rules",
"m.room.power_levels",
"m.room.member",
};
auth.make_refs(auth_events, types, user_id);
}
json::stack::member
{
event, "content", R"({"membership":"join"})"
}; };
const m::room::state state json::stack::member
{ {
room_id event, "depth", json::value(m::depth(room) + 1L)
}; };
auto auth_event_idx json::stack::member
{ {
state.get(std::nothrow, "m.room.member", user_id) event, "origin", request.origin
}; };
if(!auth_event_idx) json::stack::member
auth_event_idx = state.get("m.room.create");
const auto auth_event_id
{ {
m::event_id(auth_event_idx) event, "origin_server_ts", json::value(time<milliseconds>())
}; };
const m::event::fetch aevf
{ {
auth_event_idx, std::nothrow 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
}; };
const json::value auth[] json::stack::member
{ {
{ string_view{auth_event_id} }, event, "sender", user_id
{ json::get<"hashes"_>(aevf) }
}; };
const json::value auths[] json::stack::member
{ {
{ auth, 2 } event, "state_key", user_id
}; };
thread_local char bufs[96_KiB]; json::stack::member
mutable_buffer buf{bufs};
json::iov content, event, wrapper;
const json::iov::push push[]
{ {
{ event, { "origin", request.origin }}, event, "type", "m.room.member"
{ event, { "origin_server_ts", time<milliseconds>() }},
{ event, { "room_id", room_id }},
{ event, { "type", "m.room.member" }},
{ event, { "state_key", user_id }},
{ event, { "sender", user_id }},
{ event, { "depth", depth + 1 }},
{ event, { "membership", "join" }},
{ content, { "membership", "join" }},
{ event, { "auth_events", { auths, 1 } }},
{ event, { "prev_state", "[]" }},
{ event, { "prev_events", { prevs, 1 } }},
{ event, { "content", stringify(buf, content) }},
{ wrapper, { "event", stringify(buf, event) }},
}; };
event.~object();
top.~object();
return resource::response return resource::response
{ {
client, wrapper client, json::object
{
out.completed()
}
}; };
} }