commit of actual revision1.1.441.1.42

1 files changed, 280 insertions, 0 deletions

diff --git a/update.h b/update.h
new file mode 100644
index 0000000..3e4f8e6
--- /dev/null
+++ b/update.h
@@ -0,0 +1,280 @@
+/*
+ * update.h: EPG2VDR plugin for the Video Disk Recorder
+ *
+ * See the README file for copyright information and how to reach the author.
+ *
+ */
+
+#ifndef __UPDATE_H
+#define __UPDATE_H
+
+#include <mysql/mysql.h>
+#include <queue>
+
+#define __STL_CONFIG_H
+
+#include <vdr/status.h>
+
+#include "lib/common.h"
+#include "lib/db.h"
+#include "lib/epgservice.h"
+
+#include "epg2vdr.h"
+#include "parameters.h"
+
+#define EPGDNAME "epgd"
+
+//***************************************************************************
+// Running Recording
+//***************************************************************************
+
+class cRunningRecording : public cListObject
+{
+   public:
+
+      cRunningRecording(const cTimer* t, long did = na)
+      {
+         timer = t;
+         doneid = did;
+         lastBreak = 0;
+         info = 0;
+
+         finished = no;
+         failed = no;
+
+         // copy until timer get waste ..
+
+         aux = strdup(timer->Aux() ? timer->Aux() : "");
+      }
+
+      ~cRunningRecording()
+      {
+         free(aux);
+         free(info);
+      }
+
+      void setInfo(const char* i) { info = strdup(i); }
+
+      // data
+
+      const cTimer* timer;  // #TODO, it's may be fatal to hold a pointer to a timer!
+      time_t lastBreak;
+      int finished;
+      int failed;
+      long doneid;
+      char* aux;
+      char* info;
+};
+
+//***************************************************************************
+// Event Details
+//***************************************************************************
+
+class cEventDetails
+{
+   public:
+
+      cEventDetails()     { changes = 0; }
+      ~cEventDetails()    { }
+
+      int getChanges()    { return changes; }
+      void clearChanges() { changes = 0; }
+
+      void setValue(const char* name, const char* value);
+      void setValue(const char* name, int value);
+
+      int storeToFs(const char* path);
+      int loadFromFs(const char* path);
+      int updateByRow(cDbRow* row);
+      int updateToRow(cDbRow* row);
+
+   private:
+
+      int changes;
+      std::map<std::string, std::string> values;
+
+      static const char* fields[];
+};
+
+//***************************************************************************
+// Update
+//***************************************************************************
+
+class cUpdate : public cThread, public cStatus, public cParameters
+{
+   public:
+
+      enum MasterMode
+      {
+         mmAuto,
+         mmYes,
+         mmNo,
+
+         mmCount
+      };
+
+      cUpdate(cPluginEPG2VDR* aPlugin);
+      ~cUpdate();
+
+      // interface
+
+      int init();
+      int exit();
+
+      void Stop();
+      int isEpgdBusy()             { return epgdBusy; }
+      time_t getNextEpgdUpdateAt() { return nextEpgdUpdateAt; }
+      void triggerDbReconnect();
+      int triggerEpgUpdate(int reload = no);
+      int triggerRecUpdate();
+      int commonRecFolderOptionChanged();
+      int triggerStoreInfoFiles();
+      void triggerTimerJobs();
+      void epgdStateChange(const char* state);
+
+   protected:
+
+      // notifications from VDRs status interface
+
+      virtual void TimerChange(const cTimer* Timer, eTimerChange Change);
+      virtual void Recording(const cDevice *Device, const char *Name, const char *FileName, bool On);
+      virtual void ChannelSwitch(const cDevice *Device, int ChannelNumber, bool LiveView);
+
+   private:
+
+      struct TimerId
+      {
+         unsigned int eventId;
+         char channelId[100];
+      };
+
+      // functions
+
+      int initDb();
+      int exitDb();
+
+      void Action(void);
+      int isHandlerMaster();
+      void updateVdrData();
+      int updateRecFolderOption();
+      int dbConnected(int force = no)
+      { return connection && connection->isConnected() && (!force || connection->check() == success); }
+      int checkConnection(int& timeout);
+
+      int refreshEpg(const char* channelid = 0, int maxTries = 5);
+      cEvent* createEventFromRow(const cDbRow* row);
+      int lookupVdrEventOf(int eId, const char* cId);
+      int storePicturesToFs();
+      int cleanupPictures();
+      int pictureLinkNeeded(const char* linkName);
+
+      tChannelID toChanID(const char* chanIdStr)
+      {
+         if (isEmpty(chanIdStr))
+            return tChannelID::InvalidID;
+
+         return tChannelID::FromString(chanIdStr);
+      }
+
+      // timer stuff
+
+      int updateTimerTable();
+      int performTimerJobs();
+      int recordingChanged();
+      int updateTimerDone(int timerid, int doneid, char state);
+      int timerChanged();
+
+      // recording stuff
+
+      int updateRecordingTable(int fullReload = no);
+      int cleanupDeletedRecordings(int force = no);
+      int updateRecordingDirectory(const cRecording* recording);
+      int updatePendingRecordingInfoFiles(const cRecordings* recordings);
+      int storeAllRecordingInfoFiles();
+      int updateRecordingInfoFiles();
+
+      // data
+
+      cDbConnection* connection;
+      cPluginEPG2VDR* plugin;
+      int handlerMaster;
+      int loopActive;
+      time_t nextEpgdUpdateAt;
+      time_t lastUpdateAt;
+      time_t lastEventsUpdateAt;
+      time_t lastRecordingDeleteAt;
+      int lastRecordingCount;
+      char* epgimagedir;
+      int withutf8;
+      cCondVar waitCondition;
+      cMutex mutex;
+      int fullreload;
+      char imageExtension[3+TB];
+
+      cMutex timerMutex;
+      int dbReconnectTriggered;
+      int timerJobsUpdateTriggered;
+      int timerTableUpdateTriggered;
+      int manualTrigger;
+      int recordingStateChangedTrigger;
+      int recordingFullReloadTrigger;
+      int storeAllRecordingInfoFilesTrigger;
+      int updateRecFolderOptionTrigger;
+      cList<cRunningRecording> runningRecordings;
+      cMutex runningRecMutex;
+
+      Es::State epgdState;
+      int epgdBusy;
+      int eventsPending;
+      int mainActPending;
+      const char* videoBasePath;
+      int timersTableMaxUpdsp;
+
+      cDbTable* eventsDb;
+      cDbTable* useeventsDb;
+      cDbTable* fileDb;
+      cDbTable* imageDb;
+      cDbTable* imageRefDb;
+      cDbTable* episodeDb;
+      cDbTable* mapDb;
+      cDbTable* timerDb;
+      cDbTable* timerDoneDb;
+      cDbTable* vdrDb;
+      cDbTable* compDb;
+      cDbTable* recordingDirDb;
+      cDbTable* recordingListDb;
+
+      cDbStatement* selectMasterVdr;
+      cDbStatement* selectAllImages;
+      cDbStatement* selectUpdEvents;
+      cDbStatement* selectEventById;
+      cDbStatement* selectAllChannels;
+      cDbStatement* selectChannelById;
+      cDbStatement* markUnknownChannel;
+      cDbStatement* selectComponentsOf;
+      cDbStatement* deleteTimer;
+      cDbStatement* selectMyTimer;
+      cDbStatement* selectRecordings;
+      cDbStatement* selectRecForInfoUpdate;
+      cDbStatement* selectPendingTimerActions;
+      cDbStatement* selectTimerByEvent;
+      cDbStatement* selectTimerById;
+      cDbStatement* selectTimerByDoneId;
+      cDbStatement* selectMaxUpdSp;
+
+      cDbValue vdrEvtId;
+      cDbValue extEvtId;
+      cDbValue vdrStartTime;
+      cDbValue extChannelId;
+      cDbValue imageUpdSp;
+      cDbValue imageSize;
+      cDbValue masterId;
+
+      cDbValue* dvbDescription;
+
+      std::queue<std::string> pendingNewRecordings; // recordings to store details
+      std::vector<TimerId> deletedTimers;
+};
+
+//***************************************************************************
+#endif //__UPDATE_H