You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

SmartClientSmartServerTest.java 23KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667
  1. /*
  2. * Copyright (C) 2010, Google Inc.
  3. * and other copyright owners as documented in the project's IP log.
  4. *
  5. * This program and the accompanying materials are made available
  6. * under the terms of the Eclipse Distribution License v1.0 which
  7. * accompanies this distribution, is reproduced below, and is
  8. * available at http://www.eclipse.org/org/documents/edl-v10.php
  9. *
  10. * All rights reserved.
  11. *
  12. * Redistribution and use in source and binary forms, with or
  13. * without modification, are permitted provided that the following
  14. * conditions are met:
  15. *
  16. * - Redistributions of source code must retain the above copyright
  17. * notice, this list of conditions and the following disclaimer.
  18. *
  19. * - Redistributions in binary form must reproduce the above
  20. * copyright notice, this list of conditions and the following
  21. * disclaimer in the documentation and/or other materials provided
  22. * with the distribution.
  23. *
  24. * - Neither the name of the Eclipse Foundation, Inc. nor the
  25. * names of its contributors may be used to endorse or promote
  26. * products derived from this software without specific prior
  27. * written permission.
  28. *
  29. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
  30. * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES,
  31. * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  32. * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  33. * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
  34. * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  35. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
  36. * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  37. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  38. * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
  39. * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  40. * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  41. * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  42. */
  43. package org.eclipse.jgit.http.test;
  44. import static org.eclipse.jgit.util.HttpSupport.HDR_CONTENT_ENCODING;
  45. import static org.eclipse.jgit.util.HttpSupport.HDR_CONTENT_LENGTH;
  46. import static org.eclipse.jgit.util.HttpSupport.HDR_CONTENT_TYPE;
  47. import static org.junit.Assert.assertEquals;
  48. import static org.junit.Assert.assertFalse;
  49. import static org.junit.Assert.assertNotNull;
  50. import static org.junit.Assert.assertNull;
  51. import static org.junit.Assert.assertTrue;
  52. import static org.junit.Assert.fail;
  53. import java.io.IOException;
  54. import java.io.PrintWriter;
  55. import java.net.URISyntaxException;
  56. import java.util.Collections;
  57. import java.util.List;
  58. import java.util.Map;
  59. import javax.servlet.Filter;
  60. import javax.servlet.FilterChain;
  61. import javax.servlet.FilterConfig;
  62. import javax.servlet.ServletException;
  63. import javax.servlet.ServletRequest;
  64. import javax.servlet.ServletResponse;
  65. import javax.servlet.http.HttpServletRequest;
  66. import javax.servlet.http.HttpServletResponse;
  67. import org.eclipse.jetty.servlet.FilterHolder;
  68. import org.eclipse.jetty.servlet.FilterMapping;
  69. import org.eclipse.jetty.servlet.ServletContextHandler;
  70. import org.eclipse.jetty.servlet.ServletHolder;
  71. import org.eclipse.jgit.errors.RemoteRepositoryException;
  72. import org.eclipse.jgit.errors.RepositoryNotFoundException;
  73. import org.eclipse.jgit.errors.TransportException;
  74. import org.eclipse.jgit.http.server.GitServlet;
  75. import org.eclipse.jgit.internal.JGitText;
  76. import org.eclipse.jgit.junit.TestRepository;
  77. import org.eclipse.jgit.junit.TestRng;
  78. import org.eclipse.jgit.junit.http.AccessEvent;
  79. import org.eclipse.jgit.junit.http.HttpTestCase;
  80. import org.eclipse.jgit.lib.Constants;
  81. import org.eclipse.jgit.lib.NullProgressMonitor;
  82. import org.eclipse.jgit.lib.ObjectId;
  83. import org.eclipse.jgit.lib.Ref;
  84. import org.eclipse.jgit.lib.Repository;
  85. import org.eclipse.jgit.revwalk.RevBlob;
  86. import org.eclipse.jgit.revwalk.RevCommit;
  87. import org.eclipse.jgit.storage.file.ReflogEntry;
  88. import org.eclipse.jgit.storage.file.FileBasedConfig;
  89. import org.eclipse.jgit.storage.file.FileRepository;
  90. import org.eclipse.jgit.storage.file.ReflogReader;
  91. import org.eclipse.jgit.transport.FetchConnection;
  92. import org.eclipse.jgit.transport.HttpTransport;
  93. import org.eclipse.jgit.transport.RemoteRefUpdate;
  94. import org.eclipse.jgit.transport.Transport;
  95. import org.eclipse.jgit.transport.TransportHttp;
  96. import org.eclipse.jgit.transport.URIish;
  97. import org.eclipse.jgit.transport.resolver.RepositoryResolver;
  98. import org.eclipse.jgit.transport.resolver.ServiceNotEnabledException;
  99. import org.junit.Before;
  100. import org.junit.Test;
  101. public class SmartClientSmartServerTest extends HttpTestCase {
  102. private static final String HDR_TRANSFER_ENCODING = "Transfer-Encoding";
  103. private FileRepository remoteRepository;
  104. private URIish remoteURI;
  105. private URIish brokenURI;
  106. private RevBlob A_txt;
  107. private RevCommit A, B;
  108. @Before
  109. public void setUp() throws Exception {
  110. super.setUp();
  111. final TestRepository<FileRepository> src = createTestRepository();
  112. final String srcName = src.getRepository().getDirectory().getName();
  113. ServletContextHandler app = server.addContext("/git");
  114. GitServlet gs = new GitServlet();
  115. gs.setRepositoryResolver(new RepositoryResolver<HttpServletRequest>() {
  116. public Repository open(HttpServletRequest req, String name)
  117. throws RepositoryNotFoundException,
  118. ServiceNotEnabledException {
  119. if (!name.equals(srcName))
  120. throw new RepositoryNotFoundException(name);
  121. final Repository db = src.getRepository();
  122. db.incrementOpen();
  123. return db;
  124. }
  125. });
  126. app.addServlet(new ServletHolder(gs), "/*");
  127. ServletContextHandler broken = server.addContext("/bad");
  128. broken.addFilter(new FilterHolder(new Filter() {
  129. public void doFilter(ServletRequest request,
  130. ServletResponse response, FilterChain chain)
  131. throws IOException, ServletException {
  132. final HttpServletResponse r = (HttpServletResponse) response;
  133. r.setContentType("text/plain");
  134. r.setCharacterEncoding("UTF-8");
  135. PrintWriter w = r.getWriter();
  136. w.print("OK");
  137. w.close();
  138. }
  139. public void init(FilterConfig filterConfig) throws ServletException {
  140. //
  141. }
  142. public void destroy() {
  143. //
  144. }
  145. }), "/" + srcName + "/git-upload-pack", FilterMapping.DEFAULT);
  146. broken.addServlet(new ServletHolder(gs), "/*");
  147. server.setUp();
  148. remoteRepository = src.getRepository();
  149. remoteURI = toURIish(app, srcName);
  150. brokenURI = toURIish(broken, srcName);
  151. A_txt = src.blob("A");
  152. A = src.commit().add("A_txt", A_txt).create();
  153. B = src.commit().parent(A).add("A_txt", "C").add("B", "B").create();
  154. src.update(master, B);
  155. src.update("refs/garbage/a/very/long/ref/name/to/compress", B);
  156. }
  157. @Test
  158. public void testListRemote() throws IOException {
  159. Repository dst = createBareRepository();
  160. assertEquals("http", remoteURI.getScheme());
  161. Map<String, Ref> map;
  162. Transport t = Transport.open(dst, remoteURI);
  163. try {
  164. // I didn't make up these public interface names, I just
  165. // approved them for inclusion into the code base. Sorry.
  166. // --spearce
  167. //
  168. assertTrue("isa TransportHttp", t instanceof TransportHttp);
  169. assertTrue("isa HttpTransport", t instanceof HttpTransport);
  170. FetchConnection c = t.openFetch();
  171. try {
  172. map = c.getRefsMap();
  173. } finally {
  174. c.close();
  175. }
  176. } finally {
  177. t.close();
  178. }
  179. assertNotNull("have map of refs", map);
  180. assertEquals(3, map.size());
  181. assertNotNull("has " + master, map.get(master));
  182. assertEquals(B, map.get(master).getObjectId());
  183. assertNotNull("has " + Constants.HEAD, map.get(Constants.HEAD));
  184. assertEquals(B, map.get(Constants.HEAD).getObjectId());
  185. List<AccessEvent> requests = getRequests();
  186. assertEquals(1, requests.size());
  187. AccessEvent info = requests.get(0);
  188. assertEquals("GET", info.getMethod());
  189. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  190. assertEquals(1, info.getParameters().size());
  191. assertEquals("git-upload-pack", info.getParameter("service"));
  192. assertEquals(200, info.getStatus());
  193. assertEquals("application/x-git-upload-pack-advertisement", info
  194. .getResponseHeader(HDR_CONTENT_TYPE));
  195. assertEquals("gzip", info.getResponseHeader(HDR_CONTENT_ENCODING));
  196. }
  197. @Test
  198. public void testListRemote_BadName() throws IOException, URISyntaxException {
  199. Repository dst = createBareRepository();
  200. URIish uri = new URIish(this.remoteURI.toString() + ".invalid");
  201. Transport t = Transport.open(dst, uri);
  202. try {
  203. try {
  204. t.openFetch();
  205. fail("fetch connection opened");
  206. } catch (RemoteRepositoryException notFound) {
  207. assertEquals(uri + ": Git repository not found",
  208. notFound.getMessage());
  209. }
  210. } finally {
  211. t.close();
  212. }
  213. List<AccessEvent> requests = getRequests();
  214. assertEquals(1, requests.size());
  215. AccessEvent info = requests.get(0);
  216. assertEquals("GET", info.getMethod());
  217. assertEquals(join(uri, "info/refs"), info.getPath());
  218. assertEquals(1, info.getParameters().size());
  219. assertEquals("git-upload-pack", info.getParameter("service"));
  220. assertEquals(200, info.getStatus());
  221. assertEquals("application/x-git-upload-pack-advertisement",
  222. info.getResponseHeader(HDR_CONTENT_TYPE));
  223. }
  224. @Test
  225. public void testInitialClone_Small() throws Exception {
  226. Repository dst = createBareRepository();
  227. assertFalse(dst.hasObject(A_txt));
  228. Transport t = Transport.open(dst, remoteURI);
  229. try {
  230. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  231. } finally {
  232. t.close();
  233. }
  234. assertTrue(dst.hasObject(A_txt));
  235. assertEquals(B, dst.getRef(master).getObjectId());
  236. fsck(dst, B);
  237. List<AccessEvent> requests = getRequests();
  238. assertEquals(2, requests.size());
  239. AccessEvent info = requests.get(0);
  240. assertEquals("GET", info.getMethod());
  241. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  242. assertEquals(1, info.getParameters().size());
  243. assertEquals("git-upload-pack", info.getParameter("service"));
  244. assertEquals(200, info.getStatus());
  245. assertEquals("application/x-git-upload-pack-advertisement", info
  246. .getResponseHeader(HDR_CONTENT_TYPE));
  247. assertEquals("gzip", info.getResponseHeader(HDR_CONTENT_ENCODING));
  248. AccessEvent service = requests.get(1);
  249. assertEquals("POST", service.getMethod());
  250. assertEquals(join(remoteURI, "git-upload-pack"), service.getPath());
  251. assertEquals(0, service.getParameters().size());
  252. assertNotNull("has content-length", service
  253. .getRequestHeader(HDR_CONTENT_LENGTH));
  254. assertNull("not chunked", service
  255. .getRequestHeader(HDR_TRANSFER_ENCODING));
  256. assertEquals(200, service.getStatus());
  257. assertEquals("application/x-git-upload-pack-result", service
  258. .getResponseHeader(HDR_CONTENT_TYPE));
  259. }
  260. @Test
  261. public void testFetch_FewLocalCommits() throws Exception {
  262. // Bootstrap by doing the clone.
  263. //
  264. TestRepository dst = createTestRepository();
  265. Transport t = Transport.open(dst.getRepository(), remoteURI);
  266. try {
  267. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  268. } finally {
  269. t.close();
  270. }
  271. assertEquals(B, dst.getRepository().getRef(master).getObjectId());
  272. List<AccessEvent> cloneRequests = getRequests();
  273. // Only create a few new commits.
  274. TestRepository.BranchBuilder b = dst.branch(master);
  275. for (int i = 0; i < 4; i++)
  276. b.commit().tick(3600 /* 1 hour */).message("c" + i).create();
  277. // Create a new commit on the remote.
  278. //
  279. b = new TestRepository(remoteRepository).branch(master);
  280. RevCommit Z = b.commit().message("Z").create();
  281. // Now incrementally update.
  282. //
  283. t = Transport.open(dst.getRepository(), remoteURI);
  284. try {
  285. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  286. } finally {
  287. t.close();
  288. }
  289. assertEquals(Z, dst.getRepository().getRef(master).getObjectId());
  290. List<AccessEvent> requests = getRequests();
  291. requests.removeAll(cloneRequests);
  292. assertEquals(2, requests.size());
  293. AccessEvent info = requests.get(0);
  294. assertEquals("GET", info.getMethod());
  295. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  296. assertEquals(1, info.getParameters().size());
  297. assertEquals("git-upload-pack", info.getParameter("service"));
  298. assertEquals(200, info.getStatus());
  299. assertEquals("application/x-git-upload-pack-advertisement",
  300. info.getResponseHeader(HDR_CONTENT_TYPE));
  301. // We should have needed one request to perform the fetch.
  302. //
  303. AccessEvent service = requests.get(1);
  304. assertEquals("POST", service.getMethod());
  305. assertEquals(join(remoteURI, "git-upload-pack"), service.getPath());
  306. assertEquals(0, service.getParameters().size());
  307. assertNotNull("has content-length",
  308. service.getRequestHeader(HDR_CONTENT_LENGTH));
  309. assertNull("not chunked",
  310. service.getRequestHeader(HDR_TRANSFER_ENCODING));
  311. assertEquals(200, service.getStatus());
  312. assertEquals("application/x-git-upload-pack-result",
  313. service.getResponseHeader(HDR_CONTENT_TYPE));
  314. }
  315. @Test
  316. public void testFetch_TooManyLocalCommits() throws Exception {
  317. // Bootstrap by doing the clone.
  318. //
  319. TestRepository dst = createTestRepository();
  320. Transport t = Transport.open(dst.getRepository(), remoteURI);
  321. try {
  322. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  323. } finally {
  324. t.close();
  325. }
  326. assertEquals(B, dst.getRepository().getRef(master).getObjectId());
  327. List<AccessEvent> cloneRequests = getRequests();
  328. // Force enough into the local client that enumeration will
  329. // need multiple packets, but not too many to overflow and
  330. // not pick up the ACK_COMMON message.
  331. //
  332. TestRepository.BranchBuilder b = dst.branch(master);
  333. for (int i = 0; i < 32 - 1; i++)
  334. b.commit().tick(3600 /* 1 hour */).message("c" + i).create();
  335. // Create a new commit on the remote.
  336. //
  337. b = new TestRepository(remoteRepository).branch(master);
  338. RevCommit Z = b.commit().message("Z").create();
  339. // Now incrementally update.
  340. //
  341. t = Transport.open(dst.getRepository(), remoteURI);
  342. try {
  343. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  344. } finally {
  345. t.close();
  346. }
  347. assertEquals(Z, dst.getRepository().getRef(master).getObjectId());
  348. List<AccessEvent> requests = getRequests();
  349. requests.removeAll(cloneRequests);
  350. assertEquals(3, requests.size());
  351. AccessEvent info = requests.get(0);
  352. assertEquals("GET", info.getMethod());
  353. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  354. assertEquals(1, info.getParameters().size());
  355. assertEquals("git-upload-pack", info.getParameter("service"));
  356. assertEquals(200, info.getStatus());
  357. assertEquals("application/x-git-upload-pack-advertisement", info
  358. .getResponseHeader(HDR_CONTENT_TYPE));
  359. // We should have needed two requests to perform the fetch
  360. // due to the high number of local unknown commits.
  361. //
  362. AccessEvent service = requests.get(1);
  363. assertEquals("POST", service.getMethod());
  364. assertEquals(join(remoteURI, "git-upload-pack"), service.getPath());
  365. assertEquals(0, service.getParameters().size());
  366. assertNotNull("has content-length", service
  367. .getRequestHeader(HDR_CONTENT_LENGTH));
  368. assertNull("not chunked", service
  369. .getRequestHeader(HDR_TRANSFER_ENCODING));
  370. assertEquals(200, service.getStatus());
  371. assertEquals("application/x-git-upload-pack-result", service
  372. .getResponseHeader(HDR_CONTENT_TYPE));
  373. service = requests.get(2);
  374. assertEquals("POST", service.getMethod());
  375. assertEquals(join(remoteURI, "git-upload-pack"), service.getPath());
  376. assertEquals(0, service.getParameters().size());
  377. assertNotNull("has content-length", service
  378. .getRequestHeader(HDR_CONTENT_LENGTH));
  379. assertNull("not chunked", service
  380. .getRequestHeader(HDR_TRANSFER_ENCODING));
  381. assertEquals(200, service.getStatus());
  382. assertEquals("application/x-git-upload-pack-result", service
  383. .getResponseHeader(HDR_CONTENT_TYPE));
  384. }
  385. @Test
  386. public void testInitialClone_BrokenServer() throws Exception {
  387. Repository dst = createBareRepository();
  388. assertFalse(dst.hasObject(A_txt));
  389. Transport t = Transport.open(dst, brokenURI);
  390. try {
  391. try {
  392. t.fetch(NullProgressMonitor.INSTANCE, mirror(master));
  393. fail("fetch completed despite upload-pack being broken");
  394. } catch (TransportException err) {
  395. String exp = brokenURI + ": expected"
  396. + " Content-Type application/x-git-upload-pack-result;"
  397. + " received Content-Type text/plain;charset=UTF-8";
  398. assertEquals(exp, err.getMessage());
  399. }
  400. } finally {
  401. t.close();
  402. }
  403. List<AccessEvent> requests = getRequests();
  404. assertEquals(2, requests.size());
  405. AccessEvent info = requests.get(0);
  406. assertEquals("GET", info.getMethod());
  407. assertEquals(join(brokenURI, "info/refs"), info.getPath());
  408. assertEquals(1, info.getParameters().size());
  409. assertEquals("git-upload-pack", info.getParameter("service"));
  410. assertEquals(200, info.getStatus());
  411. assertEquals("application/x-git-upload-pack-advertisement", info
  412. .getResponseHeader(HDR_CONTENT_TYPE));
  413. AccessEvent service = requests.get(1);
  414. assertEquals("POST", service.getMethod());
  415. assertEquals(join(brokenURI, "git-upload-pack"), service.getPath());
  416. assertEquals(0, service.getParameters().size());
  417. assertEquals(200, service.getStatus());
  418. assertEquals("text/plain;charset=UTF-8", service
  419. .getResponseHeader(HDR_CONTENT_TYPE));
  420. }
  421. @Test
  422. public void testPush_NotAuthorized() throws Exception {
  423. final TestRepository src = createTestRepository();
  424. final RevBlob Q_txt = src.blob("new text");
  425. final RevCommit Q = src.commit().add("Q", Q_txt).create();
  426. final Repository db = src.getRepository();
  427. final String dstName = Constants.R_HEADS + "new.branch";
  428. Transport t;
  429. // push anonymous shouldn't be allowed.
  430. //
  431. t = Transport.open(db, remoteURI);
  432. try {
  433. final String srcExpr = Q.name();
  434. final boolean forceUpdate = false;
  435. final String localName = null;
  436. final ObjectId oldId = null;
  437. RemoteRefUpdate u = new RemoteRefUpdate(src.getRepository(),
  438. srcExpr, dstName, forceUpdate, localName, oldId);
  439. try {
  440. t.push(NullProgressMonitor.INSTANCE, Collections.singleton(u));
  441. fail("anonymous push incorrectly accepted without error");
  442. } catch (TransportException e) {
  443. final String exp = remoteURI + ": "
  444. + JGitText.get().authenticationNotSupported;
  445. assertEquals(exp, e.getMessage());
  446. }
  447. } finally {
  448. t.close();
  449. }
  450. List<AccessEvent> requests = getRequests();
  451. assertEquals(1, requests.size());
  452. AccessEvent info = requests.get(0);
  453. assertEquals("GET", info.getMethod());
  454. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  455. assertEquals(1, info.getParameters().size());
  456. assertEquals("git-receive-pack", info.getParameter("service"));
  457. assertEquals(401, info.getStatus());
  458. }
  459. @Test
  460. public void testPush_CreateBranch() throws Exception {
  461. final TestRepository src = createTestRepository();
  462. final RevBlob Q_txt = src.blob("new text");
  463. final RevCommit Q = src.commit().add("Q", Q_txt).create();
  464. final Repository db = src.getRepository();
  465. final String dstName = Constants.R_HEADS + "new.branch";
  466. Transport t;
  467. enableReceivePack();
  468. t = Transport.open(db, remoteURI);
  469. try {
  470. final String srcExpr = Q.name();
  471. final boolean forceUpdate = false;
  472. final String localName = null;
  473. final ObjectId oldId = null;
  474. RemoteRefUpdate u = new RemoteRefUpdate(src.getRepository(),
  475. srcExpr, dstName, forceUpdate, localName, oldId);
  476. t.push(NullProgressMonitor.INSTANCE, Collections.singleton(u));
  477. } finally {
  478. t.close();
  479. }
  480. assertTrue(remoteRepository.hasObject(Q_txt));
  481. assertNotNull("has " + dstName, remoteRepository.getRef(dstName));
  482. assertEquals(Q, remoteRepository.getRef(dstName).getObjectId());
  483. fsck(remoteRepository, Q);
  484. final ReflogReader log = remoteRepository.getReflogReader(dstName);
  485. assertNotNull("has log for " + dstName);
  486. final ReflogEntry last = log.getLastEntry();
  487. assertNotNull("has last entry", last);
  488. assertEquals(ObjectId.zeroId(), last.getOldId());
  489. assertEquals(Q, last.getNewId());
  490. assertEquals("anonymous", last.getWho().getName());
  491. // Assumption: The host name we use to contact the server should
  492. // be the server's own host name, because it should be the loopback
  493. // network interface.
  494. //
  495. final String clientHost = remoteURI.getHost();
  496. assertEquals("anonymous@" + clientHost, last.getWho().getEmailAddress());
  497. assertEquals("push: created", last.getComment());
  498. List<AccessEvent> requests = getRequests();
  499. assertEquals(2, requests.size());
  500. AccessEvent info = requests.get(0);
  501. assertEquals("GET", info.getMethod());
  502. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  503. assertEquals(1, info.getParameters().size());
  504. assertEquals("git-receive-pack", info.getParameter("service"));
  505. assertEquals(200, info.getStatus());
  506. assertEquals("application/x-git-receive-pack-advertisement", info
  507. .getResponseHeader(HDR_CONTENT_TYPE));
  508. AccessEvent service = requests.get(1);
  509. assertEquals("POST", service.getMethod());
  510. assertEquals(join(remoteURI, "git-receive-pack"), service.getPath());
  511. assertEquals(0, service.getParameters().size());
  512. assertNotNull("has content-length", service
  513. .getRequestHeader(HDR_CONTENT_LENGTH));
  514. assertNull("not chunked", service
  515. .getRequestHeader(HDR_TRANSFER_ENCODING));
  516. assertEquals(200, service.getStatus());
  517. assertEquals("application/x-git-receive-pack-result", service
  518. .getResponseHeader(HDR_CONTENT_TYPE));
  519. }
  520. @Test
  521. public void testPush_ChunkedEncoding() throws Exception {
  522. final TestRepository<FileRepository> src = createTestRepository();
  523. final RevBlob Q_bin = src.blob(new TestRng("Q").nextBytes(128 * 1024));
  524. final RevCommit Q = src.commit().add("Q", Q_bin).create();
  525. final FileRepository db = src.getRepository();
  526. final String dstName = Constants.R_HEADS + "new.branch";
  527. Transport t;
  528. enableReceivePack();
  529. final FileBasedConfig cfg = db.getConfig();
  530. cfg.setInt("core", null, "compression", 0);
  531. cfg.setInt("http", null, "postbuffer", 8 * 1024);
  532. cfg.save();
  533. t = Transport.open(db, remoteURI);
  534. try {
  535. final String srcExpr = Q.name();
  536. final boolean forceUpdate = false;
  537. final String localName = null;
  538. final ObjectId oldId = null;
  539. RemoteRefUpdate u = new RemoteRefUpdate(src.getRepository(),
  540. srcExpr, dstName, forceUpdate, localName, oldId);
  541. t.push(NullProgressMonitor.INSTANCE, Collections.singleton(u));
  542. } finally {
  543. t.close();
  544. }
  545. assertTrue(remoteRepository.hasObject(Q_bin));
  546. assertNotNull("has " + dstName, remoteRepository.getRef(dstName));
  547. assertEquals(Q, remoteRepository.getRef(dstName).getObjectId());
  548. fsck(remoteRepository, Q);
  549. List<AccessEvent> requests = getRequests();
  550. assertEquals(2, requests.size());
  551. AccessEvent info = requests.get(0);
  552. assertEquals("GET", info.getMethod());
  553. assertEquals(join(remoteURI, "info/refs"), info.getPath());
  554. assertEquals(1, info.getParameters().size());
  555. assertEquals("git-receive-pack", info.getParameter("service"));
  556. assertEquals(200, info.getStatus());
  557. assertEquals("application/x-git-receive-pack-advertisement", info
  558. .getResponseHeader(HDR_CONTENT_TYPE));
  559. AccessEvent service = requests.get(1);
  560. assertEquals("POST", service.getMethod());
  561. assertEquals(join(remoteURI, "git-receive-pack"), service.getPath());
  562. assertEquals(0, service.getParameters().size());
  563. assertNull("no content-length", service
  564. .getRequestHeader(HDR_CONTENT_LENGTH));
  565. assertEquals("chunked", service.getRequestHeader(HDR_TRANSFER_ENCODING));
  566. assertEquals(200, service.getStatus());
  567. assertEquals("application/x-git-receive-pack-result", service
  568. .getResponseHeader(HDR_CONTENT_TYPE));
  569. }
  570. private void enableReceivePack() throws IOException {
  571. final FileBasedConfig cfg = remoteRepository.getConfig();
  572. cfg.setBoolean("http", null, "receivepack", true);
  573. cfg.save();
  574. }
  575. }