executer.go

// Some high-level functions to perform backups, track their status, clean old backups, and upload to remote storage.
package main

import (
	"log"
	"os"
	"time"
)

// A high-level function to perform a full backup and handle tracking and uploading.
func PerformFullBackup(drive string, comment string) error {
	backupTime := time.Now()
	err := CreateFullBackup(backupTime)
	if err != nil {
		log.Println(err)
		return err
	}

	track := DatabaseTrack{
		BackupTime: backupTime,
		Status:     Saved,
		Type:       "full",
		Comment:    comment,
		Path:       FormatBackupRelativePath(backupTime, false),
	}

	err = tracker.TrackBackup(track)
	if err != nil {
		return err
	}
	go func() {
		err = UploadToRClone(track, drive)
		if err != nil {
			log.Println(err)
			return
		}
		tracker.UpdateBackupStatus(backupTime, Uploaded)
	}()

	fullBackupTicker.Reset(config.FullBackupInterval)
	return nil
}

// A high-level function to perform an incremental backup and handle tracking and uploading.
func PerformIncrementalBackup(drive string, comment string) error {
	backupTime := time.Now()
	lastTrack, err := tracker.GetLastBackup()
	if err != nil {
		return err
	}

	err = CreateIncrementalBackup(backupTime, lastTrack)
	if err != nil {
		log.Println(err)
		return err
	}

	track := DatabaseTrack{
		BackupTime: backupTime,
		Status:     Saved,
		Type:       "incremental",
		Comment:    comment,
		Path:       FormatBackupRelativePath(backupTime, true),
	}

	err = tracker.TrackBackup(track)
	if err != nil {
		return err
	}
	go func() {
		err = UploadToRClone(track, drive)
		if err != nil {
			log.Println(err)
			return
		}
		tracker.UpdateBackupStatus(backupTime, Uploaded)
	}()

	incrementalBackupTicker.Reset(config.IncrementalBackupInterval)
	return nil
}

// Delete old backup.
func DeleteLocalBackup(track DatabaseTrack) error {
	err := os.RemoveAll(track.GetBackupPath())
	if err != nil {
		return err
	}
	tracker.UpdateBackupStatus(track.BackupTime, Archived)
	log.Printf("Deleted local backup %s\n", track.GetBackupPath())
	// If this is a full backup, also delete incremental backups based on it.
	if track.IsFullBackup() {
		incrementalTracks, err := tracker.GetIncrementalTracks(track)
		if err != nil {
			return err
		}
		for _, incTrack := range incrementalTracks {
			err := os.RemoveAll(incTrack.GetBackupPath())
			if err != nil {
				return err
			}
			tracker.UpdateBackupStatus(incTrack.BackupTime, Archived)
			log.Printf("Deleted local incremental backup %s\n", incTrack.GetBackupPath())
		}
	}
	return nil
}