Feature/pnm

push-validator-manager/README.md

@@ -0,0 +1,129 @@
+# Push Validator Manager
+
+**Fast validator setup for Push Chain**
+
+## 🚀 Quick Start (1-2 minutes)
+
+### Step 1: Install & Start
+```bash
+curl -fsSL https://get.push.network/node/install.sh | bash
+```
+Automatically installs and starts your validator using state sync (no full sync needed).
+
+> **Note:** Restart terminal or run `source ~/.bashrc` to use `push-validator` from anywhere.
+
+### Step 2: Verify Sync
+```bash
+push-validator status
+```
+Wait for: `✅ Catching Up: false` (takes ~1-2 minutes with state sync)
+
+### Step 3: Register Validator
+```bash
+push-validator register-validator
+```
+**Requirements:** 2+ PC tokens from [faucet](https://faucet.push.org)
+
+**Done! Your validator is running with automatic recovery enabled! 🎉**
+
+## 📊 Dashboard
+
+Monitor your validator in real-time with an interactive dashboard:
+
+```bash
+push-validator dashboard
+```
+
+**Features:**
+- **Node Status** - Process state, RPC connectivity, resource usage (CPU, memory, disk)
+- **Chain Sync** - Real-time block height, sync progress with ETA, network latency
+- **Validator Metrics** - Bonding status, voting power, commission rate, accumulated rewards
+- **Network Overview** - Connected peers, chain ID, active validators list
+- **Live Logs** - Stream node activity with search and filtering
+- **Auto-Refresh** - Updates every 2 seconds for real-time monitoring
+
+The dashboard provides everything you need to monitor validator health and performance at a glance.
+
+## 📖 Commands
+
+### Core
+```bash
+push-validator start                # Start with state sync (2-3 min)
+push-validator stop                 # Stop node
+push-validator status               # Check sync & validator status
+push-validator dashboard            # Live interactive monitoring dashboard
+push-validator register-validator   # Register as validator
+push-validator logs                 # View logs
+```
+
+### Validator Operations
+```bash
+push-validator increase-stake       # Increase validator stake and voting power
+push-validator unjail               # Restore jailed validator to active status
+push-validator withdraw-rewards     # Withdraw validator rewards and commission
+push-validator restake              # Auto-withdraw and restake all rewards to increase validator power
+```
+
+### Monitoring
+```bash
+push-validator sync            # Monitor sync progress
+push-validator peers           # Show peer connections (from local RPC)
+push-validator doctor          # Run diagnostic checks on validator setup
+```
+
+### Management
+```bash
+push-validator restart         # Restart node
+push-validator validators      # List validators (supports --output json)
+push-validator balance         # Check balance (defaults to validator key)
+push-validator reset           # Reset chain data (keeps address book)
+push-validator full-reset      # ⚠️ Complete reset (deletes ALL keys and data)
+push-validator backup          # Backup config and validator state
+```
+
+## ⚡ Features
+
+- **State Sync**: 1-2 minute setup (no full blockchain download)
+- **Interactive Logs**: Real-time log viewer with search and filtering
+- **Smart Detection**: Monitors for sync stalls and network issues
+- **Reliable Snapshots**: Uses trusted RPC nodes for recovery
+- **Multiple Outputs**: JSON, YAML, or text format support
+
+## 📊 Network
+
+- **Chain**: `push_42101-1` (Testnet)
+- **Min Stake**: 1.5 PC
+- **Faucet**: https://faucet.push.org
+- **Explorer**: https://donut.push.network
+
+
+## 🔧 Advanced Setup (Optional)
+
+### Setup NGINX with SSL
+```bash
+bash scripts/setup-nginx.sh yourdomain.com
+```
+**Creates:**
+- `https://yourdomain.com` - Cosmos RPC endpoint
+- `https://evm.yourdomain.com` - EVM RPC endpoint
+- Automatic SSL certificates via Let's Encrypt
+- Rate limiting and security headers
+
+**Requirements:**
+- Domain pointing to your server IP
+- Ports 80/443 open
+- Ubuntu/Debian system
+
+### Log Rotation
+```bash
+bash scripts/setup-log-rotation.sh
+```
+Configures daily rotation with 14-day retention and compression.
+
+### File Locations
+- **Manager**: `~/.local/bin/push-validator`
+- **Binary**: `~/.local/bin/pchaind`
+- **Config**: `~/.pchain/config/`
+- **Data**: `~/.pchain/data/`
+- **Logs**: `~/.pchain/logs/pchaind.log`
+- **Backups**: `~/push-node-backups/`

push-validator-manager/cmd/push-validator/cmd_backup.go

@@ -0,0 +1,20 @@
+package main
+
+import (
+    "fmt"
+
+    "github.com/pushchain/push-chain-node/push-validator-manager/internal/admin"
+    "github.com/pushchain/push-chain-node/push-validator-manager/internal/config"
+)
+
+// handleBackup creates a backup archive of the node configuration and
+// prints the resulting path, or a JSON object when --output=json.
+func handleBackup(cfg config.Config) error {
+    path, err := admin.Backup(admin.BackupOptions{HomeDir: cfg.HomeDir})
+    if err != nil {
+        if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": false, "error": err.Error()}) } else { getPrinter().Error(fmt.Sprintf("backup error: %v", err)) }
+        return err
+    }
+    if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": true, "backup_path": path}) } else { getPrinter().Success(fmt.Sprintf("backup created: %s", path)) }
+    return nil
+}

push-validator-manager/cmd/push-validator/cmd_balance.go

@@ -0,0 +1,55 @@
+package main
+
+import (
+    "context"
+    "fmt"
+    "os"
+    "os/exec"
+    "strings"
+    "time"
+
+    "github.com/pushchain/push-chain-node/push-validator-manager/internal/config"
+    "github.com/pushchain/push-chain-node/push-validator-manager/internal/validator"
+)
+
+// handleBalance prints an account balance. It resolves the address from
+// either a positional argument or KEY_NAME when --address/arg is omitted.
+// When --output=json is set, it emits a structured object.
+func handleBalance(cfg config.Config, args []string) error {
+    var addr string
+    if len(args) > 0 { addr = args[0] }
+    if addr == "" {
+        key := os.Getenv("KEY_NAME")
+        if key == "" {
+            if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": false, "error": "address not provided; set KEY_NAME or pass --address"}) } else { fmt.Println("usage: push-validator balance <address> (or set KEY_NAME)") }
+            return fmt.Errorf("address not provided")
+        }
+        out, err := exec.Command(findPchaind(), "keys", "show", key, "-a", "--keyring-backend", cfg.KeyringBackend, "--home", cfg.HomeDir).Output()
+        if err != nil {
+            if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": false, "error": err.Error()}) } else { fmt.Printf("resolve address error: %v\n", err) }
+            return fmt.Errorf("resolve address: %w", err)
+        }
+        addr = strings.TrimSpace(string(out))
+    }
+
+    // Convert hex address (0x...) to bech32 if needed
+    if strings.HasPrefix(addr, "0x") || strings.HasPrefix(addr, "0X") {
+        bech32Addr, convErr := hexToBech32Address(addr)
+        if convErr != nil {
+            if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": false, "error": convErr.Error(), "address": addr}) } else { getPrinter().Error(fmt.Sprintf("address conversion error: %v", convErr)) }
+            return convErr
+        }
+        addr = bech32Addr
+    }
+
+    v := validator.NewWith(validator.Options{BinPath: findPchaind(), HomeDir: cfg.HomeDir, ChainID: cfg.ChainID, Keyring: cfg.KeyringBackend, GenesisDomain: cfg.GenesisDomain, Denom: cfg.Denom})
+    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+    defer cancel()
+    bal, err := v.Balance(ctx, addr)
+    if err != nil {
+        if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": false, "error": err.Error(), "address": addr}) } else { getPrinter().Error(fmt.Sprintf("balance error: %v", err)) }
+        return err
+    }
+    if flagOutput == "json" { getPrinter().JSON(map[string]any{"ok": true, "address": addr, "balance": bal, "denom": cfg.Denom}) } else { getPrinter().Info(fmt.Sprintf("%s %s", bal, cfg.Denom)) }
+    return nil
+}

push-validator-manager/cmd/push-validator/cmd_dashboard.go

@@ -0,0 +1,157 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"strings"
+	"time"
+
+	tea "github.com/charmbracelet/bubbletea"
+	"github.com/spf13/cobra"
+	"golang.org/x/term"
+
+	"github.com/pushchain/push-chain-node/push-validator-manager/internal/dashboard"
+)
+
+// dashboardCmd provides an interactive TUI dashboard for monitoring validator status
+func createDashboardCmd() *cobra.Command {
+	var (
+		refreshInterval time.Duration
+		rpcTimeout      time.Duration
+		debugMode       bool
+	)
+
+	cmd := &cobra.Command{
+		Use:   "dashboard",
+		Short: "Interactive dashboard for monitoring validator status",
+		Long: `Launch an interactive terminal dashboard showing real-time validator metrics:
+
+  • Node process status (running/stopped, PID, version)
+  • Chain sync progress with ETA calculation
+  • Network connectivity (peers, latency)
+  • Validator consensus power and status
+
+The dashboard auto-refreshes every 2 seconds by default. Press '?' for help.
+
+For non-interactive environments (CI/pipes), dashboard automatically falls back
+to a static text snapshot.`,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			// Load configuration
+			cfg := loadCfg()
+
+			// Build dashboard options
+			opts := dashboard.Options{
+				Config:          cfg,
+				RefreshInterval: refreshInterval,
+				RPCTimeout:      rpcTimeout,
+				NoColor:         flagNoColor,
+				NoEmoji:         flagNoEmoji,
+				Debug:           debugMode,
+			}
+			opts = normalizeDashboardOptions(opts)
+
+			// Check if we're in a TTY environment
+			isTTY := term.IsTerminal(int(os.Stdout.Fd()))
+
+			if !isTTY {
+				// Non-TTY environment (CI/pipes): use static mode
+				if debugMode {
+					fmt.Fprintln(os.Stderr, "Debug: Non-TTY detected, using static mode")
+				}
+				return runDashboardStatic(cmd.Context(), opts)
+			}
+
+			// TTY environment: use interactive Bubble Tea dashboard
+			if debugMode {
+				fmt.Fprintln(os.Stderr, "Debug: TTY detected, using interactive mode")
+			}
+			return runDashboardInteractive(opts)
+		},
+	}
+
+	// Flags
+	cmd.Flags().DurationVar(&refreshInterval, "refresh-interval", 2*time.Second, "Dashboard refresh interval")
+	cmd.Flags().DurationVar(&rpcTimeout, "rpc-timeout", 15*time.Second, "RPC request timeout")
+	cmd.Flags().BoolVar(&debugMode, "debug", false, "Enable debug mode for troubleshooting")
+
+	return cmd
+}
+
+// runDashboardStatic performs a single fetch and prints static output for non-TTY
+func runDashboardStatic(ctx context.Context, opts dashboard.Options) error {
+	// Print debug info BEFORE dashboard output
+	if opts.Debug {
+		fmt.Fprintln(os.Stderr, "Debug: Starting dashboard...")
+		fmt.Fprintf(os.Stderr, "Debug: Config loaded - HomeDir: %s, RPC: %s\n", opts.Config.HomeDir, opts.Config.RPCLocal)
+		fmt.Fprintln(os.Stderr, "Debug: Running in static mode")
+		fmt.Fprintln(os.Stderr, "---") // Separator
+	}
+
+	d := dashboard.New(opts)
+
+	// Apply RPC timeout to context (prevents hung RPCs in CI/pipes)
+	ctx, cancel := context.WithTimeout(ctx, opts.RPCTimeout)
+	defer cancel()
+
+	// Fetch data once with timeout
+	data, err := d.FetchDataOnce(ctx)
+	if err != nil {
+		return fmt.Errorf("failed to fetch dashboard data: %w", err)
+	}
+
+	// Render static text snapshot to stdout
+	fmt.Print(d.RenderStatic(data))
+	return nil
+}
+
+// runDashboardInteractive launches the Bubble Tea TUI program
+func runDashboardInteractive(opts dashboard.Options) error {
+	d := dashboard.New(opts)
+	if d == nil {
+		return fmt.Errorf("failed to create dashboard instance")
+	}
+
+	// Create Bubble Tea program with proper TTY configuration
+	// Key fix: Use stdin/stdout explicitly instead of /dev/tty
+	p := tea.NewProgram(
+		d,
+		tea.WithAltScreen(),      // Use alternate screen buffer (clean display)
+		tea.WithInput(os.Stdin),  // Use stdin instead of trying to open /dev/tty
+		tea.WithOutput(os.Stdout), // Use stdout instead of trying to open /dev/tty
+	)
+
+	// Run program - blocks until quit
+	if _, err := p.Run(); err != nil {
+		// If TTY error, fall back to static mode
+		if strings.Contains(err.Error(), "tty") || strings.Contains(err.Error(), "device not configured") {
+			if opts.Debug {
+				fmt.Fprintf(os.Stderr, "Debug: TTY error, falling back to static mode: %v\n", err)
+			}
+			return runDashboardStatic(context.Background(), opts)
+		}
+		return fmt.Errorf("dashboard error: %w", err)
+	}
+
+	return nil
+}
+
+// normalizeDashboardOptions applies default refresh/timeout values to keep behaviour
+// consistent between interactive and static dashboard modes.
+func normalizeDashboardOptions(opts dashboard.Options) dashboard.Options {
+	if opts.RefreshInterval <= 0 {
+		opts.RefreshInterval = 2 * time.Second
+	}
+	if opts.RPCTimeout <= 0 {
+		// Default to 15s but cap at twice the refresh interval so the UI remains responsive.
+		timeout := 15 * time.Second
+		if opts.RefreshInterval > 0 {
+			candidate := 2 * opts.RefreshInterval
+			if candidate < timeout {
+				timeout = candidate
+			}
+		}
+		opts.RPCTimeout = timeout
+	}
+	return opts
+}