91 lines
2.1 KiB
C++
91 lines
2.1 KiB
C++
// The 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.
|
|
|
|
decltype(ircd::m::room::messages::fopts)
|
|
ircd::m::room::messages::fopts
|
|
{
|
|
event::keys::include
|
|
{
|
|
"content",
|
|
},
|
|
};
|
|
|
|
bool
|
|
ircd::m::room::messages::for_each(const closure &closure)
|
|
const
|
|
{
|
|
event::fetch event{fopts}, replace{fopts};
|
|
return events.for_each([this, &closure, &event, &replace]
|
|
(const string_view &type, const uint64_t &depth, event::idx event_idx)
|
|
{
|
|
assert(type == "m.room.message");
|
|
if(!redacted && m::redacted(event_idx))
|
|
return true;
|
|
|
|
if(!seek(std::nothrow, event, event_idx))
|
|
return true;
|
|
|
|
room::message msg
|
|
{
|
|
json::get<"content"_>(event)
|
|
};
|
|
|
|
// Don't show messages which edit other messages, since we will or
|
|
// already have rendered it at the edited message, if we have it,
|
|
// otherwise ignored.
|
|
if(msg.replace_event())
|
|
return true;
|
|
|
|
m::replace(msg, replace, event_idx);
|
|
return closure(msg, depth, event_idx);
|
|
});
|
|
}
|
|
|
|
bool
|
|
ircd::m::replace(room::message &msg,
|
|
event::fetch &replace,
|
|
const event::idx &event_idx)
|
|
{
|
|
// Find the latest edit of this; otherwise stick with the original.
|
|
const m::replaced replaced
|
|
{
|
|
event_idx, m::replaced::latest
|
|
};
|
|
|
|
const event::idx &replace_idx
|
|
{
|
|
replaced
|
|
};
|
|
|
|
if(!replace_idx)
|
|
return false;
|
|
|
|
if(!seek(std::nothrow, replace, replace_idx))
|
|
return false;
|
|
|
|
const json::object replace_content
|
|
{
|
|
json::get<"content"_>(replace)
|
|
};
|
|
|
|
const json::object new_content
|
|
{
|
|
replace_content.get("m.new_content")
|
|
};
|
|
|
|
// XXX When m.new_content is undefined the edit does not take place.
|
|
if(!new_content && !replace_content.has("m.new_content"))
|
|
return false;
|
|
|
|
// If the content was replaced msg has to be updated.
|
|
msg = new_content;
|
|
return true;
|
|
}
|