Mercurial > hg4j
annotate src/org/tmatesoft/hg/internal/remote/HttpConnector.java @ 713:661e77dc88ba tip
Mac support: respect Mac alternatives of command-line arguments for common unix tools
| author | Artem Tikhomirov <tikhomirov.artem@gmail.com> | 
|---|---|
| date | Sun, 03 Aug 2014 18:09:00 +0200 | 
| parents | a483b2b68a2e | 
| children | 
| rev | line source | 
|---|---|
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 1 /* | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 2 * Copyright (c) 2013 TMate Software Ltd | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 3 * | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 4 * This program is free software; you can redistribute it and/or modify | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 5 * it under the terms of the GNU General Public License as published by | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 6 * the Free Software Foundation; version 2 of the License. | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 7 * | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 8 * This program is distributed in the hope that it will be useful, | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 9 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 11 * GNU General Public License for more details. | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 12 * | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 13 * For information on how to redistribute this software under | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 14 * the terms of a license other than GNU General Public License | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 15 * contact TMate Software at support@hg4j.com | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 16 */ | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 17 package org.tmatesoft.hg.internal.remote; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 18 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 19 import java.io.BufferedReader; | 
| 697 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 20 import java.io.ByteArrayInputStream; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 21 import java.io.FilterOutputStream; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 22 import java.io.IOException; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 23 import java.io.InputStream; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 24 import java.io.InputStreamReader; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 25 import java.io.OutputStream; | 
| 697 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 26 import java.io.SequenceInputStream; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 27 import java.net.HttpURLConnection; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 28 import java.net.MalformedURLException; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 29 import java.net.URL; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 30 import java.net.URLConnection; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 31 import java.util.Collection; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 32 import java.util.List; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 33 import java.util.Map; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 34 | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 35 import org.tmatesoft.hg.auth.HgAuthFailedException; | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 36 import org.tmatesoft.hg.auth.HgAuthenticator; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 37 import org.tmatesoft.hg.core.HgRemoteConnectionException; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 38 import org.tmatesoft.hg.core.Nodeid; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 39 import org.tmatesoft.hg.core.SessionContext; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 40 import org.tmatesoft.hg.internal.PropertyMarshal; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 41 import org.tmatesoft.hg.repo.HgRemoteRepository.Range; | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 42 import org.tmatesoft.hg.repo.HgRemoteRepository.RemoteDescriptor; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 43 import org.tmatesoft.hg.repo.HgRuntimeException; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 44 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 45 /** | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 46 * | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 47 * @author Artem Tikhomirov | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 48 * @author TMate Software Ltd. | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 49 */ | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 50 public class HttpConnector extends ConnectorBase { | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 51 private RemoteDescriptor rd; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 52 private URL url; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 53 private boolean debug; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 54 private SessionContext sessionCtx; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 55 // | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 56 private HttpURLConnection conn; | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 57 private HttpAuthMethod authMediator; | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 58 | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 59 public void init(RemoteDescriptor remote, SessionContext sessionContext, Object globalConfig) throws HgRuntimeException { | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 60 rd = remote; | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 61 setURI(remote.getURI()); | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 62 sessionCtx = sessionContext; | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 63 debug = new PropertyMarshal(sessionContext).getBoolean("hg4j.remote.debug", false); | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 64 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 65 | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 66 public void connect() throws HgAuthFailedException, HgRemoteConnectionException, HgRuntimeException { | 
| 698 
822f3a83ff57
in, out and clone tests pass for ssh repositories. Infrastructure to decouple HgRemoteRepository from specific Connector implementation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
697diff
changeset | 67 try { | 
| 
822f3a83ff57
in, out and clone tests pass for ssh repositories. Infrastructure to decouple HgRemoteRepository from specific Connector implementation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
697diff
changeset | 68 url = uri.toURL(); | 
| 
822f3a83ff57
in, out and clone tests pass for ssh repositories. Infrastructure to decouple HgRemoteRepository from specific Connector implementation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
697diff
changeset | 69 } catch (MalformedURLException ex) { | 
| 
822f3a83ff57
in, out and clone tests pass for ssh repositories. Infrastructure to decouple HgRemoteRepository from specific Connector implementation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
697diff
changeset | 70 throw new HgRemoteConnectionException("Bad URL", ex); | 
| 
822f3a83ff57
in, out and clone tests pass for ssh repositories. Infrastructure to decouple HgRemoteRepository from specific Connector implementation
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
697diff
changeset | 71 } | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 72 authMediator = new HttpAuthMethod(sessionCtx, url); | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 73 authenticateClient(); | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 74 } | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 75 | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 76 private void authenticateClient() throws HgAuthFailedException { | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 77 String userInfo = url.getUserInfo(); | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 78 if (userInfo != null) { | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 79 try { | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 80 authMediator.tryWithUserInfo(userInfo); | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 81 } catch (HgAuthFailedException ex) { | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 82 // FALL THROUGH to try Authenticator | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 83 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 84 } | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 85 HgAuthenticator auth = sessionCtx.getAuthenticator(rd); | 
| 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 86 auth.authenticate(rd, authMediator); | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 87 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 88 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 89 public void disconnect() throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 90 // TODO Auto-generated method stub | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 91 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 92 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 93 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 94 public void sessionBegin() throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 95 // TODO Auto-generated method stub | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 96 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 97 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 98 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 99 public void sessionEnd() throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 100 if (conn != null) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 101 conn.disconnect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 102 conn = null; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 103 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 104 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 105 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 106 public String getCapabilities() throws HgRemoteConnectionException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 107 // say hello to server, check response | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 108 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 109 URL u = new URL(url, url.getPath() + "?cmd=hello"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 110 HttpURLConnection c = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 111 c.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 112 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 113 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 114 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 115 BufferedReader r = new BufferedReader(new InputStreamReader(c.getInputStream(), "US-ASCII")); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 116 String line = r.readLine(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 117 c.disconnect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 118 final String capsPrefix = CMD_CAPABILITIES + ':'; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 119 if (line != null && line.startsWith(capsPrefix)) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 120 return line.substring(capsPrefix.length()).trim(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 121 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 122 // for whatever reason, some servers do not respond to hello command (e.g. svnkit) | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 123 // but respond to 'capabilities' instead. Try it. | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 124 // TODO [post-1.0] tests needed | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 125 u = new URL(url, url.getPath() + "?cmd=capabilities"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 126 c = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 127 c.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 128 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 129 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 130 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 131 r = new BufferedReader(new InputStreamReader(c.getInputStream(), "US-ASCII")); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 132 line = r.readLine(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 133 c.disconnect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 134 if (line != null && line.startsWith(capsPrefix)) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 135 return line.substring(capsPrefix.length()).trim(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 136 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 137 return new String(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 138 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 139 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_HELLO).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 140 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 141 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_HELLO).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 142 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 143 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 144 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 145 public InputStream heads() throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 146 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 147 URL u = new URL(url, url.getPath() + "?cmd=heads"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 148 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 149 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 150 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 151 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 152 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 153 return conn.getInputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 154 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 155 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_HEADS).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 156 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 157 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_HEADS).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 158 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 159 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 160 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 161 public InputStream between(Collection<Range> ranges) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 162 StringBuilder sb = new StringBuilder(20 + ranges.size() * 82); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 163 sb.append("pairs="); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 164 for (Range r : ranges) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 165 r.append(sb); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 166 sb.append('+'); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 167 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 168 if (sb.charAt(sb.length() - 1) == '+') { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 169 // strip last space | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 170 sb.setLength(sb.length() - 1); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 171 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 172 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 173 boolean usePOST = ranges.size() > 3; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 174 URL u = new URL(url, url.getPath() + "?cmd=between" + (usePOST ? "" : '&' + sb.toString())); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 175 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 176 if (usePOST) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 177 conn.setRequestMethod("POST"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 178 conn.setRequestProperty("Content-Length", String.valueOf(sb.length()/*nodeids are ASCII, bytes == characters */)); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 179 conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 180 conn.setDoOutput(true); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 181 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 182 OutputStream os = conn.getOutputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 183 os.write(sb.toString().getBytes()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 184 os.flush(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 185 os.close(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 186 } else { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 187 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 188 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 189 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 190 System.out.printf("%d ranges, method:%s \n", ranges.size(), conn.getRequestMethod()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 191 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 192 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 193 return conn.getInputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 194 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 195 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_BETWEEN).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 196 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 197 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_BETWEEN).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 198 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 199 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 200 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 201 public InputStream branches(List<Nodeid> nodes) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 202 StringBuilder sb = appendNodeidListArgument("nodes", nodes, null); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 203 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 204 URL u = new URL(url, url.getPath() + "?cmd=branches&" + sb.toString()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 205 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 206 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 207 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 208 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 209 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 210 return conn.getInputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 211 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 212 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_BRANCHES).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 213 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 214 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_BRANCHES).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 215 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 216 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 217 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 218 public InputStream changegroup(List<Nodeid> roots) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 219 StringBuilder sb = appendNodeidListArgument("roots", roots, null); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 220 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 221 URL u = new URL(url, url.getPath() + "?cmd=changegroup&" + sb.toString()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 222 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 223 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 224 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 225 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 226 } | 
| 697 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 227 InputStream cg = conn.getInputStream(); | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 228 InputStream prefix = new ByteArrayInputStream("HG10GZ".getBytes()); // didn't see any other that zip | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 229 return new SequenceInputStream(prefix, cg); | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 230 } catch (MalformedURLException ex) { | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 231 // although there's little user can do about this issue (URLs are constructed by our code) | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 232 // it's still better to throw it as checked exception than RT because url is likely malformed due to parameters | 
| 
24f4efedc9d5
Respect the fact ssh and http protocols use different compression approach to sent changegroup data
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
687diff
changeset | 233 // and this may help user to understand the cause (and e.g. change them) | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 234 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand("changegroup").setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 235 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 236 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand("changegroup").setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 237 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 238 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 239 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 240 // | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 241 // FIXME consider HttpURLConnection#setChunkedStreamingMode() as described at | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 242 // http://stackoverflow.com/questions/2793150/how-to-use-java-net-urlconnection-to-fire-and-handle-http-requests | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 243 public OutputStream unbundle(long outputLen, List<Nodeid> remoteHeads) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 244 StringBuilder sb = appendNodeidListArgument(CMD_HEADS, remoteHeads, null); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 245 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 246 final URL u = new URL(url, url.getPath() + "?cmd=unbundle&" + sb.toString()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 247 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 248 conn.setRequestMethod("POST"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 249 conn.setDoOutput(true); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 250 conn.setRequestProperty("Content-Type", "application/mercurial-0.1"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 251 conn.setRequestProperty("Content-Length", String.valueOf(outputLen)); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 252 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 253 return new FilterOutputStream(conn.getOutputStream()) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 254 public void close() throws IOException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 255 super.close(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 256 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 257 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 258 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 259 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 260 checkResponseOk("Push", CMD_UNBUNDLE); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 261 } catch (HgRemoteConnectionException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 262 IOException e = new IOException(ex.getMessage()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 263 // not e.initCause(ex); as HgRemoteConnectionException is just a message holder | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 264 e.setStackTrace(ex.getStackTrace()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 265 throw e; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 266 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 267 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 268 }; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 269 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 270 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_UNBUNDLE).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 271 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 272 // FIXME consume c.getErrorStream as http://docs.oracle.com/javase/6/docs/technotes/guides/net/http-keepalive.html suggests | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 273 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_UNBUNDLE).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 274 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 275 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 276 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 277 public InputStream pushkey(String opName, String namespace, String key, String oldValue, String newValue) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 278 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 279 final String p = String.format("%s?cmd=pushkey&namespace=%s&key=%s&old=%s&new=%s", url.getPath(), namespace, key, oldValue, newValue); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 280 URL u = new URL(url, p); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 281 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 282 conn.setRequestMethod("POST"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 283 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 284 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 285 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 286 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 287 checkResponseOk(opName, "pushkey"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 288 return conn.getInputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 289 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 290 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand("pushkey").setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 291 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 292 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand("pushkey").setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 293 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 294 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 295 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 296 public InputStream listkeys(String namespace, String actionName) throws HgRemoteConnectionException, HgRuntimeException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 297 try { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 298 URL u = new URL(url, url.getPath() + "?cmd=listkeys&namespace=" + namespace); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 299 conn = setupConnection(u.openConnection()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 300 conn.connect(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 301 if (debug) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 302 dumpResponseHeader(u); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 303 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 304 checkResponseOk(actionName, "listkeys"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 305 return conn.getInputStream(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 306 } catch (MalformedURLException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 307 throw new HgRemoteConnectionException("Bad URL", ex).setRemoteCommand(CMD_LISTKEYS).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 308 } catch (IOException ex) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 309 throw new HgRemoteConnectionException("Communication failure", ex).setRemoteCommand(CMD_LISTKEYS).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 310 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 311 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 312 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 313 private void checkResponseOk(String opName, String remoteCmd) throws HgRemoteConnectionException, IOException { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 314 if (conn.getResponseCode() != 200) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 315 String m = conn.getResponseMessage() == null ? "unknown reason" : conn.getResponseMessage(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 316 String em = String.format("%s failed: %s (HTTP error:%d)", opName, m, conn.getResponseCode()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 317 throw new HgRemoteConnectionException(em).setRemoteCommand(remoteCmd).setServerInfo(getServerLocation()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 318 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 319 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 320 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 321 private HttpURLConnection setupConnection(URLConnection urlConnection) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 322 urlConnection.setRequestProperty("User-Agent", "hg4j/1.0.0"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 323 urlConnection.addRequestProperty("Accept", "application/mercurial-0.1"); | 
| 699 
a483b2b68a2e
Provisional APIs and respective implementation for http, https and ssh remote repositories
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: 
698diff
changeset | 324 return authMediator.setupConnection((HttpURLConnection) urlConnection); | 
| 687 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 325 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 326 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 327 private StringBuilder appendNodeidListArgument(String key, List<Nodeid> values, StringBuilder sb) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 328 if (sb == null) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 329 sb = new StringBuilder(20 + values.size() * 41); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 330 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 331 sb.append(key); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 332 sb.append('='); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 333 for (Nodeid n : values) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 334 sb.append(n.toString()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 335 sb.append('+'); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 336 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 337 if (sb.charAt(sb.length() - 1) == '+') { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 338 // strip last space | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 339 sb.setLength(sb.length() - 1); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 340 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 341 return sb; | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 342 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 343 | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 344 private void dumpResponseHeader(URL u) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 345 System.out.printf("Query (%d bytes):%s\n", u.getQuery().length(), u.getQuery()); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 346 System.out.println("Response headers:"); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 347 final Map<String, List<String>> headerFields = conn.getHeaderFields(); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 348 for (String s : headerFields.keySet()) { | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 349 System.out.printf("%s: %s\n", s, conn.getHeaderField(s)); | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 350 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 351 } | 
| 
9859fcea475d
Towards ssh remote repositories: refactor HgRemoteRepository - move http related code to HttpConnector
 Artem Tikhomirov <tikhomirov.artem@gmail.com> parents: diff
changeset | 352 } | 
