From 41eb0583034ece1797a0e13c0612e12e5d4e4955 Mon Sep 17 00:00:00 2001 From: Timofey Koolin Date: Sun, 14 May 2023 19:54:50 +0300 Subject: [PATCH 1/2] fix args --- cmd/metricstest/iteration10a_test.go | 3 +-- cmd/metricstest/iteration10b_test.go | 5 ++--- go.sum | 6 ++++++ 3 files changed, 9 insertions(+), 5 deletions(-) diff --git a/cmd/metricstest/iteration10a_test.go b/cmd/metricstest/iteration10a_test.go index 5acc296..81c5761 100644 --- a/cmd/metricstest/iteration10a_test.go +++ b/cmd/metricstest/iteration10a_test.go @@ -40,7 +40,7 @@ func (suite *Iteration10ASuite) SetupSuite() { envs := append(os.Environ(), []string{ "ADDRESS=localhost:" + flagServerPort, "RESTORE=true", - "STORE_INTERVAL=10s", + "STORE_INTERVAL=10", "DATABASE_DSN=" + flagDatabaseDSN, }...) @@ -75,7 +75,6 @@ func (suite *Iteration10ASuite) serverUp(ctx context.Context, envs, args []strin suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration10ASuite) TearDownSuite() { diff --git a/cmd/metricstest/iteration10b_test.go b/cmd/metricstest/iteration10b_test.go index 067c098..c6fc126 100644 --- a/cmd/metricstest/iteration10b_test.go +++ b/cmd/metricstest/iteration10b_test.go @@ -39,13 +39,13 @@ func (suite *Iteration10BSuite) SetupSuite() { envs := append(os.Environ(), []string{ "ADDRESS=localhost:" + flagServerPort, "RESTORE=true", - "STORE_INTERVAL=10s", + "STORE_INTERVAL=10", "DATABASE_DSN='postgres://unknown:unknown@postgres:9999/praktikum?easter_egg_msg=you_must_prefer_this_incorrect_settings_to_those_obtained_through_arguments'", }...) serverArgs := []string{ "-r=false", - "-d" + flagDatabaseDSN, + "-d=" + flagDatabaseDSN, } ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) @@ -70,7 +70,6 @@ func (suite *Iteration10BSuite) serverUp(ctx context.Context, envs, args []strin suite.T().Logf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration10BSuite) TearDownSuite() { diff --git a/go.sum b/go.sum index ee887f5..30c1645 100644 --- a/go.sum +++ b/go.sum @@ -1,5 +1,6 @@ github.com/BurntSushi/toml v1.2.1 h1:9F2/+DoOYIOksmaJFPw1tGFy1eDnIJXg+UHjuD8lTak= github.com/BurntSushi/toml v1.2.1/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ= +github.com/chzyer/readline v1.5.0 h1:lSwwFrbNviGePhkewF1az4oLmcwqCZijQ2/Wi3BGHAI= github.com/cockroachdb/apd v1.1.0 h1:3LFP3629v+1aKXU5Q37mxmRxX/pIu1nijXydLShEq5I= github.com/cockroachdb/apd v1.1.0/go.mod h1:8Sl8LxpKi29FqWXR16WEFZRNSz3SoPzUzeMeY4+DwBQ= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -13,6 +14,7 @@ github.com/google/pprof v0.0.0-20220829040838-70bd9ae97f40 h1:ykKxL12NZd3JmWZnyq github.com/google/pprof v0.0.0-20220829040838-70bd9ae97f40/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo= github.com/gostaticanalysis/analysisutil v0.0.0-20190318220348-4088753ea4d3 h1:JVnpOZS+qxli+rgVl98ILOXVNbW+kb5wcxeGx8ShUIw= github.com/gostaticanalysis/analysisutil v0.0.0-20190318220348-4088753ea4d3/go.mod h1:eEOZF4jCKGi+aprrirO9e7WKB3beBRtWgqGunKl6pKE= +github.com/ianlancetaylor/demangle v0.0.0-20220319035150-800ac71e25c2 h1:rcanfLhLDA8nozr/K289V1zcntHr3V+SHlXwzz1ZI2g= github.com/jackc/fake v0.0.0-20150926172116-812a484cc733 h1:vr3AYkKovP8uR8AvSGGUK1IDqRa5lAAvEkZG1LKaCRc= github.com/jackc/fake v0.0.0-20150926172116-812a484cc733/go.mod h1:WrMFNQdiFJ80sQsxDoMokWK1W5TQtxBFNpzWTD84ibQ= github.com/jackc/pgx v3.6.2+incompatible h1:2zP5OD7kiyR3xzRYMhOcXVvkDZsImVXfj+yIyTQf3/o= @@ -28,6 +30,7 @@ github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZN github.com/shopspring/decimal v1.3.1 h1:2Usl1nmF/WZucqkFZhnfFYxxxu8LG21F6nPQBE5gKV8= github.com/shopspring/decimal v1.3.1/go.mod h1:DKyhrW/HYNuLGql+MJL6WCR6knT2jwCFRcu2hWCYk4o= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/objx v0.4.0 h1:M2gUjqZET1qApGOWNSnZ49BAIMX4F/1plDv3+l31EJ4= github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= @@ -35,6 +38,7 @@ github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO github.com/timakin/bodyclose v0.0.0-20210704033933-f49887972144 h1:kl4KhGNsJIbDHS9/4U9yQo1UcPQM0kOMJHn29EoH/Ro= github.com/timakin/bodyclose v0.0.0-20210704033933-f49887972144/go.mod h1:Qimiffbc6q9tBWlVV6x0P9sat/ao1xEkREYPPj9hphk= github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k= +github.com/yuin/goldmark v1.4.13 h1:fVcFKWvrslecOb/tg+Cc05dkeYx540o0FuFt3nUVDoE= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI= golang.org/x/crypto v0.6.0 h1:qfktjS5LUO+fFKeJXZ+ikTRijMmljikvG68fpMMruSc= @@ -64,6 +68,7 @@ golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.5.0 h1:MUK/U/4lj1t1oPg0HfuXDN/Z1wv31ZJ/YcPiGccS4DU= golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= +golang.org/x/term v0.5.0 h1:n2a8QNdAb0sZNpU9R1ALUXBbY+w51fCQDN+7EdxNBsY= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= @@ -78,6 +83,7 @@ golang.org/x/tools v0.4.1-0.20221208213631-3f74d914ae6d h1:9ZNWAi4CYhNv60mXGgAnc golang.org/x/tools v0.4.1-0.20221208213631-3f74d914ae6d/go.mod h1:UE5sM2OK9E/d67R0ANs2xJizIymRP5gJU295PvKXxjQ= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= From 66ac1c031493b92eacf1e5db74e58ea8557e9704 Mon Sep 17 00:00:00 2001 From: Timofey Koolin Date: Sun, 14 May 2023 20:08:32 +0300 Subject: [PATCH 2/2] output log when process failed to start --- cmd/metricstest/iteration10a_test.go | 8 ++++---- cmd/metricstest/iteration10b_test.go | 8 ++++---- cmd/metricstest/iteration11_test.go | 9 ++++----- cmd/metricstest/iteration12_test.go | 9 ++++----- cmd/metricstest/iteration13_test.go | 18 ++++++++---------- cmd/metricstest/iteration14_test.go | 18 ++++++++---------- cmd/metricstest/iteration1_test.go | 10 ++++------ cmd/metricstest/iteration2a_test.go | 10 ++++------ cmd/metricstest/iteration3b_test.go | 10 ++++------ cmd/metricstest/iteration4_test.go | 18 ++++++++---------- cmd/metricstest/iteration5_test.go | 18 ++++++++---------- cmd/metricstest/iteration7_test.go | 18 ++++++++---------- cmd/metricstest/iteration8_test.go | 18 ++++++++---------- cmd/metricstest/iteration9_test.go | 9 ++++----- 14 files changed, 80 insertions(+), 101 deletions(-) diff --git a/cmd/metricstest/iteration10a_test.go b/cmd/metricstest/iteration10a_test.go index 81c5761..13f4593 100644 --- 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 index c6fc126..5ea732f 100644 --- 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 index 6b9f460..986dcd8 100644 --- 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 index b5dcdc3..c5d664d 100644 --- 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 index d7b1020..51e2b5c 100644 --- 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 index 79028a9..793499d 100644 --- 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 index 6bcfab5..b021f44 100644 --- 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 index a798a4a..c335012 100644 --- 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 index 80d7a4f..306d55b 100644 --- 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 index e680823..86f6174 100644 --- 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() { diff --git a/cmd/metricstest/iteration5_test.go b/cmd/metricstest/iteration5_test.go index 5104f58..65041be 100644 --- a/cmd/metricstest/iteration5_test.go +++ b/cmd/metricstest/iteration5_test.go @@ -50,41 +50,39 @@ func (suite *Iteration5Suite) SetupSuite() { } func (suite *Iteration5Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) 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 *Iteration5Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - 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 } - 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 *Iteration5Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration7_test.go b/cmd/metricstest/iteration7_test.go index 9d651e4..164b698 100644 --- a/cmd/metricstest/iteration7_test.go +++ b/cmd/metricstest/iteration7_test.go @@ -61,41 +61,39 @@ func (suite *Iteration7Suite) SetupSuite() { } func (suite *Iteration7Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - 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 } - 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 *Iteration7Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - 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 } - 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 *Iteration7Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration8_test.go b/cmd/metricstest/iteration8_test.go index e05b41d..77ebc0e 100644 --- a/cmd/metricstest/iteration8_test.go +++ b/cmd/metricstest/iteration8_test.go @@ -51,41 +51,39 @@ func (suite *Iteration8Suite) SetupSuite() { } func (suite *Iteration8Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) 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 *Iteration8Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) 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 *Iteration8Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration9_test.go b/cmd/metricstest/iteration9_test.go index 1e589e2..ca9b4cd 100644 --- a/cmd/metricstest/iteration9_test.go +++ b/cmd/metricstest/iteration9_test.go @@ -74,22 +74,21 @@ func (suite *Iteration9Suite) serverUp(ctx context.Context, envs []string, port } func (suite *Iteration9Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - 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 } - 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 *Iteration9Suite) TearDownSuite() {