feat: [Update Delivery] Merge update delivery related functionality into Control Center update client

Integrate the update delivery logic from v20 into the v25 Control Center update module:

Add an update delivery master switch in the Control Center update advanced settings interface. When the switch is enabled, the interface displays two sub-items: Update Delivery - Upload Speed Limit and Update Delivery - Download Speed Limit. Each sub-item has its own control switch and speed limit input field. Simultaneously, call the relevant SetP2pEnable interface of lastore-daemon, which will attempt to start the upgrade-delivery system service during the next update check of lastore.

The switches and input fields for Update Delivery - Upload Speed Limit and Update Delivery - Download Speed Limit independently control the enabling/disabling of upload/download speed limits and their specific values. These values are set by calling the SetDeliveryUploadSpeedLimit and SetDeliveryDownloadSpeedLimit interfaces of lastore-daemon, which are then applied by lastore.

The update delivery speed limit configuration supports backend-driven busy/idle time speed limit policies via the update platform. When such policies are active, the Control Center will gray out the Update Delivery - Upload Speed Limit and Update Delivery - Download Speed Limit sub-items accordingly, preventing user modifications.

Each operation on the master switch triggers a refresh of the status values for various sub-items. The status values are read from the upgrade-delivery service.

Log: Integrate v20 update delivery functionality into v25
Task: https://pms.uniontech.com/task-view-387713.html
Influence: New update delivery logic added to the Control Center update module

feat: 【更新传递】控制中心更新客户端合入更新传递相关功能

v20的更新传递逻辑合入v25控制中心更新模块
1.添加更新传递总开关在控制中心更新高级设置界面。当开关打开时，界面展示更新传递-上传限速、更新传递-下载限速两个子项，每个子项有各自的控制开关和限速值输入框，同时调用lastore-daemon的SetP2pEnable相关接口，在lastore的下次检查更新时尝试拉起upgrade-delivery系统服务
2.更新传递-上传限速、更新传递-下载限速两个子项的开关和输入框各自控制上传、下载限速的开启和关闭以及具体数值，具体通过调用lastore-daemon的SetDeliveryUploadSpeedLimit和SetDeliveryDownloadSpeedLimit接口交由lastore来实际设置值。
3.更新传递的限速配置支持通过更新平台后端下发忙闲时的限速策略，此时控制中心会根据这一策略适时置灰更新传递-上传限速、更新传递-下载限速两个子项，禁止用户修改
4.每次操作总开关时会适时的刷新各种子项的状态值，具体是从upgrade-delivery服务中读取对应的属性值

Log: v20更新传递功能合入v25
Task: https://pms.uniontech.com/task-view-387713.html
Influence: 控制中心更新模块新增更新传递逻辑

Author: ut005973

src/common/dbus/updateassistant.cpp

@@ -0,0 +1,74 @@
+/*
+ * This file was generated by qdbusxml2cpp version 0.8
+ *
+ * qdbusxml2cpp is Copyright (C) 2017 The Qt Company Ltd.
+ *
+ * This is an auto-generated file.
+ * This file may have been hand-edited. Look for HAND-EDIT comments
+ * before re-generating it.
+ */
+
+#include "updateassistant.h"
+
+/*
+ * Implementation of interface class UpdateAssistant
+ */
+
+UpdateAssistant::UpdateAssistant(const QString &service, const QString &path, const QDBusConnection &connection, QObject *parent)
+    : QDBusAbstractInterface(service, path, staticInterfaceName(), connection, parent)
+    , d_ptr(new UpdateAssistantPrivate)
+{
+    QDBusConnection::systemBus().connect("org.deepin.upgradedelivery", "/org/deepin/upgradedelivery", "org.freedesktop.DBus.Properties", "PropertiesChanged", this, SLOT(onPropertyChanged(QString, QVariantMap, QStringList)));
+}
+
+UpdateAssistant::~UpdateAssistant()
+{
+}
+
+void UpdateAssistant::onPropertyChanged(const QString& interfaceName,
+                                   const QVariantMap& changedProperties,
+                                   const QStringList& invalidatedProperties)
+{
+    if (interfaceName != staticInterfaceName())
+        return;
+
+    if (changedProperties.contains("UploadLimitSpeed")) {
+        Q_EMIT UploadLimitSpeedChanged(uploadLimitSpeed());
+    }
+    if (changedProperties.contains("DownloadLimitSpeed")) {
+        Q_EMIT DownloadLimitSpeedChanged(downloadLimitSpeed());
+    }
+
+    return;
+}
+
+void UpdateAssistant::CallQueued(const QString &callName, const QList<QVariant> &args)
+{
+    if (d_ptr->m_waittingCalls.contains(callName)) {
+        d_ptr->m_waittingCalls[callName] = args;
+        return;
+    }
+    if (d_ptr->m_processingCalls.contains(callName)) {
+        d_ptr->m_waittingCalls.insert(callName, args);
+    } else {
+        QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(asyncCallWithArgumentList(callName, args));
+        connect(watcher, &QDBusPendingCallWatcher::finished, this, &UpdateAssistant::onPendingCallFinished);
+        d_ptr->m_processingCalls.insert(callName, watcher);
+    }
+}
+
+void UpdateAssistant::onPendingCallFinished(QDBusPendingCallWatcher *w)
+{
+    if (!w)
+        return;
+    w->deleteLater();
+    const auto callName = d_ptr->m_processingCalls.key(w);
+    Q_ASSERT(!callName.isEmpty());
+    if (callName.isEmpty())
+        return;
+    d_ptr->m_processingCalls.remove(callName);
+    if (!d_ptr->m_waittingCalls.contains(callName))
+        return;
+    const auto args = d_ptr->m_waittingCalls.take(callName);
+    CallQueued(callName, args);
+}

