/* 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 "core/application.h" #include "data/data_photo.h" #include "data/data_document.h" #include "data/data_session.h" #include "data/data_user.h" #include "base/timer.h" #include "base/concurrent_timer.h" #include "base/unixtime.h" #include "core/update_checker.h" #include "core/shortcuts.h" #include "core/sandbox.h" #include "core/local_url_handlers.h" #include "core/launcher.h" #include "core/ui_integration.h" #include "chat_helpers/emoji_keywords.h" #include "base/platform/base_platform_info.h" #include "platform/platform_specific.h" #include "mainwindow.h" #include "dialogs/dialogs_entry.h" #include "history/history.h" #include "apiwrap.h" #include "api/api_updates.h" #include "calls/calls_instance.h" #include "lang/lang_file_parser.h" #include "lang/lang_translator.h" #include "lang/lang_cloud_manager.h" #include "lang/lang_hardcoded.h" #include "mainwidget.h" #include "core/file_utilities.h" #include "main/main_account.h" #include "main/main_accounts.h" #include "main/main_session.h" #include "media/view/media_view_overlay_widget.h" #include "mtproto/mtproto_dc_options.h" #include "mtproto/mtproto_config.h" #include "mtproto/mtp_instance.h" #include "media/audio/media_audio.h" #include "media/audio/media_audio_track.h" #include "media/player/media_player_instance.h" #include "media/clip/media_clip_reader.h" // For Media::Clip::Finish(). #include "window/notifications_manager.h" #include "window/themes/window_theme.h" #include "window/window_lock_widgets.h" #include "history/history_location_manager.h" #include "ui/widgets/tooltip.h" #include "ui/image/image.h" #include "ui/text_options.h" #include "ui/emoji_config.h" #include "ui/effects/animations.h" #include "storage/serialize_common.h" #include "storage/storage_accounts.h" #include "storage/storage_databases.h" #include "storage/localstorage.h" #include "window/window_session_controller.h" #include "window/window_controller.h" #include "base/qthelp_regex.h" #include "base/qthelp_url.h" #include "boxes/connection_box.h" #include "boxes/confirm_phone_box.h" #include "boxes/confirm_box.h" #include "boxes/share_box.h" #include "facades.h" #include "app.h" #include #include #include #include namespace Core { namespace { constexpr auto kQuitPreventTimeoutMs = crl::time(1500); constexpr auto kAutoLockTimeoutLateMs = crl::time(3000); } // namespace Application *Application::Instance = nullptr; struct Application::Private { base::Timer quitTimer; UiIntegration uiIntegration; }; Application::Application(not_null launcher) : QObject() , _launcher(launcher) , _private(std::make_unique()) , _databases(std::make_unique()) , _animationsManager(std::make_unique()) , _fallbackProductionConfig( std::make_unique(MTP::Environment::Production)) , _accounts(std::make_unique(cDataFile())) , _langpack(std::make_unique()) , _langCloudManager(std::make_unique(langpack())) , _emojiKeywords(std::make_unique()) , _audio(std::make_unique()) , _logo(Window::LoadLogo()) , _logoNoMargin(Window::LoadLogoNoMargin()) , _autoLockTimer([=] { checkAutoLock(); }) { Expects(!_logo.isNull()); Expects(!_logoNoMargin.isNull()); Ui::Integration::Set(&_private->uiIntegration); passcodeLockChanges( ) | rpl::start_with_next([=] { _shouldLockAt = 0; }, _lifetime); accounts().activeSessionChanges( ) | rpl::start_with_next([=](Main::Session *session) { if (session && !UpdaterDisabled()) { // #TODO multi someSessionValue UpdateChecker().setMtproto(session); } }, _lifetime); accounts().activeValue( ) | rpl::filter(rpl::mappers::_1 != nullptr ) | rpl::take(1) | rpl::start_with_next([=] { if (_window) { // Global::DesktopNotify is used in updateTrayMenu. // This should be called when user settings are read. // Right now after they are read the startMtp() is called. _window->widget()->updateTrayMenu(); } }, _lifetime); } Application::~Application() { // Depend on activeWindow() for now :( Shortcuts::Finish(); _window.reset(); if (_mediaView) { _mediaView->clearData(); _mediaView = nullptr; } unlockTerms(); accounts().finish(); Local::finish(); Shortcuts::Finish(); Ui::Emoji::Clear(); Media::Clip::Finish(); App::deinitMedia(); Window::Theme::Uninitialize(); Media::Player::finish(_audio.get()); style::stopManager(); Global::finish(); ThirdParty::finish(); Instance = nullptr; } void Application::run() { style::internal::StartFonts(); ThirdParty::start(); Global::start(); refreshGlobalProxy(); // Depends on Global::started(). startLocalStorage(); ValidateScale(); if (Local::oldSettingsVersion() < AppVersion) { psNewVersion(); } if (cAutoStart() && !Platform::AutostartSupported()) { cSetAutoStart(false); } if (cLaunchMode() == LaunchModeAutoStart && !cAutoStart()) { psAutoStart(false, true); App::quit(); return; } _translator = std::make_unique(); QCoreApplication::instance()->installTranslator(_translator.get()); style::startManager(cScale()); Ui::InitTextOptions(); Ui::Emoji::Init(); Media::Player::start(_audio.get()); style::ShortAnimationPlaying( ) | rpl::start_with_next([=](bool playing) { if (playing) { MTP::details::pause(); } else { MTP::details::unpause(); } }, _lifetime); DEBUG_LOG(("Application Info: inited...")); cChangeTimeFormat(QLocale::system().timeFormat(QLocale::ShortFormat)); DEBUG_LOG(("Application Info: starting app...")); // Create mime database, so it won't be slow later. QMimeDatabase().mimeTypeForName(qsl("text/plain")); _window = std::make_unique(); accounts().activeChanges( ) | rpl::start_with_next([=](not_null account) { _window->showAccount(account); }, _window->widget()->lifetime()); QCoreApplication::instance()->installEventFilter(this); connect( static_cast(QCoreApplication::instance()), &QGuiApplication::applicationStateChanged, this, &Application::stateChanged); DEBUG_LOG(("Application Info: window created...")); // Depend on activeWindow() for now :( startShortcuts(); App::initMedia(); const auto state = accounts().start(QByteArray()); if (state == Storage::StartResult::IncorrectPasscode) { Global::SetLocalPasscode(true); Global::RefLocalPasscodeChanged().notify(); lockByPasscode(); DEBUG_LOG(("Application Info: passcode needed...")); } _window->widget()->show(); const auto currentGeometry = _window->widget()->geometry(); _mediaView = std::make_unique(); _window->widget()->setGeometry(currentGeometry); DEBUG_LOG(("Application Info: showing.")); _window->finishFirstShow(); if (!locked() && cStartToSettings()) { _window->showSettings(); } _window->updateIsActiveFocus(); for (const auto &error : Shortcuts::Errors()) { LOG(("Shortcuts Error: %1").arg(error)); } } bool Application::hideMediaView() { if (_mediaView && !_mediaView->isHidden()) { _mediaView->hide(); if (const auto window = activeWindow()) { window->reActivate(); } return true; } return false; } void Application::showPhoto(not_null link) { const auto photo = link->photo(); const auto peer = link->peer(); const auto item = photo->owner().message(link->context()); return (!item && peer) ? showPhoto(photo, peer) : showPhoto(photo, item); } void Application::showPhoto(not_null photo, HistoryItem *item) { Expects(_mediaView != nullptr); _mediaView->showPhoto(photo, item); _mediaView->activateWindow(); _mediaView->setFocus(); } void Application::showPhoto( not_null photo, not_null peer) { Expects(_mediaView != nullptr); _mediaView->showPhoto(photo, peer); _mediaView->activateWindow(); _mediaView->setFocus(); } void Application::showDocument(not_null document, HistoryItem *item) { Expects(_mediaView != nullptr); if (cUseExternalVideoPlayer() && document->isVideoFile() && !document->filepath().isEmpty()) { File::Launch(document->location(false).fname); } else { _mediaView->showDocument(document, item); _mediaView->activateWindow(); _mediaView->setFocus(); } } void Application::showTheme( not_null document, const Data::CloudTheme &cloud) { Expects(_mediaView != nullptr); _mediaView->showTheme(document, cloud); _mediaView->activateWindow(); _mediaView->setFocus(); } PeerData *Application::ui_getPeerForMouseAction() { if (_mediaView && !_mediaView->isHidden()) { return _mediaView->ui_getPeerForMouseAction(); } else if (const auto m = App::main()) { // multi good return m->ui_getPeerForMouseAction(); } return nullptr; } bool Application::eventFilter(QObject *object, QEvent *e) { switch (e->type()) { case QEvent::KeyPress: case QEvent::MouseButtonPress: case QEvent::TouchBegin: case QEvent::Wheel: { updateNonIdle(); } break; case QEvent::ShortcutOverride: { // handle shortcuts ourselves return true; } break; case QEvent::Shortcut: { const auto event = static_cast(e); DEBUG_LOG(("Shortcut event caught: %1" ).arg(event->key().toString())); if (Shortcuts::HandleEvent(event)) { return true; } } break; case QEvent::ApplicationActivate: { if (object == QCoreApplication::instance()) { updateNonIdle(); } } break; case QEvent::FileOpen: { if (object == QCoreApplication::instance()) { const auto event = static_cast(e); const auto url = QString::fromUtf8( event->url().toEncoded().trimmed()); if (url.startsWith(qstr("tg://"), Qt::CaseInsensitive)) { cSetStartUrl(url.mid(0, 8192)); checkStartUrl(); } if (StartUrlRequiresActivate(url)) { _window->activate(); } } } break; } return QObject::eventFilter(object, e); } void Application::saveSettingsDelayed(crl::time delay) { _saveSettingsTimer.callOnce(delay); } MTP::Config &Application::fallbackProductionConfig() const { if (!_fallbackProductionConfig) { _fallbackProductionConfig = std::make_unique( MTP::Environment::Production); } return *_fallbackProductionConfig; } void Application::refreshFallbackProductionConfig( const MTP::Config &config) { if (config.environment() == MTP::Environment::Production) { _fallbackProductionConfig = std::make_unique(config); } } void Application::constructFallbackProductionConfig( const QByteArray &serialized) { if (auto config = MTP::Config::FromSerialized(serialized)) { if (config->environment() == MTP::Environment::Production) { _fallbackProductionConfig = std::move(config); } } } void Application::setCurrentProxy( const MTP::ProxyData &proxy, MTP::ProxyData::Settings settings) { const auto current = [&] { return (Global::ProxySettings() == MTP::ProxyData::Settings::Enabled) ? Global::SelectedProxy() : MTP::ProxyData(); }; const auto was = current(); Global::SetSelectedProxy(proxy); Global::SetProxySettings(settings); const auto now = current(); refreshGlobalProxy(); _proxyChanges.fire({ was, now }); Global::RefConnectionTypeChanged().notify(); } auto Application::proxyChanges() const -> rpl::producer { return _proxyChanges.events(); } void Application::badMtprotoConfigurationError() { if (Global::ProxySettings() == MTP::ProxyData::Settings::Enabled && !_badProxyDisableBox) { const auto disableCallback = [=] { setCurrentProxy( Global::SelectedProxy(), MTP::ProxyData::Settings::System); }; _badProxyDisableBox = Ui::show(Box( Lang::Hard::ProxyConfigError(), disableCallback)); } } void Application::startLocalStorage() { Local::start(); _saveSettingsTimer.setCallback([=] { Local::writeSettings(); }); } void Application::logout(Main::Account *account) { if (account) { account->logOut(); } else { accounts().resetWithForgottenPasscode(); } } void Application::forceLogOut( not_null account, const TextWithEntities &explanation) { const auto box = Ui::show(Box( explanation, tr::lng_passcode_logout(tr::now))); box->setCloseByEscape(false); box->setCloseByOutsideClick(false); const auto weak = base::make_weak(account.get()); connect(box, &QObject::destroyed, [=] { crl::on_main(weak, [=] { account->forcedLogOut(); }); }); } void Application::checkLocalTime() { const auto adjusted = crl::adjust_time(); if (adjusted) { base::Timer::Adjust(); base::ConcurrentTimerEnvironment::Adjust(); base::unixtime::http_invalidate(); } if (const auto session = maybeActiveSession()) { session->updates().checkLastUpdate(adjusted); } } void Application::stateChanged(Qt::ApplicationState state) { if (state == Qt::ApplicationActive) { handleAppActivated(); } else { handleAppDeactivated(); } } void Application::handleAppActivated() { checkLocalTime(); if (_window) { _window->updateIsActiveFocus(); } } void Application::handleAppDeactivated() { if (_window) { _window->updateIsActiveBlur(); } Ui::Tooltip::Hide(); } void Application::call_handleObservables() { base::HandleObservables(); } void Application::switchDebugMode() { if (Logs::DebugEnabled()) { Logs::SetDebugEnabled(false); _launcher->writeDebugModeSetting(); App::restart(); } else { Logs::SetDebugEnabled(true); _launcher->writeDebugModeSetting(); DEBUG_LOG(("Debug logs started.")); Ui::hideLayer(); } } void Application::switchFreeType() { if (cUseFreeType()) { QFile(cWorkingDir() + qsl("tdata/withfreetype")).remove(); cSetUseFreeType(false); } else { QFile f(cWorkingDir() + qsl("tdata/withfreetype")); if (f.open(QIODevice::WriteOnly)) { f.write("1"); f.close(); } cSetUseFreeType(true); } App::restart(); } void Application::writeInstallBetaVersionsSetting() { _launcher->writeInstallBetaVersionsSetting(); } Main::Account &Application::activeAccount() const { return _accounts->active(); } Main::Session *Application::maybeActiveSession() const { return (_accounts->started() && activeAccount().sessionExists()) ? &activeAccount().session() : nullptr; } bool Application::exportPreventsQuit() { if (const auto session = maybeActiveSession()) { if (session->data().exportInProgress()) { session->data().stopExportWithConfirmation([] { App::quit(); }); return true; } } return false; } int Application::unreadBadge() const { return accounts().unreadBadge(); } bool Application::unreadBadgeMuted() const { return accounts().unreadBadgeMuted(); } rpl::producer<> Application::unreadBadgeChanges() const { return accounts().unreadBadgeChanges(); } bool Application::offerLegacyLangPackSwitch() const { return (accounts().list().size() == 1) && activeAccount().sessionExists(); } bool Application::canApplyLangPackWithoutRestart() const { for (const auto &[index, account] : accounts().list()) { if (account->sessionExists()) { return false; } } return true; } void Application::checkStartUrl() { if (!cStartUrl().isEmpty() && !locked()) { const auto url = cStartUrl(); cSetStartUrl(QString()); if (!openLocalUrl(url, {})) { cSetStartUrl(url); } } } bool Application::openLocalUrl(const QString &url, QVariant context) { return openCustomUrl("tg://", LocalUrlHandlers(), url, context); } bool Application::openInternalUrl(const QString &url, QVariant context) { return openCustomUrl("internal:", InternalUrlHandlers(), url, context); } bool Application::openCustomUrl( const QString &protocol, const std::vector &handlers, const QString &url, const QVariant &context) { const auto urlTrimmed = url.trimmed(); if (!urlTrimmed.startsWith(protocol, Qt::CaseInsensitive) || locked()) { return false; } const auto command = urlTrimmed.midRef(protocol.size(), 8192); const auto session = maybeActiveSession(); using namespace qthelp; const auto options = RegExOption::CaseInsensitive; for (const auto &[expression, handler] : handlers) { const auto match = regex_match(expression, command, options); if (match) { return handler(session, match, context); } } return false; } void Application::lockByPasscode() { _passcodeLock = true; _window->setupPasscodeLock(); } void Application::unlockPasscode() { clearPasscodeLock(); if (_window) { _window->clearPasscodeLock(); } } void Application::clearPasscodeLock() { cSetPasscodeBadTries(0); _passcodeLock = false; } bool Application::passcodeLocked() const { return _passcodeLock.current(); } void Application::updateNonIdle() { _lastNonIdleTime = crl::now(); if (const auto session = maybeActiveSession()) { session->updates().checkIdleFinish(); } } crl::time Application::lastNonIdleTime() const { return std::max( Platform::LastUserInputTime().value_or(0), _lastNonIdleTime); } rpl::producer Application::passcodeLockChanges() const { return _passcodeLock.changes(); } rpl::producer Application::passcodeLockValue() const { return _passcodeLock.value(); } void Application::lockByTerms(const Window::TermsLock &data) { if (!_termsLock || *_termsLock != data) { _termsLock = std::make_unique(data); _termsLockChanges.fire(true); } } bool Application::someSessionExists() const { const auto &list = _accounts->list(); for (const auto &[index, account] : list) { if (account->sessionExists()) { return true; } } return false; } void Application::checkAutoLock() { if (!Global::LocalPasscode() || passcodeLocked() || !someSessionExists()) { _shouldLockAt = 0; _autoLockTimer.cancel(); return; } checkLocalTime(); const auto now = crl::now(); const auto shouldLockInMs = Global::AutoLock() * 1000LL; const auto checkTimeMs = now - lastNonIdleTime(); if (checkTimeMs >= shouldLockInMs || (_shouldLockAt > 0 && now > _shouldLockAt + kAutoLockTimeoutLateMs)) { _shouldLockAt = 0; _autoLockTimer.cancel(); lockByPasscode(); } else { _shouldLockAt = now + (shouldLockInMs - checkTimeMs); _autoLockTimer.callOnce(shouldLockInMs - checkTimeMs); } } void Application::checkAutoLockIn(crl::time time) { if (_autoLockTimer.isActive()) { auto remain = _autoLockTimer.remainingTime(); if (remain > 0 && remain <= time) return; } _autoLockTimer.callOnce(time); } void Application::localPasscodeChanged() { _shouldLockAt = 0; _autoLockTimer.cancel(); checkAutoLock(); } void Application::unlockTerms() { if (_termsLock) { _termsLock = nullptr; _termsLockChanges.fire(false); } } std::optional Application::termsLocked() const { return _termsLock ? base::make_optional(*_termsLock) : std::nullopt; } rpl::producer Application::termsLockChanges() const { return _termsLockChanges.events(); } rpl::producer Application::termsLockValue() const { return rpl::single( _termsLock != nullptr ) | rpl::then(termsLockChanges()); } bool Application::locked() const { return passcodeLocked() || termsLocked(); } rpl::producer Application::lockChanges() const { return lockValue() | rpl::skip(1); } rpl::producer Application::lockValue() const { using namespace rpl::mappers; return rpl::combine( passcodeLockValue(), termsLockValue(), _1 || _2); } bool Application::hasActiveWindow(not_null session) const { if (App::quitting() || !_window) { return false; } else if (const auto controller = _window->sessionController()) { if (&controller->session() == session) { return _window->widget()->isActive(); } } return false; } void Application::saveCurrentDraftsToHistories() { if (!_window) { return; } else if (const auto controller = _window->sessionController()) { controller->content()->saveFieldToHistoryLocalDraft(); } } Window::Controller *Application::activeWindow() const { return _window.get(); } bool Application::closeActiveWindow() { if (hideMediaView()) { return true; } if (const auto window = activeWindow()) { window->close(); return true; } return false; } bool Application::minimizeActiveWindow() { hideMediaView(); if (const auto window = activeWindow()) { window->minimize(); return true; } return false; } QWidget *Application::getFileDialogParent() { return (_mediaView && _mediaView->isVisible()) ? (QWidget*)_mediaView.get() : activeWindow() ? (QWidget*)activeWindow()->widget() : nullptr; } void Application::notifyFileDialogShown(bool shown) { if (_mediaView) { _mediaView->notifyFileDialogShown(shown); } } QWidget *Application::getModalParent() { return Platform::IsWayland() ? App::wnd() : nullptr; } void Application::checkMediaViewActivation() { if (_mediaView && !_mediaView->isHidden()) { _mediaView->activateWindow(); QApplication::setActiveWindow(_mediaView.get()); _mediaView->setFocus(); } } QPoint Application::getPointForCallPanelCenter() const { if (const auto window = activeWindow()) { return window->getPointForCallPanelCenter(); } return QApplication::desktop()->screenGeometry().center(); } // macOS Qt bug workaround, sometimes no leaveEvent() gets to the nested widgets. void Application::registerLeaveSubscription(not_null widget) { #ifdef Q_OS_MAC if (const auto topLevel = widget->window()) { if (topLevel == _window->widget()) { auto weak = Ui::MakeWeak(widget); auto subscription = _window->widget()->leaveEvents( ) | rpl::start_with_next([weak] { if (const auto window = weak.data()) { QEvent ev(QEvent::Leave); QGuiApplication::sendEvent(window, &ev); } }); _leaveSubscriptions.emplace_back(weak, std::move(subscription)); } } #endif // Q_OS_MAC } void Application::unregisterLeaveSubscription(not_null widget) { #ifdef Q_OS_MAC _leaveSubscriptions = std::move( _leaveSubscriptions ) | ranges::action::remove_if([&](const LeaveSubscription &subscription) { auto pointer = subscription.pointer.data(); return !pointer || (pointer == widget); }); #endif // Q_OS_MAC } void Application::postponeCall(FnMut &&callable) { Sandbox::Instance().postponeCall(std::move(callable)); } void Application::refreshGlobalProxy() { Sandbox::Instance().refreshGlobalProxy(); } void Application::QuitAttempt() { auto prevents = false; if (IsAppLaunched() && !Sandbox::Instance().isSavingSession()) { if (const auto session = App().maybeActiveSession()) { if (session->updates().isQuitPrevent() || session->api().isQuitPrevent() || session->calls().isQuitPrevent()) { App().quitDelayed(); return; } } } QApplication::quit(); } void Application::quitPreventFinished() { if (App::quitting()) { QuitAttempt(); } } void Application::quitDelayed() { if (!_private->quitTimer.isActive()) { _private->quitTimer.setCallback([] { QApplication::quit(); }); _private->quitTimer.callOnce(kQuitPreventTimeoutMs); } } void Application::startShortcuts() { Shortcuts::Start(); _accounts->activeSessionChanges( ) | rpl::start_with_next([=](Main::Session *session) { const auto support = session && session->supportMode(); Shortcuts::ToggleSupportShortcuts(support); Platform::SetApplicationIcon(Window::CreateIcon(session)); }, _lifetime); Shortcuts::Requests( ) | rpl::start_with_next([=](not_null request) { using Command = Shortcuts::Command; request->check(Command::Quit) && request->handle([] { App::quit(); return true; }); request->check(Command::Lock) && request->handle([=] { if (!passcodeLocked() && Global::LocalPasscode()) { lockByPasscode(); return true; } return false; }); request->check(Command::Minimize) && request->handle([=] { return minimizeActiveWindow(); }); request->check(Command::Close) && request->handle([=] { return closeActiveWindow(); }); }, _lifetime); } bool IsAppLaunched() { return (Application::Instance != nullptr); } Application &App() { Expects(Application::Instance != nullptr); return *Application::Instance; } } // namespace Core