(8) fixed async|clientsUpdated

This commit is contained in:
dranik
2026-06-11 14:39:19 +03:00
parent adc4212f62
commit 0e6d0b444f
2 changed files with 9 additions and 4 deletions
@@ -1,6 +1,7 @@
#include "coreSignalHandlers.h" #include "coreSignalHandlers.h"
#include <QTimer> #include <QTimer>
#include <QtConcurrent>
#include "core/utils/selfhosted/sshSession.h" #include "core/utils/selfhosted/sshSession.h"
#include "core/utils/errorCodes.h" #include "core/utils/errorCodes.h"
@@ -144,8 +145,10 @@ void CoreSignalHandlers::initExportControllerHandler()
}); });
connect(m_coreController->m_exportController, &ExportController::revokeClientRequested, this, connect(m_coreController->m_exportController, &ExportController::revokeClientRequested, this,
[this](const QString &serverId, int row, DockerContainer container) { [this](const QString &serverId, int row, DockerContainer container) {
QtConcurrent::run([this, serverId, row, container]() {
m_coreController->m_usersController->revokeClient(serverId, row, container); m_coreController->m_usersController->revokeClient(serverId, row, container);
}); });
});
connect(m_coreController->m_exportController, &ExportController::renameClientRequested, this, connect(m_coreController->m_exportController, &ExportController::renameClientRequested, this,
[this](const QString &serverId, int row, const QString &clientName, DockerContainer container) { [this](const QString &serverId, int row, const QString &clientName, DockerContainer container) {
m_coreController->m_usersController->renameClient(serverId, row, clientName, container); m_coreController->m_usersController->renameClient(serverId, row, clientName, container);
@@ -202,8 +205,10 @@ void CoreSignalHandlers::initAdminConfigRevokedHandler()
{ {
connect(m_coreController->m_installController, &InstallController::clientRevocationRequested, this, connect(m_coreController->m_installController, &InstallController::clientRevocationRequested, this,
[this](const QString &serverId, const ContainerConfig &containerConfig, DockerContainer container) { [this](const QString &serverId, const ContainerConfig &containerConfig, DockerContainer container) {
QtConcurrent::run([this, serverId, containerConfig, container]() {
m_coreController->m_usersController->revokeClient(serverId, containerConfig, container); m_coreController->m_usersController->revokeClient(serverId, containerConfig, container);
}); });
});
connect(m_coreController->m_installController, &InstallController::clientAppendRequested, this, connect(m_coreController->m_installController, &InstallController::clientAppendRequested, this,
[this](const QString &serverId, const QString &clientId, const QString &clientName, DockerContainer container) { [this](const QString &serverId, const QString &clientId, const QString &clientName, DockerContainer container) {
@@ -703,7 +703,7 @@ ErrorCode UsersController::revokeXray(const int row,
); );
if (error != ErrorCode::NoError) { if (error != ErrorCode::NoError) {
logger.error() << "Failed to restart xray container"; logger.error() << "Failed to restart xray container";
return error; return ErrorCode::NoError;
} }
return error; return error;