summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'Swiften/PubSub/PubSubManagerImpl.cpp')
-rw-r--r--Swiften/PubSub/PubSubManagerImpl.cpp31
1 files changed, 31 insertions, 0 deletions
diff --git a/Swiften/PubSub/PubSubManagerImpl.cpp b/Swiften/PubSub/PubSubManagerImpl.cpp
new file mode 100644
index 0000000..38b02aa
--- /dev/null
+++ b/Swiften/PubSub/PubSubManagerImpl.cpp
@@ -0,0 +1,31 @@
+/*
+ * Copyright (c) 2013 Remko Tronçon
+ * Licensed under the GNU General Public License.
+ * See the COPYING file for more information.
+ */
+
+#include <Swiften/PubSub/PubSubManagerImpl.h>
+
+#include <boost/bind.hpp>
+
+#include <Swiften/Client/StanzaChannel.h>
+#include <Swiften/Elements/Message.h>
+#include <Swiften/Elements/PubSubEvent.h>
+
+using namespace Swift;
+
+PubSubManagerImpl::PubSubManagerImpl(StanzaChannel* stanzaChannel, IQRouter* router) :
+ stanzaChannel(stanzaChannel),
+ router(router) {
+ stanzaChannel->onMessageReceived.connect(boost::bind(&PubSubManagerImpl::handleMessageRecevied, this, _1));
+}
+
+PubSubManagerImpl::~PubSubManagerImpl() {
+ stanzaChannel->onMessageReceived.disconnect(boost::bind(&PubSubManagerImpl::handleMessageRecevied, this, _1));
+}
+
+void PubSubManagerImpl::handleMessageRecevied(boost::shared_ptr<Message> message) {
+ if (boost::shared_ptr<PubSubEvent> event = message->getPayload<PubSubEvent>()) {
+ onEvent(message->getFrom(), event->getPayload());
+ }
+}