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) }