X-Git-Url: https://git.pterodactylus.net/?p=fms.git;a=blobdiff_plain;f=src%2Fthreadbuilder.cpp;fp=src%2Fthreadbuilder.cpp;h=521cccc5ae2c951e8b0ea252a501d33f7b8a9ebb;hp=0000000000000000000000000000000000000000;hb=221236a4d3aac4144529d418ce368db5c98facb0;hpb=d5c9f7e6c1dd263dfc85a3cb5941a378a5ddd923

diff --git a/src/threadbuilder.cpp b/src/threadbuilder.cpp
new file mode 100644
index 0000000..521cccc
--- /dev/null
+++ b/src/threadbuilder.cpp
@@ -0,0 +1,85 @@
+#include "../include/threadbuilder.h"
+#include "../include/messagethread.h"
+
+const bool ThreadBuilder::Build(const long messageid, const long boardid, const bool bydate)
+{
+	int count=0;
+	int threadid=-1;
+	MessageThread mt;
+	std::vector<MessageThread::threadnode> m_threadmessages;
+
+	mt.Load(messageid,boardid,bydate);
+	m_threadmessages=mt.GetNodes();
+
+	// find threadid of this thread if it already exists in a thread
+	SQLite3DB::Statement st=m_db->Prepare("SELECT tblThread.ThreadID FROM tblThread INNER JOIN tblThreadPost ON tblThread.ThreadID=tblThreadPost.ThreadID WHERE tblThread.BoardID=? AND tblThreadPost.MessageID=?;");
+	st.Bind(0,boardid);
+	st.Bind(1,messageid);
+
+	st.Step();
+	if(st.RowReturned())
+	{
+		st.ResultInt(0,threadid);
+	}
+	else
+	{
+		st.Reset();
+		// message doesn't exist in a thread, try to find a message in the thread that is already in a thread
+		for(std::vector<MessageThread::threadnode>::const_iterator i=m_threadmessages.begin(); i!=m_threadmessages.end() && threadid==-1; i++)
+		{
+			st.Bind(0,boardid);
+			st.Bind(1,(*i).m_messageid);
+			st.Step();
+
+			if(st.RowReturned())
+			{
+				st.ResultInt(0,threadid);
+			}
+
+			st.Reset();
+
+		}
+
+		// thread doesn't exist - create it
+		if(threadid==-1)
+		{
+			st=m_db->Prepare("INSERT INTO tblThread(BoardID) VALUES(?);");
+			st.Bind(0,boardid);
+			st.Step(true);
+			threadid=st.GetLastInsertRowID();
+		}
+	}
+
+	if(m_threadmessages.size()>0)
+	{
+		st=m_db->Prepare("UPDATE tblThread SET FirstMessageID=?, LastMessageID=? WHERE ThreadID=?;");
+		st.Bind(0,m_threadmessages[0].m_messageid);
+		st.Bind(1,m_threadmessages[m_threadmessages.size()-1].m_messageid);
+		st.Bind(2,threadid);
+		st.Step();
+
+		st=m_db->Prepare("DELETE FROM tblThreadPost WHERE ThreadID=?;");
+		st.Bind(0,threadid);
+		st.Step();
+
+		count=0;
+		st=m_db->Prepare("INSERT INTO tblThreadPost(ThreadID,MessageID,PostOrder) VALUES(?,?,?);");
+		for(std::vector<MessageThread::threadnode>::const_iterator i=m_threadmessages.begin(); i!=m_threadmessages.end(); i++, count++)
+		{
+			st.Bind(0,threadid);
+			st.Bind(1,(*i).m_messageid);
+			st.Bind(2,count);
+			st.Step();
+			st.Reset();
+		}
+	}
+	else
+	{
+		st=m_db->Prepare("DELETE FROM tblThread WHERE ThreadID=?;");
+		st.Bind(0,threadid);
+		st.Step();
+	}
+
+	return true;
+
+}