Mercurial > jhg

changeset 167:86f9581f4301

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Write down results of changegroup (or any other BundleFormat) wireprotocol command
author Artem Tikhomirov <tikhomirov.artem@gmail.com>
date Tue, 22 Mar 2011 03:52:34 +0100
parents 1d0654be1466
children dd525ca65de8
files cmdline/org/tmatesoft/hg/console/Remote.java
diffstat 1 files changed, 9 insertions(+), 6 deletions(-) [+]
line wrap: on
line diff
--- a/cmdline/org/tmatesoft/hg/console/Remote.java	Wed Mar 16 03:17:00 2011 +0100
+++ b/cmdline/org/tmatesoft/hg/console/Remote.java	Tue Mar 22 03:52:34 2011 +0100
@@ -34,6 +34,7 @@
 import javax.net.ssl.TrustManager;
 import javax.net.ssl.X509TrustManager;
 
+import org.tmatesoft.hg.core.Nodeid;
 import org.tmatesoft.hg.internal.ConfigFile;
 import org.tmatesoft.hg.internal.Internals;
 
@@ -58,9 +59,9 @@
 		ConfigFile cfg = new Internals().newConfigFile();
 		cfg.addLocation(new File(System.getProperty("user.home"), ".hgrc"));
 		String svnkitServer = cfg.getSection("paths").get("svnkit");
-//		URL url = new URL(svnkitServer + "?cmd=changegroup&roots=a78c980749e3ccebb47138b547e9b644a22797a9");
+		URL url = new URL(svnkitServer + "?cmd=changegroup&roots=" + Nodeid.NULL.toString());
 //		URL url = new URL("http://localhost:8000/" + "?cmd=stream_out");
-		URL url = new URL(svnkitServer + "?cmd=stream_out");
+//		URL url = new URL(svnkitServer + "?cmd=stream_out");
 	
 		SSLContext sslContext = SSLContext.getInstance("SSL");
 		class TrustEveryone implements X509TrustManager {
@@ -95,8 +96,9 @@
 		System.out.printf("Content type is %s and its length is %d\n", urlConnection.getContentType(), urlConnection.getContentLength());
 		InputStream is = urlConnection.getInputStream();
 		//
-		dump(is, -1); // simple dump, any cmd
-//		writeBundle(is); // cmd=changegroup
+//		dump(is, -1); // simple dump, any cmd
+		writeBundle(is, false, "HG10GZ"); // cmd=changegroup
+		//writeBundle(is, true, "" or "HG10UN");
 		//
 		urlConnection.disconnect();
 		//
@@ -115,10 +117,11 @@
 		System.out.println();
 	}
 	
-	private static void writeBundle(InputStream is) throws IOException {
-		InflaterInputStream zipStream = new InflaterInputStream(is);
+	private static void writeBundle(InputStream is, boolean decompress, String header) throws IOException {
+		InputStream zipStream = decompress ? new InflaterInputStream(is) : is;
 		File tf = File.createTempFile("hg-bundle-", null);
 		FileOutputStream fos = new FileOutputStream(tf);
+		fos.write(header.getBytes());
 		int r;
 		byte[] buf = new byte[8*1024];
 		while ((r = zipStream.read(buf)) != -1) {