X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ffreenet%2Fperiodicdbmaintenance.cpp;h=f6f501bd62c6437f14f0cb7304f52c671325265c;hb=3dc3ac3cfe10b7196a7977e9c041c29fa141c35e;hp=c615d603c990edf9a679c97c5154d13d47b63619;hpb=52c0819bfc1d083c6e0738f75f0d7eeba521295a;p=fms.git

diff --git a/src/freenet/periodicdbmaintenance.cpp b/src/freenet/periodicdbmaintenance.cpp
index c615d60..f6f501b 100644
--- a/src/freenet/periodicdbmaintenance.cpp
+++ b/src/freenet/periodicdbmaintenance.cpp
@@ -1,5 +1,6 @@
 #include "../../include/freenet/periodicdbmaintenance.h"
 #include "../../include/stringfunctions.h"
+#include "../../include/option.h"
 
 #ifdef XMEM
 	#include <xmem.h>
@@ -7,6 +8,8 @@
 
 PeriodicDBMaintenance::PeriodicDBMaintenance()
 {
+	std::string tempval;
+
 	m_check10mins.SetToGMTime();
 	m_check30mins.SetToGMTime();
 	m_check1hour.SetToGMTime();
@@ -19,6 +22,10 @@ PeriodicDBMaintenance::PeriodicDBMaintenance()
 	m_check6hours.Add(0,-1,-5);
 	m_check1day.Add(0,0,-23);
 
+	tempval="180";
+	Option::Instance()->Get("DeleteMessagesOlderThan",tempval);
+	StringFunctions::Convert(tempval,m_deletemessagesolderthan);
+
 }
 
 void PeriodicDBMaintenance::Do10MinuteMaintenance()
@@ -36,8 +43,46 @@ void PeriodicDBMaintenance::Do30MinuteMaintenance()
 void PeriodicDBMaintenance::Do1HourMaintenance()
 {
 	// recalculate all trust levels - this is CPU instensive
-	// TODO - will probably have to change this to do 1 identity at a time as this locks that database for the duration
-	m_db->Execute("UPDATE tblIdentity SET PeerMessageTrust=(SELECT PeerMessageTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID), PeerTrustListTrust=(SELECT PeerTrustListTrust FROM vwCalculatedPeerTrust WHERE TargetIdentityID=IdentityID);");
+	// do 1 identity at a time as doing it with 1 UPDATE statement locks that database for the duration
+	SQLite3DB::Statement st=m_db->Prepare("SELECT TargetIdentityID,PeerMessageTrust,PeerTrustListTrust FROM vwCalculatedPeerTrust;");
+	SQLite3DB::Statement upd=m_db->Prepare("UPDATE tblIdentity SET PeerMessageTrust=?, PeerTrustListTrust=? WHERE IdentityID=?");
+	st.Step();
+	while(st.RowReturned())
+	{
+		int identityid=0;
+		int trust=0;
+		
+		st.ResultInt(0,identityid);
+
+		upd.Bind(0,identityid);
+		if(st.ResultNull(1)==false)
+		{
+			trust=0;
+			st.ResultInt(1,trust);
+			upd.Bind(0,trust);
+		}
+		else
+		{
+			upd.Bind(0);
+		}
+		if(st.ResultNull(2)==false)
+		{
+			trust=0;
+			st.ResultInt(2,trust);
+			upd.Bind(1,trust);
+		}
+		else
+		{
+			upd.Bind(1);
+		}
+		upd.Bind(2,identityid);
+		upd.Step();
+		upd.Reset();
+
+		st.Step();
+	}
+
+
 
 	m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"PeriodicDBMaintenance::Do1HourMaintenance");
 }
@@ -133,6 +178,27 @@ void PeriodicDBMaintenance::Do1DayMaintenance()
 		st.Step();
 	}
 
+	// delete single use identities that are older than 7 days
+	date.SetToGMTime();
+	date.Add(0,0,0,-7);
+	st=m_db->Prepare("DELETE FROM tblIdentity WHERE SingleUse='true' AND DateAdded<?;");
+	st.Bind(0,date.Format("%Y-%m-%d %H:%M:%S"));
+	st.Step();
+
+	// delete local single use identities that are older than 7 days
+	date.SetToGMTime();
+	date.Add(0,0,0,-7);
+	st=m_db->Prepare("DELETE FROM tblLocalIdentity WHERE SingleUse='true' AND DateCreated<?;");
+	st.Bind(0,date.Format("%Y-%m-%d %H:%M:%S"));
+	st.Step();
+
+	// delete old messages
+	date.SetToGMTime();
+	date.Add(0,0,0,-m_deletemessagesolderthan);
+	st=m_db->Prepare("DELETE FROM tblMessage WHERE MessageDate<?;");
+	st.Bind(0,date.Format("%Y-%m-%d"));
+	st.Step();
+
 }
 
 void PeriodicDBMaintenance::Process()