1 files changed, 384 insertions, 0 deletions
diff --git a/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp b/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp
new file mode 100644
index 0000000000..385dac1f9d
--- /dev/null
+++ b/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp
@@ -0,0 +1,384 @@
+#include "_globals.h"
+#include "mirandacontact.h"
+
+#include "_consts.h"
+
+#include "utils.h"
+#include "main.h"
+
+/*
+ * MirandaContact
+ */
+
+void MirandaContact::fetchSlot(int i)
+{
+	ContactInfo& ci = m_CIs[i];
+
+	if (!ci.hEvent)
+	{
+		free(ci.ei.dbe.pBlob);
+
+		m_CIs.erase(m_CIs.begin() + i);
+
+		return;
+	}
+
+	EventInfo& ei = ci.ei;
+
+	ei.hContact = ci.hContact;
+	ei.dbe.cbBlob = mu::db_event::getBlobSize(ci.hEvent);
+	ei.dbe.cbSize = sizeof(ei.dbe);
+
+	if (ei.dbe.cbBlob > ei.nAllocated)
+	{
+		ei.nAllocated = ei.dbe.cbBlob;
+		ei.dbe.pBlob = reinterpret_cast<PBYTE>(realloc(ei.dbe.pBlob, ei.dbe.cbBlob + 1));
+	}
+
+	mu::db_event::get(ci.hEvent, &ei.dbe);
+
+	stripMetaID(ei.dbe);
+
+	ci.hEvent = mu::db_event::findNext(ci.hEvent);
+}
+
+void MirandaContact::stripMetaID(DBEVENTINFO& dbe)
+{
+	if (dbe.szModule == m_strMetaProto)
+	{
+		mu_ansi* pTextBegin = reinterpret_cast<mu_ansi*>(dbe.pBlob);
+
+		if (dbe.cbBlob >= 6 && !pTextBegin[dbe.cbBlob - 1])
+		{
+			mu_ansi* pIDEnd = pTextBegin + dbe.cbBlob - 1;
+			mu_ansi* pIDBegin = pIDEnd;
+			mu_ansi* pIDSep = NULL;
+
+			while (pIDBegin >= pTextBegin + 2 && *--pIDBegin)
+			{
+				if (*pIDBegin == muC('*'))
+				{
+					pIDSep = pIDBegin;
+				}
+			}
+
+			++pIDBegin;
+
+			if (pIDSep && pIDBegin < pIDSep && !*(pIDBegin - 1))
+			{
+				dbe.cbBlob = pIDBegin - pTextBegin;
+			}
+		}
+	}
+}
+
+MirandaContact::MirandaContact(const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const SourceHandles& sources)
+	: m_strNick(strNick)
+	, m_strProtocol(strProtocol)
+	, m_strGroup(strGroup)
+	, m_Sources(sources)
+{
+	m_strMetaProto = mu::metacontacts::_available() ? mu::metacontacts::getProtocolName() : muA("");
+}
+
+MirandaContact::~MirandaContact()
+{
+	endRead();
+}
+
+void MirandaContact::merge(const MirandaContact& other)
+{
+	if (m_strNick != other.m_strNick)
+	{
+		m_strNick = i18n(muT("(multiple)"));
+	}
+
+	if (m_strProtocol != other.m_strProtocol)
+	{
+		m_strProtocol = i18n(muT("(multiple)"));
+	}
+
+	if (m_strGroup != other.m_strGroup)
+	{
+		m_strGroup = i18n(muT("(multiple)"));
+	}
+
+	citer_each_(SourceHandles, i, other.m_Sources)
+	{
+		m_Sources.push_back(*i);
+	}
+}
+
+void MirandaContact::beginRead()
+{
+	// clean up first
+	endRead();
+
+	// allocate required data
+	m_CIs.resize(m_Sources.size());
+
+	for (int j = m_Sources.size() - 1; j >= 0; --j)
+	{
+		ContactInfo& ci = m_CIs[j];
+
+		ci.hContact = m_Sources[j];
+		ci.hEvent = mu::db_event::findFirst(ci.hContact);
+		ci.ei.dbe.pBlob = NULL;
+		ci.ei.nAllocated = 0;
+
+		fetchSlot(j);
+	}
+
+	fillQueue();
+}
+
+void MirandaContact::endRead()
+{
+#if defined(_DEBUG)
+	if (m_CIs.size() + m_EIs.size() + m_SpareEIs.size() > 0)
+	{
+		ext::string strLog = ext::str(ext::format(muT("Freeing | CIs and |+| EIs...\n")) % m_CIs.size() % m_EIs.size() % m_SpareEIs.size());
+
+		OutputDebugString(strLog.c_str());
+	}
+#endif // _DEBUG
+
+	citer_each_(std::vector<ContactInfo>, i, m_CIs)
+	{
+		free(i->ei.dbe.pBlob);
+	}
+
+	citer_each_(std::list<EventInfo>, i, m_EIs)
+	{
+		free(i->dbe.pBlob);
+	}
+
+	citer_each_(std::list<EventInfo>, i, m_SpareEIs)
+	{
+		free(i->dbe.pBlob);
+	}
+
+	m_CIs.clear();
+	m_EIs.clear();
+	m_SpareEIs.clear();
+}
+
+void MirandaContact::readNext()
+{
+	if (!m_EIs.empty())
+	{
+		m_SpareEIs.push_back(m_EIs.front());
+		m_EIs.pop_front();
+	}
+
+	fillQueue();
+}
+
+/*
+ * MirandaContactTolerantMerge
+ */
+
+void MirandaContactTolerantMerge::fillQueue()
+{
+	// assume that items with +/- 30 seconds may be equal
+	static const int timestampTol = 30;
+
+	while (!m_CIs.empty() && (m_EIs.size() < 2 || (m_EIs.back().dbe.timestamp - m_EIs.front().dbe.timestamp) <= timestampTol))
+	{
+		// find oldest next event in chains
+		int nNext = 0;
+		DWORD timestampFirst = m_CIs.front().ei.dbe.timestamp;
+
+		for (int i = 1; i < m_CIs.size(); ++i)
+		{
+			if (m_CIs[i].ei.dbe.timestamp < timestampFirst)
+			{
+				timestampFirst = m_CIs[i].ei.dbe.timestamp;
+				nNext = i;
+			}
+		}
+
+		// insert the fetched at correct position or throw away if duplicate
+		ContactInfo& ci = m_CIs[nNext];
+		
+		std::list<EventInfo>::iterator insPos = m_EIs.end();
+		bool bIsDuplicate = false;
+
+		iter_each_(std::list<EventInfo>, j, m_EIs)
+		{
+			EventInfo& j_ei = *j;
+			int timestampDelta = j_ei.dbe.timestamp - ci.ei.dbe.timestamp;
+
+			if (timestampDelta > 0)
+			{
+				insPos = j;
+			}
+
+			if (j_ei.hContact != ci.ei.hContact &&
+				timestampDelta >= -timestampTol && timestampDelta <= timestampTol &&
+				j_ei.dbe.eventType == ci.ei.dbe.eventType &&
+				(j_ei.dbe.flags & ~(DBEF_FIRST | DBEF_READ)) == (ci.ei.dbe.flags & ~(DBEF_FIRST | DBEF_READ)) &&
+				j_ei.dbe.cbBlob == ci.ei.dbe.cbBlob &&
+				memcmp(j_ei.dbe.pBlob, ci.ei.dbe.pBlob, j_ei.dbe.cbBlob) == 0)
+			{
+				bIsDuplicate = true;
+
+				break;
+			}
+		}
+
+		if (!bIsDuplicate)
+		{
+			m_EIs.insert(insPos, ci.ei);
+
+			if (!m_SpareEIs.empty())
+			{
+				ci.ei = m_SpareEIs.front();
+				m_SpareEIs.pop_front();
+			}
+			else
+			{
+				ci.ei.dbe.pBlob = NULL;
+				ci.ei.nAllocated = 0;
+			}
+		}
+
+		fetchSlot(nNext);
+	}
+}
+
+/*
+ * MirandaContactStrictMerge
+ */
+
+void MirandaContactStrictMerge::fillQueue()
+{
+	// assume that items with +/- 30 seconds may be equal
+	static const int timestampTol = 0;
+
+	while (!m_CIs.empty() && (m_EIs.size() < 2 || (m_EIs.back().dbe.timestamp - m_EIs.front().dbe.timestamp) <= timestampTol))
+	{
+		// find oldest next event in chains
+		int nNext = 0;
+		DWORD timestampFirst = m_CIs.front().ei.dbe.timestamp;
+
+		for (int i = 1; i < m_CIs.size(); ++i)
+		{
+			if (m_CIs[i].ei.dbe.timestamp < timestampFirst)
+			{
+				timestampFirst = m_CIs[i].ei.dbe.timestamp;
+				nNext = i;
+			}
+		}
+
+		// insert the fetched at correct position or throw away if duplicate
+		ContactInfo& ci = m_CIs[nNext];
+		
+		std::list<EventInfo>::iterator insPos = m_EIs.end();
+		bool bIsDuplicate = false;
+
+		iter_each_(std::list<EventInfo>, j, m_EIs)
+		{
+			EventInfo& j_ei = *j;
+			int timestampDelta = j_ei.dbe.timestamp - ci.ei.dbe.timestamp;
+
+			if (timestampDelta > 0)
+			{
+				insPos = j;
+			}
+
+			if (j_ei.hContact != ci.ei.hContact &&
+				timestampDelta >= -timestampTol && timestampDelta <= timestampTol &&
+				j_ei.dbe.eventType == ci.ei.dbe.eventType &&
+				(j_ei.dbe.flags & ~(DBEF_FIRST | DBEF_READ)) == (ci.ei.dbe.flags & ~(DBEF_FIRST | DBEF_READ)) &&
+				j_ei.dbe.cbBlob == ci.ei.dbe.cbBlob &&
+				memcmp(j_ei.dbe.pBlob, ci.ei.dbe.pBlob, j_ei.dbe.cbBlob) == 0)
+			{
+				bIsDuplicate = true;
+
+				break;
+			}
+		}
+
+		if (!bIsDuplicate)
+		{
+			m_EIs.insert(insPos, ci.ei);
+
+			if (!m_SpareEIs.empty())
+			{
+				ci.ei = m_SpareEIs.front();
+				m_SpareEIs.pop_front();
+			}
+			else
+			{
+				ci.ei.dbe.pBlob = NULL;
+				ci.ei.nAllocated = 0;
+			}
+		}
+
+		fetchSlot(nNext);
+	}
+}
+
+/*
+ * MirandaContactNoMerge
+ */
+
+void MirandaContactNoMerge::fillQueue()
+{
+	while (!m_CIs.empty() && m_EIs.size() < 1)
+	{
+		// find oldest next event in chains
+		int nNext = 0;
+		DWORD timestampFirst = m_CIs.front().ei.dbe.timestamp;
+
+		for (int i = 1; i < m_CIs.size(); ++i)
+		{
+			if (m_CIs[i].ei.dbe.timestamp < timestampFirst)
+			{
+				timestampFirst = m_CIs[i].ei.dbe.timestamp;
+				nNext = i;
+			}
+		}
+
+		// insert the fetched at correct position or throw away if duplicate
+		ContactInfo& ci = m_CIs[nNext];
+		
+		m_EIs.push_back(ci.ei);
+
+		if (!m_SpareEIs.empty())
+		{
+			ci.ei = m_SpareEIs.front();
+			m_SpareEIs.pop_front();
+		}
+		else
+		{
+			ci.ei.dbe.pBlob = NULL;
+			ci.ei.nAllocated = 0;
+		}
+
+		fetchSlot(nNext);
+	}
+}
+
+/*
+ * MirandaContactFactory
+ */
+
+MirandaContact* MirandaContactFactory::makeMirandaContact(int MergeMode, const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const MirandaContact::SourceHandles& sources)
+{
+	switch (MergeMode)
+	{
+		case Settings::mmTolerantMerge:
+			return new MirandaContactTolerantMerge(strNick, strProtocol, strGroup, sources);
+
+		case Settings::mmStrictMerge:
+			return new MirandaContactStrictMerge(strNick, strProtocol, strGroup, sources);
+
+		case Settings::mmNoMerge:
+			return new MirandaContactNoMerge(strNick, strProtocol, strGroup, sources);
+
+		default:
+			return 0;
+	}
+}