From 2d1f226ab77de233d81752bd53ba44eb54841834 Mon Sep 17 00:00:00 2001 From: Senad Uka Date: Wed, 18 Mar 2020 20:42:16 +0100 Subject: [PATCH] Use worker server --- main.go | 16 +++------------- 1 file changed, 3 insertions(+), 13 deletions(-) diff --git a/main.go b/main.go index e8ed204..c19e016 100644 --- a/main.go +++ b/main.go @@ -4,6 +4,7 @@ import ( "github.com/sevlyar/go-daemon" "gitlab.com/saburly/kiviscraplib/structures" "gitlab.com/saburly/kiviscraplib/webserver" + "gitlab.com/saburly/kiviscraplib/workerserver" "log" ) @@ -37,20 +38,9 @@ func main() { end = make(chan string) go webserver.ServeHTTP(queue, end) - go func() { - for { - request := <-queue - //time.Sleep(2 * time.Second) - response := structures.Response{ - Url: request.Url, - Content: []byte("

Bla!

"), - Err: nil, - } - request.Response <- response - } - }() + go workerserver.ServeWorkers(queue, end) ended := <-end - log.Printf("%s ended so closing the daemon", ended) + log.Printf("%s ended so closing the daemon\n", ended) }