cpp: Introduce Rewind Progress handler and nofifier

This introduces a Rewind Progress notification so that it is available when generating an AssumeUTXO snapshot through the UI.

Author: D33r-Gee

src/Makefile.qt.include

@@ -406,6 +406,7 @@ QML_RES_QML = \
   qml/components/NetworkIndicator.qml \
   qml/components/ProxySettings.qml \
   qml/components/Separator.qml \
+  qml/components/SnapshotGenSettings.qml \
   qml/components/SnapshotSettings.qml \
   qml/components/StorageLocations.qml \
   qml/components/StorageOptions.qml \
@@ -465,6 +466,7 @@ QML_RES_QML = \
   qml/pages/settings/SettingsDisplay.qml \
   qml/pages/settings/SettingsProxy.qml \
   qml/pages/settings/SettingsSnapshot.qml \
+  qml/pages/settings/SettingsSnapshotGen.qml \
   qml/pages/settings/SettingsStorage.qml \
   qml/pages/settings/SettingsTheme.qml \
   qml/pages/wallet/Activity.qml \

src/interfaces/node.h

@@ -251,6 +251,10 @@ class Node
     using SnapshotLoadProgressFn = std::function<void(double progress)>;
     virtual std::unique_ptr<Handler> handleSnapshotLoadProgress(SnapshotLoadProgressFn fn) = 0;
 
+    //! Register handler for rewind progress messages.
+    using RewindProgressFn = std::function<void(double progress)>;
+    virtual std::unique_ptr<Handler> handleRewindProgress(RewindProgressFn fn) = 0;
+
     //! Register handler for wallet loader constructed messages.
     using InitWalletFn = std::function<void()>;
     virtual std::unique_ptr<Handler> handleInitWallet(InitWalletFn fn) = 0;

src/kernel/notifications_interface.h

@@ -39,8 +39,10 @@ class Notifications
 
     [[nodiscard]] virtual InterruptResult blockTip(SynchronizationState state, CBlockIndex& index) { return {}; }
     virtual void headerTip(SynchronizationState state, int64_t height, int64_t timestamp, bool presync) {}
+    virtual void blockTipDisconnected(SynchronizationState state, CBlockIndex& index) {}
     virtual void progress(const bilingual_str& title, int progress_percent, bool resume_possible) {}
     virtual void snapshotLoadProgress(double progress) {}
+    virtual void rewindProgress(double progress) {}
     virtual void warning(const bilingual_str& warning) {}
 
     //! The flush error notification is sent to notify the user that an error

src/node/interface_ui.cpp

@@ -22,8 +22,10 @@ struct UISignals {
     boost::signals2::signal<CClientUIInterface::NotifyAlertChangedSig> NotifyAlertChanged;
     boost::signals2::signal<CClientUIInterface::ShowProgressSig> ShowProgress;
     boost::signals2::signal<CClientUIInterface::SnapshotLoadProgressSig> SnapshotLoadProgress;
+    boost::signals2::signal<CClientUIInterface::RewindProgressSig> RewindProgress;
     boost::signals2::signal<CClientUIInterface::NotifyBlockTipSig> NotifyBlockTip;
     boost::signals2::signal<CClientUIInterface::NotifyHeaderTipSig> NotifyHeaderTip;
+    boost::signals2::signal<CClientUIInterface::NotifyBlockDisconnectedSig> NotifyBlockDisconnected;
     boost::signals2::signal<CClientUIInterface::BannedListChangedSig> BannedListChanged;
 };
 static UISignals g_ui_signals;
@@ -44,9 +46,10 @@ ADD_SIGNALS_IMPL_WRAPPER(NotifyAlertChanged);
 ADD_SIGNALS_IMPL_WRAPPER(ShowProgress);
 ADD_SIGNALS_IMPL_WRAPPER(NotifyBlockTip);
 ADD_SIGNALS_IMPL_WRAPPER(NotifyHeaderTip);
