tikhomirov@69: /*
tikhomirov@483:  * Copyright (c) 2011-2012 TMate Software Ltd
tikhomirov@74:  *  
tikhomirov@74:  * This program is free software; you can redistribute it and/or modify
tikhomirov@74:  * it under the terms of the GNU General Public License as published by
tikhomirov@74:  * the Free Software Foundation; version 2 of the License.
tikhomirov@74:  *
tikhomirov@74:  * This program is distributed in the hope that it will be useful,
tikhomirov@74:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
tikhomirov@74:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
tikhomirov@74:  * GNU General Public License for more details.
tikhomirov@74:  *
tikhomirov@74:  * For information on how to redistribute this software under
tikhomirov@74:  * the terms of a license other than GNU General Public License
tikhomirov@102:  * contact TMate Software at support@hg4j.com
tikhomirov@69:  */
tikhomirov@74: package org.tmatesoft.hg.console;
tikhomirov@69: 
tikhomirov@69: import java.io.File;
tikhomirov@69: import java.io.FileOutputStream;
tikhomirov@156: import java.io.IOException;
tikhomirov@69: import java.io.InputStream;
tikhomirov@177: import java.io.OutputStream;
tikhomirov@177: import java.net.HttpURLConnection;
tikhomirov@69: import java.net.URL;
tikhomirov@69: import java.security.cert.CertificateException;
tikhomirov@69: import java.security.cert.X509Certificate;
tikhomirov@69: import java.util.List;
tikhomirov@69: import java.util.Map;
tikhomirov@69: import java.util.prefs.Preferences;
tikhomirov@69: import java.util.zip.InflaterInputStream;
tikhomirov@69: 
tikhomirov@69: import javax.net.ssl.HttpsURLConnection;
tikhomirov@69: import javax.net.ssl.SSLContext;
tikhomirov@69: import javax.net.ssl.TrustManager;
tikhomirov@69: import javax.net.ssl.X509TrustManager;
tikhomirov@69: 
tikhomirov@483: import org.tmatesoft.hg.internal.BasicSessionContext;
tikhomirov@69: import org.tmatesoft.hg.internal.ConfigFile;
tikhomirov@69: 
tikhomirov@69: /**
tikhomirov@74:  * WORK IN PROGRESS, DO NOT USE
tikhomirov@74:  * 
tikhomirov@74:  * @author Artem Tikhomirov
tikhomirov@74:  * @author TMate Software Ltd.
tikhomirov@69:  */
tikhomirov@69: public class Remote {
tikhomirov@69: 
tikhomirov@69: 	/*
tikhomirov@69: 	 * @see http://mercurial.selenic.com/wiki/WireProtocol
tikhomirov@69: 	 cmd=branches gives 4 nodeids (head, root, first parent, second parent) per line (few lines possible, per branch, perhaps?)
tikhomirov@69: 	 cmd=capabilities gives lookup ...subset and 3 compress methods
tikhomirov@69: 	 // lookup changegroupsubset unbundle=HG10GZ,HG10BZ,HG10UN
tikhomirov@69: 	 cmd=heads gives space-separated list of nodeids (or just one)
tikhomirov@69: 	 nodeids are in hex (printable) format, need to convert fromAscii()
tikhomirov@69: 	 cmd=branchmap
tikhomirov@171: 	 cmd=between needs argument pairs, with first element in the pair to be head(!), second to be root of the branch (
tikhomirov@171: 	 	i.e. (newer-older), not (older-newer) as one might expect. Returned list of nodes comes in reversed order (from newer
tikhomirov@171: 	 	to older) as well
tikhomirov@171: 
tikhomirov@171: 	cmd=branches&nodes=d6d2a630f4a6d670c90a5ca909150f2b426ec88f+
tikhomirov@171: 	head, root, first parent, second parent
tikhomirov@171: 	received: d6d2a630f4a6d670c90a5ca909150f2b426ec88f dbd663faec1f0175619cf7668bddc6350548b8d6 0000000000000000000000000000000000000000 0000000000000000000000000000000000000000
tikhomirov@171: 	
tikhomirov@171: 	Sequence, for actual state with merged/closed branch, where 157:d5268ca7715b8d96204fc62abc632e8f55761547 is merge revision of 156 and 53 
tikhomirov@171: 	>branches, 170:71ddbf8603e8e09d54ac9c5fe4bb5ae824589f1d
tikhomirov@171: 	 71ddbf8603e8e09d54ac9c5fe4bb5ae824589f1d d5268ca7715b8d96204fc62abc632e8f55761547 643ddec3be36246fc052cf22ece503fa60cafe22 a6f39e595b2b54f56304470269a936ead77f5725
tikhomirov@171: 
tikhomirov@171: 	>branches, 156:643ddec3be36246fc052cf22ece503fa60cafe22
tikhomirov@171: 	 643ddec3be36246fc052cf22ece503fa60cafe22 ade65afe0906febafbf8a2e41002052e0e446471 08754fce5778a3409476ecdb3cec6b5172c34367 40d04c4f771ebbd599eb229145252732a596740a
tikhomirov@171: 	>branches, 53:a6f39e595b2b54f56304470269a936ead77f5725
tikhomirov@171: 	 a6f39e595b2b54f56304470269a936ead77f5725 a6f39e595b2b54f56304470269a936ead77f5725 9429c7bd1920fab164a9d2b621d38d57bcb49ae0 30bd389788464287cee22ccff54c330a4b715de5
tikhomirov@171: 
tikhomirov@171: 	>branches, 84:08754fce5778a3409476ecdb3cec6b5172c34367  (p1:82) 
tikhomirov@171: 	 08754fce5778a3409476ecdb3cec6b5172c34367 dbd663faec1f0175619cf7668bddc6350548b8d6 0000000000000000000000000000000000000000 0000000000000000000000000000000000000000
tikhomirov@171: 	>branches, 83:40d04c4f771ebbd599eb229145252732a596740a (p1:80)
tikhomirov@171: 	 40d04c4f771ebbd599eb229145252732a596740a dbd663faec1f0175619cf7668bddc6350548b8d6 0000000000000000000000000000000000000000 0000000000000000000000000000000000000000
tikhomirov@171: 
tikhomirov@171: 	>branches, 51:9429c7bd1920fab164a9d2b621d38d57bcb49ae0 (wrap-data-access branch)
tikhomirov@171: 	 9429c7bd1920fab164a9d2b621d38d57bcb49ae0 dbd663faec1f0175619cf7668bddc6350548b8d6 0000000000000000000000000000000000000000 0000000000000000000000000000000000000000
tikhomirov@171: 	>branches, 52:30bd389788464287cee22ccff54c330a4b715de5 (p1:50)
tikhomirov@171: 	 30bd389788464287cee22ccff54c330a4b715de5 dbd663faec1f0175619cf7668bddc6350548b8d6 0000000000000000000000000000000000000000 0000000000000000000000000000000000000000
tikhomirov@171: 
tikhomirov@171: 
tikhomirov@171: 	cmd=between&pairs=71ddbf8603e8e09d54ac9c5fe4bb5ae824589f1d-d5268ca7715b8d96204fc62abc632e8f55761547+40d04c4f771ebbd599eb229145252732a596740a-dbd663faec1f0175619cf7668bddc6350548b8d6
tikhomirov@171: 	 8c8e3f372fa1fbfcf92b004b6f2ada2dbaf60028 dd525ca65de8e78cb133919de57ea0a6e6454664 1d0654be1466d522994f8bead510e360fbeb8d79 c17a08095e4420202ac1b2d939ef6d5f8bebb569
tikhomirov@171: 	 4222b04f34ee885bc1ad547c7ef330e18a51afc1 5f9635c016819b322ae05a91b3378621b538c933 c677e159391925a50b9a23f557426b2246bc9c5d 0d279bcc44427cb5ae2f3407c02f21187ccc8aea e21df6259f8374ac136767321e837c0c6dd21907 b01500fe2604c2c7eadf44349cce9f438484474b 865bf07f381ff7d1b742453568def92576af80b6
tikhomirov@171: 
tikhomirov@171: 	Between two subsequent revisions (i.e. direct child in remote of a local root) 
tikhomirov@171: 	cmd=between&pairs=71ddbf8603e8e09d54ac9c5fe4bb5ae824589f1d-8c8e3f372fa1fbfcf92b004b6f2ada2dbaf60028
tikhomirov@171: 	 empty result
tikhomirov@69: 	 */
tikhomirov@69: 	public static void main(String[] args) throws Exception {
tikhomirov@483: 		ConfigFile cfg =  new ConfigFile(new BasicSessionContext(null));
tikhomirov@69: 		cfg.addLocation(new File(System.getProperty("user.home"), ".hgrc"));
tikhomirov@69: 		String svnkitServer = cfg.getSection("paths").get("svnkit");
tikhomirov@171: //		URL url = new URL(svnkitServer + "?cmd=branches&nodes=30bd389788464287cee22ccff54c330a4b715de5");
tikhomirov@179: //		URL url = new URL(svnkitServer + "?cmd=between"); 
tikhomirov@179: 		URL url = new URL(svnkitServer + "?cmd=changegroup&roots=71ddbf8603e8e09d54ac9c5fe4bb5ae824589f1d");
tikhomirov@177: //		URL url = new URL("http://localhost:8000/" + "?cmd=between");
tikhomirov@167: //		URL url = new URL(svnkitServer + "?cmd=stream_out");
tikhomirov@69: 	
tikhomirov@69: 		SSLContext sslContext = SSLContext.getInstance("SSL");
tikhomirov@69: 		class TrustEveryone implements X509TrustManager {
tikhomirov@69: 			public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
tikhomirov@69: 				System.out.println("checkClientTrusted " + authType);
tikhomirov@69: 			}
tikhomirov@69: 			public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
tikhomirov@69: 				System.out.println("checkServerTrusted" + authType);
tikhomirov@69: 			}
tikhomirov@69: 			public X509Certificate[] getAcceptedIssuers() {
tikhomirov@69: 				return new X509Certificate[0];
tikhomirov@69: 			}
tikhomirov@69: 		}
tikhomirov@156: 		// Hack to get Base64-encoded credentials
tikhomirov@69: 		Preferences tempNode = Preferences.userRoot().node("xxx");
tikhomirov@69: 		tempNode.putByteArray("xxx", url.getUserInfo().getBytes());
tikhomirov@69: 		String authInfo = tempNode.get("xxx", null);
tikhomirov@69: 		tempNode.removeNode();
tikhomirov@69: 		//
tikhomirov@69: 		sslContext.init(null, new TrustManager[] { new TrustEveryone() }, null);
tikhomirov@69: 		HttpsURLConnection urlConnection = (HttpsURLConnection) url.openConnection();
tikhomirov@177: //		HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();
tikhomirov@177: 		urlConnection.setRequestProperty("User-Agent", "jhg/0.1.0");
tikhomirov@177: 		urlConnection.setRequestProperty("Accept", "application/mercurial-0.1");
tikhomirov@177: 		urlConnection.setRequestProperty("Authorization", "Basic " + authInfo);
tikhomirov@69: 		urlConnection.setSSLSocketFactory(sslContext.getSocketFactory());
tikhomirov@179: //		byte[] body = "pairs=f5aed108754e817d2ca374d1a4f6daf1218dcc91-9429c7bd1920fab164a9d2b621d38d57bcb49ae0".getBytes();
tikhomirov@179: //		urlConnection.setRequestMethod("POST");
tikhomirov@179: //		urlConnection.setRequestProperty("Content-Length", String.valueOf(body.length));
tikhomirov@179: //		urlConnection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
tikhomirov@179: //		urlConnection.setDoOutput(true);
tikhomirov@179: //		urlConnection.setDoInput(true);
tikhomirov@179: 		urlConnection.connect();
tikhomirov@179: //		OutputStream os = urlConnection.getOutputStream();
tikhomirov@179: //		os.write(body);
tikhomirov@179: //		os.flush();
tikhomirov@179: //		os.close();
tikhomirov@171: 		System.out.println("Query:" + url.getQuery());
tikhomirov@69: 		System.out.println("Response headers:");
tikhomirov@69: 		final Map<String, List<String>> headerFields = urlConnection.getHeaderFields();
tikhomirov@69: 		for (String s : headerFields.keySet()) {
tikhomirov@69: 			System.out.printf("%s: %s\n", s, urlConnection.getHeaderField(s));
tikhomirov@69: 		}
tikhomirov@69: 		System.out.printf("Content type is %s and its length is %d\n", urlConnection.getContentType(), urlConnection.getContentLength());
tikhomirov@69: 		InputStream is = urlConnection.getInputStream();
tikhomirov@156: 		//
tikhomirov@179: //		dump(is, -1); // simple dump, any cmd
tikhomirov@179: 		writeBundle(is, false, "HG10GZ"); // cmd=changegroup
tikhomirov@167: 		//writeBundle(is, true, "" or "HG10UN");
tikhomirov@156: 		//
tikhomirov@156: 		urlConnection.disconnect();
tikhomirov@156: 		//
tikhomirov@156: 	}
tikhomirov@156: 
tikhomirov@156: 	private static void dump(InputStream is, int limit) throws IOException {
tikhomirov@156: 		int b;
tikhomirov@156: 		while ((b =is.read()) != -1) {
tikhomirov@156: 			System.out.print((char) b);
tikhomirov@156: 			if (limit != -1) {
tikhomirov@156: 				if (--limit < 0) {
tikhomirov@156: 					break;
tikhomirov@156: 				}
tikhomirov@156: 			}
tikhomirov@156: 		}
tikhomirov@156: 		System.out.println();
tikhomirov@156: 	}
tikhomirov@156: 	
tikhomirov@167: 	private static void writeBundle(InputStream is, boolean decompress, String header) throws IOException {
tikhomirov@167: 		InputStream zipStream = decompress ? new InflaterInputStream(is) : is;
tikhomirov@69: 		File tf = File.createTempFile("hg-bundle-", null);
tikhomirov@69: 		FileOutputStream fos = new FileOutputStream(tf);
tikhomirov@167: 		fos.write(header.getBytes());
tikhomirov@69: 		int r;
tikhomirov@69: 		byte[] buf = new byte[8*1024];
tikhomirov@69: 		while ((r = zipStream.read(buf)) != -1) {
tikhomirov@69: 			fos.write(buf, 0, r);
tikhomirov@69: 		}
tikhomirov@69: 		fos.close();
tikhomirov@69: 		zipStream.close();
tikhomirov@69: 		System.out.println(tf);
tikhomirov@69: 	}
tikhomirov@69: }