change(database): only search for missing items that have aired / in …

…cinemas.

cmd/cutoff.go

@@ -90,7 +90,7 @@ var cutoffCmd = &cobra.Command{
 		}()
 
 		// get media items from database
-		mediaItems, err := database.GetMediaItems(lowerPvrName, "cutoff")
+		mediaItems, err := database.GetMediaItems(lowerPvrName, "cutoff", false)
 		if err != nil {
 			log.WithError(err).Fatal("Failed retrieving media items from database...")
 		}

cmd/missing.go

@@ -90,7 +90,7 @@ var missingCmd = &cobra.Command{
 		}()
 
 		// get media items from database
-		mediaItems, err := database.GetMediaItems(lowerPvrName, "missing")
+		mediaItems, err := database.GetMediaItems(lowerPvrName, "missing", true)
 		if err != nil {
 			log.WithError(err).Fatal("Failed retrieving media items from database...")
 		}

database/get.go

@@ -1,14 +1,27 @@
 package database
 
-import "github.com/pkg/errors"
+import (
+	"github.com/pkg/errors"
+	"time"
+)
 
-func GetMediaItems(pvrName string, wantedType string) ([]MediaItem, error) {
+func GetMediaItems(pvrName string, wantedType string, excludeFuture bool) ([]MediaItem, error) {
 	var mediaItems []MediaItem
 
-	if err := db.Where(MediaItem{
-		PvrName:    pvrName,
-		WantedType: wantedType,
-	}).Order("air_date_utc desc").Find(&mediaItems).Error; err != nil {
+	// generate query
+	sqlQuery := "pvr_name = ? AND wanted_type = ?"
+	sqlParams := []interface{}{
+		pvrName,
+		wantedType,
+	}
+
+	if excludeFuture {
+		sqlQuery += " AND air_date_utc <= ?"
+		sqlParams = append(sqlParams, time.Now().UTC())
+	}
+
+	// exec query
+	if err := db.Where(sqlQuery, sqlParams...).Order("air_date_utc desc").Find(&mediaItems).Error; err != nil {
 		return nil, errors.Wrap(err, "failed querying for media items")
 	}