+ADD_SIGNALS_IMPL_WRAPPER(NotifyBlockDisconnected);
 ADD_SIGNALS_IMPL_WRAPPER(BannedListChanged);
 ADD_SIGNALS_IMPL_WRAPPER(SnapshotLoadProgress);
-
+ADD_SIGNALS_IMPL_WRAPPER(RewindProgress);
 bool CClientUIInterface::ThreadSafeMessageBox(const bilingual_str& message, const std::string& caption, unsigned int style) { return g_ui_signals.ThreadSafeMessageBox(message, caption, style).value_or(false);}
 bool CClientUIInterface::ThreadSafeQuestion(const bilingual_str& message, const std::string& non_interactive_message, const std::string& caption, unsigned int style) { return g_ui_signals.ThreadSafeQuestion(message, non_interactive_message, caption, style).value_or(false);}
 void CClientUIInterface::InitMessage(const std::string& message) { return g_ui_signals.InitMessage(message); }
@@ -56,8 +59,10 @@ void CClientUIInterface::NotifyNetworkActiveChanged(bool networkActive) { return
 void CClientUIInterface::NotifyAlertChanged() { return g_ui_signals.NotifyAlertChanged(); }
 void CClientUIInterface::ShowProgress(const std::string& title, int nProgress, bool resume_possible) { return g_ui_signals.ShowProgress(title, nProgress, resume_possible); }
 void CClientUIInterface::SnapshotLoadProgress(double progress) { return g_ui_signals.SnapshotLoadProgress(progress); }
+void CClientUIInterface::RewindProgress(double progress) { return g_ui_signals.RewindProgress(progress); }
 void CClientUIInterface::NotifyBlockTip(SynchronizationState s, const CBlockIndex* i) { return g_ui_signals.NotifyBlockTip(s, i); }
 void CClientUIInterface::NotifyHeaderTip(SynchronizationState s, int64_t height, int64_t timestamp, bool presync) { return g_ui_signals.NotifyHeaderTip(s, height, timestamp, presync); }
+void CClientUIInterface::NotifyBlockDisconnected(SynchronizationState s, const CBlockIndex* i) { return g_ui_signals.NotifyBlockDisconnected(s, i); }
 void CClientUIInterface::BannedListChanged() { return g_ui_signals.BannedListChanged(); }
 
 bool InitError(const bilingual_str& str)

src/node/interface_ui.h

@@ -112,12 +112,18 @@ class CClientUIInterface
     /** Snapshot load progress. */
     ADD_SIGNALS_DECL_WRAPPER(SnapshotLoadProgress, void, double progress);
 
+    /** Rewind progress. */
+    ADD_SIGNALS_DECL_WRAPPER(RewindProgress, void, double progress);
+
     /** New block has been accepted */
     ADD_SIGNALS_DECL_WRAPPER(NotifyBlockTip, void, SynchronizationState, const CBlockIndex*);
 
     /** Best header has changed */
     ADD_SIGNALS_DECL_WRAPPER(NotifyHeaderTip, void, SynchronizationState, int64_t height, int64_t timestamp, bool presync);
 
+    /** Block disconnected */
+    ADD_SIGNALS_DECL_WRAPPER(NotifyBlockDisconnected, void, SynchronizationState, const CBlockIndex*);
+
     /** Banlist did change. */
     ADD_SIGNALS_DECL_WRAPPER(BannedListChanged, void, void);
 };

src/node/interfaces.cpp

@@ -383,6 +383,10 @@ class NodeImpl : public Node
     {
         return MakeSignalHandler(::uiInterface.SnapshotLoadProgress_connect(fn));
     }
