#include "../include/dbmaintenancethread.h"\r
#include "../include/stringfunctions.h"\r
#include "../include/option.h"\r
+#include "../include/threadbuilder.h"\r
\r
#include <Poco/Timestamp.h>\r
#include <Poco/Timespan.h>\r
m_last1day=Poco::Timestamp();\r
m_last1day-=Poco::Timespan(0,23,51,0,0);\r
\r
+ m_deletemessagesolderthan=180;\r
std::string tempval="180";\r
Option::Instance()->Get("DeleteMessagesOlderThan",tempval);\r
StringFunctions::Convert(tempval,m_deletemessagesolderthan);\r
\r
+ m_messagedownloadmaxdaysbackward=5;\r
+ tempval="5";\r
+ Option::Instance()->Get("MessageDownloadMaxDaysBackward",tempval);\r
+ StringFunctions::Convert(tempval,m_messagedownloadmaxdaysbackward);\r
+\r
}\r
\r
\r
void DBMaintenanceThread::Do10MinuteMaintenance()\r
{\r
\r
+ ThreadBuilder tb;\r
+ SQLite3DB::Statement boardst=m_db->Prepare("SELECT BoardID FROM tblBoard WHERE Forum='true';");\r
+ // select messages for a board that aren't in a thread\r
+ SQLite3DB::Statement selectst=m_db->Prepare("SELECT tblMessage.MessageID FROM tblMessage \\r
+ INNER JOIN tblMessageBoard ON tblMessage.MessageID=tblMessageBoard.MessageID\\r
+ LEFT JOIN tblThreadPost ON tblMessage.MessageID=tblThreadPost.MessageID \\r
+ LEFT JOIN tblThread ON tblThreadPost.ThreadID=tblThread.ThreadID\\r
+ WHERE tblMessageBoard.BoardID=? AND tblThread.BoardID IS NULL;");\r
+\r
+ boardst.Step();\r
+ while(boardst.RowReturned())\r
+ {\r
+ int boardid=-1;\r
+\r
+ boardst.ResultInt(0,boardid);\r
+\r
+ selectst.Bind(0,boardid);\r
+ selectst.Step();\r
+\r
+ while(selectst.RowReturned())\r
+ {\r
+ int messageid=-1;\r
+\r
+ selectst.ResultInt(0,messageid);\r
+\r
+ tb.Build(messageid,boardid,true);\r
+\r
+ selectst.Step();\r
+ }\r
+ selectst.Reset();\r
+\r
+ boardst.Step();\r
+ }\r
+\r
+ // now rebuild threads where the message has been deleted\r
+ SQLite3DB::Statement st=m_db->Prepare("SELECT tblThreadPost.MessageID, tblThread.BoardID FROM tblThreadPost INNER JOIN tblThread ON tblThreadPost.ThreadID=tblThread.ThreadID LEFT JOIN tblMessage ON tblThreadPost.MessageID=tblMessage.MessageID WHERE tblMessage.MessageID IS NULL;");\r
+ st.Step();\r
+ while(st.RowReturned())\r
+ {\r
+ int messageid=-1;\r
+ int boardid=-1;\r
+\r
+ st.ResultInt(0,messageid);\r
+ st.ResultInt(1,boardid);\r
+\r
+ tb.Build(messageid,boardid,true);\r
+\r
+ st.Step();\r
+ }\r
+\r
m_log->debug("PeriodicDBMaintenance::Do10MinuteMaintenance");\r
}\r
\r
void DBMaintenanceThread::Do30MinuteMaintenance()\r
{\r
-\r
+ // UNCOMMENT method in run when code is placed here\r
m_log->debug("PeriodicDBMaintenance::Do30MinuteMaintenance");\r
}\r
\r
st.Step();\r
}\r
\r
+ // insert all identities not in trust list already\r
+ m_db->Execute("INSERT INTO tblIdentityTrust(LocalIdentityID,IdentityID) SELECT LocalIdentityID,IdentityID FROM tblLocalIdentity,tblIdentity WHERE LocalIdentityID || '_' || IdentityID NOT IN (SELECT LocalIdentityID || '_' || IdentityID FROM tblIdentityTrust);");\r
+\r
m_log->debug("PeriodicDBMaintenance::Do1HourMaintenance");\r
}\r
\r
// delete old messages\r
date=Poco::Timestamp();\r
date-=Poco::Timespan(m_deletemessagesolderthan,0,0,0,0);\r
+ m_log->trace("PeriodicDBMaintenance::Do1DayMaintenance deleting messages prior to "+Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));\r
st=m_db->Prepare("DELETE FROM tblMessage WHERE MessageDate<?;");\r
st.Bind(0,Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));\r
st.Step();\r
\r
+ // delete old message requests\r
+ date=Poco::Timestamp();\r
+ date-=Poco::Timespan(m_messagedownloadmaxdaysbackward,0,0,0,0);\r
+ st=m_db->Prepare("DELETE FROM tblMessageRequests WHERE Day<?;");\r
+ st.Bind(0,Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));\r
+ st.Step();\r
+\r
// delete tblIdentityTrust for local identities and identities that have been deleted\r
m_db->Execute("DELETE FROM tblIdentityTrust WHERE LocalIdentityID NOT IN (SELECT LocalIdentityID FROM tblLocalIdentity);");\r
m_db->Execute("DELETE FROM tblIdentityTrust WHERE IdentityID NOT IN (SELECT IdentityID FROM tblIdentity);");\r
m_log->debug("DBMaintenanceThread::run thread started.");\r
\r
Poco::DateTime now;\r
+ int i=0;\r
\r
do\r
{\r
Do10MinuteMaintenance();\r
m_last10minute=Poco::Timestamp();\r
}\r
+ /*\r
if((m_last30minute+Poco::Timespan(0,0,30,0,0))<=now)\r
{\r
Do30MinuteMaintenance();\r
m_last30minute=Poco::Timestamp();\r
}\r
+ */\r
if((m_last1hour+Poco::Timespan(0,1,0,0,0))<=now)\r
{\r
Do1HourMaintenance();\r
m_last1day=Poco::Timestamp();\r
}\r
\r
- Poco::Thread::sleep(1000);\r
+ i=0;\r
+ while(i++<5 && !IsCancelled())\r
+ {\r
+ Poco::Thread::sleep(1000);\r
+ }\r
+\r
}while(!IsCancelled());\r
\r
m_log->debug("DBMaintenanceThread::run thread exiting.");\r