Function TestDB_EnsureExists

db_test.go:1519–1657

(t *testing.T)

}

func TestDB_EnsureExists(t *testing.T) {
	t.Run("NoReplica", func(t *testing.T) {
		db := litestream.NewDB(filepath.Join(t.TempDir(), "db"))
		db.Replica = nil
		if err := db.EnsureExists(context.Background()); err == nil {
			t.Fatal("expected error")
		}
	})

	t.Run("DBAlreadyExists", func(t *testing.T) {
		dir := t.TempDir()
		dbPath := filepath.Join(dir, "db")

		if err := os.WriteFile(dbPath, []byte("dummy"), 0644); err != nil {
			t.Fatal(err)
		}

		db := litestream.NewDB(dbPath)
		client := file.NewReplicaClient(filepath.Join(dir, "replica"))
		db.Replica = litestream.NewReplicaWithClient(db, client)

		if err := db.EnsureExists(context.Background()); err != nil {
			t.Fatal(err)
		}

		data, err := os.ReadFile(dbPath)
		if err != nil {
			t.Fatal(err)
		}
		if string(data) != "dummy" {
			t.Fatal("expected file to remain unchanged")
		}
	})

	t.Run("NoBackup", func(t *testing.T) {
		dir := t.TempDir()
		dbPath := filepath.Join(dir, "db")

		db := testingutil.NewDB(t, dbPath)
		client := file.NewReplicaClient(filepath.Join(dir, "replica"))
		db.Replica = litestream.NewReplicaWithClient(db, client)

		if err := db.EnsureExists(context.Background()); err != nil {
			t.Fatalf("expected nil error for no backup, got %v", err)
		}

		if _, err := os.Stat(dbPath); !os.IsNotExist(err) {
			t.Fatal("expected database file to not exist when no backup available")
		}
	})

	t.Run("MissingParentDir", func(t *testing.T) {
		dir := t.TempDir()
		dbPath := filepath.Join(dir, "subdir", "nested", "db")

		db := testingutil.NewDB(t, dbPath)
		client := file.NewReplicaClient(filepath.Join(dir, "replica"))
		db.Replica = litestream.NewReplicaWithClient(db, client)