DefaultBtContextTest.cc 21 KB

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