class AetherRepositoryConnector
extends java.lang.Object
implements org.eclipse.aether.spi.connector.RepositoryConnector
Modifier and Type | Class and Description |
---|---|
(package private) static interface |
AetherRepositoryConnector.ExceptionWrapper<T> |
(package private) class |
AetherRepositoryConnector.FileSource |
(package private) class |
AetherRepositoryConnector.GetTask<T extends org.eclipse.aether.spi.connector.Transfer> |
private class |
AetherRepositoryConnector.LatchGuard |
(package private) class |
AetherRepositoryConnector.PutTask<T extends org.eclipse.aether.spi.connector.Transfer> |
Modifier and Type | Field and Description |
---|---|
private AetherClient |
aetherClient |
private static AetherRepositoryConnector.ExceptionWrapper<org.eclipse.aether.spi.connector.ArtifactTransfer> |
ARTIFACT |
private static java.util.Map<java.lang.String,java.lang.String> |
checksumAlgos |
private org.eclipse.aether.spi.io.FileProcessor |
fileProcessor |
private org.eclipse.aether.spi.connector.layout.RepositoryLayout |
layout |
private org.slf4j.Logger |
logger |
private static AetherRepositoryConnector.ExceptionWrapper<org.eclipse.aether.spi.connector.MetadataTransfer> |
METADATA |
private org.eclipse.aether.repository.RemoteRepository |
repository |
private org.eclipse.aether.RepositorySystemSession |
session |
Constructor and Description |
---|
AetherRepositoryConnector(org.eclipse.aether.repository.RemoteRepository repository,
org.eclipse.aether.RepositorySystemSession session,
org.eclipse.aether.spi.io.FileProcessor fileProcessor) |
AetherRepositoryConnector(org.eclipse.aether.repository.RemoteRepository repository,
org.eclipse.aether.RepositorySystemSession session,
org.eclipse.aether.spi.io.FileProcessor fileProcessor,
javax.net.ssl.SSLSocketFactory sslSocketFactory) |
Modifier and Type | Method and Description |
---|---|
private void |
await(java.util.concurrent.CountDownLatch latch) |
private java.lang.String |
buildUrl(java.lang.String path)
Builds a complete URL string from the repository URL and the relative path passed.
|
void |
close() |
void |
get(java.util.Collection<? extends org.eclipse.aether.spi.connector.ArtifactDownload> artifactDownloads,
java.util.Collection<? extends org.eclipse.aether.spi.connector.MetadataDownload> metadataDownloads)
Download artifacts and metadata.
|
private java.io.File |
getTmpFile(java.lang.String path) |
private void |
handleResponseCode(java.lang.String url,
int responseCode,
java.lang.String responseMsg) |
private static OkHttpAetherClient |
newAetherClient(org.eclipse.aether.repository.RemoteRepository repository,
org.eclipse.aether.RepositorySystemSession session,
javax.net.ssl.SSLSocketFactory sslSocketFactory) |
private org.eclipse.aether.transfer.TransferEvent.Builder |
newEvent(org.eclipse.aether.transfer.TransferResource resource,
java.lang.Exception e,
org.eclipse.aether.transfer.TransferEvent.RequestType requestType,
org.eclipse.aether.transfer.TransferEvent.EventType eventType) |
private org.eclipse.aether.transfer.TransferEvent.Builder |
newEvent(org.eclipse.aether.transfer.TransferResource resource,
org.eclipse.aether.transfer.TransferEvent.RequestType requestType,
org.eclipse.aether.transfer.TransferEvent.EventType eventType) |
void |
put(java.util.Collection<? extends org.eclipse.aether.spi.connector.ArtifactUpload> artifactUploads,
java.util.Collection<? extends org.eclipse.aether.spi.connector.MetadataUpload> metadataUploads)
Use the async http client library to upload artifacts and metadata.
|
private <T> java.util.Collection<T> |
safe(java.util.Collection<T> items) |
protected void |
transferCorrupted(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
protected void |
transferFailed(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
protected void |
transferInitiated(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
protected void |
transferProgressed(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
protected void |
transferStarted(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
protected void |
transferSucceeded(org.eclipse.aether.spi.connector.Transfer transfer,
org.eclipse.aether.transfer.TransferEvent event) |
private void |
uploadChecksum(java.io.File file,
java.lang.String uri,
java.lang.String algo,
java.lang.Object checksum) |
private static final java.util.Map<java.lang.String,java.lang.String> checksumAlgos
private final org.slf4j.Logger logger
private final org.eclipse.aether.spi.connector.layout.RepositoryLayout layout
private final org.eclipse.aether.RepositorySystemSession session
private final org.eclipse.aether.spi.io.FileProcessor fileProcessor
private final org.eclipse.aether.repository.RemoteRepository repository
private final AetherClient aetherClient
private static final AetherRepositoryConnector.ExceptionWrapper<org.eclipse.aether.spi.connector.MetadataTransfer> METADATA
private static final AetherRepositoryConnector.ExceptionWrapper<org.eclipse.aether.spi.connector.ArtifactTransfer> ARTIFACT
public AetherRepositoryConnector(org.eclipse.aether.repository.RemoteRepository repository, org.eclipse.aether.RepositorySystemSession session, org.eclipse.aether.spi.io.FileProcessor fileProcessor) throws org.eclipse.aether.transfer.NoRepositoryConnectorException
org.eclipse.aether.transfer.NoRepositoryConnectorException
public AetherRepositoryConnector(org.eclipse.aether.repository.RemoteRepository repository, org.eclipse.aether.RepositorySystemSession session, org.eclipse.aether.spi.io.FileProcessor fileProcessor, javax.net.ssl.SSLSocketFactory sslSocketFactory) throws org.eclipse.aether.transfer.NoRepositoryConnectorException
org.eclipse.aether.transfer.NoRepositoryConnectorException
private static OkHttpAetherClient newAetherClient(org.eclipse.aether.repository.RemoteRepository repository, org.eclipse.aether.RepositorySystemSession session, javax.net.ssl.SSLSocketFactory sslSocketFactory)
public void get(java.util.Collection<? extends org.eclipse.aether.spi.connector.ArtifactDownload> artifactDownloads, java.util.Collection<? extends org.eclipse.aether.spi.connector.MetadataDownload> metadataDownloads)
get
in interface org.eclipse.aether.spi.connector.RepositoryConnector
artifactDownloads
- The artifact downloads to perform, may be null
or empty.metadataDownloads
- The metadata downloads to perform, may be null
or empty.public void put(java.util.Collection<? extends org.eclipse.aether.spi.connector.ArtifactUpload> artifactUploads, java.util.Collection<? extends org.eclipse.aether.spi.connector.MetadataUpload> metadataUploads)
put
in interface org.eclipse.aether.spi.connector.RepositoryConnector
artifactUploads
- The artifact uploads to perform, may be null
or empty.metadataUploads
- The metadata uploads to perform, may be null
or empty.private void await(java.util.concurrent.CountDownLatch latch)
private void handleResponseCode(java.lang.String url, int responseCode, java.lang.String responseMsg) throws AuthorizationException, ResourceDoesNotExistException, TransferException
private org.eclipse.aether.transfer.TransferEvent.Builder newEvent(org.eclipse.aether.transfer.TransferResource resource, org.eclipse.aether.transfer.TransferEvent.RequestType requestType, org.eclipse.aether.transfer.TransferEvent.EventType eventType)
private org.eclipse.aether.transfer.TransferEvent.Builder newEvent(org.eclipse.aether.transfer.TransferResource resource, java.lang.Exception e, org.eclipse.aether.transfer.TransferEvent.RequestType requestType, org.eclipse.aether.transfer.TransferEvent.EventType eventType)
private void uploadChecksum(java.io.File file, java.lang.String uri, java.lang.String algo, java.lang.Object checksum) throws java.io.IOException
java.io.IOException
private java.lang.String buildUrl(java.lang.String path)
path
- the relative pathpublic void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface org.eclipse.aether.spi.connector.RepositoryConnector
private <T> java.util.Collection<T> safe(java.util.Collection<T> items)
private java.io.File getTmpFile(java.lang.String path)
protected void transferInitiated(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event) throws org.eclipse.aether.transfer.TransferCancelledException
org.eclipse.aether.transfer.TransferCancelledException
protected void transferSucceeded(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event)
protected void transferFailed(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event)
protected void transferStarted(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event) throws org.eclipse.aether.transfer.TransferCancelledException
org.eclipse.aether.transfer.TransferCancelledException
protected void transferProgressed(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event) throws org.eclipse.aether.transfer.TransferCancelledException
org.eclipse.aether.transfer.TransferCancelledException
protected void transferCorrupted(org.eclipse.aether.spi.connector.Transfer transfer, org.eclipse.aether.transfer.TransferEvent event) throws org.eclipse.aether.transfer.TransferCancelledException
org.eclipse.aether.transfer.TransferCancelledException