Ticket #2320: watched_flag.diff

themes/G.A.N.T./ui.xml

@@ -1315 +1315 @@
       </image>
       <image name="hdtv" draworder="6">
         <filename>type/hd.png</filename>
-        <position>275,195</position>
+        <position>265,195</position>
       </image>
+      <image name="watched" draworder="6">
+          <filename>type/watched.png</filename>
+          <position>300,195</position>
+      </image>
 
 
     </container>

themes/default/watched.png

@@ +1 @@
+‰PNG
+
+

themes/blue/ui.xml

@@ -883 +883 @@
         <filename>type/hd.png</filename>
         <position>257,106</position>
       </image>
+      <image name="watched" draworder="6">
+          <filename>type/watched.png</filename>
+          <position>302,106</position>
+      </image>
 
       <image name="processing" draworder="6">
         <filename>processing.png</filename>

themes/defaultosd/osd.xml

@@ -273 +273 @@
       <font>infofont</font>
       <altfont>infofontgray</altfont>
     </textarea>
+    <textarea name="option5">
+      <area>85,420,470,30</area>
+      <font>infofont</font>
+      <altfont>infofontgray</altfont>
+    </textarea>
     <positionrects name="selector"> <!-- draws a white rectangle at these 
                                          coords indicating the current 
                                          selection -->

themes/blueosd/osd.xml

@@ -310 +310 @@
       <font>infofont</font>
       <altfont>infofontgray</altfont>
     </textarea>
+    <textarea name="option5">
+      <area>85,420,470,30</area>
+      <font>infofont</font>
+      <altfont>infofontgray</altfont>
+    </textarea>
     <positionrects name="selector">
       <area>80,296,480,30</area>
       <area>80,326,480,30</area>

libs/libmythtv/NuppelVideoPlayer.cpp

@@ -3631 +3631 @@
                 "Audio buffer overflow, audio data lost!");
 }
 
