package org.eclipse.aether.internal.impl;
import org.eclipse.aether.RepositorySystemSession;
import org.eclipse.aether.transfer.AbstractTransferListener;
import org.eclipse.aether.transfer.TransferCancelledException;
import org.eclipse.aether.transfer.TransferEvent;
import org.eclipse.aether.transfer.TransferListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
class SafeTransferListener
extends AbstractTransferListener
{
private static final Logger LOGGER = LoggerFactory.getLogger( SafeTransferListener.class );
private final TransferListener listener;
public static TransferListener wrap( RepositorySystemSession session )
{
TransferListener listener = session.getTransferListener();
if ( listener == null )
{
return null;
}
return new SafeTransferListener( listener );
}
protected SafeTransferListener( RepositorySystemSession session )
{
this( session.getTransferListener() );
}
private SafeTransferListener( TransferListener listener )
{
this.listener = listener;
}
private void logError( TransferEvent event, Throwable e )
{
LOGGER.debug( "Failed to dispatch transfer event '{}' to {}", event, listener.getClass().getCanonicalName(),
e );
}
@Override
public void transferInitiated( TransferEvent event )
throws TransferCancelledException
{
if ( listener != null )
{
try
{
listener.transferInitiated( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
@Override
public void transferStarted( TransferEvent event )
throws TransferCancelledException
{
if ( listener != null )
{
try
{
listener.transferStarted( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
@Override
public void transferProgressed( TransferEvent event )
throws TransferCancelledException
{
if ( listener != null )
{
try
{
listener.transferProgressed( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
@Override
public void transferCorrupted( TransferEvent event )
throws TransferCancelledException
{
if ( listener != null )
{
try
{
listener.transferCorrupted( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
@Override
public void transferSucceeded( TransferEvent event )
{
if ( listener != null )
{
try
{
listener.transferSucceeded( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
@Override
public void transferFailed( TransferEvent event )
{
if ( listener != null )
{
try
{
listener.transferFailed( event );
}
catch ( RuntimeException | LinkageError e )
{
logError( event, e );
}
}
}
}