Package org.eclipse.aether.transport.http

Class HttpTransporter

java.lang.Object

org.eclipse.aether.spi.connector.transport.AbstractTransporter

org.eclipse.aether.transport.http.HttpTransporter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Transporter

final class HttpTransporter
extends AbstractTransporter

A transporter for HTTP/HTTPS.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	HttpTransporter.EntityGetter
private class	HttpTransporter.PutTaskEntity

Field Summary

Fields

Modifier and Type	Field	Description
private java.net.URI	baseUri
private org.apache.http.client.HttpClient	client
private static java.util.regex.Pattern	CONTENT_RANGE_PATTERN
private java.util.Map<?,?>	headers
private static org.slf4j.Logger	LOGGER
private org.apache.http.HttpHost	proxy
private AuthenticationContext	proxyAuthContext
private AuthenticationContext	repoAuthContext
private org.apache.http.HttpHost	server
private LocalState	state

Fields inherited from interface org.eclipse.aether.spi.connector.transport.Transporter

ERROR_NOT_FOUND, ERROR_OTHER

Constructor Summary

Constructors

Constructor	Description
HttpTransporter(RemoteRepository repository, RepositorySystemSession session)

Method Summary

Modifier and Type	Method	Description
int	classify(java.lang.Throwable error)	Classifies the type of exception that has been thrown from a previous request to the transporter.
private <T extends org.apache.http.client.methods.HttpUriRequest> T	commonHeaders(T request)
private static void	configureClient(org.apache.http.params.HttpParams params, RepositorySystemSession session, RemoteRepository repository, org.apache.http.HttpHost proxy)
private <T extends org.apache.http.HttpEntityEnclosingRequest> T	entity(T request, org.apache.http.HttpEntity entity)
private void	execute(org.apache.http.client.methods.HttpUriRequest request, HttpTransporter.EntityGetter getter)
(package private) LocalState	getState()
private void	handleStatus(org.apache.http.HttpResponse response)
protected void	implClose()	Implements AbstractTransporter.close(), gets only called if the transporter has not already been closed.
protected void	implGet(GetTask task)	Implements AbstractTransporter.get(GetTask), gets only called if the transporter has not been closed.
protected void	implPeek(PeekTask task)	Implements AbstractTransporter.peek(PeekTask), gets only called if the transporter has not been closed.
protected void	implPut(PutTask task)	Implements AbstractTransporter.put(PutTask), gets only called if the transporter has not been closed.
private boolean	isPayloadPresent(org.apache.http.client.methods.HttpUriRequest request)
private boolean	isWebDav(org.apache.http.HttpResponse response)
private void	mkdirs(java.net.URI uri, SharingHttpContext context)
private void	prepare(org.apache.http.client.methods.HttpUriRequest request, SharingHttpContext context)
private java.net.URI	resolve(TransportTask task)
private <T extends org.apache.http.client.methods.HttpUriRequest> T	resume(T request, GetTask task)
private static org.apache.http.client.CredentialsProvider	toCredentialsProvider(java.lang.String host, int port, AuthenticationContext ctx)
private static org.apache.http.client.CredentialsProvider	toCredentialsProvider(org.apache.http.HttpHost server, AuthenticationContext serverAuthCtx, org.apache.http.HttpHost proxy, AuthenticationContext proxyAuthCtx)
private static org.apache.http.HttpHost	toHost(Proxy proxy)

Methods inherited from class org.eclipse.aether.spi.connector.transport.AbstractTransporter

close, get, peek, put, utilGet, utilPut

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONTENT_RANGE_PATTERN

private static final java.util.regex.Pattern CONTENT_RANGE_PATTERN

LOGGER

private static final org.slf4j.Logger LOGGER

repoAuthContext

private final AuthenticationContext repoAuthContext

proxyAuthContext

private final AuthenticationContext proxyAuthContext

baseUri

private final java.net.URI baseUri

server

private final org.apache.http.HttpHost server

proxy

private final org.apache.http.HttpHost proxy

client

private final org.apache.http.client.HttpClient client

headers

private final java.util.Map<?,?> headers

