5 files changed, 162 insertions, 0 deletions
diff --git a/Swiften/PubSub/PubSubManager.cpp b/Swiften/PubSub/PubSubManager.cpp
new file mode 100644
index 0000000..8899b1e
--- /dev/null
+++ b/Swiften/PubSub/PubSubManager.cpp
@@ -0,0 +1,12 @@
+/*
+ * Copyright (c) 2013 Remko Tronçon
+ * Licensed under the GNU General Public License.
+ * See the COPYING file for more information.
+ */
+
+#include <Swiften/PubSub/PubSubManager.h>
+
+using namespace Swift;
+
+PubSubManager::~PubSubManager() {
+}
diff --git a/Swiften/PubSub/PubSubManager.h b/Swiften/PubSub/PubSubManager.h
new file mode 100644
index 0000000..2f3c84d
--- /dev/null
+++ b/Swiften/PubSub/PubSubManager.h
@@ -0,0 +1,53 @@
+/*
+ * Copyright (c) 2013 Remko Tronçon
+ * Licensed under the GNU General Public License.
+ * See the COPYING file for more information.
+ */
+
+#pragma once
+
+#include <boost/shared_ptr.hpp>
+
+#include <Swiften/Base/Override.h>
+#include <Swiften/Base/API.h>
+#include <Swiften/Base/boost_bsignals.h>
+#include <Swiften/Queries/PubSubRequest.h>
+#include <Swiften/PubSub/PubSubUtil.h>
+#include <Swiften/Elements/PubSub.h>
+#include <Swiften/Elements/PubSubOwnerPubSub.h>
+#include <Swiften/Elements/PubSubCreate.h>
+#include <Swiften/Elements/PubSubSubscribe.h>
+#include <Swiften/Elements/PubSubAffiliations.h>
+#include <Swiften/Elements/PubSubDefault.h>
+#include <Swiften/Elements/PubSubItems.h>
+#include <Swiften/Elements/PubSubPublish.h>
+#include <Swiften/Elements/PubSubRetract.h>
+#include <Swiften/Elements/PubSubSubscription.h>
+#include <Swiften/Elements/PubSubSubscriptions.h>
+#include <Swiften/Elements/PubSubUnsubscribe.h>
+#include <Swiften/Elements/PubSubOwnerAffiliations.h>
+#include <Swiften/Elements/PubSubOwnerConfigure.h>
+#include <Swiften/Elements/PubSubOwnerDefault.h>
+#include <Swiften/Elements/PubSubOwnerDelete.h>
+#include <Swiften/Elements/PubSubOwnerPurge.h>
+#include <Swiften/Elements/PubSubOwnerSubscriptions.h>
+#include <Swiften/Elements/IQ.h>
+#include <Swiften/Elements/PubSubEventPayload.h>
+
+#define SWIFTEN_PUBSUBMANAGER_DECLARE_CREATE_REQUEST(payload, container, response) \
+	virtual boost::shared_ptr< PubSubRequest<payload> >  \
+		createRequest(IQ::Type, const JID&, boost::shared_ptr<payload>) = 0;
+
+namespace Swift {
+	class JID;
+
+	class SWIFTEN_API PubSubManager {
+		public:
+			virtual ~PubSubManager();
+			
+			SWIFTEN_PUBSUB_FOREACH_PUBSUB_PAYLOAD_TYPE(
+					SWIFTEN_PUBSUBMANAGER_DECLARE_CREATE_REQUEST)
+
+			boost::signal<void (const JID&, const boost::shared_ptr<PubSubEventPayload>)> onEvent;
+	};
+}
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());
+	}
+}
diff --git a/Swiften/PubSub/PubSubManagerImpl.h b/Swiften/PubSub/PubSubManagerImpl.h
new file mode 100644
index 0000000..65884c0
--- /dev/null
+++ b/Swiften/PubSub/PubSubManagerImpl.h
@@ -0,0 +1,39 @@
+/*
+ * Copyright (c) 2013 Remko Tronçon
+ * Licensed under the GNU General Public License.
+ * See the COPYING file for more information.
+ */
+
+#pragma once
+
+#include <Swiften/Base/Override.h>
+#include <Swiften/Base/API.h>
+#include <Swiften/PubSub/PubSubManager.h>
+
+#define SWIFTEN_PUBSUBMANAGERIMPL_DECLARE_CREATE_REQUEST(payload, container, response) \
+	virtual boost::shared_ptr< PubSubRequest<payload> >  \
+			createRequest(IQ::Type type, const JID& receiver, boost::shared_ptr<payload> p) SWIFTEN_OVERRIDE { \
+		return boost::make_shared< PubSubRequest<payload> >(type, receiver, p, router); \
+	}
+
+namespace Swift {
+	class JID;
+	class StanzaChannel;
+	class Message;
+
+	class SWIFTEN_API PubSubManagerImpl : public PubSubManager {
+		public:
+			PubSubManagerImpl(StanzaChannel* stanzaChannel, IQRouter* router);
+			virtual ~PubSubManagerImpl();
+
+			SWIFTEN_PUBSUB_FOREACH_PUBSUB_PAYLOAD_TYPE(
+					SWIFTEN_PUBSUBMANAGERIMPL_DECLARE_CREATE_REQUEST)
+
+		private:
+			void handleMessageRecevied(boost::shared_ptr<Message>);
+
+		private:
+			StanzaChannel* stanzaChannel;
+			IQRouter* router;
+	};
+}
diff --git a/Swiften/PubSub/PubSubUtil.h b/Swiften/PubSub/PubSubUtil.h
new file mode 100644
index 0000000..3342659
--- /dev/null
+++ b/Swiften/PubSub/PubSubUtil.h
@@ -0,0 +1,27 @@
+/*
+ * Copyright (c) 2013 Remko Tronçon
+ * Licensed under the GNU General Public License.
+ * See the COPYING file for more information.
+ */
+
+#pragma once
+
+#define SWIFTEN_PUBSUB_FOREACH_PUBSUB_PAYLOAD_TYPE(action) \
+	action(PubSubCreate, PubSub, PubSubCreate) \
+	action(PubSubAffiliations, PubSub, PubSubAffiliations) \
+	action(PubSubDefault, PubSub, PubSubDefault) \
+	action(PubSubItems, PubSub, PubSubItems) \
+	action(PubSubOptions, PubSub, PubSubOptions) \
+	action(PubSubPublish, PubSub, PubSubPublish) \
+	action(PubSubRetract, PubSub, PubSubRetract) \
+	action(PubSubSubscription, PubSub, PubSubSubscription) \
+	action(PubSubSubscriptions, PubSub, PubSubSubscriptions) \
+	action(PubSubSubscribe, PubSub, PubSubSubscription) \
+	action(PubSubUnsubscribe, PubSub, PubSubUnsubscribe) \
+	action(PubSubOwnerAffiliations, PubSubOwnerPubSub, PubSubOwnerAffiliations) \
+	action(PubSubOwnerConfigure, PubSubOwnerPubSub, PubSubOwnerConfigure) \
+	action(PubSubOwnerDefault, PubSubOwnerPubSub, PubSubOwnerDefault) \
+	action(PubSubOwnerDelete, PubSubOwnerPubSub, PubSubOwnerDelete) \
+	action(PubSubOwnerPurge, PubSubOwnerPubSub, PubSubOwnerPurge) \
+	action(PubSubOwnerSubscriptions, PubSubOwnerPubSub, PubSubOwnerSubscriptions)
+