/* * Copyright (c) 2010-2016 Isode Limited. * All rights reserved. * See the COPYING file for more information. */ #include #include #include #include namespace Swift { EntityCapsManager::EntityCapsManager(CapsProvider* capsProvider, StanzaChannel* stanzaChannel) : capsProvider(capsProvider) { stanzaChannel->onPresenceReceived.connect(boost::bind(&EntityCapsManager::handlePresenceReceived, this, _1)); stanzaChannel->onAvailableChanged.connect(boost::bind(&EntityCapsManager::handleStanzaChannelAvailableChanged, this, _1)); capsProvider->onCapsAvailable.connect(boost::bind(&EntityCapsManager::handleCapsAvailable, this, _1)); } void EntityCapsManager::handlePresenceReceived(std::shared_ptr presence) { JID from = presence->getFrom(); if (presence->isAvailable()) { std::shared_ptr capsInfo = presence->getPayload(); if (!capsInfo || capsInfo->getHash() != "sha-1" || presence->getPayload()) { return; } std::string hash = capsInfo->getVersion(); std::map::iterator i = caps.find(from); if (i == caps.end() || i->second != hash) { caps.insert(std::make_pair(from, hash)); DiscoInfo::ref disco = capsProvider->getCaps(hash); if (disco) { onCapsChanged(from); } else if (i != caps.end()) { caps.erase(i); onCapsChanged(from); } } } else { std::map::iterator i = caps.find(from); if (i != caps.end()) { caps.erase(i); onCapsChanged(from); } } } void EntityCapsManager::handleStanzaChannelAvailableChanged(bool available) { if (available) { std::map capsCopy; capsCopy.swap(caps); for (std::map::const_iterator i = capsCopy.begin(); i != capsCopy.end(); ++i) { onCapsChanged(i->first); } } } void EntityCapsManager::handleCapsAvailable(const std::string& hash) { // TODO: Use Boost.Bimap ? for (std::map::const_iterator i = caps.begin(); i != caps.end(); ++i) { if (i->second == hash) { onCapsChanged(i->first); } } } DiscoInfo::ref EntityCapsManager::getCaps(const JID& jid) const { std::map::const_iterator i = caps.find(jid); if (i != caps.end()) { return capsProvider->getCaps(i->second); } return DiscoInfo::ref(); } }