Function RunCommand

cmd/river/rivercli/command.go:59–131

RunCommand bootstraps and runs a River CLI subcommand.

(ctx context.Context, bundle *RunCommandBundle, command Command[TOpts], opts TOpts)

// RunCommand bootstraps and runs a River CLI subcommand.
func RunCommand[TOpts CommandOpts](ctx context.Context, bundle *RunCommandBundle, command Command[TOpts], opts TOpts) error {
	procureAndRun := func() (bool, error) {
		if err := opts.Validate(); err != nil {
			return false, err
		}

		var (
			databaseURL        *string
			protocol           string
			urlWithoutProtocol string
		)
		if pgEnvConfigured() {
			databaseURL = ptrutil.Ptr("")
			protocol = "postgres"
		} else if bundle.DatabaseURL != nil {
			databaseURL = bundle.DatabaseURL
			var ok bool
			protocol, urlWithoutProtocol, ok = strings.Cut(*databaseURL, "://")
			if !ok {
				return false, fmt.Errorf("expected database URL (`%s`) to be formatted like `postgres://...`", *bundle.DatabaseURL)
			}
		}

		driverProcurer := bundle.DriverProcurer
		if databaseURL != nil {
			switch protocol {
			case "postgres", "postgresql":
				dbPool, err := openPgxV5DBPool(ctx, *databaseURL, bundle.StatementTimeout)
				if err != nil {
					return false, err
				}
				defer dbPool.Close()

				driverProcurerPgxV5, isPgxV5Procurer := driverProcurer.(DriverProcurerPgxV5)
				if driverProcurer != nil && isPgxV5Procurer {
					driverProcurerPgxV5.InitPgxV5(dbPool)
				} else {
					driverProcurer = &pgxV5DriverProcurer{dbPool: dbPool}
				}

			case "sqlite":
				dbPool, err := openSQLitePool(protocol, urlWithoutProtocol)
				if err != nil {
					return false, err
				}
				defer dbPool.Close()

				driverProcurer = &sqliteDriverProcurer{dbPool: dbPool}

			default:
				return false, fmt.Errorf("unsupported database URL (`%s`); try one with a `postgres://`, `postgresql://`, or `sqlite://` scheme/prefix", *bundle.DatabaseURL)
			}
		}

		command.SetCommandBase(&CommandBase{
			DriverProcurer: driverProcurer,
			Logger:         bundle.Logger,
			Out:            bundle.OutStd,