feat: bump CRDB, establish foreign key,

GitOrigin-RevId: ca6d967ddb2e2eeb2d2eaf25e851652dddbc1d47

Author: alnr

oryx/logrusx/logrus.go

@@ -245,22 +245,10 @@ func NewT(t testing.TB, opts ...Option) *Logger {
 		t.Fatalf("Logger exited with code %d", code)
 	}))
 	l := New(t.Name(), "test", opts...)
-	l.Logger.Out = &testOutput{t}
+	l.Logger.Out = t.Output()
 	return l
 }
 
-type testOutput struct {
-	t testing.TB
-}
-
-func (t *testOutput) Write(p []byte) (n int, err error) {
-	if t.t == nil {
-		return os.Stdout.Write(p)
-	}
-	t.t.Log(t.t.Name() + " " + string(p))
-	return len(p), nil
-}
-
 func NewAudit(name string, version string, opts ...Option) *Logger {
 	return New(name, version, opts...).WithField("audience", "audit")
 }

oryx/popx/migrator.go

@@ -138,6 +138,7 @@ func (mb *MigrationBox) UpTo(ctx context.Context, step int) (applied int, err er
 
 // Down runs pending "down" migrations and rolls back the
 // database by the specified number of steps.
+// If step <= 0, all down migrations are run.
 func (mb *MigrationBox) Down(ctx context.Context, steps int) (err error) {
 	ctx, span := startSpan(ctx, MigrationDownOpName, trace.WithAttributes(attribute.Int("steps", steps)))
 	defer otelx.End(span, &err)

oryx/popx/transaction.go

@@ -22,6 +22,10 @@ func WithTransaction(ctx context.Context, tx *pop.Connection) context.Context {
 	return context.WithValue(ctx, transactionKey, tx)
 }
 
+func InTransaction(ctx context.Context) bool {
+	return ctx.Value(transactionKey) != nil
+}
+
 func Transaction(ctx context.Context, connection *pop.Connection, callback func(context.Context, *pop.Connection) error) error {
 	c := ctx.Value(transactionKey)
 	if c != nil {

oryx/sqlcon/dockertest/cockroach.go

@@ -11,7 +11,7 @@ import (
 )
 
 func NewLocalTestCRDBServer(t testing.TB) string {
-	ts, err := testserver.NewTestServer(testserver.CustomVersionOpt("23.1.13"))
+	ts, err := testserver.NewTestServer(testserver.CustomVersionOpt("25.3.3"))
 	require.NoError(t, err)
 	t.Cleanup(ts.Stop)
 

oryx/sqlcon/dockertest/test_helper.go

@@ -356,7 +356,7 @@ func RunTestCockroachDB(t testing.TB) string {
 	return RunTestCockroachDBWithVersion(t, "")
 }
 
-// RunTestCockroachDB runs a CockroachDB database and returns the URL to it.
+// RunTestCockroachDBWithVersion runs a CockroachDB database and returns the URL to it.
 // If a docker container is started for the database, the container be removed
 // at the end of the test.
 func RunTestCockroachDBWithVersion(t testing.TB, version string) string {