diff options
author | Frédéric Guillot <fred@miniflux.net> | 2017-11-21 22:36:00 -0800 |
---|---|---|
committer | Frédéric Guillot <fred@miniflux.net> | 2017-11-21 22:36:00 -0800 |
commit | 855fb06bc93a628108990013813725996a090c17 (patch) | |
tree | 9b250ce620818089c4a630787c580da8bc47ebe1 /storage/job.go | |
parent | 480b0d94e2f67e96285ff9265f4c1c81d3c0392d (diff) |
Add feature to refresh all feeds from the user interface
Diffstat (limited to 'storage/job.go')
-rw-r--r-- | storage/job.go | 21 |
1 files changed, 10 insertions, 11 deletions
diff --git a/storage/job.go b/storage/job.go index 5383a5b..c9ab64c 100644 --- a/storage/job.go +++ b/storage/job.go @@ -6,19 +6,19 @@ package storage import ( "fmt" + "time" + "github.com/miniflux/miniflux2/helper" "github.com/miniflux/miniflux2/model" - "log" - "time" ) const maxParsingError = 3 -func (s *Storage) GetJobs(batchSize int) []model.Job { - defer helper.ExecutionTime(time.Now(), fmt.Sprintf("storage.GetJobs[%d]", batchSize)) - - var jobs []model.Job - query := `SELECT +// NewBatch returns a serie of jobs. +func (s *Storage) NewBatch(batchSize int) (jobs model.JobList, err error) { + defer helper.ExecutionTime(time.Now(), fmt.Sprintf("[Storage:GetJobs] batchSize=%d", batchSize)) + query := ` + SELECT id, user_id FROM feeds WHERE parsing_error_count < $1 @@ -26,19 +26,18 @@ func (s *Storage) GetJobs(batchSize int) []model.Job { rows, err := s.db.Query(fmt.Sprintf(query, batchSize), maxParsingError) if err != nil { - log.Println("Unable to fetch feed jobs:", err) + return nil, fmt.Errorf("unable to fetch batch of jobs: %v", err) } defer rows.Close() for rows.Next() { var job model.Job if err := rows.Scan(&job.FeedID, &job.UserID); err != nil { - log.Println("Unable to fetch feed job:", err) - break + return nil, fmt.Errorf("unable to fetch job: %v", err) } jobs = append(jobs, job) } - return jobs + return jobs, nil } |