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

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