/* This file is part of Telegram Desktop, the official desktop version of Telegram messaging app, see https://telegram.org Telegram Desktop is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. It is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. In addition, as a special exception, the copyright holders give permission to link the code of portions of this program with the OpenSSL library. Full license: https://github.com/telegramdesktop/tdesktop/blob/master/LICENSE Copyright (c) 2014-2017 John Preston, https://desktop.telegram.org */ #include "info/profile/info_profile_members_controllers.h" #include #include "base/weak_unique_ptr.h" #include "profile/profile_channel_controllers.h" #include "ui/widgets/popup_menu.h" #include "lang/lang_keys.h" #include "apiwrap.h" #include "auth_session.h" #include "mainwidget.h" #include "observer_peer.h" #include "boxes/confirm_box.h" #include "window/window_controller.h" #include "styles/style_info.h" namespace Info { namespace Profile { namespace { constexpr auto kSortByOnlineDelay = TimeMs(1000); class ChatMembersController : public PeerListController , private base::Subscriber , public base::enable_weak_from_this { public: ChatMembersController( not_null window, not_null chat); void prepare() override; void rowClicked(not_null row) override; void rowActionClicked(not_null row) override; Ui::PopupMenu *rowContextMenu( not_null row) override; rpl::producer onlineCountValue() const override { return _onlineCount.value(); } std::unique_ptr createRestoredRow( not_null peer) override; std::unique_ptr saveState() override; void restoreState(std::unique_ptr state) override; private: using Rights = MemberListRow::Rights; using Type = MemberListRow::Type; struct SavedState : SavedStateBase { rpl::lifetime lifetime; }; void rebuildRows(); void rebuildRowTypes(); void refreshOnlineCount(); std::unique_ptr createRow( not_null user); void sortByOnline(); void sortByOnlineDelayed(); void removeMember(not_null user); Type computeType(not_null user); not_null _window; not_null _chat; base::Timer _sortByOnlineTimer; rpl::variable _onlineCount = 0; }; ChatMembersController::ChatMembersController( not_null window, not_null chat) : PeerListController() , _window(window) , _chat(chat) { _sortByOnlineTimer.setCallback([this] { sortByOnline(); }); } void ChatMembersController::prepare() { setSearchNoResultsText(lang(lng_blocked_list_not_found)); delegate()->peerListSetSearchMode(PeerListSearchMode::Enabled); delegate()->peerListSetTitle(langFactory(lng_channel_admins)); rebuildRows(); if (!delegate()->peerListFullRowsCount()) { Auth().api().requestFullPeer(_chat); } using UpdateFlag = Notify::PeerUpdate::Flag; subscribe(Notify::PeerUpdated(), Notify::PeerUpdatedHandler( UpdateFlag::MembersChanged | UpdateFlag::UserOnlineChanged | UpdateFlag::AdminsChanged, [this](const Notify::PeerUpdate &update) { if (update.flags & UpdateFlag::MembersChanged) { if (update.peer == _chat) { rebuildRows(); } } else if (update.flags & UpdateFlag::AdminsChanged) { if (update.peer == _chat) { rebuildRowTypes(); } } else if (update.flags & UpdateFlag::UserOnlineChanged) { if (auto row = delegate()->peerListFindRow( update.peer->id)) { row->refreshStatus(); sortByOnlineDelayed(); } } })); } void ChatMembersController::sortByOnlineDelayed() { if (!_sortByOnlineTimer.isActive()) { _sortByOnlineTimer.callOnce(kSortByOnlineDelay); } } void ChatMembersController::sortByOnline() { auto now = unixtime(); delegate()->peerListSortRows([now]( const PeerListRow &a, const PeerListRow &b) { return App::onlineForSort(a.peer()->asUser(), now) > App::onlineForSort(b.peer()->asUser(), now); }); refreshOnlineCount(); } std::unique_ptr ChatMembersController::saveState() { auto result = PeerListController::saveState(); auto my = std::make_unique(); using Flag = Notify::PeerUpdate::Flag; Notify::PeerUpdateViewer(_chat, Flag::MembersChanged) | rpl::start_with_next([state = result.get()](auto update) { state->controllerState = nullptr; }, my->lifetime); result->controllerState = std::move(my); return result; } void ChatMembersController::restoreState( std::unique_ptr state) { PeerListController::restoreState(std::move(state)); sortByOnline(); } void ChatMembersController::rebuildRows() { if (_chat->participants.empty()) { // We get such updates often // (when participants list was invalidated). //while (delegate()->peerListFullRowsCount() > 0) { // delegate()->peerListRemoveRow( // delegate()->peerListRowAt(0)); //} return; } auto &participants = _chat->participants; for (auto i = 0, count = delegate()->peerListFullRowsCount(); i != count;) { auto row = delegate()->peerListRowAt(i); auto user = row->peer()->asUser(); if (participants.contains(user)) { ++i; } else { delegate()->peerListRemoveRow(row); --count; } } for (auto i = participants.cbegin(), e = participants.cend(); i != e; ++i) { if (auto row = createRow(i.key())) { delegate()->peerListAppendRow(std::move(row)); } } sortByOnline(); delegate()->peerListRefreshRows(); } void ChatMembersController::rebuildRowTypes() { auto count = delegate()->peerListFullRowsCount(); for (auto i = 0; i != count; ++i) { auto row = static_cast( delegate()->peerListRowAt(i).get()); row->setType(computeType(row->user())); } delegate()->peerListRefreshRows(); } void ChatMembersController::refreshOnlineCount() { auto now = unixtime(); auto left = 0, right = delegate()->peerListFullRowsCount(); while (right > left) { auto middle = (left + right) / 2; auto row = delegate()->peerListRowAt(middle); if (App::onlineColorUse(row->peer()->asUser(), now)) { left = middle + 1; } else { right = middle; } } _onlineCount = left; } std::unique_ptr ChatMembersController::createRestoredRow( not_null peer) { if (auto user = peer->asUser()) { return createRow(user); } return nullptr; } std::unique_ptr ChatMembersController::createRow( not_null user) { return std::make_unique(user, computeType(user)); } auto ChatMembersController::computeType( not_null user) -> Type { auto isCreator = (peerFromUser(_chat->creator) == user->id); auto isAdmin = _chat->adminsEnabled() && _chat->admins.contains(user); auto canRemove = [&] { if (user->isSelf()) { return false; } else if (_chat->amCreator()) { return true; } else if (isAdmin || isCreator) { return false; } else if (_chat->amAdmin()) { return true; } else if (_chat->invitedByMe.contains(user)) { return true; } return false; }(); auto result = Type(); result.rights = isCreator ? Rights::Creator : isAdmin ? Rights::Admin : Rights::Normal; result.canRemove = canRemove; return result; } void ChatMembersController::rowClicked(not_null row) { _window->showPeerInfo(row->peer()); } void ChatMembersController::rowActionClicked( not_null row) { removeMember(row->peer()->asUser()); } Ui::PopupMenu *ChatMembersController::rowContextMenu( not_null row) { auto my = static_cast(row.get()); auto user = my->user(); auto canRemoveMember = my->canRemove(); auto result = new Ui::PopupMenu(nullptr); result->addAction( lang(lng_context_view_profile), [weak = base::make_weak_unique(this), user] { if (weak) { weak->_window->showPeerInfo(user); } }); if (canRemoveMember) { result->addAction( lang(lng_context_remove_from_group), [weak = base::make_weak_unique(this), user] { if (weak) { weak->removeMember(user); } }); } return result; } void ChatMembersController::removeMember(not_null user) { auto text = lng_profile_sure_kick(lt_user, user->firstName); Ui::show(Box(text, lang(lng_box_remove), [user, chat = _chat] { Ui::hideLayer(); if (App::main()) App::main()->kickParticipant(chat, user); })); } } // namespace MemberListRow::MemberListRow( not_null user, Type type) : PeerListRow(user) , _type(type) { } void MemberListRow::setType(Type type) { _type = type; } QSize MemberListRow::actionSize() const { return canRemove() ? QRect( QPoint(), st::infoMembersRemoveIcon.size()).marginsAdded( st::infoMembersRemoveIconMargins).size() : QSize(); } void MemberListRow::paintAction( Painter &p, TimeMs ms, int x, int y, int outerWidth, bool selected, bool actionSelected) { if (_type.canRemove && selected) { x += st::infoMembersRemoveIconMargins.left(); y += st::infoMembersRemoveIconMargins.top(); (actionSelected ? st::infoMembersRemoveIconOver : st::infoMembersRemoveIcon).paint(p, x, y, outerWidth); } } int MemberListRow::nameIconWidth() const { return (_type.rights == Rights::Admin) ? st::infoMembersAdminIcon.width() : (_type.rights == Rights::Creator) ? st::infoMembersCreatorIcon.width() : 0; } void MemberListRow::paintNameIcon( Painter &p, int x, int y, int outerWidth, bool selected) { auto icon = [&] { return (_type.rights == Rights::Admin) ? (selected ? &st::infoMembersAdminIconOver : &st::infoMembersAdminIcon) : (selected ? &st::infoMembersCreatorIconOver : &st::infoMembersCreatorIcon); }(); icon->paint(p, x, y, outerWidth); } std::unique_ptr CreateMembersController( not_null window, not_null peer) { if (auto chat = peer->asChat()) { return std::make_unique( window, chat); } else if (auto channel = peer->asChannel()) { using ChannelMembersController = ::Profile::ParticipantsBoxController; return std::make_unique( window, channel, ChannelMembersController::Role::Profile); } Unexpected("Peer type in CreateMembersController()"); } } // namespace Profile } // namespace Info