handle env errors

3 files changed, 9 insertions, 4 deletions

diff --git a/service/env/provider.go b/service/env/provider.go
index 75a1e31b..2918f18c 100644
--- a/service/env/provider.go
+++ b/service/env/provider.go
@@ -4,5 +4,5 @@ package env
 // values from external sources.
 type Provider interface {
 	// GetEnv must return list of env variables.
-	GetEnv() map[string]string
+	GetEnv() (map[string]string, error)
 }
diff --git a/service/env/service.go b/service/env/service.go
index 95e99093..a90b0c48 100644
--- a/service/env/service.go
+++ b/service/env/service.go
@@ -16,6 +16,6 @@ func (s *Service) Init(cfg *Config) (bool, error) {
 }
 
 // GetEnv must return list of env variables.
-func (s *Service) GetEnv() map[string]string {
-	return s.cfg.Values
+func (s *Service) GetEnv() (map[string]string, error) {
+	return s.cfg.Values, nil
 }
diff --git a/service/http/service.go b/service/http/service.go
index a8f99669..9f62f5af 100644
--- a/service/http/service.go
+++ b/service/http/service.go
@@ -61,7 +61,12 @@ func (s *Service) Serve() error {
 	s.mu.Lock()
 
 	if s.env != nil {
-		for k, v := range s.env.GetEnv() {
+		values, err := s.env.GetEnv()
+		if err != nil {
+			return err
+		}
+
+		for k, v := range values {
 			s.cfg.Workers.SetEnv(k, v)
 		}
 	}