From cd5e0ef1a766c9bbbf5fc20e0977a87158d871a1 Mon Sep 17 00:00:00 2001
From: Ben Sarmiento <ben.sarmiento@forto.com>
Date: Mon, 29 Jan 2024 02:59:01 +0100
Subject: [PATCH] Remove options

---
 internal/app.go             | 28 +++++-----------------------
 internal/torrent/refresh.go |  2 +-
 2 files changed, 6 insertions(+), 24 deletions(-)

diff --git a/internal/app.go b/internal/app.go
index b2e0596..b7e75a3 100644
--- a/internal/app.go
+++ b/internal/app.go
@@ -50,44 +50,26 @@ func MainApp(configPath string) {
 
 	premium.MonitorPremiumStatus(rd, zurglog)
 
-	workerOptions := ants.Options{
-		// Nonblocking:  true,
-		PanicHandler: func(i interface{}) {},
-		Logger:       log.Named("worker"),
-	}
-
-	workerPool, err := ants.NewPool(config.GetNumOfWorkers(), ants.WithOptions(workerOptions))
+	workerPool, err := ants.NewPool(config.GetNumOfWorkers())
 	if err != nil {
 		zurglog.Errorf("Failed to create worker pool: %v", err)
 		os.Exit(1)
 	}
 	defer workerPool.Release()
 
-	refreshOptions := ants.Options{
-		// Nonblocking:  true,
-		PanicHandler: func(i interface{}) {},
-		Logger:       log.Named("refreshworker"),
-	}
-
 	// extra 1 worker for the refresh job
-	refreshPool, err := ants.NewPool(1, ants.WithOptions(refreshOptions))
+	refreshPool, err := ants.NewPool(1)
 	if err != nil {
-		zurglog.Errorf("Failed to create worker pool: %v", err)
+		zurglog.Errorf("Failed to create refresh worker: %v", err)
 		os.Exit(1)
 	}
 	defer refreshPool.Release()
 
-	repairOptions := ants.Options{
-		// Nonblocking:  true,
-		PanicHandler: func(i interface{}) {},
-		Logger:       log.Named("repairworker"),
-	}
-
 	var repairPool *ants.Pool
 	if config.EnableRepair() {
-		repairPool, err = ants.NewPool(1, ants.WithOptions(repairOptions))
+		repairPool, err = ants.NewPool(1)
 		if err != nil {
-			zurglog.Errorf("Failed to create repair pool: %v", err)
+			zurglog.Errorf("Failed to create repair worker: %v", err)
 			os.Exit(1)
 		}
 		defer repairPool.Release()
diff --git a/internal/torrent/refresh.go b/internal/torrent/refresh.go
index 91342f6..c353062 100644
--- a/internal/torrent/refresh.go
+++ b/internal/torrent/refresh.go
@@ -45,6 +45,7 @@ func (t *TorrentManager) refreshTorrents() []string {
 	}
 
 	wg.Wait()
+	close(infoChan)
 	t.log.Infof("Fetched info for %d torrents", len(instances))
 
 	// delete expired fixers
@@ -73,7 +74,6 @@ func (t *TorrentManager) refreshTorrents() []string {
 	}
 	t.log.Debugf("Delete once done left: %d", t.deleteOnceDone.Cardinality())
 
-	close(infoChan)
 	newlyFetchedKeys := mapset.NewSet[string]()
 	noInfoCount := 0
 	for info := range infoChan {