awesome-bookmarks/tdesktop-dpi-fix-patch-example
3
0
Fork 0
mirror of https://github.com/Qz3rK/tdesktop.git synced 2026-07-03 14:15:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

Use translation providers for chat translation with parallel requests

Browse Source 
Co-Authored-By: Codex <codex@openai.com>
This commit is contained in:
Ilya Fedin
2026-03-06 10:24:31 +00:00
committed by John Preston
parent f0a47c8769
commit 87ef5d06df
2 changed files with 53 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Telegram/SourceFiles/history/view/history_view_translate_tracker.cpp
+47 -45
View File
@@ -8,7 +8,6 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
#include "history/view/history_view_translate_tracker.h"
#include "apiwrap.h"
#include "api/api_text_entities.h"
#include "api/api_transcribes.h"
#include "core/application.h"
#include "core/core_settings.h"
@@ -21,6 +20,7 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
#include "history/history_item.h"
#include "history/history_item_components.h"
#include "history/view/history_view_element.h"
#include "lang/translate_provider.h"
#include "main/main_session.h"
#include "spellcheck/platform/platform_language.h"
@@ -37,6 +37,7 @@ constexpr auto kRequestCountLimit = 20;
TranslateTracker::TranslateTracker(not_null<History*> history)
: _history(history)
, _provider(Ui::CreateTranslateProvider(&_history->session()))
, _limit(kEnoughForRecognition) {
setup();
}
@@ -236,19 +237,20 @@ void TranslateTracker::cancelToRequest() {
}
void TranslateTracker::cancelSentRequest() {
if (_requestId) {
if (_requestInProcess) {
const auto owner = &_history->owner();
for (const auto &id : base::take(_requested)) {
if (const auto item = owner->message(id)) {
item->translationShowRequiresRequest({});
}
}
_history->session().api().request(base::take(_requestId)).cancel();
++_requestToken;
_requestInProcess = false;
}
}
void TranslateTracker::requestSome() {
if (_requestId || _itemsToRequest.empty()) {
if (_requestInProcess || _itemsToRequest.empty()) {
return;
}
const auto to = _history->translatedTo();
@@ -260,60 +262,60 @@ void TranslateTracker::requestSome() {
_requested.reserve(_itemsToRequest.size());
const auto session = &_history->session();
const auto peerId = _itemsToRequest.back().first.peer;
auto peer = (peerId == _history->peer->id)
? _history->peer
: session->data().peer(peerId);
auto length = 0;
auto list = QVector<MTPint>();
list.reserve(_itemsToRequest.size());
for (auto i = _itemsToRequest.end(); i != _itemsToRequest.begin();) {
if ((--i)->first.peer != peerId) {
break;
}
length += i->second.length;
_requested.push_back(i->first);
list.push_back(MTP_int(i->first.msg));
i = _itemsToRequest.erase(i);
if (list.size() >= kRequestCountLimit
if (_requested.size() >= kRequestCountLimit
|| length >= kRequestLengthLimit) {
break;
}
}
using Flag = MTPmessages_TranslateText::Flag;
_requestId = session->api().request(MTPmessages_TranslateText(
MTP_flags(Flag::f_peer | Flag::f_id),
peer->input(),
MTP_vector<MTPint>(list),
MTPVector<MTPTextWithEntities>(),
MTP_string(to.twoLetterCode())
)).done([=](const MTPmessages_TranslatedText &result) {
requestDone(to, result.data().vresult().v);
}).fail([=] {
requestDone(to, {});
}).send();
}
void TranslateTracker::requestDone(
LanguageId to,
const QVector<MTPTextWithEntities> &list) {
auto index = 0;
const auto session = &_history->session();
const auto owner = &session->data();
for (const auto &id : base::take(_requested)) {
if (const auto item = owner->message(id)) {
const auto data = (index >= list.size())
? nullptr
: &list[index].data();
auto text = data ? TextWithEntities{
qs(data->vtext()),
Api::EntitiesFromMTP(session, data->ventities().v)
} : TextWithEntities();
item->translationDone(to, std::move(text));
}
++index;
if (_requested.empty()) {
return;
}
const auto owner = &session->data();
_requestInProcess = true;
const auto requestToken = ++_requestToken;
const auto remaining = std::make_shared<int>(_requested.size());
for (const auto &id : _requested) {
const auto item = owner->message(id);
if (!item) {
if (!--*remaining) {
_requestInProcess = false;
_requested.clear();
requestSome();
}
continue;
}
auto request = Ui::PrepareTranslateProviderRequest(
_provider.get(),
session->data().peer(id.peer),
id.msg,
item->originalText());
_provider->request(
std::move(request),
to,
[=](Ui::TranslateProviderResult result) {
if (!_requestInProcess || (_requestToken != requestToken)) {
return;
}
if (const auto item = owner->message(id)) {
item->translationDone(
to,
result.text.value_or(TextWithEntities()));
}
if (!--*remaining) {
_requestInProcess = false;
_requested.clear();
requestSome();
}
});
}
_requestId = 0;
requestSome();
}
void TranslateTracker::applyLimit() {
Telegram/SourceFiles/history/view/history_view_translate_tracker.h
+6 -5
View File
@@ -11,6 +11,9 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
class History;
class HistoryItem;
namespace Ui {
class TranslateProvider;
} // namespace Ui
namespace HistoryView {
@@ -54,11 +57,8 @@ private:
void cancelSentRequest();
void switchTranslation(not_null<HistoryItem*> item, LanguageId id);
void requestDone(
LanguageId to,
const QVector<MTPTextWithEntities> &list);
const not_null<History*> _history;
const std::unique_ptr<Ui::TranslateProvider> _provider;
rpl::variable<bool> _trackingLanguage = false;
base::flat_map<FullMsgId, ItemForRecognize> _itemsForRecognize;
uint64 _generation = 0;
@@ -70,7 +70,8 @@ private:
base::flat_map<not_null<HistoryItem*>, LanguageId> _switchTranslations;
base::flat_map<FullMsgId, ItemToRequest> _itemsToRequest;
std::vector<FullMsgId> _requested;
mtpRequestId _requestId = 0;
uint64 _requestToken = 0;
bool _requestInProcess = false;
rpl::lifetime _trackingLifetime;
rpl::lifetime _lifetime;