+void NuppelVideoPlayer::SetWatched(bool forceWatched)
+{
+    if (!m_playbackinfo)
+        return;
+
+    int numFrames = totalFrames;
+
+    if (m_playbackinfo->GetTranscodedStatus() != TRANSCODING_COMPLETE)
+        numFrames = (m_playbackinfo->endts.toTime_t() -
+                    m_playbackinfo->recstartts.toTime_t()) * video_frame_rate;
+
+    int offset = (int) round(0.2 * (numFrames / video_frame_rate));
+
+    if (offset < 300)
+        offset = 300; // 5 Minutes Min
+    else if (offset > 720)
+        offset = 720; // 12 Minutes Max
+
+    if (forceWatched || framesPlayed > numFrames - (offset * video_frame_rate))
+    {
+        m_playbackinfo->SetWatchedFlag(true);
+        VERBOSE(VB_GENERAL, QString("Marking recording as watched using offset %1 minutes").arg(offset/60));
+    }
+    else
+    {
+        m_playbackinfo->SetWatchedFlag(false);
+        VERBOSE(VB_GENERAL, "Marking recording as unwatched");
+    }
+}
+
 void NuppelVideoPlayer::SetBookmark(void)
 {
     if (!m_playbackinfo || !osd)
@@ -6689 +6719 @@
 {
     osdtheme = QDeepCopy<QString>(themename);
 }
+
+NuppelVideoPlayer SetLiveTVChain( LiveTVChain * tvchain )
+{
+}
 // EIA-708 caption support -- end
 
 /* vim: set expandtab tabstop=4 shiftwidth=4: */

libs/libmythtv/dbcheck.cpp

@@ -10 +10 @@
 #include "mythdbcon.h"
 
 /// This is the DB schema version expected by the running MythTV instance.
-const QString currentDatabaseVersion = "1157";
+const QString currentDatabaseVersion = "1158";
 
 static bool UpdateDBVersionNumber(const QString &newnumber);
 static bool performActualUpdate(const QString updates[], QString version,
@@ -2497 +2497 @@
             return false;
     }
 
+    if (dbver == "1157")
+    {
+        const QString updates[] = {
+"ALTER TABLE recorded ADD COLUMN watched TINYINT NOT NULL DEFAULT '0';",
+""
+};
+
+        if (!performActualUpdate(updates, "1158", dbver))
+            return false;
+    }
+
 //"ALTER TABLE capturecard DROP COLUMN dvb_recordts;" in 0.21
 //"ALTER TABLE capturecard DROP COLUMN dvb_hw_decoder;" in 0.21
 //"ALTER TABLE cardinput DROP COLUMN preference;" in 0.22

libs/libmythtv/NuppelVideoPlayer.h

@@ -145 +145 @@
 
     void SetTranscoding(bool value);
     void SetWatchingRecording(bool mode);
+    void SetWatched(bool forceWatched = false);
     void SetBookmark(void);
     void SetKeyframeDistance(int keyframedistance);
     void SetVideoParams(int w, int h, double fps, int keydist,

libs/libmythtv/tv_play.cpp

@@ -1216 +1216 @@
     {
         VERBOSE(VB_PLAYBACK,LOC + " StopStuff() -- get dvd player out of still frame or wait status");
         prbuffer->DVD()->IgnoreStillOrWait(true);
-    } 
+    }
 
     if (stopRingBuffers)
     {
@@ -2116 +2116 @@
                             wantsToQuit = true;
                             exitPlayer = true;
                             break;
-                        case 3: case 0:
+                        case 3:
+                            nvp->SetWatched(true);
+                            wantsToQuit = true;
+                            exitPlayer = true;
+                            break;
+                        case 4: case 0:
                             paused = !paused;
                             DoPause();
                             break;
-                        case 4:
+                        case 5:
                             wantsToQuit = true;
                             exitPlayer = true;
                             requestDelete = true;
@@ -2486 +2491 @@
                 QStringList options;
                 options += tr("Save this position and go to the menu");
                 options += tr("Do not save, just exit to the menu");
+                options += tr("Mark as watched and go to the menu");
                 options += tr("Keep watching");
                 options += tr("Delete this recording");
 
@@ -2520 +2526 @@
             {
                 if (nvp && gContext->GetNumSetting("PlaybackExitPrompt") == 2)
                     nvp->SetBookmark();
+                if (nvp && gContext->GetNumSetting("AutomaticSetWatched", 0))
+                    nvp->SetWatched();
                 exitPlayer = true;
                 wantsToQuit = true;
             }

libs/libmythtv/programinfo.h

@@ -55 +55 @@
     FL_STEREO         = 0x080,
     FL_CC             = 0x100,
     FL_HDTV           = 0x200,
-    FL_TRANSCODED     = 0x400
+    FL_TRANSCODED     = 0x400,
+    FL_WATCHED        = 0x800
 };
 
 enum RecStatusType {
@@ -183 +184 @@
     bool IsCommFlagged(void) const;
     bool IsInUse(QString &byWho) const;
     int GetAutoExpireFromRecorded(void) const;
+    int GetTranscodedStatus(void) const;
     bool GetPreserveEpisodeFromRecorded(void) const;
     bool UsesMaxEpisodes(void) const;
     int getProgramFlags(void) const;
@@ -195 +197 @@
     void SetBookmark(long long pos) const;
     void SetEditing(bool edit) const;
     void SetTranscoded(int transFlag) const;
+    void SetWatchedFlag(bool watchedFlag) const;
     void SetDeleteFlag(bool deleteFlag) const;
     void SetCommFlagged(int flag) const; // 1 = flagged, 2 = processing
     void SetAutoExpire(int autoExpire) const;

libs/libmythtv/programinfo.cpp

@@ -1808 +1808 @@
     return pos;
 }
 
+/** \fn ProgramInfo::SetWatchedFlag(bool) const
+ *  \brief Set "watched" field in "recorded" table to "watchedFlag".
+ *  \param watchedFlag value to set watched field to.
+ */
+void ProgramInfo::SetWatchedFlag(bool watchedFlag) const
+{
+    MSqlQuery query(MSqlQuery::InitCon());
+
+    query.prepare("UPDATE recorded"
+                  " SET watched = :WATCHEDFLAG"
+                  " WHERE chanid = :CHANID"
+                  " AND starttime = :STARTTIME ;");
+    query.bindValue(":CHANID", chanid);
+    query.bindValue(":STARTTIME", recstartts);
+
+    if (watchedFlag)
+        query.bindValue(":WATCHEDFLAG", 1);
+    else
+        query.bindValue(":WATCHEDFLAG", 0);
+
+    if (!query.exec() || !query.isActive())
+        MythContext::DBError("Set watched flag", query);
+}
+
 /** \fn ProgramInfo::IsEditing(void) const
  *  \brief Queries "recorded" table for its "editing" field
  *         and returns true if it is set to true.
@@ -1950 +1974 @@
     return false;
 }
 
+/** \fn ProgramInfo::GetTranscodedStatus(void) const
+ *  \brief Returns the "transcoded" field in "recorded" table.
+ */
+int ProgramInfo::GetTranscodedStatus(void) const
+{
+    MSqlQuery query(MSqlQuery::InitCon());
+
+    query.prepare("SELECT transcoded FROM recorded"
+                 " WHERE chanid = :CHANID"
+                 " AND starttime = :STARTTIME ;");
+    query.bindValue(":CHANID", chanid);
+    query.bindValue(":STARTTIME", recstartts);
+
+    if (query.exec() && query.isActive() && query.size() > 0)
+    {
+        query.next();
+        return query.value(0).toInt();
+    }
+
+    return false;
+}
+
 /** \fn ProgramInfo::SetTranscoded(int transFlag) const
  *  \brief Set "transcoded" field in "recorded" table to "transFlag".
  *  \param transFlag value to set transcoded field to.
@@ -3513 +3559 @@
     MSqlQuery query(MSqlQuery::InitCon());
 
     query.prepare("SELECT commflagged, cutlist, autoexpire, "
-                  "editing, bookmark, stereo, closecaptioned, hdtv "
+                  "editing, bookmark, stereo, closecaptioned, hdtv, watched "
                   "FROM recorded LEFT JOIN recordedprogram ON "
                   "(recorded.chanid = recordedprogram.chanid AND "
                   "recorded.starttime = recordedprogram.starttime) "
@@ -3535 +3581 @@
         flags |= (query.value(5).toInt() == 1) ? FL_STEREO : 0;
         flags |= (query.value(6).toInt() == 1) ? FL_CC : 0;
         flags |= (query.value(7).toInt() == 1) ? FL_HDTV : 0;
+        flags |= (query.value(8).toInt() == 1) ? FL_WATCHED : 0;
     }
 
     return flags;
@@ -4181 +4228 @@
         "recorded.basename, recorded.progstart, "
         "recorded.progend, recorded.stars, "
         "recordedprogram.stereo, recordedprogram.hdtv, "
-        "recordedprogram.closecaptioned "
+        "recordedprogram.closecaptioned, recorded.watched "
         "FROM recorded "
         "LEFT JOIN record ON recorded.recordid = record.recordid "
         "LEFT JOIN channel ON recorded.chanid = channel.chanid "
@@ -4274 +4321 @@
             flags |= (query.value(32).toInt() == 1)           ? FL_STEREO   : 0;
             flags |= (query.value(34).toInt() == 1)           ? FL_CC       : 0;
             flags |= (query.value(33).toInt() == 1)           ? FL_HDTV     : 0;
+            flags |= (query.value(35).toInt() == 1)           ? FL_WATCHED  : 0;
 
             inUseKey = query.value(0).toString() + " " +
                        query.value(1).toDateTime().toString(Qt::ISODate);

programs/mythfrontend/playbackbox.cpp

@@ -786 +786 @@
         iconMap["stereo"]      = FL_STEREO;
         iconMap["cc"]          = FL_CC;
         iconMap["hdtv"]        = FL_HDTV;
+        iconMap["watched"]     = FL_WATCHED;
 
         UIImageType *itype;
         for (it = iconMap.begin(); it != iconMap.end(); ++it)
@@ -2793 +2794 @@
             popup->addButton(tr("Enable Auto Expire"), this, SLOT(doAutoExpire()));
     }
 
+    if (curitem->programflags & FL_WATCHED)
+    {
+        popup->addButton(tr("Mark as Unwatched"), this,
+                                    SLOT(setUnwatched()));
+    }
+    else
+    {
+        popup->addButton(tr("Mark as Watched"), this,
+                                    SLOT(setWatched()));
+    }
+
     popup->addButton(tr("Recording Options"), this, SLOT(showRecordingPopup()));
     popup->addButton(tr("Job Options"), this, SLOT(showJobPopup()));
 
@@ -3304 +3316 @@
     return NULL;
 }
 
+void PlaybackBox::setUnwatched(void)
+{
+    if (!expectingPopup && delitem)
+        return;
+
+    cancelPopup();
+
+    delitem->SetWatchedFlag(0);
+
+    ProgramInfo *tmpItem = findMatchingProg(delitem);
+    if (tmpItem)
+        tmpItem->programflags &= ~FL_WATCHED;
+
+    delete delitem;
+    delitem = NULL;
+
+    previewVideoState = kChanging;
+
+    update(drawListBounds);
+}
+
+void PlaybackBox::setWatched(void)
+{
+    if (!expectingPopup)
+        return;
+
+    cancelPopup();
+
+    delitem->SetWatchedFlag(1);
+
+    ProgramInfo *tmpItem = findMatchingProg(delitem);
+    if (tmpItem)
+        tmpItem->programflags |= FL_WATCHED;
+
+    delete delitem;
+    delitem = NULL;
+
+    previewVideoState = kChanging;
+
+    update(drawListBounds);
+}
+
 void PlaybackBox::noAutoExpire(void)
 {
     if (!expectingPopup && delitem)

programs/mythfrontend/globalsettings.cpp

@@ -570 +570 @@
     return bc;
 }
 
+static GlobalCheckBox *AutoExpireWatchedPriority() 
+{
+    GlobalCheckBox *bc = new GlobalCheckBox("AutoExpireWatchedPriority"); 
+    bc->setLabel(QObject::tr("Auto Expire watched programs before unwatched")); 
+    bc->setValue(false); 
+    bc->setHelpText(QObject::tr("If set, programs that have been marked as "
+                    "watched will be expired first"));
+    return bc;
+}
+
 static GlobalSpinBox *AutoExpireDayPriority()
 {
     GlobalSpinBox *bs = new GlobalSpinBox("AutoExpireDayPriority", 1, 400, 1);
@@ -620 +630 @@
 }
 #endif
 
+static GlobalCheckBox *RerecordWatched() 
+{
+    GlobalCheckBox *bc = new GlobalCheckBox("RerecordWatched"); 
+    bc->setLabel(QObject::tr("Re-record watched programs")); 
+    bc->setValue(true); 
+    bc->setHelpText(QObject::tr("If set, programs that have been marked as "
+                    "watched and are auto-expired will be re-recorded if "
+                    "they are shown again."));
+    return bc;
+}
+
 static GlobalSpinBox *RecordPreRoll()
 {
     GlobalSpinBox *bs = new GlobalSpinBox("RecordPreRoll", 0, 600, 60, true);
@@ -1226 +1247 @@
     return gc;
 }
 
+static HostCheckBox *AutomaticSetWatched()
+{
+    HostCheckBox *gc = new HostCheckBox("AutomaticSetWatched");
+    gc->setLabel(QObject::tr("Automatically mark a record watched"));
+    gc->setValue(false);
+    gc->setHelpText(QObject::tr("If set, when you exit near the end of a "
+                    "recording it will be marked as watched. The automatic "
+                    "detection is not foolproof, so do not enable this "
+                    "setting if you don't want an unwatched recording marked "
+                    "as watched."));
+    return gc;
+}
+
 static HostCheckBox *GeneratePreviewPixmaps()
 {
     HostCheckBox *gc = new HostCheckBox("GeneratePreviewPixmaps");
@@ -3416 +3450 @@
     gen2->setLabel(QObject::tr("General playback (part 2)"));
     gen2->addChild(PlaybackExitPrompt());
     gen2->addChild(EndOfRecordingExitPrompt());
+    gen2->addChild(AutomaticSetWatched());
     gen2->addChild(ClearSavedPosition());
     gen2->addChild(AltClearSavedPosition());
 #ifdef USING_XV
@@ -3540 +3575 @@
     VerticalConfigurationGroup* autoexp = new VerticalConfigurationGroup(false);
     autoexp->setLabel(QObject::tr("General (AutoExpire)"));
     autoexp->addChild(AutoExpireMethod());
+    autoexp->addChild(AutoExpireWatchedPriority());
     autoexp->addChild(AutoExpireDayPriority());
     autoexp->addChild(AutoExpireDefault());
     autoexp->addChild(AutoExpireLiveTVMaxAge());
+    autoexp->addChild(RerecordWatched());
     autoexp->addChild(AutoExpireExtraSpace());
     addChild(autoexp);
 

programs/mythfrontend/playbackbox.h

@@ -161 +161 @@
     void doForceDelete();
     void noDelete();
 
+    void setWatched();
+    void setUnwatched();
+
     void doAutoExpire();
     void noAutoExpire();
     void doPreserveEpisode();

programs/mythtranscode/main.cpp

@@ -662 +662 @@
                 MythContext::DBError("Error in mythtranscode", query);
 
             query.prepare("UPDATE recorded "
-                          "SET cutlist = :CUTLIST, bookmark = :BOOKMARK "
-                          "WHERE chanid = :CHANID "
+                          "SET cutlist = :CUTLIST, bookmark = :BOOKMARK, "
+                          "watched = :WATCHED WHERE chanid = :CHANID "
                           "AND starttime = :STARTTIME ;");
             query.bindValue(":CUTLIST", "0");
             query.bindValue(":BOOKMARK", "0");
+            query.bindValue(":WATCHED", "0");
             query.bindValue(":CHANID", pginfo->chanid);
             query.bindValue(":STARTTIME", pginfo->recstartts);
             query.exec();

programs/mythbackend/mainserver.cpp

@@ -661 +661 @@
             if (pinfo)
             {
                 // allow re-record if auto expired but not expired live buffers
-                if (pinfo->recgroup != "LiveTV")
+                if (pinfo->recgroup != "LiveTV" &&
+                    (gContext->GetNumSetting("RerecordWatched", 0) ||
+                    (!pinfo->getProgramFlags() & FL_WATCHED)))
                     pinfo->ForgetHistory();
+
                 DoHandleDeleteRecording(pinfo, NULL, false);
             }
             else
@@ -1028 +1031 @@
         "recorded.progend, recorded.stars, "
         "recordedprogram.stereo, recordedprogram.hdtv, "
         "recordedprogram.closecaptioned, transcoded, "
-        "recorded.recpriority "
+        "recorded.recpriority, watched "
         "FROM recorded "
         "LEFT JOIN record ON recorded.recordid = record.recordid "
         "LEFT JOIN channel ON recorded.chanid = channel.chanid "
@@ -1132 +1135 @@
             flags |= (query.value(34).toInt() == 1) ? FL_CC : 0;
             flags |= (query.value(35).toInt() == TRANSCODING_COMPLETE) ?
                       FL_TRANSCODED : 0;
+            flags |= (query.value(37).toInt() == 1) ? FL_WATCHED : 0;
 
             inUseKey = query.value(0).toString() + " " +
                        query.value(1).toDateTime().toString(Qt::ISODate);

programs/mythbackend/autoexpire.cpp

@@ -762 +762 @@
         default:
         case emOldestFirst:
             where = "autoexpire > 0";
-            orderby = "starttime ASC";
+            if (gContext->GetNumSetting("AutoExpireWatchedPriority", 0))
+                orderby = "recorded.watched DESC, ";
+            orderby += "starttime ASC";
             break;
         case emLowestPriorityFirst:
             where = "autoexpire > 0";
-            orderby = "recorded.recpriority ASC, starttime ASC";
+            if (gContext->GetNumSetting("AutoExpireWatchedPriority", 0))
+                orderby = "recorded.watched DESC, ";
+            orderby += "recorded.recpriority ASC, starttime ASC";
             break;
         case emWeightedTimePriority:
             where = "autoexpire > 0";
-            orderby = QString("DATE_ADD(starttime, INTERVAL '%1' * "
+            if (gContext->GetNumSetting("AutoExpireWatchedPriority", 0))
+                orderby = "recorded.watched DESC, ";
+            orderby += QString("DATE_ADD(starttime, INTERVAL '%1' * "
                                         "recorded.recpriority DAY) ASC")
                       .arg(gContext->GetNumSetting("AutoExpireDayPriority", 3));
             break;