src/common/dbus/updateassistant.h

@@ -0,0 +1,96 @@
+/*
+ * This file was generated by qdbusxml2cpp version 0.8
+ *
+ * qdbusxml2cpp is Copyright (C) 2017 The Qt Company Ltd.
+ *
+ * This is an auto-generated file.
+ * Do not edit! All changes made to it will be lost.
+ */
+
+#ifndef UPDATEASSISTANT_H
+#define UPDATEASSISTANT_H
+
+#include <QtCore/QObject>
+#include <QtCore/QByteArray>
+#include <QtCore/QList>
+#include <QtCore/QMap>
+#include <QtCore/QString>
+#include <QtCore/QStringList>
+#include <QtCore/QVariant>
+#include <QtDBus/QtDBus>
+
+//#include "module/updatedatastructs.h"
+
+#define TRANSIMISSION_MAX_SPEED 102400
+#define TRANSIMISSION_MIN_SPEED 0
+#define TRANSIMISSION_SERVICE_ENABLED 1
+
+class UpdateAssistantPrivate
+{
+public:
+    UpdateAssistantPrivate() = default;
+
+public:
+    QMap<QString, QDBusPendingCallWatcher *> m_processingCalls;
+    QMap<QString, QList<QVariant>> m_waittingCalls;
+};
+
+/*
+ * Proxy class for interface org.deepin.updateassistant
+ */
+class UpdateAssistant: public QDBusAbstractInterface
+{
+    Q_OBJECT
+public:
+    static inline const char *staticInterfaceName()
+    { return "org.deepin.upgradedelivery"; }
+
+public:
+    UpdateAssistant(const QString &service, const QString &path, const QDBusConnection &connection, QObject *parent = nullptr);
+
+    ~UpdateAssistant();
+
+    Q_PROPERTY(QString UploadLimitSpeed READ uploadLimitSpeed NOTIFY UploadLimitSpeedChanged)
+    inline QString uploadLimitSpeed() const
+    { return qvariant_cast<QString>(internalPropGet("UploadLimitSpeed")); }
+
+    Q_PROPERTY(QString DownloadLimitSpeed READ downloadLimitSpeed NOTIFY DownloadLimitSpeedChanged)
+    inline QString downloadLimitSpeed() const
+    { return qvariant_cast<QString>(internalPropGet("DownloadLimitSpeed")); }
+
+public Q_SLOTS: // METHODS
+
+    inline QDBusPendingReply<void> SetUploadRateLimit(int speed)
+    {
+        QList<QVariant> argumentList;
+        argumentList << QVariant::fromValue(speed);
+        return asyncCallWithArgumentList(QStringLiteral("SetUploadRateLimit"), argumentList);
+    }
+
+    inline QDBusPendingReply<void> SetDownloadRateLimit(int speed)
+    {
+        QList<QVariant> argumentList;
+        argumentList << QVariant::fromValue(speed);
+        return asyncCallWithArgumentList(QStringLiteral("SetDownloadRateLimit"), argumentList);
+    }
+
+Q_SIGNALS: // SIGNALS
+    // begin property changed signals
+    void propertyChanged(const QString &propertyName, const QVariant &value);
+    void UploadLimitSpeedChanged(const QString & speed) const;
+    void DownloadLimitSpeedChanged(const QString & speed) const;
+
+public Q_SLOTS:
+    void CallQueued(const QString &callName, const QList<QVariant> &args);
+
+private Q_SLOTS:
+    void onPendingCallFinished(QDBusPendingCallWatcher *w);
+    void onPropertyChanged(const QString& interfaceName,
+                           const QVariantMap& changedProperties,
+                           const QStringList& invalidatedProperties);
+
+private:
+    UpdateAssistantPrivate *d_ptr;
+};
+
+#endif // UPDATEASSISTANT_H

src/common/dbus/updatedbusproxy.cpp

@@ -207,6 +207,16 @@ QString UpdateDBusProxy::updateStatus()
     return qvariant_cast<QString>(m_managerInter->property("UpdateStatus"));
 }
 
+bool UpdateDBusProxy::p2PUpdateEnable()
+{
+    return qvariant_cast<bool>(m_managerInter->property("P2PUpdateEnable"));
+}
+
+bool UpdateDBusProxy::p2PUpdateSupport()
+{
+    return qvariant_cast<bool>(m_managerInter->property("P2PUpdateSupport"));
+}
+
 bool UpdateDBusProxy::immutableAutoRecovery()
 {
     return qvariant_cast<bool>(m_managerInter->property("ImmutableAutoRecovery"));
@@ -387,6 +397,36 @@ QDBusPendingReply<QString> UpdateDBusProxy::GetUpdateLogs(int updateType)
     return m_managerInter->asyncCallWithArgumentList(QStringLiteral("GetUpdateLogs"), argumentList);
 }
 
