82 lines
1.8 KiB
C++
82 lines
1.8 KiB
C++
// Matrix Construct
|
|
//
|
|
// Copyright (C) The Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2022 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
|
|
bool
|
|
ircd::m::trace::for_each(const event::idx &event_idx,
|
|
const closure &closure)
|
|
{
|
|
event::fetch event
|
|
{
|
|
std::nothrow, event_idx
|
|
};
|
|
|
|
if(!event.valid)
|
|
return true;
|
|
|
|
if(redacted(event))
|
|
return true;
|
|
|
|
room::messages messages
|
|
{
|
|
room::id{json::get<"room_id"_>(event)},
|
|
{
|
|
json::get<"depth"_>(event), -1L
|
|
}
|
|
};
|
|
|
|
bool ret(true), loop; do
|
|
{
|
|
loop = false;
|
|
messages.for_each([&closure, &event, &messages, &loop, &ret]
|
|
(const room::message &msg, const int64_t &depth, const event::idx &event_idx)
|
|
{
|
|
// Ignore messages at the same depth as the initial
|
|
if(event.event_idx != event_idx && depth == json::get<"depth"_>(event))
|
|
return true;
|
|
|
|
// Call user; check if they want to break iteration
|
|
if(!(ret = closure(event_idx, depth, msg)))
|
|
return false;
|
|
|
|
const auto reply_to_id
|
|
{
|
|
msg.reply_to_event()
|
|
};
|
|
|
|
// If this is not a reply continue to the prior message.
|
|
if(!reply_to_id)
|
|
return true;
|
|
|
|
// If we don't have the message being replied to, break here
|
|
if(!seek(std::nothrow, event, reply_to_id))
|
|
return false;
|
|
|
|
// The message replied to was redacted, break here.
|
|
if(redacted(event))
|
|
return false;
|
|
|
|
// Jump to the message being replied to
|
|
messages =
|
|
{
|
|
room::id{json::get<"room_id"_>(event)},
|
|
{
|
|
json::get<"depth"_>(event), -1L
|
|
}
|
|
};
|
|
|
|
loop = true;
|
|
return false;
|
|
});
|
|
}
|
|
while(ret && loop);
|
|
|
|
return ret;
|
|
}
|