X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fdbmaintenancethread.cpp;h=3f4bdbcdbedde9d0f5fcf374d39ab218459115b1;hb=221236a4d3aac4144529d418ce368db5c98facb0;hp=b6137150e09204be68442bced6d37910b90adbbb;hpb=76805933f794915a72b7f0a21b12af6654759f4f;p=fms.git

diff --git a/src/dbmaintenancethread.cpp b/src/dbmaintenancethread.cpp
index b613715..3f4bdbc 100644
--- a/src/dbmaintenancethread.cpp
+++ b/src/dbmaintenancethread.cpp
@@ -1,6 +1,7 @@
 #include "../include/dbmaintenancethread.h"
 #include "../include/stringfunctions.h"
 #include "../include/option.h"
+#include "../include/threadbuilder.h"
 
 #include <Poco/Timestamp.h>
 #include <Poco/Timespan.h>
@@ -20,22 +21,78 @@ DBMaintenanceThread::DBMaintenanceThread()
 	m_last1day=Poco::Timestamp();
 	m_last1day-=Poco::Timespan(0,23,51,0,0);
 
+	m_deletemessagesolderthan=180;
 	std::string tempval="180";
 	Option::Instance()->Get("DeleteMessagesOlderThan",tempval);
 	StringFunctions::Convert(tempval,m_deletemessagesolderthan);
 
+	m_messagedownloadmaxdaysbackward=5;
+	tempval="5";
+	Option::Instance()->Get("MessageDownloadMaxDaysBackward",tempval);
+	StringFunctions::Convert(tempval,m_messagedownloadmaxdaysbackward);
+
 }
 
 
 void DBMaintenanceThread::Do10MinuteMaintenance()
 {
 
+	ThreadBuilder tb;
+	SQLite3DB::Statement boardst=m_db->Prepare("SELECT BoardID FROM tblBoard WHERE Forum='true';");
+	// select messages for a board that aren't in a thread
+	SQLite3DB::Statement selectst=m_db->Prepare("SELECT tblMessage.MessageID FROM tblMessage \
+												INNER JOIN tblMessageBoard ON tblMessage.MessageID=tblMessageBoard.MessageID\
+												LEFT JOIN tblThreadPost ON tblMessage.MessageID=tblThreadPost.MessageID \
+												LEFT JOIN tblThread ON tblThreadPost.ThreadID=tblThread.ThreadID\
+												WHERE tblMessageBoard.BoardID=? AND tblThread.BoardID IS NULL;");
+
+	boardst.Step();
+	while(boardst.RowReturned())
+	{
+		int boardid=-1;
+
+		boardst.ResultInt(0,boardid);
+
+		selectst.Bind(0,boardid);
+		selectst.Step();
+
+		while(selectst.RowReturned())
+		{
+			int messageid=-1;
+
+			selectst.ResultInt(0,messageid);
+
+			tb.Build(messageid,boardid,true);
+
+			selectst.Step();
+		}
+		selectst.Reset();
+
+		boardst.Step();
+	}
+
+	// now rebuild threads where the message has been deleted
+	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;");
+	st.Step();
+	while(st.RowReturned())
+	{
+		int messageid=-1;
+		int boardid=-1;
+
+		st.ResultInt(0,messageid);
+		st.ResultInt(1,boardid);
+
+		tb.Build(messageid,boardid,true);
+
+		st.Step();
+	}
+
 	m_log->debug("PeriodicDBMaintenance::Do10MinuteMaintenance");
 }
 
 void DBMaintenanceThread::Do30MinuteMaintenance()
 {
-
+	// UNCOMMENT method in run when code is placed here
 	m_log->debug("PeriodicDBMaintenance::Do30MinuteMaintenance");
 }
 
@@ -252,10 +309,18 @@ void DBMaintenanceThread::Do1DayMaintenance()
 	// delete old messages
 	date=Poco::Timestamp();
 	date-=Poco::Timespan(m_deletemessagesolderthan,0,0,0,0);
+	m_log->trace("PeriodicDBMaintenance::Do1DayMaintenance deleting messages prior to "+Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));
 	st=m_db->Prepare("DELETE FROM tblMessage WHERE MessageDate<?;");
 	st.Bind(0,Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));
 	st.Step();
 
+	// delete old message requests
+	date=Poco::Timestamp();
+	date-=Poco::Timespan(m_messagedownloadmaxdaysbackward,0,0,0,0);
+	st=m_db->Prepare("DELETE FROM tblMessageRequests WHERE Day<?;");
+	st.Bind(0,Poco::DateTimeFormatter::format(date,"%Y-%m-%d"));
+	st.Step();
+
 	// delete tblIdentityTrust for local identities and identities that have been deleted
 	m_db->Execute("DELETE FROM tblIdentityTrust WHERE LocalIdentityID NOT IN (SELECT LocalIdentityID FROM tblLocalIdentity);");
 	m_db->Execute("DELETE FROM tblIdentityTrust WHERE IdentityID NOT IN (SELECT IdentityID FROM tblIdentity);");
@@ -269,6 +334,7 @@ void DBMaintenanceThread::run()
 	m_log->debug("DBMaintenanceThread::run thread started.");
 
 	Poco::DateTime now;
+	int i=0;
 
 	do
 	{
@@ -279,11 +345,13 @@ void DBMaintenanceThread::run()
 			Do10MinuteMaintenance();
 			m_last10minute=Poco::Timestamp();
 		}
+		/*
 		if((m_last30minute+Poco::Timespan(0,0,30,0,0))<=now)
 		{
 			Do30MinuteMaintenance();
 			m_last30minute=Poco::Timestamp();
 		}
+		*/
 		if((m_last1hour+Poco::Timespan(0,1,0,0,0))<=now)
 		{
 			Do1HourMaintenance();
@@ -300,7 +368,12 @@ void DBMaintenanceThread::run()
 			m_last1day=Poco::Timestamp();
 		}
 
-		Poco::Thread::sleep(1000);
+		i=0;
+		while(i++<5 && !IsCancelled())
+		{
+			Poco::Thread::sleep(1000);
+		}
+
 	}while(!IsCancelled());
 
 	m_log->debug("DBMaintenanceThread::run thread exiting.");