+    std::unique_ptr<Handler> handleRewindProgress(RewindProgressFn fn) override
+    {
+        return MakeSignalHandler(::uiInterface.RewindProgress_connect(fn));
+    }
     std::unique_ptr<Handler> handleInitWallet(InitWalletFn fn) override
     {
         return MakeSignalHandler(::uiInterface.InitWallet_connect(fn));

src/node/kernel_notifications.cpp

@@ -83,6 +83,11 @@ void KernelNotifications::snapshotLoadProgress(double progress)
     uiInterface.SnapshotLoadProgress(progress);
 }
 
+void KernelNotifications::rewindProgress(double progress)
+{
+    uiInterface.RewindProgress(progress);
+}
+
 void KernelNotifications::warning(const bilingual_str& warning)
 {
     DoWarning(warning);

src/node/kernel_notifications.h

@@ -33,6 +33,8 @@ class KernelNotifications : public kernel::Notifications
 
     void snapshotLoadProgress(double progress) override;
 
+    void rewindProgress(double progress) override;
+
     void warning(const bilingual_str& warning) override;
 
     void flushError(const std::string& debug_message) override;

src/qml/bitcoin_qml.qrc

@@ -15,6 +15,7 @@
         <file>components/ProxySettings.qml</file>
         <file>components/StorageLocations.qml</file>
         <file>components/Separator.qml</file>
+        <file>components/SnapshotGenSettings.qml</file>
         <file>components/SnapshotSettings.qml</file>
         <file>components/StorageOptions.qml</file>
         <file>components/StorageSettings.qml</file>
@@ -72,6 +73,7 @@
         <file>pages/settings/SettingsDeveloper.qml</file>
         <file>pages/settings/SettingsDisplay.qml</file>
         <file>pages/settings/SettingsProxy.qml</file>
+        <file>pages/settings/SettingsSnapshotGen.qml</file>
         <file>pages/settings/SettingsSnapshot.qml</file>
         <file>pages/settings/SettingsStorage.qml</file>
         <file>pages/settings/SettingsTheme.qml</file>

src/qml/components/ConnectionSettings.qml

@@ -11,13 +11,43 @@ ColumnLayout {
     id: root
     signal next
     signal gotoSnapshot
+    signal gotoGenerateSnapshot
     property bool snapshotImportCompleted: onboarding ? false : chainModel.isSnapshotActive
     property bool onboarding: false
-
+    property bool generateSnapshot: false
+    property bool isSnapshotGenerated: nodeModel.isSnapshotGenerated
+    property bool isIBDCompleted: nodeModel.isIBDCompleted
     spacing: 4
+    Setting {
+        id: gotoGenerateSnapshot
+        visible: !root.onboarding && (root.snapshotImportCompleted || root.isIBDCompleted)
+        Layout.fillWidth: true
+        header: qsTr("Generate snapshot")
+        description: qsTr("Speed up the setup of other nodes")
+        actionItem: Item {
+            width: 26
+            height: 26
+            CaretRightIcon {
+                anchors.centerIn: parent
+                color: gotoGenerateSnapshot.stateColor
+            }
+        }
+        onClicked: {
+            if (!nodeModel.isSnapshotFileExists()) {
+                root.generateSnapshot = true
+                root.gotoGenerateSnapshot()
+            } else {
+                root.gotoGenerateSnapshot()
+            }
+        }
+    }
+    Separator {
+        visible: !root.onboarding && (root.snapshotImportCompleted || root.isIBDCompleted)
+        Layout.fillWidth: true
+    }
     Setting {
         id: gotoSnapshot
-        visible: !root.onboarding
+        visible: !root.onboarding && !snapshotImportCompleted && !root.isIBDCompleted
         Layout.fillWidth: true
         header: qsTr("Load snapshot")
         description: qsTr("Instant use with background sync")
@@ -39,7 +69,7 @@ ColumnLayout {
         onClicked: root.gotoSnapshot()
     }
     Separator {
-        visible: !root.onboarding
+        visible: !root.onboarding && !snapshotImportCompleted && !root.isIBDCompleted
         Layout.fillWidth: true
     }
     Setting {