Add logger

2 files changed, 7 insertions, 7 deletions

diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go
index a1f1778..3eac0d1 100644
--- a/scheduler/scheduler.go
+++ b/scheduler/scheduler.go
@@ -5,9 +5,9 @@
 package scheduler
 
 import (
-	"log"
 	"time"
 
+	"github.com/miniflux/miniflux/logger"
 	"github.com/miniflux/miniflux/storage"
 )
 
@@ -18,9 +18,9 @@ func NewScheduler(store *storage.Storage, workerPool *WorkerPool, frequency, bat
 		for now := range c {
 			jobs, err := store.NewBatch(batchSize)
 			if err != nil {
-				log.Println("[Scheduler]", err)
+				logger.Error("[Scheduler] %v", err)
 			} else {
-				log.Printf("[Scheduler:%v] => Pushing %d jobs\n", now, len(jobs))
+				logger.Debug("[Scheduler:%v] => Pushing %d jobs", now, len(jobs))
 				workerPool.Push(jobs)
 			}
 		}
diff --git a/scheduler/worker.go b/scheduler/worker.go
index be130ca..8c3999e 100644
--- a/scheduler/worker.go
+++ b/scheduler/worker.go
@@ -5,9 +5,9 @@
 package scheduler
 
 import (
-	"log"
 	"time"
 
+	"github.com/miniflux/miniflux/logger"
 	"github.com/miniflux/miniflux/model"
 	"github.com/miniflux/miniflux/reader/feed"
 )
@@ -20,15 +20,15 @@ type Worker struct {
 
 // Run wait for a job and refresh the given feed.
 func (w *Worker) Run(c chan model.Job) {
-	log.Printf("[Worker] #%d started\n", w.id)
+	logger.Debug("[Worker] #%d started", w.id)
 
 	for {
 		job := <-c
-		log.Printf("[Worker #%d] got userID=%d, feedID=%d\n", w.id, job.UserID, job.FeedID)
+		logger.Debug("[Worker #%d] got userID=%d, feedID=%d", w.id, job.UserID, job.FeedID)
 
 		err := w.feedHandler.RefreshFeed(job.UserID, job.FeedID)
 		if err != nil {
-			log.Println("Worker:", err)
+			logger.Error("[Worker] %v", err)
 		}
 
 		time.Sleep(time.Millisecond * 1000)