From 470b3df7c27aea77b1cb026d6fa44b7697caba37 Mon Sep 17 00:00:00 2001
From: chrisparker126 <retroshare.project@gmail.com>
Date: Tue, 18 Dec 2012 22:25:00 +0000
Subject: [PATCH] Added update broadcast component, works, but don't use yet,
 will change

git-svn-id: http://svn.code.sf.net/p/retroshare/code/trunk@6017 b45a01b8-16f6-495d-af2f-9b41ad6348cc
---
 .../src/util/RsGxsUpdateBroadcast.cpp         | 44 +++++++++++++++++++
 .../src/util/RsGxsUpdateBroadcast.h           | 33 ++++++++++++++
 2 files changed, 77 insertions(+)
 create mode 100644 retroshare-gui/src/util/RsGxsUpdateBroadcast.cpp
 create mode 100644 retroshare-gui/src/util/RsGxsUpdateBroadcast.h

diff --git a/retroshare-gui/src/util/RsGxsUpdateBroadcast.cpp b/retroshare-gui/src/util/RsGxsUpdateBroadcast.cpp
new file mode 100644
index 000000000..1813577ac
--- /dev/null
+++ b/retroshare-gui/src/util/RsGxsUpdateBroadcast.cpp
@@ -0,0 +1,44 @@
+#include <QTimer>
+
+#include "RsGxsUpdateBroadcast.h"
+
+
+RsGxsUpdateBroadcast::RsGxsUpdateBroadcast(RsGxsIfaceImpl *ifaceImpl, float dt, QObject *parent) :
+    QObject(parent), mIfaceImpl(ifaceImpl), mDt(dt)
+{
+}
+
+void RsGxsUpdateBroadcast::startMonitor()
+{
+    slowPoll();
+}
+
+
+void RsGxsUpdateBroadcast::fastPoll()
+{
+
+}
+
+void RsGxsUpdateBroadcast::slowPoll()
+{
+    std::map<RsGxsGroupId, std::vector<RsGxsMessageId> > msgs;
+    std::list<RsGxsGroupId> grps;
+
+    if(mIfaceImpl->updated())
+    {
+        mIfaceImpl->msgsChanged(msgs);
+        if(!msgs.empty())
+        {
+            emit msgsChanged(msgs);
+        }
+
+        mIfaceImpl->groupsChanged(grps);
+
+        if(!grps.empty())
+        {
+            emit grpsChanged(grps);
+        }
+
+        QTimer::singleShot((int) (mDt * 1000.0), this, SLOT(slowPoll()));
+    }
+}
diff --git a/retroshare-gui/src/util/RsGxsUpdateBroadcast.h b/retroshare-gui/src/util/RsGxsUpdateBroadcast.h
new file mode 100644
index 000000000..d464491a5
--- /dev/null
+++ b/retroshare-gui/src/util/RsGxsUpdateBroadcast.h
@@ -0,0 +1,33 @@
+#ifndef RSGXSUPDATEBROADCAST_H
+#define RSGXSUPDATEBROADCAST_H
+
+#include <QObject>
+
+#include <gxs/rsgxsifaceimpl.h>
+
+class RsGxsUpdateBroadcast : public QObject
+{
+    Q_OBJECT
+public:
+    explicit RsGxsUpdateBroadcast(RsGxsIfaceImpl* ifaceImpl, float dt, QObject *parent = 0);
+
+    void startMonitor();
+    void update();
+
+signals:
+
+    void msgsChanged(const std::map<RsGxsGroupId, std::vector<RsGxsMessageId> > & msgIds);
+    void grpsChanged(const std::list<RsGxsGroupId>& grpIds);
+
+public slots:
+
+    void fastPoll();
+    void slowPoll();
+
+private:
+
+    RsGxsIfaceImpl* mIfaceImpl;
+    float mDt;
+};
+
+#endif // RSGXSUPDATEBROADCAST_H