quick_sync.php

#!/usr/bin/env php
<?php
/**
 * Quick Sync Script
 * Simple script for emergency blockchain synchronization
 */

require_once __DIR__ . '/network_sync.php';

function showUsage() {
 echo "Blockchain Quick Sync Tool\n";
 echo "==========================\n\n";
 echo "Usage: php quick_sync.php [command] [options]\n\n";
 echo "Commands:\n";
 echo " sync - Start full synchronization\n";
 echo " status - Show current database status\n";
 echo " check - Quick network connectivity check\n";
 echo " repair - Repair and re-sync missing data\n";
 echo " help - Show this help message\n\n";
 echo "Options:\n";
 echo " --verbose - Show detailed output\n";
 echo " --quiet - Minimal output\n";
 echo " --force - Force sync even if up-to-date\n\n";
 echo "Examples:\n";
 echo " php quick_sync.php sync --verbose\n";
 echo " php quick_sync.php status\n";
 echo " php quick_sync.php repair --force\n\n";
}

function formatBytes($bytes, $precision = 2) {
 $units = array('B', 'KB', 'MB', 'GB', 'TB');
 
 for ($i = 0; $bytes > 1024; $i++) {
 $bytes /= 1024;
 }
 
 return round($bytes, $precision) . ' ' . $units[$i];
}

function showStatus($syncManager, $verbose = false) {
 echo "📊 Blockchain Database Status\n";
 echo "============================\n\n";
 
 $status = $syncManager->getStatus();
 
 // Show table statistics
 $totalRecords = 0;
 foreach ($status['tables'] as $table => $count) {
 $totalRecords += $count;
 printf("%-20s: %s records\n", 
 ucfirst(str_replace('_', ' ', $table)), 
 number_format($count)
 );
 }
 
 echo "\n";
 printf("Total records: %s\n", number_format($totalRecords));
 printf("Latest block: #%s\n", $status['latest_block']);
 printf("Latest timestamp: %s\n", $status['latest_timestamp'] ?? 'Unknown');
 
 if ($verbose) {
 echo "\n📈 Additional Information\n";
 echo "========================\n";
 
 // Memory usage
 printf("Memory usage: %s\n", formatBytes(memory_get_usage(true)));
 printf("Peak memory: %s\n", formatBytes(memory_get_peak_usage(true)));
 
 // Log file size
 $logFile = 'logs/network_sync.log';
 if (file_exists($logFile)) {
 printf("Log file size: %s\n", formatBytes(filesize($logFile)));
 }
 }
}

function checkConnectivity($syncManager) {
 echo "🌐 Network Connectivity Check\n";
 echo "=============================\n\n";
 
 try {
 // This is a simplified check - we'll use the selectBestNode method
 $reflection = new ReflectionClass($syncManager);
 $method = $reflection->getMethod('selectBestNode');
 $method->setAccessible(true);
 
 $bestNode = $method->invoke($syncManager);
 echo "✅ Successfully connected to: $bestNode\n";
 echo "🔗 Network is accessible and responsive\n";
 
 } catch (Exception $e) {
 echo "❌ Network check failed: " . $e->getMessage() . "\n";
 echo "🔧 Try checking your internet connection or network configuration\n";
 return false;
 }
 
 return true;
}

function performSync($syncManager, $options = []) {
 $verbose = in_array('--verbose', $options);
 $quiet = in_array('--quiet', $options);
 $force = in_array('--force', $options);
 
 if (!$quiet) {
 echo "🚀 Starting Blockchain Synchronization\n";
 echo "======================================\n\n";
 
 if ($force) {
 echo "⚠️ Force mode enabled - will re-sync all data\n\n";
 }
 }
 
 try {
 $startTime = microtime(true);
 $result = $syncManager->syncAll();
 $duration = microtime(true) - $startTime;
 
 if (!$quiet) {
 echo "\n✅ Synchronization Completed Successfully!\n";
 echo "==========================================\n\n";
 printf("📊 Blocks synced: %s\n", number_format($result['blocks_synced']));
 printf("💰 Transactions synced: %s\n", number_format($result['transactions_synced']));
 printf("🌐 Source node: %s\n", $result['node']);
 printf("⏱️ Duration: %.2f seconds\n", $duration);
 printf("📅 Completed at: %s\n", $result['completion_time']);
 }
 
 return true;
 
 } catch (Exception $e) {
 echo "\n❌ Synchronization Failed!\n";
 echo "==========================\n";
 echo "Error: " . $e->getMessage() . "\n";
 
 if ($verbose) {
 echo "\nStack trace:\n";
 echo $e->getTraceAsString() . "\n";
 }
 
 echo "\n🔧 Troubleshooting tips:\n";
 echo "- Check your internet connection\n";
 echo "- Verify database credentials\n";
 echo "- Check if network nodes are accessible\n";
 echo "- Try running: php quick_sync.php check\n";
 
 return false;
 }
}

function performRepair($syncManager, $options = []) {
 echo "🔧 Blockchain Data Repair\n";
 echo "=========================\n\n";
 
 $verbose = in_array('--verbose', $options);
 
 echo "🔍 Checking for missing or corrupted data...\n";
 
 try {
 // Force a complete re-sync
 echo "🔄 Performing complete data re-synchronization...\n";
 $result = performSync($syncManager, array_merge($options, ['--force']));
 
 if ($result) {
 echo "\n✅ Repair completed successfully!\n";
 } else {
 echo "\n❌ Repair failed - manual intervention may be required\n";
 }
 
 } catch (Exception $e) {
 echo "\n❌ Repair failed: " . $e->getMessage() . "\n";
 }
}

// Main execution
if (php_sapi_name() !== 'cli') {
 echo "This script must be run from command line\n";
 exit(1);
}

$command = $argv[1] ?? 'help';
$options = array_slice($argv, 2);

try {
 $syncManager = new NetworkSyncManager(false);
 
 switch ($command) {
 case 'sync':
 performSync($syncManager, $options);
 break;
 
 case 'status':
 $verbose = in_array('--verbose', $options);
 showStatus($syncManager, $verbose);
 break;
 
 case 'check':
 checkConnectivity($syncManager);
 break;
 
 case 'repair':
 performRepair($syncManager, $options);
 break;
 
 case 'help':
 case '--help':
 case '-h':
 default:
 showUsage();
 break;
 }
 
} catch (Exception $e) {
 echo "💥 Fatal Error: " . $e->getMessage() . "\n";
 echo "\nThis usually indicates a configuration or database issue.\n";
 echo "Please check:\n";
 echo "- Database connection settings\n";
 echo "- File permissions\n";
 echo "- PHP requirements\n";
 exit(1);
}
?>