Function TestManagers

persistence/sql/persister_test.go:171–215

(t *testing.T)

}

func TestManagers(t *testing.T) {
	t.Parallel()

	dsns := map[string]string{
		"sqlite": dbal.NewSQLiteTestDatabase(t),
	}
	if !testing.Short() {
		dsns["postgres"], dsns["mysql"], dsns["cockroach"] = testhelpers.ConnectDatabasesURLs(t)
	}
	network1NID, network2NID, invalidNID := uuid.Must(uuid.NewV4()), uuid.Must(uuid.NewV4()), uuid.Must(uuid.NewV4())

	for db, dsn := range dsns {
		t.Run(db, func(t *testing.T) {
			t.Parallel()
			t.Logf("Testing database %s: %q", db, dsn)

			r1 := testhelpers.NewRegistrySQLFromURL(t, dsn, true, true, driver.DisableValidation(), driver.WithServiceLocatorOptions(servicelocatorx.WithContextualizer(&contextx.Static{NID: network1NID})))
			r2 := testhelpers.NewRegistrySQLFromURL(t, dsn, false, true, driver.DisableValidation(), driver.WithServiceLocatorOptions(servicelocatorx.WithContextualizer(&contextx.Static{NID: network2NID})))
			rInv := testhelpers.NewRegistrySQLFromURL(t, dsn, false, true, driver.DisableValidation(), driver.SkipNetworkInit(), driver.WithServiceLocatorOptions(servicelocatorx.WithContextualizer(&contextx.Static{NID: invalidNID})))

			require.NoError(t, r1.Persister().Connection(t.Context()).Create(&networkx.Network{ID: network1NID}))
			require.NoError(t, r1.Persister().Connection(t.Context()).Create(&networkx.Network{ID: network2NID}))

			require.Equal(t, network1NID, r1.Persister().NetworkID(t.Context()))
			require.Equal(t, network2NID, r2.Persister().NetworkID(t.Context()))
			require.Equal(t, invalidNID, rInv.Persister().NetworkID(t.Context()))

			t.Run("parallel boundary", func(t *testing.T) { testRegistry(t, db, r1, r2) })

			if db == "sqlite" {
				// The following tests rely on foreign key constraints, which some of them are not correctly created in the SQLite schema.
				return
			}

			// if !r1.Config().HSMEnabled() {
			t.Run("jwk nid",
				jwk.TestHelperNID(r1.KeyManager(), rInv.KeyManager()),
			)
			// }
			t.Run("login nid",
				test.LoginNIDTest(r1.Persister(), rInv.Persister()),
			)
		})
	}
}