feat(light-nodes): identical retry/confirmation tracking for BitmapTX as HeartbeatCommitment

- Replace fire-and-forget HashSet with DashMap<u64, HeartbeatCommitmentStatus> for BitmapTX
- Add retry logic: 3 retries with 10-block timeout, identical to HeartbeatCommitment
- Add confirmation scan: detect BitmapTX inclusion in chain within 20-block window
- Replace send_network_message with send_critical_tx_with_ack for producer forwarding
- Add Gulf Stream logging and forwarded_to_producer tracking for BitmapTX
- Remove RAM attestation fallback: reward proof is on-chain BitmapTX only
- Fix light node ping response routing: include response_url in FCM and UnifiedPush payload
- Mobile wallet: respond to pinging genesis node URL instead of random bootstrap node
- Add QNET_HALT_HEIGHT for coordinated upgrades (Cosmos-style halt at target block)
- All 10 lifecycle steps of BitmapTX now identical to HeartbeatCommitment

Made-with: Cursor

Author: AIQnetLab

applications/qnet-mobile/src/services/PushService.js

@@ -337,7 +337,7 @@ export async function getNextPingTime() {
  * Respond to ping challenge (sign and send)
  * MANDATORY: Dilithium3 (ML-DSA-65) quantum signature — no Ed25519 fallback
  */
-export async function respondToChallenge(nodeId, challenge) {
+export async function respondToChallenge(nodeId, challenge, responseUrl) {
   try {
       const Keychain = require('react-native-keychain');
 
@@ -359,7 +359,7 @@ export async function respondToChallenge(nodeId, challenge) {
               const dilithiumSig = await signWithDilithium(challenge, pingSkHex, pingPkHex, pingNodeId);
               const formattedSignature = `ping_dilithium:${dilithiumSig}`;
 
-              const apiUrl = await getRandomBootstrapNodeAsync();
+              const apiUrl = responseUrl || await getRandomBootstrapNodeAsync();
               const response = await fetch(
                 `${apiUrl}/api/v1/light-node/ping-response`,
                 {
@@ -405,8 +405,8 @@ export async function respondToChallenge(nodeId, challenge) {
  */
 export async function handlePushMessage(data) {
   if (data?.action === 'ping_response' && data?.challenge && data?.node_id) {
-    console.log('[Push] 📥 Ping received:', data.node_id);
-    return await respondToChallenge(data.node_id, data.challenge);
+    console.log('[Push] 📥 Ping received:', data.node_id, 'from:', data.response_url || 'random');
+    return await respondToChallenge(data.node_id, data.challenge, data.response_url);
   }
   return false;
 }

development/qnet-integration/src/bin/qnet-node.rs

@@ -2902,6 +2902,19 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     }
 
     // Start background node monitoring
+    // v8.0: Read QNET_HALT_HEIGHT once at startup for coordinated upgrades.
+    // Cosmos equivalent: halt-height flag. When ALL nodes set the same halt height,
+    // they all stop gracefully at the same block → operator updates binaries → restarts.
+    // Use case: breaking consensus changes (hard fork).
+    // Normal rolling updates: leave unset (nodes restart one-by-one, catch up via snapshot).
+    let halt_height: Option<u64> = std::env::var("QNET_HALT_HEIGHT")
+        .ok()
+        .and_then(|s| s.trim().parse::<u64>().ok());
+
+    if let Some(h) = halt_height {
+        println!("[INFO][HALT] QNET_HALT_HEIGHT={} — node will stop at this block (coordinated upgrade)", h);
+    }
+
     let node_clone = node.clone();
     let node_handle = tokio::spawn(async move {
         // Keep node running and monitor
@@ -2916,6 +2929,24 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
                     println!("[MONITOR] ⚠️ No peers connected - running standalone");
                 }
             }
+
+            // v8.0: QNET_HALT_HEIGHT — coordinated upgrade stop
+            // Works like Cosmos halt-height: set same value on all nodes,
+            // they all stop at that block → update binaries → restart.
+            if let Some(stop_at) = halt_height {
+                let current_height = node_clone.get_height().await;
+                if current_height >= stop_at {
+                    println!("[INFO][HALT] Reached halt_height={} current={} — flushing and stopping for coordinated upgrade",
+                             stop_at, current_height);
+                    let storage = node_clone.get_storage();
+                    match storage.flush_all() {
+                        Ok(()) => println!("[INFO][HALT] storage.flush_all() complete"),
+                        Err(e) => println!("[ERR][HALT] storage.flush_all() failed: {}", e),
+                    }
+                    println!("[INFO][HALT] Node stopped. Update binary and restart (remove QNET_HALT_HEIGHT).");
+                    std::process::exit(0);
+                }
+            }
         }
     });