state

private final LocalState state

Constructor Detail

HttpTransporter

HttpTransporter(RemoteRepository repository,
                RepositorySystemSession session)
         throws NoTransporterException

Throws:

NoTransporterException

Method Detail

toHost

private static org.apache.http.HttpHost toHost(Proxy proxy)

configureClient

private static void configureClient(org.apache.http.params.HttpParams params,
                                    RepositorySystemSession session,
                                    RemoteRepository repository,
                                    org.apache.http.HttpHost proxy)

toCredentialsProvider

private static org.apache.http.client.CredentialsProvider toCredentialsProvider(org.apache.http.HttpHost server,
                                                                                AuthenticationContext serverAuthCtx,
                                                                                org.apache.http.HttpHost proxy,
                                                                                AuthenticationContext proxyAuthCtx)

toCredentialsProvider

private static org.apache.http.client.CredentialsProvider toCredentialsProvider(java.lang.String host,
                                                                                int port,
                                                                                AuthenticationContext ctx)

getState

LocalState getState()

resolve

private java.net.URI resolve(TransportTask task)

classify

public int classify(java.lang.Throwable error)

Description copied from interface: Transporter

Classifies the type of exception that has been thrown from a previous request to the transporter. The exception types employed by a transporter are generally unknown to its caller. Where a caller needs to distinguish between certain error cases, it employs this method to detect which error case corresponds to the exception.

Parameters:

error - The exception to classify, must not be null.

Returns:

The classification of the error, either Transporter.ERROR_NOT_FOUND or Transporter.ERROR_OTHER.

implPeek

protected void implPeek(PeekTask task)
                 throws java.lang.Exception

Description copied from class: AbstractTransporter

Implements AbstractTransporter.peek(PeekTask), gets only called if the transporter has not been closed.

Specified by:

implPeek in class AbstractTransporter

Parameters:

task - The existence check to perform, must not be null.

Throws:

java.lang.Exception - If the existence of the specified resource could not be confirmed.

implGet

protected void implGet(GetTask task)
                throws java.lang.Exception

Description copied from class: AbstractTransporter

Implements AbstractTransporter.get(GetTask), gets only called if the transporter has not been closed.

Specified by:

implGet in class AbstractTransporter

Parameters:

task - The download to perform, must not be null.

Throws:

java.lang.Exception - If the transfer failed.

implPut

protected void implPut(PutTask task)
                throws java.lang.Exception

Description copied from class: AbstractTransporter

Implements AbstractTransporter.put(PutTask), gets only called if the transporter has not been closed.

Specified by:

implPut in class AbstractTransporter

Parameters:

task - The upload to perform, must not be null.

Throws:

java.lang.Exception - If the transfer failed.

execute

private void execute(org.apache.http.client.methods.HttpUriRequest request,
                     HttpTransporter.EntityGetter getter)
              throws java.lang.Exception

Throws:

java.lang.Exception

prepare

private void prepare(org.apache.http.client.methods.HttpUriRequest request,
                     SharingHttpContext context)

isWebDav

private boolean isWebDav(org.apache.http.HttpResponse response)

mkdirs

private void mkdirs(java.net.URI uri,
                    SharingHttpContext context)

entity

private <T extends org.apache.http.HttpEntityEnclosingRequest> T entity(T request,
                                                                        org.apache.http.HttpEntity entity)

isPayloadPresent

private boolean isPayloadPresent(org.apache.http.client.methods.HttpUriRequest request)

commonHeaders

private <T extends org.apache.http.client.methods.HttpUriRequest> T commonHeaders(T request)

resume

private <T extends org.apache.http.client.methods.HttpUriRequest> T resume(T request,
                                                                           GetTask task)

handleStatus

private void handleStatus(org.apache.http.HttpResponse response)
                   throws org.apache.http.client.HttpResponseException

Throws:

org.apache.http.client.HttpResponseException

implClose

protected void implClose()

Description copied from class: AbstractTransporter

Implements AbstractTransporter.close(), gets only called if the transporter has not already been closed.

Specified by:

implClose in class AbstractTransporter