ClusterCockpit/cc-backend
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-backend synced 2025-12-19 05:36:17 +01:00
Code Issues Packages Releases Activity

Adapt unit test to new API

Browse Source
This commit is contained in:
Jan Eitzinger
2025-12-17 08:44:37 +01:00
parent d1a78c13a4
commit 79a2ca8ae8
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
tools/archive-manager/import_test.go
View File

@@ -48,7 +48,7 @@ func TestImportFileToSqlite(t *testing.T) {
} }
// Perform import // Perform import
imported, failed, err := importArchive(srcBackend, dstBackend) imported, failed, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Import failed: %s", err.Error()) t.Errorf("Import failed: %s", err.Error())
} }
@@ -111,13 +111,13 @@ func TestImportFileToFile(t *testing.T) {
} }
// Create destination archive directory // Create destination archive directory
if err := os.MkdirAll(dstArchive, 0755); err != nil { if err := os.MkdirAll(dstArchive, 0o755); err != nil {
t.Fatalf("Failed to create destination directory: %s", err.Error()) t.Fatalf("Failed to create destination directory: %s", err.Error())
} }
// Write version file // Write version file
versionFile := filepath.Join(dstArchive, "version.txt") versionFile := filepath.Join(dstArchive, "version.txt")
if err := os.WriteFile(versionFile, []byte("3"), 0644); err != nil { if err := os.WriteFile(versionFile, []byte("3"), 0o644); err != nil {
t.Fatalf("Failed to write version file: %s", err.Error()) t.Fatalf("Failed to write version file: %s", err.Error())
} }
@@ -136,7 +136,7 @@ func TestImportFileToFile(t *testing.T) {
} }
// Perform import // Perform import
imported, failed, err := importArchive(srcBackend, dstBackend) imported, failed, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Import failed: %s", err.Error()) t.Errorf("Import failed: %s", err.Error())
} }
@@ -183,7 +183,7 @@ func TestImportDataIntegrity(t *testing.T) {
} }
// Perform import // Perform import
_, _, err = importArchive(srcBackend, dstBackend) _, _, err = importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Import failed: %s", err.Error()) t.Errorf("Import failed: %s", err.Error())
} }
@@ -253,13 +253,13 @@ func TestImportEmptyArchive(t *testing.T) {
dstDb := filepath.Join(tmpdir, "dst-archive.db") dstDb := filepath.Join(tmpdir, "dst-archive.db")
// Create empty source archive // Create empty source archive
if err := os.MkdirAll(srcArchive, 0755); err != nil { if err := os.MkdirAll(srcArchive, 0o755); err != nil {
t.Fatalf("Failed to create source directory: %s", err.Error()) t.Fatalf("Failed to create source directory: %s", err.Error())
} }
// Write version file // Write version file
versionFile := filepath.Join(srcArchive, "version.txt") versionFile := filepath.Join(srcArchive, "version.txt")
if err := os.WriteFile(versionFile, []byte("3"), 0644); err != nil { if err := os.WriteFile(versionFile, []byte("3"), 0o644); err != nil {
t.Fatalf("Failed to write version file: %s", err.Error()) t.Fatalf("Failed to write version file: %s", err.Error())
} }
@@ -277,7 +277,7 @@ func TestImportEmptyArchive(t *testing.T) {
} }
// Perform import // Perform import
imported, failed, err := importArchive(srcBackend, dstBackend) imported, failed, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Import from empty archive should not fail: %s", err.Error()) t.Errorf("Import from empty archive should not fail: %s", err.Error())
} }
@@ -321,13 +321,13 @@ func TestImportDuplicateJobs(t *testing.T) {
} }
// First import // First import
imported1, _, err := importArchive(srcBackend, dstBackend) imported1, _, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Fatalf("First import failed: %s", err.Error()) t.Fatalf("First import failed: %s", err.Error())
} }
// Second import (should skip all jobs) // Second import (should skip all jobs)
imported2, _, err := importArchive(srcBackend, dstBackend) imported2, _, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Second import failed: %s", err.Error()) t.Errorf("Second import failed: %s", err.Error())
} }
@@ -366,7 +366,7 @@ func TestImportToEmptyFileDestination(t *testing.T) {
util.CopyDir(testDataPath, srcArchive) util.CopyDir(testDataPath, srcArchive)
// Setup empty destination directory // Setup empty destination directory
os.MkdirAll(dstArchive, 0755) os.MkdirAll(dstArchive, 0o755)
// NOTE: NOT writing version.txt here! // NOTE: NOT writing version.txt here!
// Initialize source // Initialize source
@@ -384,7 +384,7 @@ func TestImportToEmptyFileDestination(t *testing.T) {
} }
// Perform import // Perform import
imported, _, err := importArchive(srcBackend, dstBackend) imported, _, err := importArchive(srcBackend, dstBackend, srcConfig)
if err != nil { if err != nil {
t.Errorf("Import failed: %v", err) t.Errorf("Import failed: %v", err)
} }