Function startTempPostgresSetURL

scripts/develop/dbrecovery.go:543–594

(ctx context.Context, logger slog.Logger, cfg *devConfig, pgURL *string)

}

func startTempPostgresSetURL(ctx context.Context, logger slog.Logger, cfg *devConfig, pgURL *string) (func(), error) {
	pgDir := filepath.Join(cfg.configDir, "postgres")
	cleanStalePIDFile(filepath.Join(pgDir, "data"))

	passwordBytes, err := os.ReadFile(filepath.Join(pgDir, "password"))
	if err != nil {
		return nil, xerrors.Errorf("read postgres password: %w", err)
	}
	password := strings.TrimSpace(string(passwordBytes))

	listener, err := net.Listen("tcp4", "127.0.0.1:0")
	if err != nil {
		return nil, xerrors.Errorf("find ephemeral port: %w", err)
	}
	tcpAddr, ok := listener.Addr().(*net.TCPAddr)
	if !ok {
		return nil, xerrors.New("listener returned non-TCP addr")
	}
	port := tcpAddr.Port
	_ = listener.Close()

	ep := embeddedpostgres.NewDatabase(
		embeddedpostgres.DefaultConfig().
			Version(embeddedpostgres.V13).
			BinariesPath(filepath.Join(pgDir, "bin")).
			CachePath(filepath.Join(pgDir, "cache")).
			DataPath(filepath.Join(pgDir, "data")).
			RuntimePath(filepath.Join(pgDir, "runtime")).
			Port(uint32(port)). //nolint:gosec // port from listener, fits uint32.
			Username("coder").
			Password(password).
			Database("coder").
			Logger(nil),
	)

	logger.Info(ctx, "starting temporary postgres for migration check",
		slog.F("port", port))
	if err := ep.Start(); err != nil {
		return nil, xerrors.Errorf("start embedded postgres: %w", err)
	}

	*pgURL = fmt.Sprintf(
		"postgres://coder@localhost:%d/coder?sslmode=disable&password=%s",
		port, url.QueryEscape(password))

	return func() {
		if err := ep.Stop(); err != nil {
			logger.Warn(ctx, "failed to stop temporary postgres",
				slog.Error(err))
		}
	}, nil
}

func cleanStalePIDFile(dataDir string) {
	pidPath := filepath.Join(dataDir, "postmaster.pid")