Update User-Agent for DNS to Chrome 130.0.0.0.

Telegram/CMakeLists.txt

@@ -617,6 +617,8 @@ PRIVATE
     data/data_saved_sublist.h
     data/data_search_controller.cpp
     data/data_search_controller.h
+    data/data_secret_chat.cpp
+    data/data_secret_chat.h
     data/data_send_action.cpp
     data/data_send_action.h
     data/data_session.cpp
@@ -1160,6 +1162,8 @@ PRIVATE
     media/streaming/media_streaming_loader_local.h
     media/streaming/media_streaming_loader_mtproto.cpp
     media/streaming/media_streaming_loader_mtproto.h
+    media/streaming/media_streaming_loader_tdb.cpp
+    media/streaming/media_streaming_loader_tdb.h
     media/streaming/media_streaming_player.cpp
     media/streaming/media_streaming_player.h
     media/streaming/media_streaming_reader.cpp
@@ -1231,6 +1235,7 @@ PRIVATE
     overview/overview_layout.cpp
     overview/overview_layout.h
     overview/overview_layout_delegate.h
+    passport/passport_common.h
     passport/passport_encryption.cpp
     passport/passport_encryption.h
     passport/passport_form_controller.cpp
@@ -1449,6 +1454,8 @@ PRIVATE
     storage/file_download.h
     storage/file_download_mtproto.cpp
     storage/file_download_mtproto.h
+    storage/file_download_tdb.cpp
+    storage/file_download_tdb.h
     storage/file_download_web.cpp
     storage/file_download_web.h
     storage/file_upload.cpp

Telegram/SourceFiles/_other/packer.cpp

@@ -495,11 +495,11 @@ int main(int argc, char *argv[])
 	cout << "Signature verified!\n";
 	RSA_free(pbKey);
 #ifdef Q_OS_WIN
-	QString outName((targetwinarm ? QString("tarm64upd%1") : targetwin64 ? QString("tx64upd%1") : QString("tupdate%1")).arg(AlphaVersion ? AlphaVersion : version));
+	QString outName((targetwinarm ? QString("update-win-arm-%1") : targetwin64 ? QString("update-win-x64-%1") : QString("update-win-x86-%1")).arg(AlphaVersion ? AlphaVersion : version));
 #elif defined Q_OS_MAC
-	QString outName((targetarmac ? QString("tarmacupd%1") : QString("tmacupd%1")).arg(AlphaVersion ? AlphaVersion : version));
+	QString outName((targetarmac ? QString("update-mac-arm-%1") : QString("update-mac-x64-%1")).arg(AlphaVersion ? AlphaVersion : version));
 #else
-	QString outName(QString("tlinuxupd%1").arg(AlphaVersion ? AlphaVersion : version));
+	QString outName(QString("update-linux-x64-%1").arg(AlphaVersion ? AlphaVersion : version));
 #endif
 	if (AlphaVersion) {
 		outName += "_" + AlphaSignature;

Telegram/SourceFiles/api/api_attached_stickers.cpp

@@ -16,12 +16,17 @@ For license and copyright information please follow this link:
 #include "lang/lang_keys.h"
 #include "window/window_session_controller.h"
 
+#include "tdb/tdb_tl_scheme.h"
+
 namespace Api {
 
+using namespace Tdb;
+
 AttachedStickers::AttachedStickers(not_null<ApiWrap*> api)
 : _api(&api->instance()) {
 }
 
+#if 0 // mtp
 void AttachedStickers::request(
 		not_null<Window::SessionController*> controller,
 		MTPmessages_GetAttachedStickers &&mtpRequest) {
@@ -70,23 +75,80 @@ void AttachedStickers::request(
 		}
 	}).send();
 }
