Function RunReplicationScripts

testing/go/replication_test.go:510–540

RunScripts runs the given collection of scripts.

(t *testing.T, scripts []ReplicationTest)

// RunScripts runs the given collection of scripts.
func RunReplicationScripts(t *testing.T, scripts []ReplicationTest) {
	// First, we'll run through the scripts to check for the Focus variable. If it's true, then append it to the new slice.
	focusScripts := make([]ReplicationTest, 0, len(scripts))
	for _, script := range scripts {
		if script.Focus {
			// If this is running in GitHub Actions, then we'll panic, because someone forgot to disable it before committing
			if _, ok := os.LookupEnv("GITHUB_ACTION"); ok {
				panic(fmt.Sprintf("The script `%s` has Focus set to `true`. GitHub Actions requires that "+
					"all tests are run, which Focus circumvents, leading to this error. Please disable Focus on "+
					"all tests.", script.Name))
			}
			focusScripts = append(focusScripts, script)
		}
	}
	// If we have scripts with Focus set, then we replace the normal script slice with the new slice.
	if len(focusScripts) > 0 {
		scripts = focusScripts
	}

	primaryDns := fmt.Sprintf("postgres://postgres:password@127.0.0.1:%d/%s?sslmode=disable&replication=database", localPostgresPort, "postgres")

	// We drop and recreate the replication slot once at the beginning of the test suite. Postgres seems to do a little
	// work in the background with a publication, so we need to wait a little bit before running any test scripts.
	require.NoError(t, logrepl.DropPublication(primaryDns, slotName))
	require.NoError(t, logrepl.CreatePublication(primaryDns, slotName))
	time.Sleep(500 * time.Millisecond)

	for _, script := range scripts {
		RunReplicationScript(t, script)
	}
}

const slotName = "doltgres_slot"
const localPostgresPort = 5432