+QDBusPendingReply<void> UpdateDBusProxy::SetUpgradeDeliveryEnable(bool enable)
+{
+    qCDebug(logCommon) << "Setting upgrade delivery enable :" << enable;
+    QList<QVariant> argumentList;
+    argumentList << QVariant::fromValue(enable);
+    return m_updateInter->asyncCallWithArgumentList(QStringLiteral("SetP2PUpdateEnable"), argumentList);
+}
+
+QDBusPendingReply<void> UpdateDBusProxy::SetUpgradeDeliveryDownloadSpeedLimit(const QString& downloadLimit)
+{
+    qCDebug(logCommon) << "Setting upgrade delivery download speed limit : " << downloadLimit;
+    QList<QVariant> argumentList;
+    argumentList << QVariant::fromValue(downloadLimit);
+    return m_updateInter->asyncCallWithArgumentList(QStringLiteral("SetDeliveryDownloadSpeedLimit"), argumentList);
+}
+
+QDBusPendingReply<void> UpdateDBusProxy::SetUpgradeDeliveryUploadSpeedLimit(const QString& uploadLimit)
+{
+    qCDebug(logCommon) << "Setting upgrade delivery upload speed limit : " << uploadLimit;
+    QList<QVariant> argumentList;
+    argumentList << QVariant::fromValue(uploadLimit);
+    return m_updateInter->asyncCallWithArgumentList(QStringLiteral("SetDeliveryUploadSpeedLimit"), argumentList);
+}
+
+QDBusPendingReply<void> UpdateDBusProxy::ClearUpgradeDeliveryCache()
+{
+    qCDebug(logCommon) << "Clearing upgrade delivery cache";
+    return m_updateInter->asyncCall(QStringLiteral("CleanTransmissionFiles"));
+}
+
 QDBusPendingReply<void> UpdateDBusProxy::SetIdleDownloadConfig(const QString& config)
 {
     qCDebug(logCommon) << "Setting idle download config:" << config;

src/common/dbus/updatedbusproxy.h

@@ -70,6 +70,12 @@ class UpdateDBusProxy : public QObject
     Q_PROPERTY(bool ImmutableAutoRecovery READ immutableAutoRecovery NOTIFY ImmutableAutoRecoveryChanged)
     bool immutableAutoRecovery();
 
+    Q_PROPERTY(bool P2PUpdateEnable READ p2PUpdateEnable NOTIFY P2PUpdateEnableChanged)
+    bool p2PUpdateEnable();
+
+    Q_PROPERTY(bool P2PUpdateSupport READ p2PUpdateSupport NOTIFY P2PUpdateSupportChanged)
+    bool p2PUpdateSupport();
+
     QString hardwareId();
 
     quint64 checkUpdateMode();
@@ -103,6 +109,10 @@ class UpdateDBusProxy : public QObject
     QDBusPendingReply<void> SetDownloadSpeedLimit(const QString &config);
     QDBusPendingReply<qlonglong> QueryAllSizeWithSource(int updateType);
     QDBusPendingReply<QString> GetUpdateLogs(int updateType);
+    QDBusPendingReply<void> SetUpgradeDeliveryEnable(bool enable);
+    QDBusPendingReply<void> SetUpgradeDeliveryDownloadSpeedLimit(const QString& downloadLimit);
+    QDBusPendingReply<void> SetUpgradeDeliveryUploadSpeedLimit(const QString& uploadLimit);
+    QDBusPendingReply<void> ClearUpgradeDeliveryCache();
     QDBusPendingReply<void> SetIdleDownloadConfig(const QString &config);
     QDBusPendingReply<QDBusObjectPath> PrepareDistUpgradePartly(int updateMode);
     QDBusPendingReply<QDBusObjectPath> fixError(const QString &errorType);
@@ -137,6 +147,7 @@ class UpdateDBusProxy : public QObject
     void AutoInstallUpdatesChanged(bool value) const;
     void AutoInstallUpdateTypeChanged(qulonglong value) const;
     void MirrorSourceChanged(const QString &value) const;
+    void UpgradeDeliveryEnabledChanged(bool value) const;
     void AutoCheckUpdatesChanged(bool value) const;
     void ClassifiedUpdatablePackagesChanged(LastoreUpdatePackagesInfo value) const;
 
@@ -146,6 +157,8 @@ class UpdateDBusProxy : public QObject
     void UpdateModeChanged(qulonglong value) const;
     void UpdateStatusChanged(QString value) const;
     void ImmutableAutoRecoveryChanged(bool value) const;
+    void P2PUpdateEnableChanged(bool value) const;
+    void P2PUpdateSupportChanged(bool value) const;
     void managerInterServiceValidChanged(bool value) const;
 
     // Power