-
Notifications
You must be signed in to change notification settings - Fork 41
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
🚑 Custom ConnectionFactory for jgit
- Loading branch information
Showing
3 changed files
with
233 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
165 changes: 165 additions & 0 deletions
165
fuse-products/src/main/java/software/tnb/product/git/support/GitHttpConnection.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,165 @@ | ||
| package software.tnb.product.git.support; | ||
|
|
||
| import software.tnb.common.utils.HTTPUtils; | ||
|
|
||
| import org.eclipse.jgit.transport.http.HttpConnection; | ||
|
|
||
| import javax.net.ssl.HostnameVerifier; | ||
| import javax.net.ssl.HttpsURLConnection; | ||
| import javax.net.ssl.KeyManager; | ||
| import javax.net.ssl.TrustManager; | ||
|
|
||
| import java.io.IOException; | ||
| import java.io.InputStream; | ||
| import java.io.OutputStream; | ||
| import java.net.HttpURLConnection; | ||
| import java.net.ProtocolException; | ||
| import java.net.Proxy; | ||
| import java.net.URL; | ||
| import java.security.KeyManagementException; | ||
| import java.security.NoSuchAlgorithmException; | ||
| import java.security.SecureRandom; | ||
| import java.util.List; | ||
| import java.util.Map; | ||
| import java.util.Optional; | ||
|
|
||
| public class GitHttpConnection implements HttpConnection { | ||
| HttpURLConnection delegate; | ||
|
|
||
| public GitHttpConnection(URL url) throws IOException { | ||
| delegate = (HttpURLConnection) url.openConnection(); | ||
| } | ||
|
|
||
| public GitHttpConnection(URL url, Proxy proxy) throws IOException { | ||
| delegate = (HttpURLConnection) url.openConnection(proxy); | ||
| } | ||
|
|
||
| @Override | ||
| public int getResponseCode() throws IOException { | ||
| return delegate.getResponseCode(); | ||
| } | ||
|
|
||
| @Override | ||
| public URL getURL() { | ||
| return delegate.getURL(); | ||
| } | ||
|
|
||
| @Override | ||
| public String getResponseMessage() throws IOException { | ||
| return delegate.getResponseMessage(); | ||
| } | ||
|
|
||
| @Override | ||
| public Map<String, List<String>> getHeaderFields() { | ||
| return delegate.getHeaderFields(); | ||
| } | ||
|
|
||
| @Override | ||
| public void setRequestProperty(String key, String value) { | ||
| delegate.setRequestProperty(key, value); | ||
| } | ||
|
|
||
| @Override | ||
| public void setRequestMethod(String method) throws ProtocolException { | ||
| delegate.setRequestMethod(method); | ||
| } | ||
|
|
||
| @Override | ||
| public void setUseCaches(boolean usecaches) { | ||
| delegate.setUseCaches(usecaches); | ||
| } | ||
|
|
||
| @Override | ||
| public void setConnectTimeout(int timeout) { | ||
| delegate.setConnectTimeout(timeout); | ||
| } | ||
|
|
||
| @Override | ||
| public void setReadTimeout(int timeout) { | ||
| delegate.setReadTimeout(timeout); | ||
| } | ||
|
|
||
| @Override | ||
| public String getContentType() { | ||
| return delegate.getContentType(); | ||
| } | ||
|
|
||
| @Override | ||
| public InputStream getInputStream() throws IOException { | ||
| return delegate.getInputStream(); | ||
| } | ||
|
|
||
| @Override | ||
| public String getHeaderField(String name) { | ||
| return delegate.getHeaderField(name); | ||
| } | ||
|
|
||
| @Override | ||
| public List<String> getHeaderFields(String name) { | ||
| return delegate.getHeaderFields().get(name); | ||
| } | ||
|
|
||
| @Override | ||
| public int getContentLength() { | ||
| return delegate.getContentLength(); | ||
| } | ||
|
|
||
| @Override | ||
| public void setInstanceFollowRedirects(boolean followRedirects) { | ||
| delegate.setInstanceFollowRedirects(followRedirects); | ||
| } | ||
|
|
||
| @Override | ||
| public void setDoOutput(boolean dooutput) { | ||
| delegate.setDoOutput(dooutput); | ||
| } | ||
|
|
||
| @Override | ||
| public void setFixedLengthStreamingMode(int contentLength) { | ||
| delegate.setFixedLengthStreamingMode(contentLength); | ||
| } | ||
|
|
||
| @Override | ||
| public OutputStream getOutputStream() throws IOException { | ||
| return delegate.getOutputStream(); | ||
| } | ||
|
|
||
| @Override | ||
| public void setChunkedStreamingMode(int chunklen) { | ||
| delegate.setChunkedStreamingMode(chunklen); | ||
| } | ||
|
|
||
| @Override | ||
| public String getRequestMethod() { | ||
| return delegate.getRequestMethod(); | ||
| } | ||
|
|
||
| @Override | ||
| public boolean usingProxy() { | ||
| return delegate.usingProxy(); | ||
| } | ||
|
|
||
| @Override | ||
| public void connect() throws IOException { | ||
| delegate.connect(); | ||
| } | ||
|
|
||
| @Override | ||
| public void configure(KeyManager[] km, TrustManager[] tm, SecureRandom random) throws NoSuchAlgorithmException, KeyManagementException { | ||
| //the configuration is managed by HTTPUtils | ||
| Optional.of(delegate) | ||
| .filter(d -> d instanceof HttpsURLConnection) | ||
| .map(d -> (HttpsURLConnection) d) | ||
| .orElseThrow(() -> new RuntimeException("unable to apply ssl context")) | ||
| .setSSLSocketFactory(HTTPUtils.getSslContext().getSocketFactory()); | ||
| } | ||
|
|
||
| @Override | ||
| public void setHostnameVerifier(HostnameVerifier hostnameverifier) throws NoSuchAlgorithmException, KeyManagementException { | ||
| Optional.of(delegate) | ||
| .filter(d -> d instanceof HttpsURLConnection) | ||
| .map(d -> (HttpsURLConnection) d) | ||
| .orElseThrow(() -> new RuntimeException("unable to apply hostname verifier")) | ||
| .setHostnameVerifier(hostnameverifier); | ||
| } | ||
| } |
50 changes: 50 additions & 0 deletions
50
fuse-products/src/main/java/software/tnb/product/git/support/GitHttpConnectionFactory.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,50 @@ | ||
| package software.tnb.product.git.support; | ||
|
|
||
| import org.eclipse.jgit.transport.http.HttpConnection; | ||
| import org.eclipse.jgit.transport.http.HttpConnectionFactory2; | ||
|
|
||
| import javax.net.ssl.SSLContext; | ||
| import javax.net.ssl.SSLSocketFactory; | ||
|
|
||
| import java.io.IOException; | ||
| import java.net.Proxy; | ||
| import java.net.URL; | ||
|
|
||
| public class GitHttpConnectionFactory implements HttpConnectionFactory2 { | ||
| @Override | ||
| public HttpConnection create(URL url) throws IOException { | ||
| return new GitHttpConnection(url); | ||
| } | ||
|
|
||
| @Override | ||
| public HttpConnection create(URL url, Proxy proxy) | ||
| throws IOException { | ||
| return new GitHttpConnection(url, proxy); | ||
| } | ||
|
|
||
| @Override | ||
| public GitSession newSession() { | ||
| return new GitHttpConnectionFactory.JdkConnectionSession(); | ||
| } | ||
|
|
||
| private static class JdkConnectionSession implements GitSession { | ||
|
|
||
| private SSLContext securityContext; | ||
|
|
||
| private SSLSocketFactory socketFactory; | ||
|
|
||
| @Override | ||
| public GitHttpConnection configure(HttpConnection connection, boolean sslVerify) { | ||
| if (!(connection instanceof GitHttpConnection)) { | ||
| throw new RuntimeException("connection type is not " + GitHttpConnection.class.getName()); | ||
| } | ||
| return (GitHttpConnection) connection; | ||
| } | ||
|
|
||
| @Override | ||
| public void close() { | ||
| securityContext = null; | ||
| socketFactory = null; | ||
| } | ||
| } | ||
| } |