feat(backup): Add backup and scheduler system

Implement complete backup and scheduled task functionality:

- Add scheduler package with cron-based task execution
- Add backup package for deployment backup/restore
- Add API endpoints for managing backups and scheduled tasks
- Extend ServiceMetadata model with backup specifications
- Update WordPress and Laravel templates with backup definitions

Backup features:
- Backup compose files, env files, and metadata
- Export container data using docker cp
- Dump MySQL/PostgreSQL databases
- Pre/post backup hooks for maintenance mode
- Retention-based cleanup

Scheduler features:
- Cron expression support for task scheduling
- Backup and command task types
- Task execution history tracking
- On-demand task execution

Signed-off-by: nfebe <fenn25.fn@gmail.com>

Author: nfebe

go.mod

@@ -33,6 +33,7 @@ require (
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/pelletier/go-toml/v2 v2.0.8 // indirect
+	github.com/robfig/cron/v3 v3.0.1 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.11 // indirect
 	golang.org/x/arch v0.3.0 // indirect

go.sum

@@ -61,6 +61,8 @@ github.com/pelletier/go-toml/v2 v2.0.8 h1:0ctb6s9mE31h0/lhu+J6OPmVeDxJn+kYnJc2jZ
 github.com/pelletier/go-toml/v2 v2.0.8/go.mod h1:vuYfssBdrU2XDZ9bYydBu6t+6a6PYNcZljzZR9VXg+4=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
+github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=

internal/api/backup_handlers.go

@@ -0,0 +1,214 @@
+package api
+
+import (
+	"net/http"
+	"strconv"
+
+	"github.com/flatrun/agent/internal/backup"
+	"github.com/flatrun/agent/pkg/models"
+	"github.com/gin-gonic/gin"
+)
+
+func (s *Server) listBackups(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	filter := &backup.BackupListFilter{
+		DeploymentName: c.Query("deployment"),
+	}
+
+	if limit := c.Query("limit"); limit != "" {
+		if l, err := strconv.Atoi(limit); err == nil {
+			filter.Limit = l
+		}
+	}
+
+	backups, err := s.backupManager.ListBackups(filter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"backups": backups})
+}
+
+func (s *Server) getBackup(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	backupID := c.Param("id")
+	b, err := s.backupManager.GetBackup(backupID)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"backup": b})
+}
+
+func (s *Server) createBackup(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	var req backup.CreateBackupRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+		return
+	}
+
+	deployment, err := s.manager.GetDeployment(req.DeploymentName)
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Deployment not found: " + req.DeploymentName})
+		return
+	}
+
+	var spec *backup.BackupSpec
+	if deployment.Metadata != nil && deployment.Metadata.Backup != nil {
+		spec = deployment.Metadata.Backup
+	}
+
+	b, err := s.backupManager.CreateBackup(c.Request.Context(), req.DeploymentName, spec)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusCreated, gin.H{"backup": b})
+}
+
+func (s *Server) createDeploymentBackup(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	deploymentName := c.Param("name")
+	deployment, err := s.manager.GetDeployment(deploymentName)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Deployment not found"})
+		return
+	}
+
+	var spec *backup.BackupSpec
+	if deployment.Metadata != nil && deployment.Metadata.Backup != nil {
+		spec = deployment.Metadata.Backup
+	}
+
+	b, err := s.backupManager.CreateBackup(c.Request.Context(), deploymentName, spec)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusCreated, gin.H{"backup": b})
+}
+
+func (s *Server) listDeploymentBackups(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	deploymentName := c.Param("name")
+
+	filter := &backup.BackupListFilter{
+		DeploymentName: deploymentName,
+	}
+
+	if limit := c.Query("limit"); limit != "" {
+		if l, err := strconv.Atoi(limit); err == nil {
+			filter.Limit = l
+		}
+	}
+
+	backups, err := s.backupManager.ListBackups(filter)
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"backups": backups})
+}
+
+func (s *Server) deleteBackup(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	backupID := c.Param("id")
+	if err := s.backupManager.DeleteBackup(backupID); err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"message": "Backup deleted successfully"})
+}
+
+func (s *Server) downloadBackup(c *gin.Context) {
+	if s.backupManager == nil {
+		c.JSON(http.StatusServiceUnavailable, gin.H{"error": "Backup manager not enabled"})
+		return
+	}
+
+	backupID := c.Param("id")
+	backupPath, err := s.backupManager.GetBackupPath(backupID)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.Header("Content-Description", "File Transfer")
+	c.Header("Content-Disposition", "attachment; filename="+backupID+".tar.gz")
+	c.Header("Content-Type", "application/gzip")
+	c.File(backupPath)
+}
+
+func (s *Server) getDeploymentBackupConfig(c *gin.Context) {
+	deploymentName := c.Param("name")
+	deployment, err := s.manager.GetDeployment(deploymentName)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Deployment not found"})
+		return
+	}
+
+	var spec *backup.BackupSpec
+	if deployment.Metadata != nil && deployment.Metadata.Backup != nil {
+		spec = deployment.Metadata.Backup
+	}
+
+	c.JSON(http.StatusOK, gin.H{"backup_config": spec})
+}
+
+func (s *Server) updateDeploymentBackupConfig(c *gin.Context) {
+	deploymentName := c.Param("name")
+	deployment, err := s.manager.GetDeployment(deploymentName)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Deployment not found"})
+		return
+	}
+
+	var spec backup.BackupSpec
+	if err := c.ShouldBindJSON(&spec); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+		return
+	}
+
+	if deployment.Metadata == nil {
+		deployment.Metadata = &models.ServiceMetadata{}
+	}
+	deployment.Metadata.Backup = &spec
+
+	if err := s.manager.SaveMetadata(deploymentName, deployment.Metadata); err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
+		return
+	}
+
+	c.JSON(http.StatusOK, gin.H{"backup_config": spec})
+}