output log when process failed to start

Yandex-Practicum · May 14, 2023 · 66ac1c0 · 66ac1c0
1 parent 41eb058
commit 66ac1c0
Show file tree

Hide file tree

Showing 14 changed files with 80 additions and 101 deletions.
diff --git a/cmd/metricstest/iteration10a_test.go b/cmd/metricstest/iteration10a_test.go
@@ -59,18 +59,18 @@ func (suite *Iteration10ASuite) SetupSuite() {
 }
 
 func (suite *Iteration10ASuite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return

diff --git a/cmd/metricstest/iteration10b_test.go b/cmd/metricstest/iteration10b_test.go
@@ -54,18 +54,18 @@ func (suite *Iteration10BSuite) SetupSuite() {
 }
 
 func (suite *Iteration10BSuite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Logf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return

diff --git a/cmd/metricstest/iteration11_test.go b/cmd/metricstest/iteration11_test.go
@@ -85,23 +85,22 @@ func (suite *Iteration11Suite) SetupSuite() {
 }
 
 func (suite *Iteration11Suite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-	suite.serverProcess = p
 }
 
 func (suite *Iteration11Suite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration12_test.go b/cmd/metricstest/iteration12_test.go
@@ -86,23 +86,22 @@ func (suite *Iteration12Suite) SetupSuite() {
 }
 
 func (suite *Iteration12Suite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-	suite.serverProcess = p
 }
 
 func (suite *Iteration12Suite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration13_test.go b/cmd/metricstest/iteration13_test.go
@@ -60,43 +60,41 @@ func (suite *Iteration13Suite) SetupSuite() {
 }
 
 func (suite *Iteration13Suite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-	suite.serverProcess = p
 }
 
 func (suite *Iteration13Suite) agentUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
+	suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.agentProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args)
 		return
 	}
 
-	err = p.ListenPort(ctx, "tcp", port)
+	err = suite.agentProcess.ListenPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err)
 		return
 	}
-	suite.agentProcess = p
 }
 
 func (suite *Iteration13Suite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration14_test.go b/cmd/metricstest/iteration14_test.go
@@ -66,43 +66,41 @@ func (suite *Iteration14Suite) SetupSuite() {
 }
 
 func (suite *Iteration14Suite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-	suite.serverProcess = p
 }
 
 func (suite *Iteration14Suite) agentUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
+	suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.agentProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args)
 		return
 	}
 
-	err = p.ListenPort(ctx, "tcp", port)
+	err = suite.agentProcess.ListenPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err)
 		return
 	}
-	suite.agentProcess = p
 }
 
 func (suite *Iteration14Suite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration1_test.go b/cmd/metricstest/iteration1_test.go
@@ -31,27 +31,25 @@ func (suite *Iteration1Suite) SetupSuite() {
 	envs := append(os.Environ(), []string{
 		"RESTORE=false",
 	}...)
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 	)
 
 	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
 	defer cancel()
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs)
+		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.serverProcess, err, envs)
 		return
 	}
 
 	port := "8080"
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-
-	suite.serverProcess = p
 }
 
 func (suite *Iteration1Suite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration2a_test.go b/cmd/metricstest/iteration2a_test.go
@@ -28,27 +28,25 @@ func (suite *Iteration2ASuite) SetupSuite() {
 	envs := append(os.Environ(), []string{
 		"RESTORE=false",
 	}...)
-	p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
+	suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
 		fork.WithEnv(envs...),
 	)
 
 	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
 	defer cancel()
 
-	err := p.Start(ctx)
+	err := suite.agentProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs)
+		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.agentProcess, err, envs)
 		return
 	}
 
 	port := "8080"
-	err = p.ListenPort(ctx, "tcp", port)
+	err = suite.agentProcess.ListenPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err)
 		return
 	}
-
-	suite.agentProcess = p
 }
 
 func (suite *Iteration2ASuite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration3b_test.go b/cmd/metricstest/iteration3b_test.go
@@ -34,27 +34,25 @@ func (suite *Iteration3BSuite) SetupSuite() {
 	envs := append(os.Environ(), []string{
 		"RESTORE=false",
 	}...)
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 	)
 
 	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
 	defer cancel()
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs)
+		suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.serverProcess, err, envs)
 		return
 	}
 
 	port := "8080"
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-
-	suite.serverProcess = p
 }
 
 func (suite *Iteration3BSuite) TearDownSuite() {

diff --git a/cmd/metricstest/iteration4_test.go b/cmd/metricstest/iteration4_test.go
@@ -63,43 +63,41 @@ func (suite *Iteration4Suite) SetupSuite() {
 }
 
 func (suite *Iteration4Suite) serverUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
+	suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.serverProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args)
 		return
 	}
 
-	err = p.WaitPort(ctx, "tcp", port)
+	err = suite.serverProcess.WaitPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err)
 		return
 	}
-	suite.serverProcess = p
 }
 
 func (suite *Iteration4Suite) agentUp(ctx context.Context, envs, args []string, port string) {
-	p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
+	suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath,
 		fork.WithEnv(envs...),
 		fork.WithArgs(args...),
 	)
 
-	err := p.Start(ctx)
+	err := suite.agentProcess.Start(ctx)
 	if err != nil {
-		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args)
+		suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args)
 		return
 	}
 
-	err = p.ListenPort(ctx, "tcp", port)
+	err = suite.agentProcess.ListenPort(ctx, "tcp", port)
 	if err != nil {
 		suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err)
 		return
 	}
-	suite.agentProcess = p
 }
 
 func (suite *Iteration4Suite) TearDownSuite() {