MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-28 19:58:53 +02:00
Code Issues Releases Wiki Activity

modules/client/sync/rooms/state: Make the linear-sync handler able to handle belated state events.

Browse source
This commit is contained in:
Jason Volk 2019-06-08 01:05:50 -07:00
parent 5cfac64bee
commit 2e80a5ab02
1 changed files with 22 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
modules/client/sync/rooms/state.cc
View file

@ -22,6 +22,7 @@ namespace ircd::m::sync
static bool room_invite_state_linear(data &);
static bool room_state_linear(data &);
extern conf::item<int64_t> state_exposure_depth; //TODO: XXX
extern const event::keys::include _default_keys;
extern event::fetch::opts _default_fopts;
@ -95,27 +96,40 @@ ircd::m::sync::room_invite_state_linear(data &data)
return room_state_linear_events(data);
}
//TODO: This has to be merged into the timeline conf items
decltype(ircd::m::sync::state_exposure_depth)
ircd::m::sync::state_exposure_depth
{
{ "name", "ircd.client.sync.rooms.state.exposure.depth" },
{ "default", 20L },
};
bool
ircd::m::sync::room_state_linear_events(data &data)
{
// if since token is non-zero, any events in the range are
// included in the timeline array and not the state array.
if(data.range.first)
return false;
if(!data.event_idx)
return false;
if(!data.membership)
return false;
if(!data.room)
return false;
if(!data.membership)
return false;
assert(data.event);
if(!json::get<"state_key"_>(*data.event))
return false;
// Figure out whether the event was included in the timeline or whether
// to include it here in the state, which comes before the timeline.
// Since linear-sync is already distinct from polylog-sync, the
// overwhelming majority of state events coming through linear-sync will
// use the timeline. We make an exception for past state events the server
// only recently obtained, to hide them from the timeline.
if(int64_t(state_exposure_depth) > -1)
if(json::get<"depth"_>(*data.event) + int64_t(state_exposure_depth) >= data.room_depth)
return false;
json::stack::object rooms
{
*data.out, "rooms"