134 lines
3.1 KiB
C++
134 lines
3.1 KiB
C++
/*
|
|
This file is part of Telegram Desktop,
|
|
the official desktop application for the Telegram messaging service.
|
|
|
|
For license and copyright information please follow this link:
|
|
https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
|
|
*/
|
|
#include "api/api_websites.h"
|
|
|
|
#include "api/api_authorizations.h"
|
|
#include "api/api_blocked_peers.h"
|
|
#include "apiwrap.h"
|
|
#include "data/data_session.h"
|
|
#include "data/data_user.h"
|
|
#include "main/main_session.h"
|
|
|
|
namespace Api {
|
|
namespace {
|
|
|
|
[[nodiscard]] Websites::Entry ParseEntry(
|
|
not_null<Data::Session*> owner,
|
|
const MTPDwebAuthorization &data) {
|
|
auto result = Websites::Entry{
|
|
.hash = data.vhash().v,
|
|
.bot = owner->user(data.vbot_id()),
|
|
.platform = qs(data.vplatform()),
|
|
.domain = qs(data.vdomain()),
|
|
.browser = qs(data.vbrowser()),
|
|
.ip = qs(data.vip()),
|
|
.location = qs(data.vregion()),
|
|
};
|
|
result.activeTime = data.vdate_active().v
|
|
? data.vdate_active().v
|
|
: data.vdate_created().v;
|
|
result.active = Authorizations::ActiveDateString(result.activeTime);
|
|
return result;
|
|
}
|
|
|
|
} // namespace
|
|
|
|
Websites::Websites(not_null<ApiWrap*> api)
|
|
: _session(&api->session())
|
|
, _api(&api->instance()) {
|
|
}
|
|
|
|
void Websites::reload() {
|
|
if (_requestId) {
|
|
return;
|
|
}
|
|
|
|
_requestId = _api.request(MTPaccount_GetWebAuthorizations(
|
|
)).done([=](const MTPaccount_WebAuthorizations &result) {
|
|
_requestId = 0;
|
|
_lastReceived = crl::now();
|
|
const auto owner = &_session->data();
|
|
const auto &data = result.data();
|
|
owner->processUsers(data.vusers());
|
|
_list = ranges::views::all(
|
|
data.vauthorizations().v
|
|
) | ranges::views::transform([&](const MTPwebAuthorization &auth) {
|
|
return ParseEntry(owner, auth.data());
|
|
}) | ranges::to<List>;
|
|
_listChanges.fire({});
|
|
}).fail([=] {
|
|
_requestId = 0;
|
|
}).send();
|
|
}
|
|
|
|
void Websites::cancelCurrentRequest() {
|
|
_api.request(base::take(_requestId)).cancel();
|
|
}
|
|
|
|
void Websites::requestTerminate(
|
|
Fn<void(const MTPBool &result)> &&done,
|
|
Fn<void(const MTP::Error &error)> &&fail,
|
|
std::optional<uint64> hash,
|
|
UserData *botToBlock) {
|
|
const auto send = [&](auto request) {
|
|
_api.request(
|
|
std::move(request)
|
|
).done([=, done = std::move(done)](const MTPBool &result) {
|
|
done(result);
|
|
if (hash) {
|
|
_list.erase(
|
|
ranges::remove(_list, *hash, &Entry::hash),
|
|
end(_list));
|
|
} else {
|
|
_list.clear();
|
|
}
|
|
_listChanges.fire({});
|
|
}).fail(
|
|
std::move(fail)
|
|
).send();
|
|
};
|
|
if (hash) {
|
|
send(MTPaccount_ResetWebAuthorization(MTP_long(*hash)));
|
|
if (botToBlock) {
|
|
botToBlock->session().api().blockedPeers().block(botToBlock);
|
|
}
|
|
} else {
|
|
send(MTPaccount_ResetWebAuthorizations());
|
|
}
|
|
}
|
|
|
|
Websites::List Websites::list() const {
|
|
return _list;
|
|
}
|
|
|
|
auto Websites::listValue() const
|
|
-> rpl::producer<Websites::List> {
|
|
return rpl::single(
|
|
list()
|
|
) | rpl::then(
|
|
_listChanges.events() | rpl::map([=] { return list(); })
|
|
);
|
|
}
|
|
|
|
rpl::producer<int> Websites::totalValue() const {
|
|
return rpl::single(
|
|
total()
|
|
) | rpl::then(
|
|
_listChanges.events() | rpl::map([=] { return total(); })
|
|
);
|
|
}
|
|
|
|
int Websites::total() const {
|
|
return _list.size();
|
|
}
|
|
|
|
crl::time Websites::lastReceivedTime() {
|
|
return _lastReceived;
|
|
}
|
|
|
|
} // namespace Api
|