+#endif
+
+void AttachedStickers::request(
+		not_null<Window::SessionController*> controller,
+		FileId fileId) {
+	const auto weak = base::make_weak(controller.get());
+	_api.request(_requestId).cancel();
+	_requestId = _api.request(TLgetAttachedStickerSets(
+		tl_int32(fileId)
+	)).done([=](const TLstickerSets &result) {
+		_requestId = 0;
+		const auto strongController = weak.get();
+		if (!strongController) {
+			return;
+		}
+		const auto &data = result.data();
+		const auto &list = data.vsets().v;
+		if (list.isEmpty()) {
+			strongController->show(
+				Ui::MakeInformBox(tr::lng_stickers_not_found()));
+			return;
+		} else if (list.size() > 1) {
+			strongController->show(
+				Box<StickersBox>(
+					strongController->uiShow(),
+					data.vsets().v));
+			return;
+		}
+		// Single attached sticker pack.
+		const auto setId = StickerSetIdentifier{
+			.id = uint64(list.front().data().vid().v),
+		};
+		strongController->show(
+			Box<StickerSetBox>(
+				strongController->uiShow(),
+				setId,
+				Data::TypeFromTL(list.front().data().vsticker_type())),
+			Ui::LayerOption::KeepOther);
+	}).fail([=] {
+		_requestId = 0;
+		if (const auto strongController = weak.get()) {
+			strongController->show(
+				Ui::MakeInformBox(tr::lng_stickers_not_found()));
+		}
+	}).send();
+}
 
 void AttachedStickers::requestAttachedStickerSets(
 		not_null<Window::SessionController*> controller,
 		not_null<PhotoData*> photo) {
+#if 0 // mtp
 	request(
 		controller,
 		MTPmessages_GetAttachedStickers(
 			MTP_inputStickeredMediaPhoto(photo->mtpInput())));
+#endif
+	const auto &location = photo->location(Data::PhotoSize::Large).file();
+	if (const auto tdb = std::get_if<TdbFileLocation>(&location.data)) {
+		request(controller, tdb->fileId);
+	}
 }
 
 void AttachedStickers::requestAttachedStickerSets(
 		not_null<Window::SessionController*> controller,
 		not_null<DocumentData*> document) {
+#if 0 // mtp
 	request(
 		controller,
 		MTPmessages_GetAttachedStickers(
 			MTP_inputStickeredMediaDocument(document->mtpInput())));
+#endif
+	if (const auto fileId = document->tdbFileId()) {
+		request(controller, fileId);
+	}
 }
 
 } // namespace Api

Telegram/SourceFiles/api/api_attached_stickers.h

@@ -9,6 +9,8 @@ For license and copyright information please follow this link:
 
 #include "mtproto/sender.h"
 
+#include "tdb/tdb_request_id.h"
+
 class ApiWrap;
 class DocumentData;
 class PhotoData;
@@ -32,13 +34,19 @@ class AttachedStickers final {
 		not_null<DocumentData*> document);
 
 private:
+#if 0 // mtp
 	void request(
 		not_null<Window::SessionController*> controller,
 		MTPmessages_GetAttachedStickers &&mtpRequest);
+#endif
 
 	MTP::Sender _api;
 	mtpRequestId _requestId = 0;
 
+	void request(
+		not_null<Window::SessionController*> controller,
+		FileId fileId);
+
 };
 
 } // namespace Api

Telegram/SourceFiles/api/api_authorizations.cpp

@@ -14,13 +14,18 @@ For license and copyright information please follow this link:
 #include "core/core_settings.h"
 #include "lang/lang_keys.h"
 
