File indexing completed on 2025-04-27 10:09:33

 /*
     This file is part of the KDE libraries
     SPDX-FileCopyrightText: 2012 Dawit Alemayehu <adawit@kde.org>
 
     SPDX-License-Identifier: LGPL-2.0-only
 */
 
 #include "askuseractioninterface.h"
 #include "usernotificationhandler_p.h"
 
 #include "job_p.h"
 #include "kiocoredebug.h"
 #include "slave.h"
 #include "workerbase.h"
 
 #include <QTimer>
 
 using namespace KIO;
 
 QString UserNotificationHandler::Request::key() const
 {
     QString key;
     if (slave) {
         key = slave->protocol();
         key += slave->host();
         key += slave->port();
         key += QLatin1Char('-');
         key += QChar(type);
     }
     return key;
 }
 
 UserNotificationHandler::UserNotificationHandler(QObject *parent)
     : QObject(parent)
 {
 }
 
 UserNotificationHandler::~UserNotificationHandler()
 {
     qDeleteAll(m_pendingRequests);
 }
 
 void UserNotificationHandler::requestMessageBox(SlaveInterface *iface, int type, const QHash<MessageBoxDataType, QVariant> &data)
 {
     Request *r = new Request;
     r->type = type;
     r->slave = qobject_cast<KIO::Slave *>(iface);
     r->data = data;
 
     m_pendingRequests.append(r);
     if (m_pendingRequests.count() == 1) {
         QTimer::singleShot(0, this, &UserNotificationHandler::processRequest);
     }
 }
 
 void UserNotificationHandler::processRequest()
 {
     if (m_pendingRequests.isEmpty()) {
         return;
     }
 
     int result = -1;
     Request *r = m_pendingRequests.first();
 
     if (r->slave) {
         const QString key = r->key();
 
         if (m_cachedResults.contains(key)) {
             result = *(m_cachedResults[key]);
         } else {
             KIO::SimpleJob *job = r->slave->job();
             AskUserActionInterface *askUserIface = job ? KIO::delegateExtension<KIO::AskUserActionInterface *>(job) : nullptr;
 
             if (askUserIface) {
                 connect(askUserIface, &AskUserActionInterface::messageBoxResult, this, &UserNotificationHandler::slotProcessRequest, Qt::UniqueConnection);
 
                 const auto type = [r]() -> AskUserActionInterface::MessageDialogType {
                     switch (r->type) {
                     case WorkerBase::QuestionTwoActions:
                         return AskUserActionInterface::QuestionTwoActions;
                     case WorkerBase::WarningTwoActions:
                         return AskUserActionInterface::WarningTwoActions;
                     case WorkerBase::WarningContinueCancel:
                     case WorkerBase::WarningContinueCancelDetailed:
                         return AskUserActionInterface::WarningContinueCancel;
                     case WorkerBase::WarningTwoActionsCancel:
                         return AskUserActionInterface::WarningTwoActionsCancel;
                     case WorkerBase::Information:
                         return AskUserActionInterface::Information;
                     case WorkerBase::SSLMessageBox:
                         return AskUserActionInterface::SSLMessageBox;
                     default:
                         Q_UNREACHABLE();
                         return AskUserActionInterface::MessageDialogType{};
                     }
                 }();
 
                 askUserIface->requestUserMessageBox(type,
                                                     r->data.value(MSG_TEXT).toString(),
                                                     r->data.value(MSG_TITLE).toString(),
                                                     r->data.value(MSG_PRIMARYACTION_TEXT).toString(),
                                                     r->data.value(MSG_SECONDARYACTION_TEXT).toString(),
                                                     r->data.value(MSG_PRIMARYACTION_ICON).toString(),
                                                     r->data.value(MSG_SECONDARYACTION_ICON).toString(),
                                                     r->data.value(MSG_DONT_ASK_AGAIN).toString(),
                                                     r->data.value(MSG_DETAILS).toString(),
                                                     r->data.value(MSG_META_DATA).toMap());
                 return;
             }
         }
     } else {
         qCWarning(KIO_CORE) << "Cannot prompt user because the requesting KIO worker died!" << r->slave;
     }
 
     slotProcessRequest(result);
 }
 
 void UserNotificationHandler::slotProcessRequest(int result)
 {
     Request *request = m_pendingRequests.takeFirst();
     m_cachedResults.insert(request->key(), new int(result));
 
     request->slave->sendMessageBoxAnswer(result);
     delete request;
 
     if (m_pendingRequests.isEmpty()) {
         m_cachedResults.clear();
     } else {
         processRequest();
     }
 }
 
 #include "moc_usernotificationhandler_p.cpp"