+#include "Swiften/MUC/MUCManager.h"

+ChatsManager::ChatsManager(JID jid, StanzaChannel* stanzaChannel, IQRouter* iqRouter, EventController* eventController, ChatWindowFactory* chatWindowFactory, NickResolver* nickResolver, PresenceOracle* presenceOracle, PresenceSender* presenceSender, UIEventStream* uiEventStream, ChatListWindowFactory* chatListWindowFactory, bool useDelayForLatency, TimerFactory* timerFactory, MUCRegistry* mucRegistry, EntityCapsManager* entityCapsManager, MUCManager* mucManager) : jid_(jid), useDelayForLatency_(useDelayForLatency), mucRegistry_(mucRegistry), entityCapsManager_(entityCapsManager), mucManager(mucManager) {

+void ChatsManager::handleJoinMUCRequest(const JID &mucJID, const boost::optional<String>& nickMaybe) {

+ std::map<JID, MUCController*>::iterator it = mucControllers_.find(mucJID);

+ MUC::ref muc = mucManager->createMUC(mucJID);

+ MUCController* controller = new MUCController(jid_, muc, nick, stanzaChannel_, iqRouter_, chatWindowFactory_, presenceOracle_, avatarManager_, uiEventStream_, false, timerFactory_, eventController_);

+ mucControllers_[mucJID] = controller;

+ mucControllers_[mucJID]->activateChatWindow();

+ class MUCManager;

+ class DirectedPresenceSender;

+ ChatsManager(JID jid, StanzaChannel* stanzaChannel, IQRouter* iqRouter, EventController* eventController, ChatWindowFactory* chatWindowFactory, NickResolver* nickResolver, PresenceOracle* presenceOracle, PresenceSender* presenceSender, UIEventStream* uiEventStream, ChatListWindowFactory* chatListWindowFactory, bool useDelayForLatency, TimerFactory* timerFactory, MUCRegistry* mucRegistry, EntityCapsManager* entityCapsManager, MUCManager* mucManager);

+ MUCManager* mucManager;

+ MUC::ref muc,

+ ChatControllerBase(self, stanzaChannel, iqRouter, chatWindowFactory, muc->getJID(), presenceOracle, avatarManager, useDelayForLatency, uiEventStream, eventController, timerFactory), muc_(muc), nick_(nick) {

+ chatWindow_->setName(muc->getJID().getNode());

+ MUCController(const JID& self, MUC::ref muc, const String &nick, StanzaChannel* stanzaChannel, IQRouter* iqRouter, ChatWindowFactory* chatWindowFactory, PresenceOracle* presenceOracle, AvatarManager* avatarManager, UIEventStream* events, bool useDelayForLatency, TimerFactory* timerFactory, EventController* eventController);

+ MUC::ref muc_;

+#include "Swiften/MUC/MUCManager.h"

+#include "Swiften/Presence/StanzaChannelPresenceSender.h"

+#include "Swiften/Presence/DirectedPresenceSender.h"

+ presenceSender_ = new StanzaChannelPresenceSender(stanzaChannel_);

+ directedPresenceSender_ = new DirectedPresenceSender(presenceSender_);

+ mucManager_ = new MUCManager(stanzaChannel_, iqRouter_, directedPresenceSender_, mucRegistry_);

+ manager_ = new ChatsManager(jid_, stanzaChannel_, iqRouter_, eventController_, chatWindowFactory_, nickResolver_, presenceOracle_, directedPresenceSender_, uiEventStream_, chatListWindowFactory_, true, NULL, mucRegistry_, entityCapsManager_, mucManager_);

+ delete directedPresenceSender_;

+ delete mucManager_;

+ DirectedPresenceSender* directedPresenceSender_;

+ MUCManager* mucManager_;

+#include "Swiften/Presence/DirectedPresenceSender.h"

+#include "Swiften/Presence/StanzaChannelPresenceSender.h"

+ presenceSender_ = new StanzaChannelPresenceSender(stanzaChannel_);

+ directedPresenceSender_ = new DirectedPresenceSender(presenceSender_);

+ mucRegistry_ = new MUCRegistry();

+ muc_ = MUC::ref(new MUC(stanzaChannel_, iqRouter_, directedPresenceSender_, JID("teaparty@rooms.wonderland.lit"), mucRegistry_));

+ mocks_->ExpectCall(chatWindowFactory_, ChatWindowFactory::createChatWindow).With(muc_->getJID(), uiEventStream_).Return(window_);

+ controller_ = new MUCController (self_, muc_, nick_, stanzaChannel_, iqRouter_, chatWindowFactory_, presenceOracle_, avatarManager_, uiEventStream_, false, timerFactory, eventController_);

+ delete directedPresenceSender_;

+ delete mucRegistry_;

+ presence->setFrom(JID(muc_->getJID().toString() + "/" + nick_));

+ message->setFrom(JID(muc_->getJID().toString() + "/otherperson"));

+ message->setFrom(JID(muc_->getJID().toString() + "/other"));

+ message->setFrom(JID(muc_->getJID().toString() + "/other2"));

+ message->setFrom(JID(muc_->getJID().toString() + "/other3"));

+ message->setFrom(JID(muc_->getJID().toString() + "/" + nick_));

+ MUC::ref muc_;

+ StanzaChannelPresenceSender* presenceSender_;

+ DirectedPresenceSender* directedPresenceSender_;

+ MUCRegistry* mucRegistry_;

+ rosterController_ = new RosterController(jid_, client_->getRoster(), client_->getAvatarManager(), mainWindowFactory_, client_->getNickResolver(), client_->getPresenceOracle(), client_->getSubscriptionManager(), eventController_, uiEventStream_, client_->getIQRouter(), settings_);

+ chatsManager_ = new ChatsManager(jid_, client_->getStanzaChannel(), client_->getIQRouter(), eventController_, chatWindowFactory_, client_->getNickResolver(), client_->getPresenceOracle(), client_->getPresenceSender(), uiEventStream_, chatListWindowFactory_, useDelayForLatency_, &timerFactory_, client_->getMUCRegistry(), client_->getEntityCapsManager(), client_->getMUCManager());

+#include "Swiften/Presence/SubscriptionManager.h"

+RosterController::RosterController(const JID& jid, XMPPRoster* xmppRoster, AvatarManager* avatarManager, MainWindowFactory* mainWindowFactory, NickResolver* nickResolver, PresenceOracle* presenceOracle, SubscriptionManager* subscriptionManager, EventController* eventController, UIEventStream* uiEventStream, IQRouter* iqRouter, SettingsProvider* settings)

+ subscriptionManager_ = subscriptionManager;

+ subscriptionManager_->onPresenceSubscriptionRequest.connect(boost::bind(&RosterController::handleSubscriptionRequest, this, _1, _2));

+ subscriptionManager_->requestSubscription(addContactEvent->getJID());

+ subscriptionManager_->confirmSubscription(jid);

+ subscriptionManager_->confirmSubscription(event->getJID());

+ subscriptionManager_->requestSubscription(event->getJID());

+ subscriptionManager_->cancelSubscription(event->getJID());

+#pragma once

+ class SubscriptionManager;

+ RosterController(const JID& jid, XMPPRoster* xmppRoster, AvatarManager* avatarManager, MainWindowFactory* mainWindowFactory, NickResolver* nickResolver, PresenceOracle* presenceOracle, SubscriptionManager* subscriptionManager, EventController* eventController, UIEventStream* uiEventStream, IQRouter* iqRouter_, SettingsProvider* settings);

+ SubscriptionManager* subscriptionManager_;

+#include "Swiften/Presence/SubscriptionManager.h"

+ subscriptionManager_ = new SubscriptionManager(stanzaChannel_);

+ rosterController_ = new RosterController(jid_, xmppRoster_, avatarManager_, mainWindowFactory_, nickResolver_, presenceOracle_, subscriptionManager_, eventController_, uiEventStream_, router_, settings_);

+ delete subscriptionManager_;

+ SubscriptionManager* subscriptionManager_;

+#include "Swiften/Presence/StanzaChannelPresenceSender.h"

+#include "Swiften/Presence/DirectedPresenceSender.h"

+#include "Swiften/MUC/MUCManager.h"

+#include "Swiften/Presence/SubscriptionManager.h"

+ subscriptionManager = new SubscriptionManager(getStanzaChannel());

+

+ stanzaChannelPresenceSender = new StanzaChannelPresenceSender(getStanzaChannel());

+ directedPresenceSender = new DirectedPresenceSender(stanzaChannelPresenceSender);

+ mucManager = new MUCManager(getStanzaChannel(), getIQRouter(), directedPresenceSender, mucRegistry);

+ delete mucManager;

+ delete directedPresenceSender;

+ delete stanzaChannelPresenceSender;

+ delete subscriptionManager;

+PresenceSender* Client::getPresenceSender() const {

+ return directedPresenceSender;

+}

+ class MUCManager;

+ class DirectedPresenceSender;

+ class StanzaChannelPresenceSender;

+ class SubscriptionManager;

+ PresenceSender* getPresenceSender() const;

+

+ MUCManager* getMUCManager() const {

+ return mucManager;

+ SubscriptionManager* getSubscriptionManager() const {

+ return subscriptionManager;

+ }

+

+

+ DirectedPresenceSender* directedPresenceSender;

+ StanzaChannelPresenceSender* stanzaChannelPresenceSender;

+ SubscriptionManager* subscriptionManager;

+ MUCManager* mucManager;

+#include "Swiften/Presence/DirectedPresenceSender.h"

+#include "Swiften/MUC/MUCRegistry.h"

+MUC::MUC(StanzaChannel* stanzaChannel, IQRouter* iqRouter, DirectedPresenceSender* presenceSender, const JID &muc, MUCRegistry* mucRegistry) : ownMUCJID(muc), stanzaChannel(stanzaChannel), iqRouter_(iqRouter), presenceSender(presenceSender), mucRegistry(mucRegistry) {

+ mucRegistry->addMUC(getJID());

+ mucRegistry->removeMUC(getJID());

+ boost::shared_ptr<IQ> iq(IQ::createRequest(IQ::Set, getJID(), iqRouter_->getNewIQID(), mucPayload));

+#include "Swiften/MUC/MUCRegistry.h"

+ class DirectedPresenceSender;

+ typedef boost::shared_ptr<MUC> ref;

+

+ enum LeavingType { Part, Disconnect };

+ MUC(StanzaChannel* stanzaChannel, IQRouter* iqRouter, DirectedPresenceSender* presenceSender, const JID &muc, MUCRegistry* mucRegistry);

+

+ /**

+ * Returns the (bare) JID of the MUC.

+ */

+ JID getJID() const {

+ return ownMUCJID.toBare();

+ }

+ DirectedPresenceSender* presenceSender;

+ MUCRegistry* mucRegistry;

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#include "Swiften/MUC/MUCManager.h"

+

+namespace Swift {

+

+MUCManager::MUCManager(StanzaChannel* stanzaChannel, IQRouter* iqRouter, DirectedPresenceSender* presenceSender, MUCRegistry* mucRegistry) : stanzaChannel(stanzaChannel), iqRouter(iqRouter), presenceSender(presenceSender), mucRegistry(mucRegistry) {

+}

+

+MUC::ref MUCManager::createMUC(const JID& jid) {

+ return MUC::ref(new MUC(stanzaChannel, iqRouter, presenceSender, jid, mucRegistry));

+}

+

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#pragma once

+

+#include "Swiften/MUC/MUC.h"

+

+namespace Swift {

+ class IQRouter;

+ class StanzaChannel;

+ class DirectedPresenceSender;

+ class MUCRegistry;

+

+ class MUCManager {

+ public:

+ MUCManager(StanzaChannel* stanzaChannel, IQRouter* iqRouter, DirectedPresenceSender* presenceSender, MUCRegistry* mucRegistry);

+

+ MUC::ref createMUC(const JID&);

+

+ private:

+ StanzaChannel* stanzaChannel;

+ IQRouter* iqRouter;

+ DirectedPresenceSender* presenceSender;

+ MUCRegistry* mucRegistry;

+ };

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#include "Swiften/Presence/DirectedPresenceSender.h"

+#include "Swiften/Base/foreach.h"

+

+namespace Swift {

+

+DirectedPresenceSender::DirectedPresenceSender(PresenceSender* sender) : sender(sender) {

+}

+

+void DirectedPresenceSender::sendPresence(boost::shared_ptr<Presence> presence) {

+ if (!sender->isAvailable()) {

+ return;

+ }

+

+ sender->sendPresence(presence);

+

+ if (!presence->getTo().isValid()) {

+ boost::shared_ptr<Presence> presenceCopy(new Presence(*presence));

+ foreach(const JID& jid, directedPresenceReceivers) {

+ presenceCopy->setTo(jid);

+ sender->sendPresence(presenceCopy);

+ }

+

+ lastSentUndirectedPresence = presence;

+ }

+}

+

+/**

+ * Gets either the last broadcast presence, or an empty stanza if none has been sent.

+ */

+boost::shared_ptr<Presence> DirectedPresenceSender::getLastSentUndirectedPresence() {

+ boost::shared_ptr<Presence> presenceCopy(lastSentUndirectedPresence ? new Presence(*lastSentUndirectedPresence) : new Presence());

+ return presenceCopy;

+}

+

+void DirectedPresenceSender::addDirectedPresenceReceiver(const JID& jid) {

+ directedPresenceReceivers.insert(jid);

+ if (sender->isAvailable()) {

+ if (lastSentUndirectedPresence && lastSentUndirectedPresence->getType() == Presence::Available) {

+ boost::shared_ptr<Presence> presenceCopy(new Presence(*lastSentUndirectedPresence));

+ presenceCopy->setTo(jid);

+ sender->sendPresence(presenceCopy);

+ }

+ }

+}

+

+void DirectedPresenceSender::removeDirectedPresenceReceiver(const JID& jid) {

+ directedPresenceReceivers.erase(jid);

+ if (sender->isAvailable()) {

+ boost::shared_ptr<Presence> presence(new Presence());

+ presence->setType(Presence::Unavailable);

+ presence->setTo(jid);

+ sender->sendPresence(presence);

+ }

+}

+

+bool DirectedPresenceSender::isAvailable() const {

+ return sender->isAvailable();

+}

+

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#pragma once

+

+#include <set>

+

+#include "Swiften/Elements/Presence.h"

+#include "Swiften/Presence/PresenceSender.h"

+

+namespace Swift {

+ class DirectedPresenceSender : public PresenceSender {

+ public:

+ DirectedPresenceSender(PresenceSender*);

+

+ void addDirectedPresenceReceiver(const JID&);

+ void removeDirectedPresenceReceiver(const JID&);

+

+ void sendPresence(Presence::ref);

+

+ Presence::ref getLastSentUndirectedPresence();

+

+ bool isAvailable() const;

+

+ private:

+ Presence::ref lastSentUndirectedPresence;

+ PresenceSender* sender;

+ std::set<JID> directedPresenceReceivers;

+ };

+}

+ }

+ else {

+PresenceSender::~PresenceSender() {

+ virtual ~PresenceSender();

+ virtual void sendPresence(Presence::ref) = 0;

+ virtual bool isAvailable() const = 0;

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#include "Swiften/Presence/StanzaChannelPresenceSender.h"

+#include "Swiften/Client/StanzaChannel.h"

+

+namespace Swift {

+

+StanzaChannelPresenceSender::StanzaChannelPresenceSender(StanzaChannel* channel) : channel(channel) {

+}

+

+void StanzaChannelPresenceSender::sendPresence(Presence::ref presence) {

+ channel->sendPresence(presence);

+}

+

+bool StanzaChannelPresenceSender::isAvailable() const {

+ return channel->isAvailable();

+}

+

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#pragma once

+

+#include "Swiften/Presence/PresenceSender.h"

+

+namespace Swift {

+ class StanzaChannel;

+

+ class StanzaChannelPresenceSender : public PresenceSender {

+ public:

+ StanzaChannelPresenceSender(StanzaChannel*);

+

+ void sendPresence(Presence::ref);

+

+ bool isAvailable() const;

+

+ private:

+ StanzaChannel* channel;

+ };

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#include "Swiften/Presence/SubscriptionManager.h"

+

+#include <boost/bind.hpp>

+

+#include "Swiften/Base/foreach.h"

+#include "Swiften/Client/StanzaChannel.h"

+

+namespace Swift {

+

+SubscriptionManager::SubscriptionManager(StanzaChannel* channel) : stanzaChannel(channel) {

+ stanzaChannel->onPresenceReceived.connect(boost::bind(&SubscriptionManager::handleIncomingPresence, this, _1));

+}

+

+SubscriptionManager::~SubscriptionManager() {

+ stanzaChannel->onPresenceReceived.disconnect(boost::bind(&SubscriptionManager::handleIncomingPresence, this, _1));

+}

+

+void SubscriptionManager::cancelSubscription(const JID& jid) {

+ Presence::ref stanza(new Presence());

+ stanza->setType(Presence::Unsubscribed);

+ stanza->setTo(jid);

+ stanzaChannel->sendPresence(stanza);

+}

+

+void SubscriptionManager::confirmSubscription(const JID& jid) {

+ Presence::ref stanza(new Presence());

+ stanza->setType(Presence::Subscribed);

+ stanza->setTo(jid);

+ stanzaChannel->sendPresence(stanza);

+}

+

+

+void SubscriptionManager::requestSubscription(const JID& jid) {

+ Presence::ref stanza(new Presence());

+ stanza->setType(Presence::Subscribe);

+ stanza->setTo(jid);

+ stanzaChannel->sendPresence(stanza);

+}

+

+void SubscriptionManager::handleIncomingPresence(Presence::ref presence) {

+ JID bareJID(presence->getFrom().toBare());

+ if (presence->getType() == Presence::Subscribe) {

+ onPresenceSubscriptionRequest(bareJID, presence->getStatus());

+ }

+ else if (presence->getType() == Presence::Unsubscribe) {

+ onPresenceSubscriptionRevoked(bareJID, presence->getStatus());

+ }

+}

+

+

+}

+/*

+ * Copyright (c) 2010 Remko Tronçon

+ * Licensed under the GNU General Public License v3.

+ * See Documentation/Licenses/GPLv3.txt for more information.

+ */

+

+#pragma once

+

+#include <map>

+

+#include "Swiften/Base/String.h"

+#include "Swiften/JID/JID.h"

+#include "Swiften/Base/boost_bsignals.h"

+#include "Swiften/Elements/Presence.h"

+

+namespace Swift {

+ class StanzaChannel;

+

+ class SubscriptionManager {

+ public:

+ SubscriptionManager(StanzaChannel* stanzaChannel);

+ ~SubscriptionManager();

+

+ void cancelSubscription(const JID& jid);

+ void confirmSubscription(const JID& jid);

+ void requestSubscription(const JID& jid);

+

+ /**

+ * This signal is emitted when a presence subscription request is received.

+ */

+ boost::signal<void (const JID&, const String&)> onPresenceSubscriptionRequest;

+

+ boost::signal<void (const JID&, const String&)> onPresenceSubscriptionRevoked;

+

+ private:

+ void handleIncomingPresence(Presence::ref presence);

+

+ private:

+ StanzaChannel* stanzaChannel;

+ };

+}

+#include "Swiften/Presence/DirectedPresenceSender.h"

+#include "Swiften/Presence/StanzaChannelPresenceSender.h"

+class DirectedPresenceSenderTest : public CppUnit::TestFixture {

+ CPPUNIT_TEST_SUITE(DirectedPresenceSenderTest);

+ stanzaChannelPresenceSender = new StanzaChannelPresenceSender(channel);

+ delete stanzaChannelPresenceSender;

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ std::auto_ptr<DirectedPresenceSender> testling(createPresenceSender());

+ DirectedPresenceSender* createPresenceSender() {

+ return new DirectedPresenceSender(stanzaChannelPresenceSender);

+ StanzaChannelPresenceSender* stanzaChannelPresenceSender;

+CPPUNIT_TEST_SUITE_REGISTRATION(DirectedPresenceSenderTest);

+#include "Swiften/Presence/SubscriptionManager.h"

+ subscriptionManager_ = new SubscriptionManager(stanzaChannel_);

+ subscriptionManager_->onPresenceSubscriptionRequest.connect(boost::bind(&PresenceOracleTest::handlePresenceSubscriptionRequest, this, _1, _2));

+ delete subscriptionManager_;

+ SubscriptionManager* subscriptionManager_;

+ "MUC/MUCManager.cpp",

+ "Presence/DirectedPresenceSender.cpp",

+ "Presence/StanzaChannelPresenceSender.cpp",

+ "Presence/SubscriptionManager.cpp",

+ File("Presence/UnitTest/DirectedPresenceSenderTest.cpp"),