From ed27e28a306fd1135f66aa10eaf37f8e926da15f Mon Sep 17 00:00:00 2001
From: Roman Khimov <roman@nspcc.ru>
Date: Thu, 15 Apr 2021 17:16:44 +0300
Subject: [PATCH] app: drop unused Worker/jobDone

---
 app.go  | 14 +-------------
 main.go |  1 -
 2 files changed, 1 insertion(+), 14 deletions(-)

diff --git a/app.go b/app.go
index 09d14bc..d3de2f2 100644
--- a/app.go
+++ b/app.go
@@ -24,13 +24,11 @@ type (
 		cfg          *viper.Viper
 		auxiliaryLog logger.Logger
 		webServer    *fasthttp.Server
-		jobDone      chan struct{}
 		webDone      chan struct{}
 	}
 
 	App interface {
 		Wait()
-		Worker(context.Context)
 		Serve(context.Context)
 	}
 
@@ -65,7 +63,6 @@ func newApp(ctx context.Context, opt ...Option) App {
 		log:       zap.L(),
 		cfg:       viper.GetViper(),
 		webServer: new(fasthttp.Server),
-		jobDone:   make(chan struct{}),
 		webDone:   make(chan struct{}),
 	}
 	for i := range opt {
@@ -134,16 +131,7 @@ func newApp(ctx context.Context, opt ...Option) App {
 
 func (a *app) Wait() {
 	a.log.Info("starting application")
-	select {
-	case <-a.jobDone: // wait for job is stopped
-		<-a.webDone
-	case <-a.webDone: // wait for web-server is stopped
-		<-a.jobDone
-	}
-}
-
-func (a *app) Worker(ctx context.Context) {
-	close(a.jobDone)
+	<-a.webDone // wait for web-server to be stopped
 }
 
 func (a *app) Serve(ctx context.Context) {
diff --git a/main.go b/main.go
index 9e07835..66f3f95 100644
--- a/main.go
+++ b/main.go
@@ -15,7 +15,6 @@ func main() {
 	globalContext := global.Context()
 	app := newApp(globalContext, WithLogger(l), WithConfig(v))
 	go app.Serve(globalContext)
-	go app.Worker(globalContext)
 	app.Wait()
 }