From 0a131511a81037ad255172ba3c53c2552afb4f31 Mon Sep 17 00:00:00 2001 From: Rostislav Dugin Date: Sun, 29 Mar 2026 14:35:46 +0300 Subject: [PATCH] FIX (agent): Fix uploading WAL to storages --- .../features/backups/config/repository.go | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/backend/internal/features/backups/config/repository.go b/backend/internal/features/backups/config/repository.go index 7c31d57..c24b1e6 100644 --- a/backend/internal/features/backups/config/repository.go +++ b/backend/internal/features/backups/config/repository.go @@ -62,6 +62,14 @@ func (r *BackupConfigRepository) FindByDatabaseID(databaseID uuid.UUID) (*Backup GetDb(). Preload("BackupInterval"). Preload("Storage"). + Preload("Storage.LocalStorage"). + Preload("Storage.S3Storage"). + Preload("Storage.GoogleDriveStorage"). + Preload("Storage.NASStorage"). + Preload("Storage.AzureBlobStorage"). + Preload("Storage.FTPStorage"). + Preload("Storage.SFTPStorage"). + Preload("Storage.RcloneStorage"). Where("database_id = ?", databaseID). First(&backupConfig).Error; err != nil { if errors.Is(err, gorm.ErrRecordNotFound) { @@ -81,6 +89,14 @@ func (r *BackupConfigRepository) GetWithEnabledBackups() ([]*BackupConfig, error GetDb(). Preload("BackupInterval"). Preload("Storage"). + Preload("Storage.LocalStorage"). + Preload("Storage.S3Storage"). + Preload("Storage.GoogleDriveStorage"). + Preload("Storage.NASStorage"). + Preload("Storage.AzureBlobStorage"). + Preload("Storage.FTPStorage"). + Preload("Storage.SFTPStorage"). + Preload("Storage.RcloneStorage"). Where("is_backups_enabled = ?", true). Find(&backupConfigs).Error; err != nil { return nil, err