chore(backup_test): remove TestBackupRestoreIntegration

We haven't been supporting ansible script restore for
a long time, so we don't need to keep on testing it.

Author: Michal-Leszczynski

pkg/service/backup/service_backup_integration_test.go

@@ -20,7 +20,6 @@ import (
 	"testing"
 	"time"
 
-	"github.com/gocql/gocql"
 	"github.com/google/go-cmp/cmp"
 	"github.com/google/go-cmp/cmp/cmpopts"
 	"github.com/pkg/errors"
@@ -2120,141 +2119,6 @@ func TestValidateIntegration(t *testing.T) {
 	}
 }
 
-func TestBackupRestoreIntegration(t *testing.T) {
-	const (
-		testBucket   = "backuptest-restore"
-		testKeyspace = "backuptest_restore"
-	)
-
-	location := s3Location(testBucket)
-	config := defaultConfig()
-
-	var (
-		session         = CreateScyllaManagerDBSession(t)
-		h               = newBackupTestHelper(t, session, config, location, nil)
-		ctx             = context.Background()
-		clusterSession  = CreateSessionAndDropAllKeyspaces(t, h.Client)
-		initialRowCount = 100
-		addedRowCount   = 150
-	)
-
-	Print("When: cluster has data")
-	ExecStmt(t, clusterSession, "CREATE KEYSPACE IF NOT EXISTS "+testKeyspace+" WITH replication = {'class': 'NetworkTopologyStrategy', 'dc1': 3, 'dc2': 3}")
-	ExecStmt(t, clusterSession, "CREATE TABLE IF NOT EXISTS "+testKeyspace+".test_table (id int PRIMARY KEY)")
-	for i := 1; i <= initialRowCount; i++ {
-		ExecStmt(t, clusterSession, "INSERT INTO "+testKeyspace+".test_table (id) VALUES "+fmt.Sprintf("(%d)", i))
-	}
-
-	target := backup.Target{
-		Units: []backup.Unit{
-			{
-				Keyspace: testKeyspace,
-				Tables:   []string{"test_table"},
-			},
-			{
-				Keyspace:  "system_schema",
-				AllTables: true,
-			},
-		},
-		DC:        []string{"dc1", "dc2"},
-		Location:  []backupspec.Location{location},
-		Retention: 3,
-	}
-	if err := h.service.InitTarget(ctx, h.ClusterID, &target); err != nil {
-		t.Fatal(err)
-	}
-
-	Print("And: run backup")
-	if err := h.service.Backup(ctx, h.ClusterID, h.TaskID, h.RunID, target); err != nil {
-		t.Fatal(err)
-	}
-
-	Print("Then: there is one backup")
-	items, err := h.service.List(ctx, h.ClusterID, []backupspec.Location{location}, backup.ListFilter{ClusterID: h.ClusterID})
-	if err != nil {
-		t.Fatal(err)
-	}
-	if len(items) != 1 {
-		t.Fatalf("List() = %v, expected one item", items)
-	}
-	item := items[0]
-	if len(item.SnapshotInfo) != 1 {
-		t.Fatalf("List() = %v, expected one SnapshotTag", items)
-	}
-	snapshotTag := item.SnapshotInfo[0].SnapshotTag
-
-	Print("And: add more data")
-	for i := initialRowCount + 1; i <= addedRowCount; i++ {
-		ExecStmt(t, clusterSession, "INSERT INTO "+testKeyspace+".test_table (id) VALUES "+fmt.Sprintf("(%d)", i))
-	}
-
-	Print("Then: there is 15 rows")
-	count := func() int {
-		c := 0
-		if err := clusterSession.Query("SELECT COUNT(*) FROM "+testKeyspace+".test_table;", nil).Scan(&c); err != nil {
-			t.Fatal("select count:", err)
-		}
-		return c
-	}
-	if c := count(); c != addedRowCount {
-		t.Errorf("SELECT COUNT(*) = %d, expected %d", c, addedRowCount)
-	}
-
-	Print("When: delete data")
-	q := clusterSession.Query("TRUNCATE "+testKeyspace+".test_table", nil)
-	q.Consistency(gocql.All)
-	if err := q.ExecRelease(); err != nil {
-		t.Fatal("TRUNCATE error", err)
-	}
-
-	Print("And: restore snapshot")
-	status, err := h.Client.Status(ctx)
-	if err != nil {
-		t.Fatal("Status() error", err)
-	}
-
-	for _, nis := range status {
-		stdout, stderr, err := ExecOnHost(nis.Addr, "chown scylla:scylla -R /var/lib/scylla/data/"+testKeyspace)
-		if err != nil {
-			t.Log("stdout", stdout)
-			t.Log("stderr", stderr)
-			t.Fatal("Command failed on host", nis.Addr, err)
-		}
-	}
-	downloadFilesCmd := []string{
-		"su scylla -c",
-		"scylla-manager-agent",
-		"download-files",
-		"-d", "/var/lib/scylla/data",
-		"-L", location.String(),
-		"-T", snapshotTag,
-		"-K", testKeyspace,
-		"--mode", "upload",
-	}
-	for _, nis := range status {
-		stdout, stderr, err := ExecOnHost(nis.Addr, strings.Join(downloadFilesCmd, " "))
-		if err != nil {
-			t.Log("stdout", stdout)
-			t.Log("err", err)
-			t.Log("stderr", stderr)
-			t.Fatal("Command failed on host", nis.Addr, err)
-		}
-	}
-	for _, nis := range status {
-		stdout, stderr, err := ExecOnHost(nis.Addr, "nodetool refresh "+testKeyspace+" test_table")
-		if err != nil {
-			t.Log("stdout", stdout)
-			t.Log("stderr", stderr)
-			t.Fatal("Command failed on host", nis.Addr, err)
-		}
-	}
-
-	Print("Then: there is previous number of rows")
-	if c := count(); c != initialRowCount {
-		t.Errorf("SELECT COUNT(*) = %d, expected %d", c, addedRowCount)
-	}
-}
-
 func TestBackupListIntegration(t *testing.T) {
 	const (
 		testBucket    = "backuptest-list"