Function runRequest

http/integration_test.go:320–373

(
	clientConfig config.HTTPClientConfiguration,
	serverConfig config.HTTPServerConfiguration,
	t *testing.T,
	message string,
)

}

func runRequest(
	clientConfig config.HTTPClientConfiguration,
	serverConfig config.HTTPServerConfiguration,
	t *testing.T,
	message string,
) (Response, int, error) {
	response := Response{}
	logger := log.NewTestLogger(t)
	client, err := http2.NewClient(clientConfig, logger)
	if err != nil {
		return response, 0, fmt.Errorf("failed to create client (%w)", err)
	}

	ready := make(chan bool, 1)
	server, err := http2.NewServer(
		"HTTP",
		serverConfig,
		http2.NewServerHandler(&handler{}, logger),
		logger,
		func(_ string) {

		},
	)
	if err != nil {
		return response, 0, fmt.Errorf("failed to create server (%w)", err)
	}
	lifecycle := service.NewLifecycle(server)
	lifecycle.OnRunning(func(s service.Service, l service.Lifecycle) {
		ready <- true
	})

	errorChannel := make(chan error, 2)
	responseStatus := 0
	go func() {
		if err := lifecycle.Run(); err != nil {
			errorChannel <- err
		}
		close(errorChannel)
	}()
	<-ready
	if responseStatus, err = client.Post(
		"",
		&Request{Message: message},
		&response,
	); err != nil {
		lifecycle.Stop(context.Background())
		return response, 0, err
	}
	lifecycle.Stop(context.Background())
	if err, ok := <-errorChannel; ok {
		return response, 0, err
	}
	return response, responseStatus, nil
}