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

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