Function RunUntilEndpointHit

interactive/interactive.go:45–89

RunUntilEndpointHit stalls current goroutine executions and prints the URL to local address. When URL is hit this function returns with nil to continue the execution. It also watches for SIGINT, SIGKILL or SIGHUP signals and does the same when any of those is seen. This function is useful when you

()

// as opposed to RunUntilSignal for certain IDEs that does not send correct signal on stop (e.g. Goland pre 2022.3,
// see https://youtrack.jetbrains.com/issue/GO-5982).
func RunUntilEndpointHit() (err error) {
	once := sync.Once{}
	wg := sync.WaitGroup{}
	stopWG := sync.WaitGroup{}
	stopWG.Add(1)

	l, err := net.Listen("tcp", "localhost:0")
	if err != nil {
		return err
	}
	srv := &http.Server{Handler: http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
		once.Do(func() { stopWG.Done() })
	})}

	wg.Add(2)
	go func() {
		if serr := srv.Serve(l); serr != nil {
			once.Do(func() {
				err = errors.Wrap(serr, "unexpected error")
				stopWG.Done()
			})
		}
		wg.Done()
	}()
	ctx, cancel := context.WithCancel(context.Background())
	go func() {
		s := make(chan os.Signal, 1)
		signal.Notify(s, syscall.SIGINT, syscall.SIGTERM, syscall.SIGHUP)
		select {
		case <-s:
		case <-ctx.Done():
		}
		once.Do(func() { stopWG.Done() })
		wg.Done()
	}()

	fmt.Println("Waiting for user HTTP request on ", "http://"+l.Addr().String(), " or SIGINT, SIGKILL or SIGHUP signal...")
	stopWG.Wait()

	// Cleanup.
	cancel()
	_ = l.Close()
	wg.Wait()
	return nil
}

// RunUntilSignal stops the current goroutine execution and watches for SIGINT, SIGKILL and SIGHUP signals. Once spotted it continues
// the execution. This function is useful when you want to interact with e2e tests and manually decide when to finish.