Supervise cron process for better logging/signal handling/environment…

… management.

cmd/start/main.go

@@ -38,6 +38,7 @@ func main() {
 		}
 
 		svisor := supervisor.New("flybarman", 1*time.Minute)
+		svisor.AddProcess("cron", "/usr/sbin/cron -f", supervisor.WithRestart(0, 5*time.Second))
 		svisor.AddProcess("barman", fmt.Sprintf("tail -f %s", node.LogFile))
 		svisor.AddProcess("admin", "/usr/local/bin/start_admin_server",
 			supervisor.WithRestart(0, 5*time.Second),

internal/flybarman/node.go

@@ -140,7 +140,7 @@ wal_retention_policy = main
 	}
 
 	if _, err := os.Stat(n.BarmanCronFile); os.IsNotExist(err) {
-		barmanCronFileContent := `* * * * * /usr/bin/barman cron
+		barmanCronFileContent := `* * * * * . $HOME/.profile; /usr/bin/barman cron >> /proc/1/fd/1 2>/proc/1/fd/2
 `
 		if err := os.WriteFile(n.BarmanCronFile, []byte(barmanCronFileContent), 0644); err != nil {
 			return fmt.Errorf("failed write %s: %s", n.BarmanCronFile, err)
@@ -167,17 +167,6 @@ wal_retention_policy = main
 
 		log.Println("Crontab updated")
 
-		serviceCmd := exec.Command("/usr/sbin/service", "--version")
-		if err := serviceCmd.Run(); err != nil {
-			log.Println("service command not found, skipping initializing cron service")
-		} else {
-			serviceCronStartCommand := exec.Command("service", "cron", "start")
-			if _, err := serviceCronStartCommand.Output(); err != nil {
-				return fmt.Errorf("failed starting cron service: %s", err)
-			}
-			log.Println("Started cron service")
-		}
-
 		switchWalCommand := exec.Command("barman", "switch-wal", "--archive", "--force", "pg")
 		if _, err := switchWalCommand.Output(); err != nil {
 			log.Println(fmt.Errorf("failed switching WAL: %s", err))