/* */ #include "UTMetadataPostDownloadHandler.h" #include "BDE.h" #include "bittorrent_helper.h" #include "RequestGroup.h" #include "download_helper.h" #include "RecoverableException.h" #include "A2STR.h" #include "DownloadContext.h" #include "Logger.h" #include "util.h" #include "a2functional.h" #include "DiskAdaptor.h" #include "PieceStorage.h" #include "bencode.h" namespace aria2 { bool UTMetadataPostDownloadHandler::Criteria::match (const RequestGroup* requestGroup) const { SharedHandle dctx = requestGroup->getDownloadContext(); if(dctx->hasAttribute(bittorrent::BITTORRENT)) { const BDE& attrs = dctx->getAttribute(bittorrent::BITTORRENT); if(!attrs.containsKey(bittorrent::METADATA)) { return true; } } return false; } UTMetadataPostDownloadHandler::UTMetadataPostDownloadHandler() { setCriteria(SharedHandle(new Criteria())); } void UTMetadataPostDownloadHandler::getNextRequestGroups (std::deque >& groups, RequestGroup* requestGroup) { SharedHandle dctx = requestGroup->getDownloadContext(); const BDE& attrs = dctx->getAttribute(bittorrent::BITTORRENT); std::string metadata = util::toString(requestGroup->getPieceStorage()->getDiskAdaptor()); std::string torrent = bittorrent::metadata2Torrent(metadata, attrs); try { std::deque > newRgs; createRequestGroupForBitTorrent(newRgs, requestGroup->getOption(), std::deque(), torrent); groups.insert(groups.end(), newRgs.begin(), newRgs.end()); } catch(RecoverableException& e) { _logger->error("Failed to parse BitTorrent metadata.", e); } } } // namespace aria2