Update parallel_miner_v3.py

parallel_miner_v3.py

@@ -157,9 +157,9 @@ class NetworkIntegration:
     def __init__(self, wallet_address: str = None):
         # Multiple API endpoints for redundancy
         self.api_endpoints = [
+            "https://api.blockchain.com/v3",
             "https://blockchain.info",
-            "https://api.blockchain.com/v3/btc",
-            "https://api.blockchair.com/bitcoin",
+            "https://blockchair.com/api/stats",
         ]
         self.api_base = self.api_endpoints[0]  # Default endpoint
         self.node = "seed.bitcoin.sipa.be"
@@ -169,9 +169,17 @@ class NetworkIntegration:
         self._template_cache = None
         self._last_cache_time = 0
         
+        # Configure requests session with SSL verification and proper headers
+        import requests
+        self.session = requests.Session()
+        self.session.verify = True  # Enable SSL verification
+        self.session.headers.update({
+            'User-Agent': 'Mozilla/5.0 Bitcoin Miner',
+            'Accept': 'application/json'
+        })
+        
     def connect(self) -> bool:
         """Connect to Bitcoin mainnet with fallback endpoints"""
-        import requests
         import socket
         
         # First check internet connectivity
@@ -186,13 +194,20 @@ class NetworkIntegration:
         for endpoint in self.api_endpoints:
             try:
                 self.api_base = endpoint
-                response = requests.get(f"{endpoint}/blockchain/blocks/last", timeout=10)
+                if 'api.blockchain.com' in endpoint:
+                    test_url = f"{endpoint}/blocks/latest"
+                elif 'blockchain.info' in endpoint:
+                    test_url = f"{endpoint}/latestblock"
+                else:
+                    test_url = endpoint
+                    
+                response = self.session.get(test_url, timeout=10)
                 if response.status_code == 200:
                     self.connected = True
                     logging.info(f"✅ Connected to Bitcoin mainnet via {endpoint}")
                     return True
-            except requests.RequestException as e:
-                logging.warning(f"Failed to connect to {endpoint}: {e}")
+            except Exception as e:
+                logging.warning(f"Failed to connect to {endpoint}: {str(e)}")
                 continue
                 
         logging.error("❌ Failed to connect to all available endpoints")
@@ -209,14 +224,18 @@ class NetworkIntegration:
             if self._template_cache and current_time - self._last_cache_time < 300:
                 return self._template_cache
             
-            # Get latest block info
-            response = requests.get("https://blockchain.info/latestblock", timeout=10)
+            # Get latest block info based on endpoint
+            if 'api.blockchain.com' in self.api_base:
+                response = self.session.get(f"{self.api_base}/blocks/latest", timeout=10)
+            else:
+                response = self.session.get("https://blockchain.info/latestblock", timeout=10)
+                
             if response.status_code != 200:
                 raise Exception(f"Failed to get latest block: {response.status_code}")
             
             latest = response.json()
-            height = latest['height']
-            current_block = latest['hash']
+            height = latest.get('height') or latest.get('block_index')
+            current_block = latest.get('hash') or latest.get('block_hash')
             
             logging.info(f"📦 Current block height: {height}, hash: {current_block}")