Method GetExpiredStorageBucketBackups

internal/server/db/backups.go:737–778

GetExpiredStorageBucketBackups returns a list of expired storage bucket backups.

(ctx context.Context)

// GetExpiredStorageBucketBackups returns a list of expired storage bucket backups.
func (c *ClusterTx) GetExpiredStorageBucketBackups(ctx context.Context) ([]StoragePoolBucketBackup, error) {
	var backups []StoragePoolBucketBackup

	q := `
SELECT
	storage_buckets_backups.id,
	storage_buckets_backups.name,
	storage_buckets_backups.expiry_date,
	storage_buckets_backups.storage_bucket_id
FROM storage_buckets_backups`

	err := query.Scan(ctx, c.Tx(), q, func(scan func(dest ...any) error) error {
		var b StoragePoolBucketBackup
		var expiryTime sql.NullTime

		err := scan(&b.ID, &b.Name, &expiryTime, &b.BucketID)
		if err != nil {
			return err
		}

		b.ExpiryDate = expiryTime.Time // Convert nulls to zero.

		// Since zero time causes some issues due to timezones, we check the
		// unix timestamp instead of IsZero().
		if b.ExpiryDate.Unix() <= 0 {
			// Backup doesn't expire
			return nil
		}

		// Backup has expired
		if time.Now().Unix()-b.ExpiryDate.Unix() >= 0 {
			backups = append(backups, b)
		}

		return nil
	})
	if err != nil {
		return nil, err
	}

	return backups, nil
}

// RenameBucketBackup renames a bucket backup from the given current name to the new one.
func (c *ClusterTx) RenameBucketBackup(ctx context.Context, oldName, newName string) error {