DefaultBtContextTest.cc 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610
  1. #include "DefaultBtContext.h"
  2. #include <cstring>
  3. #include <iostream>
  4. #include <cppunit/extensions/HelperMacros.h>
  5. #include "Util.h"
  6. #include "RecoverableException.h"
  7. #include "AnnounceTier.h"
  8. #include "FixedNumberRandomizer.h"
  9. #include "FileEntry.h"
  10. #include "array_fun.h"
  11. namespace aria2 {
  12. class DefaultBtContextTest:public CppUnit::TestFixture {
  13. CPPUNIT_TEST_SUITE(DefaultBtContextTest);
  14. CPPUNIT_TEST(testGetInfoHash);
  15. CPPUNIT_TEST(testGetPieceHash);
  16. CPPUNIT_TEST(testGetFileEntries);
  17. CPPUNIT_TEST(testGetTotalLength);
  18. CPPUNIT_TEST(testGetFileEntriesSingle);
  19. CPPUNIT_TEST(testGetTotalLengthSingle);
  20. CPPUNIT_TEST(testGetFileModeMulti);
  21. CPPUNIT_TEST(testGetFileModeSingle);
  22. CPPUNIT_TEST(testGetNameMulti);
  23. CPPUNIT_TEST(testGetNameSingle);
  24. CPPUNIT_TEST(testOverrideName);
  25. CPPUNIT_TEST(testGetAnnounceTier);
  26. CPPUNIT_TEST(testGetAnnounceTierAnnounceList);
  27. CPPUNIT_TEST(testGetPieceLength);
  28. CPPUNIT_TEST(testGetInfoHashAsString);
  29. CPPUNIT_TEST(testGetPeerId);
  30. CPPUNIT_TEST(testComputeFastSet);
  31. CPPUNIT_TEST(testGetFileEntries_multiFileUrlList);
  32. CPPUNIT_TEST(testGetFileEntries_singleFileUrlList);
  33. CPPUNIT_TEST(testGetFileEntries_singleFileUrlListEndsWithSlash);
  34. CPPUNIT_TEST(testLoadFromMemory);
  35. CPPUNIT_TEST(testLoadFromMemory_somethingMissing);
  36. CPPUNIT_TEST(testLoadFromMemory_overrideName);
  37. CPPUNIT_TEST(testLoadFromMemory_joinPathMulti);
  38. CPPUNIT_TEST(testLoadFromMemory_joinPathSingle);
  39. CPPUNIT_TEST(testGetNodes);
  40. CPPUNIT_TEST(testGetActualBasePath);
  41. CPPUNIT_TEST(testSetFileFilter_single);
  42. CPPUNIT_TEST(testSetFileFilter_multi);
  43. CPPUNIT_TEST(testUTF8Torrent);
  44. CPPUNIT_TEST_SUITE_END();
  45. public:
  46. void setUp() {
  47. }
  48. void testGetInfoHash();
  49. void testGetPieceHash();
  50. void testGetFileEntries();
  51. void testGetTotalLength();
  52. void testGetFileEntriesSingle();
  53. void testGetTotalLengthSingle();
  54. void testGetFileModeMulti();
  55. void testGetFileModeSingle();
  56. void testGetNameMulti();
  57. void testGetNameSingle();
  58. void testOverrideName();
  59. void testGetAnnounceTier();
  60. void testGetAnnounceTierAnnounceList();
  61. void testGetPieceLength();
  62. void testGetInfoHashAsString();
  63. void testGetPeerId();
  64. void testComputeFastSet();
  65. void testGetFileEntries_multiFileUrlList();
  66. void testGetFileEntries_singleFileUrlList();
  67. void testGetFileEntries_singleFileUrlListEndsWithSlash();
  68. void testLoadFromMemory();
  69. void testLoadFromMemory_somethingMissing();
  70. void testLoadFromMemory_overrideName();
  71. void testLoadFromMemory_joinPathMulti();
  72. void testLoadFromMemory_joinPathSingle();
  73. void testGetNodes();
  74. void testGetActualBasePath();
  75. void testSetFileFilter_single();
  76. void testSetFileFilter_multi();
  77. void testUTF8Torrent();
  78. };
  79. CPPUNIT_TEST_SUITE_REGISTRATION(DefaultBtContextTest);
  80. void DefaultBtContextTest::testGetInfoHash() {
  81. DefaultBtContext btContext;
  82. btContext.load("test.torrent");
  83. std::string correctHash = "248d0a1cd08284299de78d5c1ed359bb46717d8c";
  84. CPPUNIT_ASSERT_EQUAL((size_t)20, btContext.getInfoHashLength());
  85. CPPUNIT_ASSERT_EQUAL(correctHash, Util::toHex(btContext.getInfoHash(),
  86. btContext.getInfoHashLength()));
  87. }
  88. void DefaultBtContextTest::testGetPieceHash() {
  89. DefaultBtContext btContext;
  90. btContext.load("test.torrent");
  91. CPPUNIT_ASSERT_EQUAL(Util::toHex((const unsigned char*)"AAAAAAAAAAAAAAAAAAAA", 20),
  92. btContext.getPieceHash(0));
  93. CPPUNIT_ASSERT_EQUAL(Util::toHex((const unsigned char*)"BBBBBBBBBBBBBBBBBBBB", 20),
  94. btContext.getPieceHash(1));
  95. CPPUNIT_ASSERT_EQUAL(Util::toHex((const unsigned char*)"CCCCCCCCCCCCCCCCCCCC", 20),
  96. btContext.getPieceHash(2));
  97. CPPUNIT_ASSERT_EQUAL(std::string(""),
  98. btContext.getPieceHash(3));
  99. }
  100. void DefaultBtContextTest::testGetFileEntries() {
  101. DefaultBtContext btContext;
  102. btContext.load("test.torrent");
  103. // This is multi-file torrent.
  104. std::deque<SharedHandle<FileEntry> > fileEntries = btContext.getFileEntries();
  105. // There are 2 file entries.
  106. CPPUNIT_ASSERT_EQUAL((size_t)2, fileEntries.size());
  107. std::deque<SharedHandle<FileEntry> >::iterator itr = fileEntries.begin();
  108. SharedHandle<FileEntry> fileEntry1 = *itr;
  109. CPPUNIT_ASSERT_EQUAL(std::string("./aria2-test/aria2/src/aria2c"),
  110. fileEntry1->getPath());
  111. itr++;
  112. SharedHandle<FileEntry> fileEntry2 = *itr;
  113. CPPUNIT_ASSERT_EQUAL(std::string("./aria2-test/aria2-0.2.2.tar.bz2"),
  114. fileEntry2->getPath());
  115. }
  116. void DefaultBtContextTest::testGetFileEntriesSingle() {
  117. DefaultBtContext btContext;
  118. btContext.load("single.torrent");
  119. // This is multi-file torrent.
  120. std::deque<SharedHandle<FileEntry> > fileEntries = btContext.getFileEntries();
  121. // There is 1 file entry.
  122. CPPUNIT_ASSERT_EQUAL((size_t)1, fileEntries.size());
  123. std::deque<SharedHandle<FileEntry> >::iterator itr = fileEntries.begin();
  124. SharedHandle<FileEntry> fileEntry1 = *itr;
  125. CPPUNIT_ASSERT_EQUAL(std::string("./aria2-0.8.2.tar.bz2"),
  126. fileEntry1->getPath());
  127. }
  128. void DefaultBtContextTest::testGetTotalLength() {
  129. DefaultBtContext btContext;
  130. btContext.load("test.torrent");
  131. CPPUNIT_ASSERT_EQUAL((uint64_t)384ULL, btContext.getTotalLength());
  132. }
  133. void DefaultBtContextTest::testGetTotalLengthSingle() {
  134. DefaultBtContext btContext;
  135. btContext.load("single.torrent");
  136. CPPUNIT_ASSERT_EQUAL((uint64_t)384ULL, btContext.getTotalLength());
  137. }
  138. void DefaultBtContextTest::testGetFileModeMulti() {
  139. DefaultBtContext btContext;
  140. btContext.load("test.torrent");
  141. CPPUNIT_ASSERT_EQUAL(BtContext::MULTI, btContext.getFileMode());
  142. }
  143. void DefaultBtContextTest::testGetFileModeSingle() {
  144. DefaultBtContext btContext;
  145. btContext.load("single.torrent");
  146. CPPUNIT_ASSERT_EQUAL(BtContext::SINGLE, btContext.getFileMode());
  147. }
  148. void DefaultBtContextTest::testGetNameMulti() {
  149. DefaultBtContext btContext;
  150. btContext.load("test.torrent");
  151. CPPUNIT_ASSERT_EQUAL(std::string("aria2-test"), btContext.getName());
  152. }
  153. void DefaultBtContextTest::testGetNameSingle() {
  154. DefaultBtContext btContext;
  155. btContext.load("single.torrent");
  156. CPPUNIT_ASSERT_EQUAL(std::string("aria2-0.8.2.tar.bz2"), btContext.getName());
  157. }
  158. void DefaultBtContextTest::testOverrideName()
  159. {
  160. DefaultBtContext btContext;
  161. btContext.load("test.torrent", "aria2-override.name");
  162. CPPUNIT_ASSERT_EQUAL(std::string("aria2-override.name"), btContext.getName());
  163. }
  164. void DefaultBtContextTest::testGetAnnounceTier() {
  165. DefaultBtContext btContext;
  166. btContext.load("single.torrent");
  167. std::deque<SharedHandle<AnnounceTier> > tiers = btContext.getAnnounceTiers();
  168. // There is 1 tier.
  169. CPPUNIT_ASSERT_EQUAL((size_t)1, tiers.size());
  170. std::deque<SharedHandle<AnnounceTier> >::iterator itr = tiers.begin();
  171. SharedHandle<AnnounceTier> tier1 = *itr;
  172. CPPUNIT_ASSERT_EQUAL((size_t)1, tier1->urls.size());
  173. CPPUNIT_ASSERT_EQUAL(std::string("http://aria.rednoah.com/announce.php"),
  174. tier1->urls.at(0));
  175. }
  176. void DefaultBtContextTest::testGetAnnounceTierAnnounceList() {
  177. DefaultBtContext btContext;
  178. btContext.load("test.torrent");
  179. std::deque<SharedHandle<AnnounceTier> > tiers = btContext.getAnnounceTiers();
  180. // There are 3 tiers.
  181. CPPUNIT_ASSERT_EQUAL((size_t)3, tiers.size());
  182. SharedHandle<AnnounceTier> tier1 = tiers.at(0);
  183. CPPUNIT_ASSERT_EQUAL((size_t)1, tier1->urls.size());
  184. CPPUNIT_ASSERT_EQUAL(std::string("http://tracker1"),
  185. tier1->urls.at(0));
  186. SharedHandle<AnnounceTier> tier2 = tiers.at(1);
  187. CPPUNIT_ASSERT_EQUAL((size_t)1, tier2->urls.size());
  188. CPPUNIT_ASSERT_EQUAL(std::string("http://tracker2"), tier2->urls.at(0));
  189. SharedHandle<AnnounceTier> tier3 = tiers.at(2);
  190. CPPUNIT_ASSERT_EQUAL((size_t)1, tier3->urls.size());
  191. CPPUNIT_ASSERT_EQUAL(std::string("http://tracker3"), tier3->urls.at(0));
  192. }
  193. void DefaultBtContextTest::testGetPieceLength() {
  194. DefaultBtContext btContext;
  195. btContext.load("test.torrent");
  196. CPPUNIT_ASSERT_EQUAL((size_t)128, btContext.getPieceLength());
  197. }
  198. void DefaultBtContextTest::testGetInfoHashAsString() {
  199. DefaultBtContext btContext;
  200. btContext.load("test.torrent");
  201. CPPUNIT_ASSERT_EQUAL(std::string("248d0a1cd08284299de78d5c1ed359bb46717d8c"),
  202. btContext.getInfoHashAsString());
  203. }
  204. void DefaultBtContextTest::testGetPeerId() {
  205. DefaultBtContext btContext;
  206. btContext.setRandomizer(SharedHandle<Randomizer>(new FixedNumberRandomizer()));
  207. CPPUNIT_ASSERT_EQUAL(std::string("%2Daria2%2DAAAAAAAAAAAAA"), Util::torrentUrlencode(btContext.getPeerId(), 20));
  208. }
  209. void DefaultBtContextTest::testComputeFastSet()
  210. {
  211. std::string ipaddr = "192.168.0.1";
  212. unsigned char infoHash[20];
  213. memset(infoHash, 0, sizeof(infoHash));
  214. infoHash[0] = 0xff;
  215. int fastSetSize = 10;
  216. DefaultBtContext btContext;
  217. btContext.setInfoHash(infoHash);
  218. btContext.setNumPieces(1000);
  219. {
  220. std::deque<size_t> fastSet;
  221. btContext.computeFastSet(fastSet, ipaddr, fastSetSize);
  222. size_t ans[] = { 686, 459, 278, 200, 404, 834, 64, 203, 760, 950 };
  223. std::deque<size_t> ansSet(&ans[0], &ans[arrayLength(ans)]);
  224. CPPUNIT_ASSERT(std::equal(fastSet.begin(), fastSet.end(), ansSet.begin()));
  225. }
  226. ipaddr = "10.0.0.1";
  227. {
  228. std::deque<size_t> fastSet;
  229. btContext.computeFastSet(fastSet, ipaddr, fastSetSize);
  230. size_t ans[] = { 568, 188, 466, 452, 550, 662, 109, 226, 398, 11 };
  231. std::deque<size_t> ansSet(&ans[0], &ans[arrayLength(ans)]);
  232. CPPUNIT_ASSERT(std::equal(fastSet.begin(), fastSet.end(), ansSet.begin()));
  233. }
  234. // See when pieces < fastSetSize
  235. btContext.setNumPieces(9);
  236. {
  237. std::deque<size_t> fastSet;
  238. btContext.computeFastSet(fastSet, ipaddr, fastSetSize);
  239. size_t ans[] = { 8, 6, 7, 5, 1, 4, 0, 2, 3 };
  240. std::deque<size_t> ansSet(&ans[0], &ans[arrayLength(ans)]);
  241. CPPUNIT_ASSERT(std::equal(fastSet.begin(), fastSet.end(), ansSet.begin()));
  242. }
  243. }
  244. void DefaultBtContextTest::testGetFileEntries_multiFileUrlList() {
  245. DefaultBtContext btContext;
  246. btContext.load("url-list-multiFile.torrent");
  247. // This is multi-file torrent.
  248. std::deque<SharedHandle<FileEntry> > fileEntries = btContext.getFileEntries();
  249. // There are 2 file entries.
  250. CPPUNIT_ASSERT_EQUAL((size_t)2, fileEntries.size());
  251. std::deque<SharedHandle<FileEntry> >::iterator itr = fileEntries.begin();
  252. SharedHandle<FileEntry> fileEntry1 = *itr;
  253. CPPUNIT_ASSERT_EQUAL(std::string("./aria2-test/aria2/src/aria2c"),
  254. fileEntry1->getPath());
  255. std::deque<std::string> uris1 = fileEntry1->getAssociatedUris();
  256. CPPUNIT_ASSERT_EQUAL((size_t)2, uris1.size());
  257. CPPUNIT_ASSERT_EQUAL(std::string("http://localhost/dist/aria2-test/aria2/src/aria2c"),
  258. uris1[0]);
  259. CPPUNIT_ASSERT_EQUAL(std::string("http://mirror/dist/aria2-test/aria2/src/aria2c"),
  260. uris1[1]);
  261. itr++;
  262. SharedHandle<FileEntry> fileEntry2 = *itr;
  263. CPPUNIT_ASSERT_EQUAL(std::string("./aria2-test/aria2-0.2.2.tar.bz2"),
  264. fileEntry2->getPath());
  265. std::deque<std::string> uris2 = fileEntry2->getAssociatedUris();
  266. CPPUNIT_ASSERT_EQUAL((size_t)2, uris2.size());
  267. CPPUNIT_ASSERT_EQUAL(std::string("http://localhost/dist/aria2-test/aria2-0.2.2.tar.bz2"),
  268. uris2[0]);
  269. CPPUNIT_ASSERT_EQUAL(std::string("http://mirror/dist/aria2-test/aria2-0.2.2.tar.bz2"),
  270. uris2[1]);
  271. }
  272. void DefaultBtContextTest::testGetFileEntries_singleFileUrlList() {
  273. DefaultBtContext btContext;
  274. btContext.load("url-list-singleFile.torrent");
  275. // This is single-file torrent.
  276. std::deque<SharedHandle<FileEntry> > fileEntries = btContext.getFileEntries();
  277. // There are 1 file entries.
  278. CPPUNIT_ASSERT_EQUAL((size_t)1, fileEntries.size());
  279. SharedHandle<FileEntry> fileEntry1 = fileEntries.front();
  280. CPPUNIT_ASSERT_EQUAL(std::string("./aria2.tar.bz2"),
  281. fileEntry1->getPath());
  282. std::deque<std::string> uris1 = fileEntry1->getAssociatedUris();
  283. CPPUNIT_ASSERT_EQUAL((size_t)1, uris1.size());
  284. CPPUNIT_ASSERT_EQUAL(std::string("http://localhost/dist/aria2.tar.bz2"),
  285. uris1[0]);
  286. }
  287. void DefaultBtContextTest::testGetFileEntries_singleFileUrlListEndsWithSlash() {
  288. DefaultBtContext btContext;
  289. btContext.load("url-list-singleFileEndsWithSlash.torrent");
  290. // This is single-file torrent.
  291. std::deque<SharedHandle<FileEntry> > fileEntries = btContext.getFileEntries();
  292. // There are 1 file entries.
  293. CPPUNIT_ASSERT_EQUAL((size_t)1, fileEntries.size());
  294. SharedHandle<FileEntry> fileEntry1 = fileEntries.front();
  295. CPPUNIT_ASSERT_EQUAL(std::string("./aria2.tar.bz2"),
  296. fileEntry1->getPath());
  297. std::deque<std::string> uris1 = fileEntry1->getAssociatedUris();
  298. CPPUNIT_ASSERT_EQUAL((size_t)1, uris1.size());
  299. CPPUNIT_ASSERT_EQUAL(std::string("http://localhost/dist/aria2.tar.bz2"),
  300. uris1[0]);
  301. }
  302. void DefaultBtContextTest::testLoadFromMemory()
  303. {
  304. std::string memory = "d8:announce36:http://aria.rednoah.com/announce.php13:announce-listll16:http://tracker1 el15:http://tracker2el15:http://tracker3ee7:comment17:REDNOAH.COM RULES13:creation datei1123456789e4:infod5:filesld6:lengthi284e4:pathl5:aria23:src6:aria2ceed6:lengthi100e4:pathl19:aria2-0.2.2.tar.bz2eee4:name10:aria2-test12:piece lengthi128e6:pieces60:AAAAAAAAAAAAAAAAAAAABBBBBBBBBBBBBBBBBBBBCCCCCCCCCCCCCCCCCCCCee";
  305. DefaultBtContext btContext;
  306. btContext.loadFromMemory(memory, "default");
  307. std::string correctHash = "248d0a1cd08284299de78d5c1ed359bb46717d8c";
  308. CPPUNIT_ASSERT_EQUAL((size_t)20, btContext.getInfoHashLength());
  309. CPPUNIT_ASSERT_EQUAL(correctHash, Util::toHex(btContext.getInfoHash(),
  310. btContext.getInfoHashLength()));
  311. }
  312. void DefaultBtContextTest::testLoadFromMemory_somethingMissing()
  313. {
  314. // pieces missing
  315. try {
  316. std::string memory = "d8:announce36:http://aria.rednoah.com/announce.php4:infod4:name13:aria2.tar.bz26:lengthi262144eee";
  317. DefaultBtContext btContext;
  318. btContext.loadFromMemory(memory, "default");
  319. CPPUNIT_FAIL("exception must be thrown.");
  320. } catch(Exception& e) {
  321. std::cerr << e.stackTrace() << std::endl;
  322. }
  323. }
  324. void DefaultBtContextTest::testLoadFromMemory_overrideName()
  325. {
  326. std::string memory = "d8:announce36:http://aria.rednoah.com/announce.php13:announce-listll16:http://tracker1 el15:http://tracker2el15:http://tracker3ee7:comment17:REDNOAH.COM RULES13:creation datei1123456789e4:infod5:filesld6:lengthi284e4:pathl5:aria23:src6:aria2ceed6:lengthi100e4:pathl19:aria2-0.2.2.tar.bz2eee4:name10:aria2-test12:piece lengthi128e6:pieces60:AAAAAAAAAAAAAAAAAAAABBBBBBBBBBBBBBBBBBBBCCCCCCCCCCCCCCCCCCCCee";
  327. DefaultBtContext btContext;
  328. btContext.loadFromMemory(memory, "default", "aria2-override.name");
  329. CPPUNIT_ASSERT_EQUAL(std::string("aria2-override.name"), btContext.getName());
  330. }
  331. void DefaultBtContextTest::testLoadFromMemory_joinPathMulti()
  332. {
  333. std::string memory =
  334. "d8:announce27:http://example.com/announce4:infod5:filesld6:lengthi262144e4:pathl7:../dir14:dir28:file.imgeee4:name14:../name1/name212:piece lengthi262144e6:pieces20:00000000000000000000ee";
  335. DefaultBtContext btContext;
  336. btContext.setDir("/tmp");
  337. btContext.loadFromMemory(memory, "default");
  338. CPPUNIT_ASSERT_EQUAL(std::string("../name1/name2"), btContext.getName());
  339. CPPUNIT_ASSERT_EQUAL(std::string("/tmp/name1/dir1/dir2/file.img"),
  340. btContext.getFileEntries().front()->getPath());
  341. }
  342. void DefaultBtContextTest::testLoadFromMemory_joinPathSingle()
  343. {
  344. std::string memory =
  345. "d8:announce27:http://example.com/announce4:infod4:name14:../name1/name26:lengthi262144e12:piece lengthi262144e6:pieces20:00000000000000000000ee";
  346. DefaultBtContext btContext;
  347. btContext.setDir("/tmp");
  348. btContext.loadFromMemory(memory, "default");
  349. CPPUNIT_ASSERT_EQUAL(std::string("../name1/name2"), btContext.getName());
  350. CPPUNIT_ASSERT_EQUAL(std::string("/tmp/name1/name2"),
  351. btContext.getFileEntries().front()->getPath());
  352. }
  353. void DefaultBtContextTest::testGetNodes()
  354. {
  355. {
  356. std::string memory =
  357. "d5:nodesl"
  358. "l11:192.168.0.1i6881ee"
  359. "l11:192.168.0.2i6882ee"
  360. "e4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  361. "12:piece lengthi262144e"
  362. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  363. "ee";
  364. DefaultBtContext btContext;
  365. btContext.loadFromMemory(memory, "default");
  366. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  367. btContext.getNodes();
  368. CPPUNIT_ASSERT_EQUAL((size_t)2, nodes.size());
  369. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.1"), nodes[0].first);
  370. CPPUNIT_ASSERT_EQUAL((uint16_t)6881, nodes[0].second);
  371. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.2"), nodes[1].first);
  372. CPPUNIT_ASSERT_EQUAL((uint16_t)6882, nodes[1].second);
  373. }
  374. {
  375. // empty hostname
  376. std::string memory =
  377. "d5:nodesl"
  378. "l1: i6881ee"
  379. "l11:192.168.0.2i6882ee"
  380. "e4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  381. "12:piece lengthi262144e"
  382. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  383. "ee";
  384. DefaultBtContext btContext;
  385. btContext.loadFromMemory(memory, "default");
  386. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  387. btContext.getNodes();
  388. CPPUNIT_ASSERT_EQUAL((size_t)1, nodes.size());
  389. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.2"), nodes[0].first);
  390. CPPUNIT_ASSERT_EQUAL((uint16_t)6882, nodes[0].second);
  391. }
  392. {
  393. // bad port
  394. std::string memory =
  395. "d5:nodesl"
  396. "l11:192.168.0.11:xe"
  397. "l11:192.168.0.2i6882ee"
  398. "e4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  399. "12:piece lengthi262144e"
  400. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  401. "ee";
  402. DefaultBtContext btContext;
  403. btContext.loadFromMemory(memory, "default");
  404. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  405. btContext.getNodes();
  406. CPPUNIT_ASSERT_EQUAL((size_t)1, nodes.size());
  407. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.2"), nodes[0].first);
  408. CPPUNIT_ASSERT_EQUAL((uint16_t)6882, nodes[0].second);
  409. }
  410. {
  411. // port missing
  412. std::string memory =
  413. "d5:nodesl"
  414. "l11:192.168.0.1e"
  415. "l11:192.168.0.2i6882ee"
  416. "e4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  417. "12:piece lengthi262144e"
  418. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  419. "ee";
  420. DefaultBtContext btContext;
  421. btContext.loadFromMemory(memory, "default");
  422. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  423. btContext.getNodes();
  424. CPPUNIT_ASSERT_EQUAL((size_t)1, nodes.size());
  425. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.2"), nodes[0].first);
  426. CPPUNIT_ASSERT_EQUAL((uint16_t)6882, nodes[0].second);
  427. }
  428. {
  429. // nodes is not a list
  430. std::string memory =
  431. "d5:nodes"
  432. "l11:192.168.0.1e"
  433. "4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  434. "12:piece lengthi262144e"
  435. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  436. "ee";
  437. DefaultBtContext btContext;
  438. btContext.loadFromMemory(memory, "default");
  439. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  440. btContext.getNodes();
  441. CPPUNIT_ASSERT_EQUAL((size_t)0, nodes.size());
  442. }
  443. {
  444. // the element of node is not Data
  445. std::string memory =
  446. "d5:nodesl"
  447. "ll11:192.168.0.1i6881eee"
  448. "l11:192.168.0.2i6882ee"
  449. "e4:infod4:name13:aria2.tar.bz26:lengthi262144e"
  450. "12:piece lengthi262144e"
  451. "6:pieces20:AAAAAAAAAAAAAAAAAAAA"
  452. "ee";
  453. DefaultBtContext btContext;
  454. btContext.loadFromMemory(memory, "default");
  455. const std::deque<std::pair<std::string, uint16_t> >& nodes =
  456. btContext.getNodes();
  457. CPPUNIT_ASSERT_EQUAL((size_t)1, nodes.size());
  458. CPPUNIT_ASSERT_EQUAL(std::string("192.168.0.2"), nodes[0].first);
  459. CPPUNIT_ASSERT_EQUAL((uint16_t)6882, nodes[0].second);
  460. }
  461. }
  462. void DefaultBtContextTest::testGetActualBasePath()
  463. {
  464. DefaultBtContext singleCtx;
  465. singleCtx.load("single.torrent");
  466. singleCtx.setFilePathWithIndex(1, "new-path");
  467. CPPUNIT_ASSERT_EQUAL(std::string("new-path"), singleCtx.getActualBasePath());
  468. DefaultBtContext multiCtx;
  469. multiCtx.setDir("downloads");
  470. multiCtx.load("test.torrent");
  471. CPPUNIT_ASSERT_EQUAL(std::string("downloads/aria2-test"),
  472. multiCtx.getActualBasePath());
  473. }
  474. void DefaultBtContextTest::testSetFileFilter_single()
  475. {
  476. DefaultBtContext ctx;
  477. ctx.load("single.torrent");
  478. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  479. ctx.setFileFilter(Util::parseIntRange(""));
  480. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  481. ctx.setFileFilter(Util::parseIntRange("1"));
  482. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  483. // For single file torrent, file is always selected whatever range
  484. // is passed.
  485. ctx.setFileFilter(Util::parseIntRange("2"));
  486. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  487. }
  488. void DefaultBtContextTest::testSetFileFilter_multi()
  489. {
  490. DefaultBtContext ctx;
  491. ctx.load("test.torrent");
  492. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  493. CPPUNIT_ASSERT(ctx.getFileEntries()[1]->isRequested());
  494. ctx.setFileFilter(Util::parseIntRange(""));
  495. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  496. CPPUNIT_ASSERT(ctx.getFileEntries()[1]->isRequested());
  497. ctx.setFileFilter(Util::parseIntRange("2"));
  498. CPPUNIT_ASSERT(!ctx.getFileEntries()[0]->isRequested());
  499. CPPUNIT_ASSERT(ctx.getFileEntries()[1]->isRequested());
  500. ctx.setFileFilter(Util::parseIntRange("3"));
  501. CPPUNIT_ASSERT(!ctx.getFileEntries()[0]->isRequested());
  502. CPPUNIT_ASSERT(!ctx.getFileEntries()[1]->isRequested());
  503. ctx.setFileFilter(Util::parseIntRange("1,2"));
  504. CPPUNIT_ASSERT(ctx.getFileEntries()[0]->isRequested());
  505. CPPUNIT_ASSERT(ctx.getFileEntries()[1]->isRequested());
  506. }
  507. void DefaultBtContextTest::testUTF8Torrent()
  508. {
  509. DefaultBtContext ctx;
  510. ctx.load("utf8.torrent");
  511. CPPUNIT_ASSERT_EQUAL(std::string("name in utf-8"), ctx.getName());
  512. CPPUNIT_ASSERT_EQUAL(std::string("./name in utf-8/path in utf-8"),
  513. ctx.getFileEntries()[0]->getPath());
  514. }
  515. } // namespace aria2