Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 62ddc57fb7 | |||
| 510175ff04 |
@@ -4,8 +4,8 @@ This directory contains pre-compiled binaries for the DB Backup Tool across mult
|
|||||||
|
|
||||||
## Build Information
|
## Build Information
|
||||||
- **Version**: 3.42.34
|
- **Version**: 3.42.34
|
||||||
- **Build Time**: 2026-01-15_17:50:35_UTC
|
- **Build Time**: 2026-01-16_12:38:18_UTC
|
||||||
- **Git Commit**: 4938dc1
|
- **Git Commit**: 510175f
|
||||||
|
|
||||||
## Recent Updates (v1.1.0)
|
## Recent Updates (v1.1.0)
|
||||||
- ✅ Fixed TUI progress display with line-by-line output
|
- ✅ Fixed TUI progress display with line-by-line output
|
||||||
|
|||||||
@@ -84,19 +84,13 @@ func findHbaFileViaPostgres() string {
|
|||||||
|
|
||||||
// parsePgHbaConf parses pg_hba.conf and returns the authentication method
|
// parsePgHbaConf parses pg_hba.conf and returns the authentication method
|
||||||
func parsePgHbaConf(path string, user string) AuthMethod {
|
func parsePgHbaConf(path string, user string) AuthMethod {
|
||||||
// Try with sudo if we can't read directly
|
// Try to read the file directly - do NOT use sudo as it triggers password prompts
|
||||||
|
// If we can't read pg_hba.conf, we'll rely on connection attempts to determine auth
|
||||||
file, err := os.Open(path)
|
file, err := os.Open(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
// Try with sudo (with timeout)
|
// If we can't read the file, return unknown and let the connection determine auth
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
// This avoids sudo password prompts when running as postgres via su
|
||||||
defer cancel()
|
return AuthUnknown
|
||||||
|
|
||||||
cmd := exec.CommandContext(ctx, "sudo", "cat", path)
|
|
||||||
output, err := cmd.Output()
|
|
||||||
if err != nil {
|
|
||||||
return AuthUnknown
|
|
||||||
}
|
|
||||||
return parseHbaContent(string(output), user)
|
|
||||||
}
|
}
|
||||||
defer file.Close()
|
defer file.Close()
|
||||||
|
|
||||||
|
|||||||
@@ -49,9 +49,9 @@ type Engine struct {
|
|||||||
debugLogPath string // Path to save debug log on error
|
debugLogPath string // Path to save debug log on error
|
||||||
|
|
||||||
// TUI progress callback for detailed progress reporting
|
// TUI progress callback for detailed progress reporting
|
||||||
progressCallback ProgressCallback
|
progressCallback ProgressCallback
|
||||||
dbProgressCallback DatabaseProgressCallback
|
dbProgressCallback DatabaseProgressCallback
|
||||||
dbProgressTimingCallback DatabaseProgressWithTimingCallback
|
dbProgressTimingCallback DatabaseProgressWithTimingCallback
|
||||||
}
|
}
|
||||||
|
|
||||||
// New creates a new restore engine
|
// New creates a new restore engine
|
||||||
|
|||||||
@@ -380,22 +380,83 @@ func (m BackupExecutionModel) View() string {
|
|||||||
s.WriteString("\n [KEY] Press Ctrl+C or ESC to cancel\n")
|
s.WriteString("\n [KEY] Press Ctrl+C or ESC to cancel\n")
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
s.WriteString(fmt.Sprintf(" %s\n\n", m.status))
|
// Show completion summary with detailed stats
|
||||||
|
|
||||||
if m.err != nil {
|
if m.err != nil {
|
||||||
s.WriteString(fmt.Sprintf(" [FAIL] Error: %v\n", m.err))
|
s.WriteString("\n")
|
||||||
} else if m.result != "" {
|
s.WriteString(errorStyle.Render(" ╔══════════════════════════════════════════════════════════╗"))
|
||||||
// Parse and display result cleanly
|
s.WriteString("\n")
|
||||||
lines := strings.Split(m.result, "\n")
|
s.WriteString(errorStyle.Render(" ║ [FAIL] BACKUP FAILED ║"))
|
||||||
for _, line := range lines {
|
s.WriteString("\n")
|
||||||
line = strings.TrimSpace(line)
|
s.WriteString(errorStyle.Render(" ╚══════════════════════════════════════════════════════════╝"))
|
||||||
if line != "" {
|
s.WriteString("\n\n")
|
||||||
s.WriteString(" " + line + "\n")
|
s.WriteString(errorStyle.Render(fmt.Sprintf(" Error: %v", m.err)))
|
||||||
|
s.WriteString("\n")
|
||||||
|
} else {
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(successStyle.Render(" ╔══════════════════════════════════════════════════════════╗"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(successStyle.Render(" ║ [OK] BACKUP COMPLETED SUCCESSFULLY ║"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(successStyle.Render(" ╚══════════════════════════════════════════════════════════╝"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
|
||||||
|
// Summary section
|
||||||
|
s.WriteString(infoStyle.Render(" ─── Summary ─────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
|
||||||
|
// Backup type specific info
|
||||||
|
switch m.backupType {
|
||||||
|
case "cluster":
|
||||||
|
s.WriteString(" Type: Cluster Backup\n")
|
||||||
|
if m.dbTotal > 0 {
|
||||||
|
s.WriteString(fmt.Sprintf(" Databases: %d backed up\n", m.dbTotal))
|
||||||
}
|
}
|
||||||
|
case "single":
|
||||||
|
s.WriteString(" Type: Single Database Backup\n")
|
||||||
|
s.WriteString(fmt.Sprintf(" Database: %s\n", m.databaseName))
|
||||||
|
case "sample":
|
||||||
|
s.WriteString(" Type: Sample Backup\n")
|
||||||
|
s.WriteString(fmt.Sprintf(" Database: %s\n", m.databaseName))
|
||||||
|
s.WriteString(fmt.Sprintf(" Sample Ratio: %d\n", m.ratio))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
s.WriteString("\n")
|
||||||
|
|
||||||
|
// Timing section
|
||||||
|
s.WriteString(infoStyle.Render(" ─── Timing ──────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
|
||||||
|
elapsed := time.Since(m.startTime)
|
||||||
|
s.WriteString(fmt.Sprintf(" Total Time: %s\n", formatBackupDuration(elapsed)))
|
||||||
|
|
||||||
|
if m.backupType == "cluster" && m.dbTotal > 0 {
|
||||||
|
avgPerDB := elapsed / time.Duration(m.dbTotal)
|
||||||
|
s.WriteString(fmt.Sprintf(" Avg per DB: %s\n", formatBackupDuration(avgPerDB)))
|
||||||
|
}
|
||||||
|
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(infoStyle.Render(" ─────────────────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n")
|
||||||
}
|
}
|
||||||
s.WriteString("\n [KEY] Press Enter or ESC to return to menu\n")
|
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(" [KEY] Press Enter or ESC to return to menu\n")
|
||||||
}
|
}
|
||||||
|
|
||||||
return s.String()
|
return s.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// formatBackupDuration formats duration in human readable format
|
||||||
|
func formatBackupDuration(d time.Duration) string {
|
||||||
|
if d < time.Minute {
|
||||||
|
return fmt.Sprintf("%.1fs", d.Seconds())
|
||||||
|
}
|
||||||
|
if d < time.Hour {
|
||||||
|
minutes := int(d.Minutes())
|
||||||
|
seconds := int(d.Seconds()) % 60
|
||||||
|
return fmt.Sprintf("%dm %ds", minutes, seconds)
|
||||||
|
}
|
||||||
|
hours := int(d.Hours())
|
||||||
|
minutes := int(d.Minutes()) % 60
|
||||||
|
return fmt.Sprintf("%dh %dm", hours, minutes)
|
||||||
|
}
|
||||||
|
|||||||
@@ -544,22 +544,71 @@ func (m RestoreExecutionModel) View() string {
|
|||||||
s.WriteString("\n")
|
s.WriteString("\n")
|
||||||
|
|
||||||
if m.done {
|
if m.done {
|
||||||
// Show result
|
// Show result with comprehensive summary
|
||||||
if m.err != nil {
|
if m.err != nil {
|
||||||
s.WriteString(errorStyle.Render("[FAIL] Restore Failed"))
|
s.WriteString(errorStyle.Render("╔══════════════════════════════════════════════════════════════╗"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(errorStyle.Render("║ [FAIL] RESTORE FAILED ║"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(errorStyle.Render("╚══════════════════════════════════════════════════════════════╝"))
|
||||||
s.WriteString("\n\n")
|
s.WriteString("\n\n")
|
||||||
s.WriteString(errorStyle.Render(fmt.Sprintf("Error: %v", m.err)))
|
s.WriteString(errorStyle.Render(fmt.Sprintf(" Error: %v", m.err)))
|
||||||
s.WriteString("\n")
|
s.WriteString("\n")
|
||||||
} else {
|
} else {
|
||||||
s.WriteString(successStyle.Render("[OK] Restore Completed Successfully"))
|
s.WriteString(successStyle.Render("╔══════════════════════════════════════════════════════════════╗"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(successStyle.Render("║ [OK] RESTORE COMPLETED SUCCESSFULLY ║"))
|
||||||
|
s.WriteString("\n")
|
||||||
|
s.WriteString(successStyle.Render("╚══════════════════════════════════════════════════════════════╝"))
|
||||||
s.WriteString("\n\n")
|
s.WriteString("\n\n")
|
||||||
s.WriteString(successStyle.Render(m.result))
|
|
||||||
|
// Summary section
|
||||||
|
s.WriteString(infoStyle.Render(" ─── Summary ───────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
|
||||||
|
// Archive info
|
||||||
|
s.WriteString(fmt.Sprintf(" Archive: %s\n", m.archive.Name))
|
||||||
|
if m.archive.Size > 0 {
|
||||||
|
s.WriteString(fmt.Sprintf(" Archive Size: %s\n", FormatBytes(m.archive.Size)))
|
||||||
|
}
|
||||||
|
|
||||||
|
// Restore type specific info
|
||||||
|
if m.restoreType == "restore-cluster" {
|
||||||
|
s.WriteString(fmt.Sprintf(" Type: Cluster Restore\n"))
|
||||||
|
if m.dbTotal > 0 {
|
||||||
|
s.WriteString(fmt.Sprintf(" Databases: %d restored\n", m.dbTotal))
|
||||||
|
}
|
||||||
|
if m.cleanClusterFirst && len(m.existingDBs) > 0 {
|
||||||
|
s.WriteString(fmt.Sprintf(" Cleaned: %d existing database(s) dropped\n", len(m.existingDBs)))
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
s.WriteString(fmt.Sprintf(" Type: Single Database Restore\n"))
|
||||||
|
s.WriteString(fmt.Sprintf(" Target DB: %s\n", m.targetDB))
|
||||||
|
}
|
||||||
|
|
||||||
s.WriteString("\n")
|
s.WriteString("\n")
|
||||||
}
|
}
|
||||||
|
|
||||||
s.WriteString(fmt.Sprintf("\nElapsed Time: %s\n", formatDuration(m.elapsed)))
|
// Timing section
|
||||||
|
s.WriteString(infoStyle.Render(" ─── Timing ────────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
s.WriteString(fmt.Sprintf(" Total Time: %s\n", formatDuration(m.elapsed)))
|
||||||
|
|
||||||
|
// Calculate and show throughput if we have size info
|
||||||
|
if m.archive.Size > 0 && m.elapsed.Seconds() > 0 {
|
||||||
|
throughput := float64(m.archive.Size) / m.elapsed.Seconds()
|
||||||
|
s.WriteString(fmt.Sprintf(" Throughput: %s/s (average)\n", FormatBytes(int64(throughput))))
|
||||||
|
}
|
||||||
|
|
||||||
|
if m.dbTotal > 0 && m.err == nil {
|
||||||
|
avgPerDB := m.elapsed / time.Duration(m.dbTotal)
|
||||||
|
s.WriteString(fmt.Sprintf(" Avg per DB: %s\n", formatDuration(avgPerDB)))
|
||||||
|
}
|
||||||
|
|
||||||
s.WriteString("\n")
|
s.WriteString("\n")
|
||||||
s.WriteString(infoStyle.Render("[KEYS] Press Enter to continue"))
|
s.WriteString(infoStyle.Render(" ───────────────────────────────────────────────────────────"))
|
||||||
|
s.WriteString("\n\n")
|
||||||
|
s.WriteString(infoStyle.Render(" [KEYS] Press Enter to continue"))
|
||||||
} else {
|
} else {
|
||||||
// Show progress
|
// Show progress
|
||||||
s.WriteString(fmt.Sprintf("Phase: %s\n", m.phase))
|
s.WriteString(fmt.Sprintf("Phase: %s\n", m.phase))
|
||||||
|
|||||||
Reference in New Issue
Block a user