HttpResponseTest.cc 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674
  1. #include "HttpResponse.h"
  2. #include <iostream>
  3. #include <cppunit/extensions/HelperMacros.h>
  4. #include "prefs.h"
  5. #include "PiecedSegment.h"
  6. #include "Piece.h"
  7. #include "Request.h"
  8. #include "HttpHeader.h"
  9. #include "HttpRequest.h"
  10. #include "Exception.h"
  11. #include "A2STR.h"
  12. #include "DlRetryEx.h"
  13. #include "CookieStorage.h"
  14. #include "AuthConfigFactory.h"
  15. #include "AuthConfig.h"
  16. #include "StreamFilter.h"
  17. #include "MetalinkHttpEntry.h"
  18. #include "Option.h"
  19. #include "Checksum.h"
  20. namespace aria2 {
  21. class HttpResponseTest : public CppUnit::TestFixture {
  22. CPPUNIT_TEST_SUITE(HttpResponseTest);
  23. CPPUNIT_TEST(testGetContentLength_null);
  24. CPPUNIT_TEST(testGetContentLength_contentLength);
  25. //CPPUNIT_TEST(testGetContentLength_range);
  26. CPPUNIT_TEST(testGetEntityLength);
  27. CPPUNIT_TEST(testGetContentType);
  28. CPPUNIT_TEST(testDeterminFilename_without_ContentDisposition);
  29. CPPUNIT_TEST(testDeterminFilename_with_ContentDisposition_zero_length);
  30. CPPUNIT_TEST(testDeterminFilename_with_ContentDisposition);
  31. CPPUNIT_TEST(testGetRedirectURI_without_Location);
  32. CPPUNIT_TEST(testGetRedirectURI_with_Location);
  33. CPPUNIT_TEST(testIsRedirect);
  34. CPPUNIT_TEST(testIsTransferEncodingSpecified);
  35. CPPUNIT_TEST(testGetTransferEncoding);
  36. CPPUNIT_TEST(testGetTransferEncodingStreamFilter);
  37. CPPUNIT_TEST(testIsContentEncodingSpecified);
  38. CPPUNIT_TEST(testGetContentEncoding);
  39. CPPUNIT_TEST(testGetContentEncodingStreamFilter);
  40. CPPUNIT_TEST(testValidateResponse);
  41. CPPUNIT_TEST(testValidateResponse_good_range);
  42. CPPUNIT_TEST(testValidateResponse_bad_range);
  43. CPPUNIT_TEST(testValidateResponse_chunked);
  44. CPPUNIT_TEST(testValidateResponse_withIfModifiedSince);
  45. CPPUNIT_TEST(testProcessRedirect);
  46. CPPUNIT_TEST(testRetrieveCookie);
  47. CPPUNIT_TEST(testSupportsPersistentConnection);
  48. CPPUNIT_TEST(testGetMetalinKHttpEntries);
  49. #ifdef ENABLE_MESSAGE_DIGEST
  50. CPPUNIT_TEST(testGetDigest);
  51. #endif // ENABLE_MESSAGE_DIGEST
  52. CPPUNIT_TEST_SUITE_END();
  53. private:
  54. public:
  55. void setUp() {
  56. }
  57. void testGetContentLength_null();
  58. void testGetContentLength_contentLength();
  59. void testGetEntityLength();
  60. void testGetContentType();
  61. void testDeterminFilename_without_ContentDisposition();
  62. void testDeterminFilename_with_ContentDisposition_zero_length();
  63. void testDeterminFilename_with_ContentDisposition();
  64. void testGetRedirectURI_without_Location();
  65. void testGetRedirectURI_with_Location();
  66. void testIsRedirect();
  67. void testIsTransferEncodingSpecified();
  68. void testGetTransferEncoding();
  69. void testGetTransferEncodingStreamFilter();
  70. void testIsContentEncodingSpecified();
  71. void testGetContentEncoding();
  72. void testGetContentEncodingStreamFilter();
  73. void testValidateResponse();
  74. void testValidateResponse_good_range();
  75. void testValidateResponse_bad_range();
  76. void testValidateResponse_chunked();
  77. void testValidateResponse_withIfModifiedSince();
  78. void testProcessRedirect();
  79. void testRetrieveCookie();
  80. void testSupportsPersistentConnection();
  81. void testGetMetalinKHttpEntries();
  82. #ifdef ENABLE_MESSAGE_DIGEST
  83. void testGetDigest();
  84. #endif // ENABLE_MESSAGE_DIGEST
  85. };
  86. CPPUNIT_TEST_SUITE_REGISTRATION( HttpResponseTest );
  87. void HttpResponseTest::testGetContentLength_null()
  88. {
  89. HttpResponse httpResponse;
  90. CPPUNIT_ASSERT_EQUAL((int64_t)0LL, httpResponse.getContentLength());
  91. }
  92. void HttpResponseTest::testGetContentLength_contentLength()
  93. {
  94. HttpResponse httpResponse;
  95. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  96. httpHeader->put(HttpHeader::CONTENT_LENGTH, "4294967296");
  97. httpResponse.setHttpHeader(httpHeader);
  98. CPPUNIT_ASSERT_EQUAL((int64_t)4294967296LL, httpResponse.getContentLength());
  99. }
  100. void HttpResponseTest::testGetEntityLength()
  101. {
  102. HttpResponse httpResponse;
  103. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  104. httpHeader->put(HttpHeader::CONTENT_LENGTH, "4294967296");
  105. httpResponse.setHttpHeader(httpHeader);
  106. CPPUNIT_ASSERT_EQUAL((int64_t)4294967296LL, httpResponse.getEntityLength());
  107. httpHeader->put(HttpHeader::CONTENT_RANGE, "bytes 1-4294967296/4294967297");
  108. CPPUNIT_ASSERT_EQUAL((int64_t)4294967297LL, httpResponse.getEntityLength());
  109. }
  110. void HttpResponseTest::testGetContentType()
  111. {
  112. HttpResponse httpResponse;
  113. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  114. httpHeader->put(HttpHeader::CONTENT_TYPE,
  115. "application/metalink+xml; charset=UTF-8");
  116. httpResponse.setHttpHeader(httpHeader);
  117. // See paramter is ignored.
  118. CPPUNIT_ASSERT_EQUAL(std::string("application/metalink+xml"),
  119. httpResponse.getContentType());
  120. }
  121. void HttpResponseTest::testDeterminFilename_without_ContentDisposition()
  122. {
  123. HttpResponse httpResponse;
  124. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  125. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  126. SharedHandle<Request> request(new Request());
  127. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  128. httpRequest->setRequest(request);
  129. httpResponse.setHttpHeader(httpHeader);
  130. httpResponse.setHttpRequest(httpRequest);
  131. CPPUNIT_ASSERT_EQUAL(std::string("aria2-1.0.0.tar.bz2"),
  132. httpResponse.determinFilename());
  133. }
  134. void HttpResponseTest::testDeterminFilename_with_ContentDisposition_zero_length
  135. ()
  136. {
  137. HttpResponse httpResponse;
  138. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  139. httpHeader->put(HttpHeader::CONTENT_DISPOSITION, "attachment; filename=\"\"");
  140. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  141. SharedHandle<Request> request(new Request());
  142. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  143. httpRequest->setRequest(request);
  144. httpResponse.setHttpHeader(httpHeader);
  145. httpResponse.setHttpRequest(httpRequest);
  146. CPPUNIT_ASSERT_EQUAL(std::string("aria2-1.0.0.tar.bz2"),
  147. httpResponse.determinFilename());
  148. }
  149. void HttpResponseTest::testDeterminFilename_with_ContentDisposition()
  150. {
  151. HttpResponse httpResponse;
  152. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  153. httpHeader->put(HttpHeader::CONTENT_DISPOSITION,
  154. "attachment; filename=\"aria2-current.tar.bz2\"");
  155. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  156. SharedHandle<Request> request(new Request());
  157. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  158. httpRequest->setRequest(request);
  159. httpResponse.setHttpHeader(httpHeader);
  160. httpResponse.setHttpRequest(httpRequest);
  161. CPPUNIT_ASSERT_EQUAL(std::string("aria2-current.tar.bz2"),
  162. httpResponse.determinFilename());
  163. }
  164. void HttpResponseTest::testGetRedirectURI_without_Location()
  165. {
  166. HttpResponse httpResponse;
  167. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  168. httpResponse.setHttpHeader(httpHeader);
  169. CPPUNIT_ASSERT_EQUAL(std::string(""),
  170. httpResponse.getRedirectURI());
  171. }
  172. void HttpResponseTest::testGetRedirectURI_with_Location()
  173. {
  174. HttpResponse httpResponse;
  175. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  176. httpHeader->put(HttpHeader::LOCATION, "http://localhost/download/aria2-1.0.0.tar.bz2");
  177. httpResponse.setHttpHeader(httpHeader);
  178. CPPUNIT_ASSERT_EQUAL
  179. (std::string("http://localhost/download/aria2-1.0.0.tar.bz2"),
  180. httpResponse.getRedirectURI());
  181. }
  182. void HttpResponseTest::testIsRedirect()
  183. {
  184. HttpResponse httpResponse;
  185. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  186. httpHeader->setStatusCode(200);
  187. httpHeader->put(HttpHeader::LOCATION,
  188. "http://localhost/download/aria2-1.0.0.tar.bz2");
  189. httpResponse.setHttpHeader(httpHeader);
  190. CPPUNIT_ASSERT(!httpResponse.isRedirect());
  191. httpHeader->setStatusCode(301);
  192. CPPUNIT_ASSERT(httpResponse.isRedirect());
  193. }
  194. void HttpResponseTest::testIsTransferEncodingSpecified()
  195. {
  196. HttpResponse httpResponse;
  197. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  198. httpResponse.setHttpHeader(httpHeader);
  199. CPPUNIT_ASSERT(!httpResponse.isTransferEncodingSpecified());
  200. httpHeader->put(HttpHeader::TRANSFER_ENCODING, "chunked");
  201. CPPUNIT_ASSERT(httpResponse.isTransferEncodingSpecified());
  202. }
  203. void HttpResponseTest::testGetTransferEncoding()
  204. {
  205. HttpResponse httpResponse;
  206. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  207. httpResponse.setHttpHeader(httpHeader);
  208. CPPUNIT_ASSERT_EQUAL(std::string(""), httpResponse.getTransferEncoding());
  209. httpHeader->put(HttpHeader::TRANSFER_ENCODING, "chunked");
  210. CPPUNIT_ASSERT_EQUAL(std::string("chunked"),
  211. httpResponse.getTransferEncoding());
  212. }
  213. void HttpResponseTest::testGetTransferEncodingStreamFilter()
  214. {
  215. HttpResponse httpResponse;
  216. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  217. httpResponse.setHttpHeader(httpHeader);
  218. CPPUNIT_ASSERT(!httpResponse.getTransferEncodingStreamFilter());
  219. httpHeader->put(HttpHeader::TRANSFER_ENCODING, "chunked");
  220. CPPUNIT_ASSERT(httpResponse.getTransferEncodingStreamFilter());
  221. }
  222. void HttpResponseTest::testIsContentEncodingSpecified()
  223. {
  224. HttpResponse httpResponse;
  225. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  226. httpResponse.setHttpHeader(httpHeader);
  227. CPPUNIT_ASSERT(!httpResponse.isContentEncodingSpecified());
  228. httpHeader->put(HttpHeader::CONTENT_ENCODING, "gzip");
  229. CPPUNIT_ASSERT(httpResponse.isContentEncodingSpecified());
  230. }
  231. void HttpResponseTest::testGetContentEncoding()
  232. {
  233. HttpResponse httpResponse;
  234. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  235. httpResponse.setHttpHeader(httpHeader);
  236. CPPUNIT_ASSERT_EQUAL(A2STR::NIL, httpResponse.getContentEncoding());
  237. httpHeader->put(HttpHeader::CONTENT_ENCODING, "gzip");
  238. CPPUNIT_ASSERT_EQUAL(std::string("gzip"), httpResponse.getContentEncoding());
  239. }
  240. void HttpResponseTest::testGetContentEncodingStreamFilter()
  241. {
  242. HttpResponse httpResponse;
  243. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  244. httpResponse.setHttpHeader(httpHeader);
  245. CPPUNIT_ASSERT(!httpResponse.getContentEncodingStreamFilter());
  246. #ifdef HAVE_ZLIB
  247. httpHeader->put(HttpHeader::CONTENT_ENCODING, "gzip");
  248. {
  249. SharedHandle<StreamFilter> filter =
  250. httpResponse.getContentEncodingStreamFilter();
  251. CPPUNIT_ASSERT(filter);
  252. CPPUNIT_ASSERT_EQUAL(std::string("GZipDecodingStreamFilter"),
  253. filter->getName());
  254. }
  255. httpHeader.reset(new HttpHeader());
  256. httpResponse.setHttpHeader(httpHeader);
  257. httpHeader->put(HttpHeader::CONTENT_ENCODING, "deflate");
  258. {
  259. SharedHandle<StreamFilter> filter =
  260. httpResponse.getContentEncodingStreamFilter();
  261. CPPUNIT_ASSERT(filter);
  262. CPPUNIT_ASSERT_EQUAL(std::string("GZipDecodingStreamFilter"),
  263. filter->getName());
  264. }
  265. #endif // HAVE_ZLIB
  266. httpHeader.reset(new HttpHeader());
  267. httpResponse.setHttpHeader(httpHeader);
  268. httpHeader->put(HttpHeader::CONTENT_ENCODING, "bzip2");
  269. {
  270. SharedHandle<StreamFilter> filter =
  271. httpResponse.getContentEncodingStreamFilter();
  272. CPPUNIT_ASSERT(!filter);
  273. }
  274. }
  275. void HttpResponseTest::testValidateResponse()
  276. {
  277. HttpResponse httpResponse;
  278. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  279. httpResponse.setHttpHeader(httpHeader);
  280. httpHeader->setStatusCode(301);
  281. try {
  282. httpResponse.validateResponse();
  283. CPPUNIT_FAIL("exception must be thrown.");
  284. } catch(Exception& e) {
  285. }
  286. httpHeader->put(HttpHeader::LOCATION,
  287. "http://localhost/archives/aria2-1.0.0.tar.bz2");
  288. try {
  289. httpResponse.validateResponse();
  290. } catch(Exception& e) {
  291. CPPUNIT_FAIL("exception must not be thrown.");
  292. }
  293. }
  294. void HttpResponseTest::testValidateResponse_good_range()
  295. {
  296. HttpResponse httpResponse;
  297. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  298. httpResponse.setHttpHeader(httpHeader);
  299. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  300. SharedHandle<Piece> p(new Piece(1, 1024*1024));
  301. SharedHandle<Segment> segment(new PiecedSegment(1024*1024, p));
  302. httpRequest->setSegment(segment);
  303. SharedHandle<FileEntry> fileEntry(new FileEntry("file", 1024*1024*10, 0));
  304. httpRequest->setFileEntry(fileEntry);
  305. SharedHandle<Request> request(new Request());
  306. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  307. httpRequest->setRequest(request);
  308. httpResponse.setHttpRequest(httpRequest);
  309. httpHeader->setStatusCode(206);
  310. httpHeader->put(HttpHeader::CONTENT_RANGE, "bytes 1048576-10485760/10485760");
  311. try {
  312. httpResponse.validateResponse();
  313. } catch(Exception& e) {
  314. std::cerr << e.stackTrace() << std::endl;
  315. CPPUNIT_FAIL("exception must not be thrown.");
  316. }
  317. }
  318. void HttpResponseTest::testValidateResponse_bad_range()
  319. {
  320. HttpResponse httpResponse;
  321. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  322. httpResponse.setHttpHeader(httpHeader);
  323. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  324. SharedHandle<Piece> p(new Piece(1, 1024*1024));
  325. SharedHandle<Segment> segment(new PiecedSegment(1024*1024, p));
  326. httpRequest->setSegment(segment);
  327. SharedHandle<FileEntry> fileEntry(new FileEntry("file", 1024*1024*10, 0));
  328. httpRequest->setFileEntry(fileEntry);
  329. SharedHandle<Request> request(new Request());
  330. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  331. httpRequest->setRequest(request);
  332. httpResponse.setHttpRequest(httpRequest);
  333. httpHeader->setStatusCode(206);
  334. httpHeader->put(HttpHeader::CONTENT_RANGE, "bytes 0-10485760/10485761");
  335. try {
  336. httpResponse.validateResponse();
  337. CPPUNIT_FAIL("exception must be thrown.");
  338. } catch(Exception& e) {
  339. }
  340. }
  341. void HttpResponseTest::testValidateResponse_chunked()
  342. {
  343. HttpResponse httpResponse;
  344. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  345. httpResponse.setHttpHeader(httpHeader);
  346. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  347. SharedHandle<Piece> p(new Piece(1, 1024*1024));
  348. SharedHandle<Segment> segment(new PiecedSegment(1024*1024, p));
  349. httpRequest->setSegment(segment);
  350. SharedHandle<FileEntry> fileEntry(new FileEntry("file", 1024*1024*10, 0));
  351. httpRequest->setFileEntry(fileEntry);
  352. SharedHandle<Request> request(new Request());
  353. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  354. httpRequest->setRequest(request);
  355. httpResponse.setHttpRequest(httpRequest);
  356. httpHeader->setStatusCode(206);
  357. httpHeader->put(HttpHeader::CONTENT_RANGE, "bytes 0-10485760/10485761");
  358. httpHeader->put(HttpHeader::TRANSFER_ENCODING, "chunked");
  359. // if transfer-encoding is specified, then range validation is skipped.
  360. try {
  361. httpResponse.validateResponse();
  362. } catch(Exception& e) {
  363. CPPUNIT_FAIL("exception must not be thrown.");
  364. }
  365. }
  366. void HttpResponseTest::testValidateResponse_withIfModifiedSince()
  367. {
  368. HttpResponse httpResponse;
  369. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  370. httpResponse.setHttpHeader(httpHeader);
  371. httpHeader->setStatusCode(304);
  372. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  373. httpResponse.setHttpRequest(httpRequest);
  374. try {
  375. httpResponse.validateResponse();
  376. CPPUNIT_FAIL("exception must be thrown.");
  377. } catch(Exception& e) {
  378. }
  379. httpRequest->setIfModifiedSinceHeader("Fri, 16 Jul 2010 12:56:59 GMT");
  380. httpResponse.validateResponse();
  381. }
  382. void HttpResponseTest::testProcessRedirect()
  383. {
  384. HttpResponse httpResponse;
  385. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  386. httpResponse.setHttpHeader(httpHeader);
  387. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  388. SharedHandle<Request> request(new Request());
  389. request->setUri("http://localhost/archives/aria2-1.0.0.tar.bz2");
  390. httpRequest->setRequest(request);
  391. httpResponse.setHttpRequest(httpRequest);
  392. httpHeader->put(HttpHeader::LOCATION, "http://mirror/aria2-1.0.0.tar.bz2");
  393. httpResponse.processRedirect();
  394. httpHeader->clearField();
  395. // Test for percent-encode
  396. httpHeader->put(HttpHeader::LOCATION, "http://example.org/white space#aria2");
  397. httpResponse.processRedirect();
  398. CPPUNIT_ASSERT_EQUAL(std::string("http://example.org/white%20space"),
  399. request->getCurrentUri());
  400. httpHeader->clearField();
  401. // Give unsupported scheme
  402. httpHeader->put(HttpHeader::LOCATION,
  403. "unsupported://mirror/aria2-1.0.0.tar.bz2");
  404. try {
  405. httpResponse.processRedirect();
  406. CPPUNIT_FAIL("DlRetryEx exception must be thrown.");
  407. } catch(DlRetryEx& e) {
  408. // Success
  409. } catch(...) {
  410. CPPUNIT_FAIL("DlRetryEx exception must be thrown.");
  411. }
  412. }
  413. void HttpResponseTest::testRetrieveCookie()
  414. {
  415. HttpResponse httpResponse;
  416. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  417. httpResponse.setHttpHeader(httpHeader);
  418. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  419. SharedHandle<Request> request(new Request());
  420. request->setUri("http://www.aria2.org/archives/aria2-1.0.0.tar.bz2");
  421. httpRequest->setRequest(request);
  422. SharedHandle<CookieStorage> st(new CookieStorage());
  423. httpRequest->setCookieStorage(st);
  424. httpResponse.setHttpRequest(httpRequest);
  425. httpHeader->put(HttpHeader::SET_COOKIE,
  426. "k1=v1; expires=Sun, 10-Jun-2007 11:00:00 GMT;"
  427. "path=/; domain=.aria2.org;");
  428. httpHeader->put(HttpHeader::SET_COOKIE,
  429. "k2=v2; expires=Sun, 01-Jan-38 00:00:00 GMT;"
  430. "path=/; domain=.aria2.org;");
  431. httpHeader->put(HttpHeader::SET_COOKIE, "k3=v3;");
  432. httpResponse.retrieveCookie();
  433. CPPUNIT_ASSERT_EQUAL((size_t)2, st->size());
  434. std::vector<Cookie> cookies;
  435. st->dumpCookie(std::back_inserter(cookies));
  436. CPPUNIT_ASSERT_EQUAL(std::string("k2=v2"), cookies[0].toString());
  437. CPPUNIT_ASSERT_EQUAL(std::string("k3=v3"), cookies[1].toString());
  438. }
  439. void HttpResponseTest::testSupportsPersistentConnection()
  440. {
  441. HttpResponse httpResponse;
  442. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  443. httpResponse.setHttpHeader(httpHeader);
  444. SharedHandle<HttpRequest> httpRequest(new HttpRequest());
  445. httpResponse.setHttpRequest(httpRequest);
  446. httpHeader->setVersion("HTTP/1.1");
  447. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  448. httpHeader->put(HttpHeader::CONNECTION, "close");
  449. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  450. httpHeader->clearField();
  451. httpHeader->put(HttpHeader::CONNECTION, "keep-alive");
  452. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  453. httpHeader->clearField();
  454. httpHeader->setVersion("HTTP/1.0");
  455. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  456. httpHeader->put(HttpHeader::CONNECTION, "close");
  457. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  458. httpHeader->clearField();
  459. httpHeader->put(HttpHeader::CONNECTION, "keep-alive");
  460. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  461. httpHeader->clearField();
  462. // test proxy connection
  463. SharedHandle<Request> proxyRequest(new Request());
  464. httpRequest->setProxyRequest(proxyRequest);
  465. httpHeader->setVersion("HTTP/1.1");
  466. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  467. httpHeader->put(HttpHeader::CONNECTION, "close");
  468. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  469. httpHeader->clearField();
  470. httpHeader->put(HttpHeader::CONNECTION, "keep-alive");
  471. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  472. httpHeader->clearField();
  473. httpHeader->setVersion("HTTP/1.0");
  474. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  475. httpHeader->put(HttpHeader::CONNECTION, "close");
  476. CPPUNIT_ASSERT(!httpResponse.supportsPersistentConnection());
  477. httpHeader->clearField();
  478. httpHeader->put(HttpHeader::CONNECTION, "keep-alive");
  479. CPPUNIT_ASSERT(httpResponse.supportsPersistentConnection());
  480. httpHeader->clearField();
  481. }
  482. void HttpResponseTest::testGetMetalinKHttpEntries()
  483. {
  484. HttpResponse httpResponse;
  485. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  486. httpResponse.setHttpHeader(httpHeader);
  487. SharedHandle<Option> option(new Option());
  488. httpHeader->put(HttpHeader::LINK,
  489. "<http://uri1/>; rel=duplicate; pri=1; pref; geo=JP");
  490. httpHeader->put(HttpHeader::LINK,
  491. "<http://uri2/>; rel=duplicate");
  492. httpHeader->put(HttpHeader::LINK,
  493. "<http://uri3/>;;;;;;;;rel=duplicate;;;;;pri=2;;;;;");
  494. httpHeader->put(HttpHeader::LINK, "<http://uri4/>;rel=duplicate;=pri=1;pref");
  495. httpHeader->put(HttpHeader::LINK, "<http://describedby>; rel=describedby");
  496. httpHeader->put(HttpHeader::LINK, "<http://norel/>");
  497. httpHeader->put(HttpHeader::LINK, "<baduri>; rel=duplicate; pri=-1;");
  498. std::vector<MetalinkHttpEntry> result;
  499. httpResponse.getMetalinKHttpEntries(result, option);
  500. CPPUNIT_ASSERT_EQUAL((size_t)5, result.size());
  501. MetalinkHttpEntry e = result[0];
  502. CPPUNIT_ASSERT_EQUAL(std::string("http://uri1/"), e.uri);
  503. CPPUNIT_ASSERT_EQUAL(1, e.pri);
  504. CPPUNIT_ASSERT(e.pref);
  505. CPPUNIT_ASSERT_EQUAL(std::string("jp"), e.geo);
  506. e = result[1];
  507. CPPUNIT_ASSERT_EQUAL(std::string("http://uri4/"), e.uri);
  508. CPPUNIT_ASSERT_EQUAL(999999, e.pri);
  509. CPPUNIT_ASSERT(e.pref);
  510. CPPUNIT_ASSERT(e.geo.empty());
  511. e = result[2];
  512. CPPUNIT_ASSERT_EQUAL(std::string("http://uri3/"), e.uri);
  513. CPPUNIT_ASSERT_EQUAL(2, e.pri);
  514. CPPUNIT_ASSERT(!e.pref);
  515. CPPUNIT_ASSERT(e.geo.empty());
  516. e = result[3];
  517. CPPUNIT_ASSERT_EQUAL(std::string("http://uri2/"), e.uri);
  518. CPPUNIT_ASSERT_EQUAL(999999, e.pri);
  519. CPPUNIT_ASSERT(!e.pref);
  520. CPPUNIT_ASSERT(e.geo.empty());
  521. e = result[4];
  522. CPPUNIT_ASSERT_EQUAL(std::string("baduri"), e.uri);
  523. CPPUNIT_ASSERT_EQUAL(999999, e.pri);
  524. CPPUNIT_ASSERT(!e.pref);
  525. CPPUNIT_ASSERT(e.geo.empty());
  526. }
  527. #ifdef ENABLE_MESSAGE_DIGEST
  528. void HttpResponseTest::testGetDigest()
  529. {
  530. HttpResponse httpResponse;
  531. SharedHandle<HttpHeader> httpHeader(new HttpHeader());
  532. httpResponse.setHttpHeader(httpHeader);
  533. SharedHandle<Option> option(new Option());
  534. // Python binascii.hexlify(base64.b64decode(B64ED_HASH)) is handy to
  535. // retrieve ascii hex hash string.
  536. httpHeader->put(HttpHeader::DIGEST, "SHA-1=82AD8itGL/oYQ5BTPFANiYnp9oE=");
  537. httpHeader->put(HttpHeader::DIGEST, "NOT_SUPPORTED");
  538. httpHeader->put(HttpHeader::DIGEST,
  539. "SHA-224=rQdowoLHQJTMVZ3rF7vmYOIzUXlu7F+FcMbPnA==");
  540. httpHeader->put(HttpHeader::DIGEST,
  541. "SHA-224=6Ik6LNZ1iPy6cbmlKO4NHfvxzaiurmHilMyhGA==");
  542. httpHeader->put(HttpHeader::DIGEST,
  543. "SHA-256=+D8nGudz3G/kpkVKQeDrI3xD57v0UeQmzGCZOk03nsU=,"
  544. "MD5=LJDK2+9ClF8Nz/K5WZd/+A==");
  545. std::vector<Checksum> result;
  546. httpResponse.getDigest(result);
  547. CPPUNIT_ASSERT_EQUAL((size_t)3, result.size());
  548. Checksum c = result[0];
  549. CPPUNIT_ASSERT_EQUAL(std::string("sha-256"), c.getHashType());
  550. CPPUNIT_ASSERT_EQUAL(std::string("f83f271ae773dc6fe4a6454a41e0eb237c43e7bbf451e426cc60993a4d379ec5"),
  551. util::toHex(c.getDigest()));
  552. c = result[1];
  553. CPPUNIT_ASSERT_EQUAL(std::string("sha-1"), c.getHashType());
  554. CPPUNIT_ASSERT_EQUAL(std::string("f36003f22b462ffa184390533c500d8989e9f681"),
  555. util::toHex(c.getDigest()));
  556. }
  557. #endif // ENABLE_MESSAGE_DIGEST
  558. } // namespace aria2