0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-24 14:34:00 +01:00
construct/modules/m_user_events.cc
2019-08-30 14:43:19 -07:00

86 lines
1.6 KiB
C++

// Matrix Construct
//
// Copyright (C) Matrix Construct Developers, Authors & Contributors
// Copyright (C) 2016-2019 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.
ircd::mapi::header
IRCD_MODULE
{
"Matrix events for a user."
};
IRCD_MODULE_EXPORT
ircd::m::user::events::events(const m::user &user)
:user{user}
{
}
size_t
IRCD_MODULE_EXPORT
ircd::m::user::events::count()
const
{
size_t ret{0};
for_each([&ret](const event::idx &)
{
++ret;
return true;
});
return ret;
}
bool
IRCD_MODULE_EXPORT
ircd::m::user::events::for_each(const closure_bool &closure)
const
{
m::event::fetch event;
return for_each([&closure, &event]
(const event::idx &event_idx)
{
if(!seek(event, event_idx, std::nothrow))
return true;
return closure(event);
});
}
bool
IRCD_MODULE_EXPORT
ircd::m::user::events::for_each(const idx_closure_bool &closure)
const
{
const m::user::rooms rooms
{
user
};
return rooms.for_each(rooms::closure_bool{[this, &closure]
(const m::room &room, const string_view &membership)
{
m::room::events it
{
room
};
bool ret{true};
for(; ret && it; --it)
{
const auto &idx{it.event_idx()};
m::get(std::nothrow, idx, "sender", [this, &closure, &idx, &ret]
(const string_view &sender)
{
if(sender == this->user.user_id)
ret = closure(idx);
});
}
return ret;
}});
}