Discuz! Board

 找回密码
 立即注册
搜索
热搜: 活动 交友 discuz
查看: 1257|回复: 4
打印 上一主题 下一主题

联系人获取存放逻辑

[复制链接]

1228

主题

1997

帖子

7580

积分

认证用户组

Rank: 5Rank: 5

积分
7580
跳转到指定楼层
楼主
发表于 2020-3-20 17:03:57 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式
本帖最后由 Qter 于 2020-3-26 09:36 编辑

void DialogsWidget::dialogsReceived(..){
Auth().api().requestContacts(); }
void ApiWrap::requestContacts() {
        if (_session->data().contactsLoaded().value() || _contactsRequestId) {
                return;
        }
        _contactsRequestId = request(MTPcontacts_GetContacts(
                MTP_int(0)
        )).done([=](const MTPcontacts_Contacts &result) {
                _contactsRequestId = 0;
                if (result.type() == mtpc_contacts_contactsNotModified) {
                        return;
                }
                Assert(result.type() == mtpc_contacts_contacts);
                const auto &d = result.c_contacts_contacts();
                _session->data().processUsers(d.vusers);
                for (const auto &contact : d.vcontacts.v) {
                        if (contact.type() != mtpc_contact) continue;

                        const auto userId = contact.c_contact().vuser_id.v;
                        if (userId == _session->userId()) {
                                _session->user()->setContactStatus(
                                        UserData::ContactStatus::Contact);
                        }
                }
                _session->data().contactsLoaded().set(true);
        }).fail([=](const RPCError &error) {
                _contactsRequestId = 0;
        }).send();
}

session
App::main() --> mainwidget.h

Dialogs::IndexedList *MainWidget::contactsList() {
        return _dialogs->contactsList();
}

        object_ptr<DialogsWidget> _dialogs;

DialogsWidget
return _inner->contactsList();
QPointer<DialogsInner> _inner;
return _contacts.get();
std::unique_ptr<Dialogs::IndexedList> _contacts;

        QMap<uint64, QSet<uint64>> _mapUser2Group;

////////////////
void MainWidget::start() {
MTP::send(MTPupdates_GetState(), rpcDone(&MainWidget::gotState));
/////////////////////////
/////////////////
DialogsWidget:ialogsWidget
构造函数中调用loadDialogs

void DialogsWidget::loadDialogs() {
        _dialogsRequestId = MTP::send(
                MTPmessages_GetDialogs(
                        MTP_flags(flags),
                        //MTP_int(feedId), // #feed
                        MTP_int(_dialogsOffsetDate),
                        MTP_int(_dialogsOffsetId),
                        _dialogsOffsetPeer
                                ? _dialogsOffsetPeer->input
                                : MTP_inputPeerEmpty(),
                        MTP_int(loadCount),
                        MTP_int(hash)),
                rpcDone(&DialogsWidget::dialogsReceived),
                rpcFail(&DialogsWidget::dialogsFailed));
        if (!_pinnedDialogsReceived) {
                loadPinnedDialogs();
        }
        refreshLoadMoreButton();
}

/////////////////
DialogsWidget:ialogsWidget
在构造函数中调用
////////////






回复

使用道具 举报

1228

主题

1997

帖子

7580

积分

认证用户组

Rank: 5Rank: 5

积分
7580
沙发
 楼主| 发表于 2020-3-20 17:13:02 | 只看该作者
contacts.getContacts#c023849f hash:int = contacts.Contacts;

contacts.contacts#eae87e42 contacts:Vector<Contact> saved_count:int users:Vector<User> = contacts.Contacts;

contact#f911c994 user_id:int mutual:Bool = Contact;

回复 支持 反对

使用道具 举报

1228

主题

1997

帖子

7580

积分

认证用户组

Rank: 5Rank: 5

积分
7580
板凳
 楼主| 发表于 2020-3-20 17:37:43 | 只看该作者
void ContactsBoxController::prepare() {
        setSearchNoResultsText(lang(lng_blocked_list_not_found));
        delegate()->peerListSetSearchMode(PeerListSearchMode::Enabled);
        delegate()->peerListSetTitle(langFactory(lng_contacts_header));

        prepareViewHook();

        rebuildRows();

        auto &sessionData = Auth().data();
        subscribe(sessionData.contactsLoaded(), [this](bool loaded) {
                rebuildRows();
        });
}

回复 支持 反对

使用道具 举报

1228

主题

1997

帖子

7580

积分

认证用户组

Rank: 5Rank: 5

积分
7580
地板
 楼主| 发表于 2020-3-20 17:54:36 | 只看该作者
本帖最后由 Qter 于 2020-3-20 18:00 编辑

Auth().data().notifySavedGifsUpdated();

Global::RefDownloadPathChanged().notify();

base::Observable<void> _changed;
_changed.notify();

base::Observable<State> _stateChanged;
_stateChanged.notify(state, true);


Auth().data().notifyStickersUpdated();
_stickersUpdated.fire({});
rpl::event_stream<> _stickersUpdated;
return _stickersUpdated.events();
  1. subscribe(Notify::PeerUpdated(), Notify::PeerUpdatedHandler(observeEvents, [this](const Notify::PeerUpdate &update) {
  2.                 notifyPeerUpdated(update);
  3.         }));
复制代码
subscribe(Auth().downloaderTaskFinished(), [this] { update(); });base::Observable<void> &AuthSession::downloaderTaskFinished() {
        return downloader().taskFinished();
}


base::Observable<void> &downloaderTaskFinished();
回复 支持 反对

使用道具 举报

1228

主题

1997

帖子

7580

积分

认证用户组

Rank: 5Rank: 5

积分
7580
5#
 楼主| 发表于 2020-3-20 18:07:42 | 只看该作者
本帖最后由 Qter 于 2020-3-20 18:49 编辑

1.在\Telegram\SourceFiles\auth_session.h这里加一份  ---添加要不要对chatlist中添加的判断
与服端定期同步时,对比有没有变化?---服务端有变化时,主动推送,推送了就一定有改变,这里不用保存数据,只发送订阅通知出去就行
2.在\Telegram\SourceFiles\dialogs\dialogs_inner_widget.h中添加一份
这里保存一份数据,用于界面显示,服务端有更新时,自动写入这里

3.对于本地修改分组的情况
要发送通知出去,更改2中的本地缓存? 还是等待服务端推送过来这次修改的变化,然后拉取全新数据,等全新数据拉取完后,再更新。
回复 支持 反对

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|Archiver|手机版|小黑屋|firemail ( 粤ICP备15085507号-1 )

GMT+8, 2024-4-30 01:44 , Processed in 0.058638 second(s), 18 queries .

Powered by Discuz! X3

© 2001-2013 Comsenz Inc.

快速回复 返回顶部 返回列表