summaryrefslogtreecommitdiff
path: root/plugins/!NotAdopted/HistoryStats/mirandacontact.h
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/!NotAdopted/HistoryStats/mirandacontact.h')
-rw-r--r--plugins/!NotAdopted/HistoryStats/mirandacontact.h146
1 files changed, 146 insertions, 0 deletions
diff --git a/plugins/!NotAdopted/HistoryStats/mirandacontact.h b/plugins/!NotAdopted/HistoryStats/mirandacontact.h
new file mode 100644
index 0000000000..10f07e6d09
--- /dev/null
+++ b/plugins/!NotAdopted/HistoryStats/mirandacontact.h
@@ -0,0 +1,146 @@
+#if !defined(HISTORYSTATS_GUARD_MIRANDACONTACT_H)
+#define HISTORYSTATS_GUARD_MIRANDACONTACT_H
+
+#include "_globals.h"
+
+#include <vector>
+#include <list>
+
+/*
+ * MirandaContact
+ */
+
+class MirandaContact
+ : private pattern::NotCopyable<MirandaContact>
+{
+public:
+ struct EventInfo {
+ HANDLE hContact;
+ DBEVENTINFO dbe;
+ int nAllocated;
+// int nDuplicates;
+ };
+
+ struct ContactInfo {
+ HANDLE hContact;
+ HANDLE hEvent;
+ EventInfo ei;
+ };
+
+ typedef std::vector<HANDLE> SourceHandles;
+
+private:
+ // general info
+ ext::string m_strNick;
+ ext::string m_strProtocol;
+ ext::string m_strGroup;
+ SourceHandles m_Sources;
+
+ // internal data
+ ext::a::string m_strMetaProto;
+
+protected:
+ // reading messages
+ std::vector<ContactInfo> m_CIs;
+ std::list<EventInfo> m_EIs;
+ std::list<EventInfo> m_SpareEIs;
+
+private:
+ // reading messages
+ void stripMetaID(DBEVENTINFO& dbe);
+
+protected:
+ // reading messages
+ void fetchSlot(int i);
+ virtual void fillQueue() = 0;
+
+public:
+ explicit MirandaContact(const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const SourceHandles& sources);
+ virtual ~MirandaContact();
+
+ // general info
+ const ext::string& getNick() const { return m_strNick; }
+ const ext::string& getProtocol() const { return m_strProtocol; }
+ const ext::string& getGroup() const { return m_strGroup; }
+ const SourceHandles& getSources() const { return m_Sources; }
+
+ // merge
+ void merge(const MirandaContact& other);
+
+ // reading messages
+ void beginRead();
+ void endRead();
+ bool hasNext() { return !m_EIs.empty(); }
+ const DBEVENTINFO& getNext() { return m_EIs.front().dbe; }
+ void readNext();
+};
+
+/*
+ * MirandaContactTolerantMerge
+ */
+
+class MirandaContactTolerantMerge
+ : private pattern::NotCopyable<MirandaContactTolerantMerge>
+ , public MirandaContact
+{
+protected:
+ // reading message
+ virtual void fillQueue();
+
+public:
+ explicit MirandaContactTolerantMerge(const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const SourceHandles& sources)
+ : MirandaContact(strNick, strProtocol, strGroup, sources)
+ {
+ }
+};
+
+/*
+ * MirandaContactStrictMerge
+ */
+
+class MirandaContactStrictMerge
+ : private pattern::NotCopyable<MirandaContactStrictMerge>
+ , public MirandaContact
+{
+protected:
+ // reading message
+ virtual void fillQueue();
+
+public:
+ explicit MirandaContactStrictMerge(const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const SourceHandles& sources)
+ : MirandaContact(strNick, strProtocol, strGroup, sources)
+ {
+ }
+};
+
+/*
+ * MirandaContactNoMerge
+ */
+
+class MirandaContactNoMerge
+ : private pattern::NotCopyable<MirandaContactNoMerge>
+ , public MirandaContact
+{
+protected:
+ // reading message
+ virtual void fillQueue();
+
+public:
+ explicit MirandaContactNoMerge(const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const SourceHandles& sources)
+ : MirandaContact(strNick, strProtocol, strGroup, sources)
+ {
+ }
+};
+
+/*
+ * MirandaContactFactory
+ */
+
+class MirandaContactFactory
+ : public pattern::NotInstantiable<MirandaContactFactory>
+{
+public:
+ static MirandaContact* makeMirandaContact(int MergeMode, const ext::string& strNick, const ext::string& strProtocol, const ext::string& strGroup, const MirandaContact::SourceHandles& sources);
+};
+
+#endif // HISTORYSTATS_GUARD_MIRANDACONTACT_H