pgbackweb/internal/service/backups/schedule_all.go

package backups

import (
	"context"

	"github.com/eduardolat/pgbackweb/internal/logger"
)

func (s *Service) ScheduleAll() {
	activeBackups, err := s.dbgen.BackupsServiceGetScheduleAllData(
		context.Background(),
	)
	if err != nil {
		logger.Error("error getting all active backups", logger.KV{"error": err})
	}

	for _, backup := range activeBackups {
		if !backup.IsActive {
			err := s.jobRemove(backup.ID)
			if err != nil {
				logger.Error("error removing inactive backup", logger.KV{"error": err})
			}
		}

		if backup.IsActive {
			err := s.jobUpsert(backup.ID, backup.TimeZone, backup.CronExpression)
			if err != nil {
				logger.Error("error scheduling backup", logger.KV{"error": err})
			}
		}
	}

	logger.Info("all active backups scheduled")
}