X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ffreenet%2Fmessageinserter.cpp;h=cc7cfd5c13d853743fcb88ecb687f7ef4fac8d9a;hb=c7fcb4c4bc5012a584add81a9509fc1f84c3c688;hp=d28e262d6f4f6a5244a6061bd5310cce85b11191;hpb=868c533e84b3c81b6604b45b84efa32073aa20b4;p=fms.git diff --git a/src/freenet/messageinserter.cpp b/src/freenet/messageinserter.cpp index d28e262..cc7cfd5 100644 --- a/src/freenet/messageinserter.cpp +++ b/src/freenet/messageinserter.cpp @@ -53,10 +53,13 @@ const bool MessageInserter::HandlePutFailed(FCPMessage &message) const bool MessageInserter::HandlePutSuccessful(FCPMessage &message) { + DateTime date; + int localidentityid; int index; std::vector idparts; StringFunctions::Split(message["Identifier"],"|",idparts); StringFunctions::Convert(idparts[3],index); + StringFunctions::Convert(idparts[2],localidentityid); SQLite3DB::Statement st=m_db->Prepare("UPDATE tblMessageInserts SET Day=?, InsertIndex=?, Inserted='true' WHERE MessageUUID=?;"); st.Bind(0,idparts[5]); @@ -64,6 +67,13 @@ const bool MessageInserter::HandlePutSuccessful(FCPMessage &message) st.Bind(2,idparts[1]); st.Step(); + // insert record into temp table so MessageList will be inserted ASAP + date.SetToGMTime(); + st=m_db->Prepare("INSERT INTO tmpMessageListInsert(LocalIdentityID,Date) VALUES(?,?);"); + st.Bind(0,localidentityid); + st.Bind(1,date.Format("%Y-%m-%d")); + st.Step(); + RemoveFromInsertList(idparts[1]); m_log->WriteLog(LogFile::LOGLEVEL_DEBUG,"MessageInserter::HandlePutSuccessful successfully inserted message "+message["Identifier"]);