+#include "tdb/tdb_tl_scheme.h"
+
 namespace Api {
 namespace {
 
+using namespace Tdb;
+
 constexpr auto TestApiId = 17349;
 constexpr auto SnapApiId = 611335;
 constexpr auto DesktopApiId = 2040;
 
+#if 0 // goodToRemove
 Authorizations::Entry ParseEntry(const MTPDauthorization &data) {
 	auto result = Authorizations::Entry();
 
@@ -79,6 +84,72 @@ Authorizations::Entry ParseEntry(const MTPDauthorization &data) {
 
 	return result;
 }
+#endif
+
+Authorizations::Entry ParseEntry(const Tdb::TLDsession &data) {
+	auto result = Authorizations::Entry();
+
+	result.hash = data.vis_current().v ? 0 : data.vid().v;
+	result.incomplete = data.vis_password_pending().v;
+
+	const auto apiId = data.vapi_id().v;
+	const auto isTest = (apiId == TestApiId);
+	const auto isDesktop = (apiId == DesktopApiId) || isTest;
+
+	const auto appName = isDesktop
+		? QString("Telegram Desktop%1").arg(isTest ? " (GitHub)" : QString())
+		: data.vapplication_name().v;
+	const auto appVer = [&] {
+		const auto version = data.vapplication_version().v;
+		if (isDesktop) {
+			const auto verInt = version.toInt();
+			if (version == QString::number(verInt)) {
+				return Core::FormatVersionDisplay(verInt);
+			}
+		} else {
+			if (const auto index = version.indexOf('('); index >= 0) {
+				return version.mid(index);
+			}
+		}
+		return version;
+	}();
+
+	result.name = result.hash
+		? data.vdevice_model().v
+		: Core::App().settings().deviceModel();
+	result.system = data.vsystem_version().v;
+	result.platform = data.vplatform().v;
+	result.activeTime = data.vlast_active_date().v
+		? data.vlast_active_date().v
+		: data.vlog_in_date().v;
+	result.info = QString("%1%2").arg(
+		appName,
+		appVer.isEmpty() ? QString() : (' ' + appVer));
+	result.ip = data.vip_address().v;
+	if (!result.hash) {
+		result.active = tr::lng_status_online(tr::now);
+	} else {
+		const auto now = QDateTime::currentDateTime();
+		const auto lastTime = base::unixtime::parse(result.activeTime);
+		const auto nowDate = now.date();
+		const auto lastDate = lastTime.date();
+		if (lastDate == nowDate) {
+			result.active = QLocale().toString(
+				lastTime.time(),
+				QLocale::ShortFormat);
+		} else if (lastDate.year() == nowDate.year()
+			&& lastDate.weekNumber() == nowDate.weekNumber()) {
+			result.active = langDayOfWeek(lastDate);
+		} else {
+			result.active = QLocale().toString(
+				lastDate,
+				QLocale::ShortFormat);
+		}
+	}
+	result.location = data.vlocation().v;
+
+	return result;
+}
 
 } // namespace
 
@@ -108,6 +179,7 @@ void Authorizations::reload() {
 		return;
 	}
 
+#if 0 // goodToRemove
 	_requestId = _api.request(MTPaccount_GetAuthorizations(
 	)).done([=](const MTPaccount_Authorizations &result) {
 		_requestId = 0;
@@ -124,10 +196,30 @@ void Authorizations::reload() {
 	}).fail([=] {
 		_requestId = 0;
 	}).send();
+#endif
+
+	using namespace Tdb;
+	_requestId = _api.request(TLgetActiveSessions(
+	)).done([=](const TLDsessions &data) {
+		_requestId = 0;
+		_lastReceived = crl::now();
+		_ttlDays = data.vinactive_session_ttl_days().v;
+		_list = (
+			data.vsessions().v
+		) | ranges::views::transform([](const TLsession &d) {
+			return ParseEntry(d.c_session());
+		}) | ranges::to<List>;
+		refreshCallsDisabledHereFromCloud();
+		_listChanges.fire({});
+	}).fail([=](const Error &error) {
+		_requestId = 0;
+	}).send();
 }
 
 void Authorizations::cancelCurrentRequest() {
+#if 0 // goodToRemove
 	_api.request(base::take(_requestId)).cancel();
+#endif
 }
 
 void Authorizations::refreshCallsDisabledHereFromCloud() {
@@ -138,6 +230,7 @@ void Authorizations::refreshCallsDisabledHereFromCloud() {
 	}
 }
 
+#if 0 // goodToRemove
 void Authorizations::requestTerminate(
 		Fn<void(const MTPBool &result)> &&done,
 		Fn<void(const MTP::Error &error)> &&fail,
@@ -167,6 +260,35 @@ void Authorizations::requestTerminate(
 		send(MTPauth_ResetAuthorizations());
 	}
 }
+#endif
+
+void Authorizations::requestTerminate(
+		Fn<void()> &&done,
+		Fn<void()> &&fail,
+		std::optional<uint64> hash) {
+	const auto send = [&](auto request) {
+		_api.request(
+			std::move(request)
+		).done([=, done = std::move(done)] {
+			done();
+			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(Tdb::TLterminateSession(Tdb::tl_int64(*hash)));
+	} else {
+		send(Tdb::TLterminateAllOtherSessions());
+	}
+}
 
 Authorizations::List Authorizations::list() const {
 	return _list;
@@ -191,8 +313,12 @@ rpl::producer<int> Authorizations::totalValue() const {
 
 void Authorizations::updateTTL(int days) {
 	_api.request(_ttlRequestId).cancel();
+#if 0 // mtp
 	_ttlRequestId = _api.request(MTPaccount_SetAuthorizationTTL(
 		MTP_int(days)
+#endif
+	_ttlRequestId = _api.request(TLsetInactiveSessionTtl(
+		tl_int32(days)
 	)).done([=] {
 		_ttlRequestId = 0;
 	}).fail([=] {
@@ -209,12 +335,17 @@ void Authorizations::toggleCallsDisabled(uint64 hash, bool disabled) {
 	if (const auto sent = _toggleCallsDisabledRequests.take(hash)) {
 		_api.request(*sent).cancel();
 	}
+#if 0 // mtp
 	using Flag = MTPaccount_ChangeAuthorizationSettings::Flag;
 	const auto id = _api.request(MTPaccount_ChangeAuthorizationSettings(
 		MTP_flags(Flag::f_call_requests_disabled),
 		MTP_long(hash),
 		MTPBool(), // encrypted_requests_disabled
 		MTP_bool(disabled)
+#endif
+	const auto id = _api.request(TLtoggleSessionCanAcceptCalls(
+		tl_int64(hash),
+		tl_bool(!disabled)
 	)).done([=] {
 		_toggleCallsDisabledRequests.remove(hash);
 	}).fail([=] {