diff options
Diffstat (limited to 'plugins/!NotAdopted/HistoryStats/mirandacontact.cpp')
| -rw-r--r-- | plugins/!NotAdopted/HistoryStats/mirandacontact.cpp | 384 |
1 files changed, 0 insertions, 384 deletions
diff --git a/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp b/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp deleted file mode 100644 index 385dac1f9d..0000000000 --- a/plugins/!NotAdopted/HistoryStats/mirandacontact.cpp +++ /dev/null @@ -1,384 +0,0 @@ -#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;
- }
-}
|