002_bundle_path_test.go

package migrations_test

import (
	"context"
	"testing"

	"github.com/operator-framework/operator-registry/pkg/sqlite"
	"github.com/operator-framework/operator-registry/pkg/sqlite/migrations"
	"github.com/stretchr/testify/require"
)

func TestBundlePathUp(t *testing.T) {
	db, migrator, cleanup := CreateTestDbAt(t, migrations.BundlePathMigrationKey-1)
	defer cleanup()

	err := migrator.Up(context.TODO(), migrations.Only(migrations.BundlePathMigrationKey))
	require.NoError(t, err)

	// Adding row with bundlepath colum should not fail after migrating up
	tx, err := db.Begin()
	stmt, err := tx.Prepare("insert into operatorbundle(name, csv, bundle, bundlepath) values(?, ?, ?, ?)")
	require.NoError(t, err)
	defer stmt.Close()

	_, err = stmt.Exec("testName", "testCSV", "testBundle", "quay.io/test")
	require.NoError(t, err)

}

func TestBundlePathDown(t *testing.T) {
	db, migrator, cleanup := CreateTestDbAt(t, migrations.BundlePathMigrationKey)
	defer cleanup()

	querier := sqlite.NewSQLLiteQuerierFromDb(db)
	imagesBeforeMigration, err := querier.GetImagesForBundle(context.TODO(), "etcdoperator.v0.6.1")

	err = migrator.Down(context.TODO(), migrations.Only(migrations.BundlePathMigrationKey))
	require.NoError(t, err)

	imagesAfterMigration, err := querier.GetImagesForBundle(context.TODO(), "etcdoperator.v0.6.1")

	// Migrating down entails sensitive operations. Ensure data is preserved accross down migration
	require.Equal(t, len(imagesBeforeMigration), len(imagesAfterMigration))
}