From 4c32ad8cf5c2f70086ded5d11460be598b4c8117 Mon Sep 17 00:00:00 2001
From: Valery Piashchynski <piashchynski_valery@hotmail.com>
Date: Mon, 18 Jan 2021 18:10:41 +0300
Subject: Fix incorrectly set environment variables in the server plugin

---
 pkg/pipe/pipe_factory_spawn_test.go |  2 +-
 plugins/http/plugin.go              | 11 +++++++++--
 plugins/logger/plugin.go            |  1 -
 plugins/server/plugin.go            |  8 +-------
 4 files changed, 11 insertions(+), 11 deletions(-)

diff --git a/pkg/pipe/pipe_factory_spawn_test.go b/pkg/pipe/pipe_factory_spawn_test.go
index 6decedf8..805a24ee 100644
--- a/pkg/pipe/pipe_factory_spawn_test.go
+++ b/pkg/pipe/pipe_factory_spawn_test.go
@@ -116,7 +116,7 @@ func Test_Pipe_Failboot2(t *testing.T) {
 	assert.Contains(t, err.Error(), "failboot")
 }
 
-func Test_Pipe_Invalid2t(t *testing.T) {
+func Test_Pipe_Invalid2(t *testing.T) {
 	cmd := exec.Command("php", "../../tests/invalid.php")
 	w, err := NewPipeFactory().SpawnWorker(cmd)
 	assert.Error(t, err)
diff --git a/plugins/http/plugin.go b/plugins/http/plugin.go
index 70e91cbe..222bf852 100644
--- a/plugins/http/plugin.go
+++ b/plugins/http/plugin.go
@@ -33,8 +33,8 @@ const (
 	// PluginName declares plugin name.
 	PluginName = "http"
 
-	// EventInitSSL thrown at moment of https initialization. SSL server passed as context.
-	EventInitSSL = 750
+	// RR_HTTP env variable key (internal) if the HTTP presents
+	RR_HTTP = "RR_HTTP" //nolint:golint,stylecheck
 )
 
 // Middleware interface
@@ -89,6 +89,13 @@ func (s *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Se
 		return errors.E(op, errors.Disabled)
 	}
 
+	// init if nil
+	if s.cfg.Env == nil {
+		s.cfg.Env = make(map[string]string)
+	}
+
+	s.cfg.Env[RR_HTTP] = "true"
+
 	s.pool, err = server.NewWorkerPool(context.Background(), poolImpl.Config{
 		Debug:           s.cfg.Pool.Debug,
 		NumWorkers:      s.cfg.Pool.NumWorkers,
diff --git a/plugins/logger/plugin.go b/plugins/logger/plugin.go
index 01bf5cc0..250127b0 100644
--- a/plugins/logger/plugin.go
+++ b/plugins/logger/plugin.go
@@ -64,6 +64,5 @@ func (z *ZapLogger) ServiceLogger(n endure.Named) (Logger, error) {
 func (z *ZapLogger) Provides() []interface{} {
 	return []interface{}{
 		z.ServiceLogger,
-		z.DefaultLogger,
 	}
 }
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go
index 8c39b783..721cbd0f 100644
--- a/plugins/server/plugin.go
+++ b/plugins/server/plugin.go
@@ -27,9 +27,7 @@ const PluginName = "server"
 // RR_RELAY env variable key (internal)
 const RR_RELAY = "RR_RELAY" //nolint:golint,stylecheck
 // RR_RPC env variable key (internal) if the RPC presents
-const RR_RPC = "" //nolint:golint,stylecheck
-// RR_HTTP env variable key (internal) if the HTTP presents
-const RR_HTTP = "false" //nolint:golint,stylecheck
+const RR_RPC = "RR_RPC" //nolint:golint,stylecheck
 
 // Plugin manages worker
 type Plugin struct {
@@ -189,10 +187,6 @@ func (server *Plugin) setEnv(e Env) []string {
 		env = append(env, fmt.Sprintf("%s=%s", strings.ToUpper(k), v))
 	}
 
-	// set internal env variables
-	if server.cfg.HTTP != nil {
-		env = append(env, fmt.Sprintf("%s=%s", RR_HTTP, "true"))
-	}
 	if server.cfg.RPC != nil && server.cfg.RPC.Listen != "" {
 		env = append(env, fmt.Sprintf("%s=%s", RR_RPC, server.cfg.RPC.Listen))
 	}
-- 
cgit v1.2.3