feat: add ListJobsForShows

importer/job_inventory.go

@@ -69,6 +69,33 @@ func (i *jobInventory) ListJobs(showID uint64, offset, limit int) (jobs []*Job)
 	return
 }
 
+func (i *jobInventory) ListJobsForShows(showIDs []uint64, offset int, limit int) (jobs []*Job) {
+	i.mu.RLock()
+	defer i.mu.RUnlock()
+
+	for _, showID := range showIDs {
+		ig, exists := i.shows[showID]
+		if exists {
+			for _, job := range ig.jobs {
+				jobs = append(jobs, job)
+			}
+
+			sort.Slice(jobs, func(i, j int) bool { return jobs[i].ID < jobs[j].ID })
+		}
+	}
+	if offset > 0 {
+		if offset >= len(jobs) {
+			return []*Job{}
+		}
+		jobs = jobs[offset:]
+	}
+	if limit >= 0 && limit < len(jobs) {
+		jobs = jobs[:limit]
+	}
+
+	return
+}
+
 func (i *jobInventory) SubscribeJobs(showID uint64) (jobs []*Job, changed <-chan struct{}) {
 	i.mu.RLock()
 	defer i.mu.RUnlock()