001package org.eclipse.aether.internal.impl; 002 003/* 004 * Licensed to the Apache Software Foundation (ASF) under one 005 * or more contributor license agreements. See the NOTICE file 006 * distributed with this work for additional information 007 * regarding copyright ownership. The ASF licenses this file 008 * to you under the Apache License, Version 2.0 (the 009 * "License"); you may not use this file except in compliance 010 * with the License. You may obtain a copy of the License at 011 * 012 * http://www.apache.org/licenses/LICENSE-2.0 013 * 014 * Unless required by applicable law or agreed to in writing, 015 * software distributed under the License is distributed on an 016 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 017 * KIND, either express or implied. See the License for the 018 * specific language governing permissions and limitations 019 * under the License. 020 */ 021 022import java.util.ArrayList; 023import java.util.Collection; 024import static java.util.Objects.requireNonNull; 025import java.util.Set; 026 027import javax.inject.Inject; 028import javax.inject.Named; 029 030import org.eclipse.aether.RepositoryEvent; 031import org.eclipse.aether.RepositoryListener; 032import org.eclipse.aether.impl.RepositoryEventDispatcher; 033import org.eclipse.aether.spi.locator.Service; 034import org.eclipse.aether.spi.locator.ServiceLocator; 035import org.eclipse.aether.spi.log.Logger; 036import org.eclipse.aether.spi.log.LoggerFactory; 037import org.eclipse.aether.spi.log.NullLoggerFactory; 038 039/** 040 */ 041@Named 042public class DefaultRepositoryEventDispatcher 043 implements RepositoryEventDispatcher, Service 044{ 045 046 private Logger logger = NullLoggerFactory.LOGGER; 047 048 private Collection<RepositoryListener> listeners = new ArrayList<RepositoryListener>(); 049 050 public DefaultRepositoryEventDispatcher() 051 { 052 // enables no-arg constructor 053 } 054 055 @Inject 056 DefaultRepositoryEventDispatcher( Set<RepositoryListener> listeners, LoggerFactory loggerFactory ) 057 { 058 setRepositoryListeners( listeners ); 059 setLoggerFactory( loggerFactory ); 060 } 061 062 public DefaultRepositoryEventDispatcher setLoggerFactory( LoggerFactory loggerFactory ) 063 { 064 this.logger = NullLoggerFactory.getSafeLogger( loggerFactory, getClass() ); 065 return this; 066 } 067 068 public DefaultRepositoryEventDispatcher addRepositoryListener( RepositoryListener listener ) 069 { 070 this.listeners.add( requireNonNull( listener, "repository listener cannot be null" ) ); 071 return this; 072 } 073 074 public DefaultRepositoryEventDispatcher setRepositoryListeners( Collection<RepositoryListener> listeners ) 075 { 076 if ( listeners == null ) 077 { 078 this.listeners = new ArrayList<RepositoryListener>(); 079 } 080 else 081 { 082 this.listeners = listeners; 083 } 084 return this; 085 } 086 087 public void initService( ServiceLocator locator ) 088 { 089 setLoggerFactory( locator.getService( LoggerFactory.class ) ); 090 setRepositoryListeners( locator.getServices( RepositoryListener.class ) ); 091 } 092 093 public void dispatch( RepositoryEvent event ) 094 { 095 if ( !listeners.isEmpty() ) 096 { 097 for ( RepositoryListener listener : listeners ) 098 { 099 dispatch( event, listener ); 100 } 101 } 102 103 RepositoryListener listener = event.getSession().getRepositoryListener(); 104 105 if ( listener != null ) 106 { 107 dispatch( event, listener ); 108 } 109 } 110 111 private void dispatch( RepositoryEvent event, RepositoryListener listener ) 112 { 113 try 114 { 115 switch ( event.getType() ) 116 { 117 case ARTIFACT_DEPLOYED: 118 listener.artifactDeployed( event ); 119 break; 120 case ARTIFACT_DEPLOYING: 121 listener.artifactDeploying( event ); 122 break; 123 case ARTIFACT_DESCRIPTOR_INVALID: 124 listener.artifactDescriptorInvalid( event ); 125 break; 126 case ARTIFACT_DESCRIPTOR_MISSING: 127 listener.artifactDescriptorMissing( event ); 128 break; 129 case ARTIFACT_DOWNLOADED: 130 listener.artifactDownloaded( event ); 131 break; 132 case ARTIFACT_DOWNLOADING: 133 listener.artifactDownloading( event ); 134 break; 135 case ARTIFACT_INSTALLED: 136 listener.artifactInstalled( event ); 137 break; 138 case ARTIFACT_INSTALLING: 139 listener.artifactInstalling( event ); 140 break; 141 case ARTIFACT_RESOLVED: 142 listener.artifactResolved( event ); 143 break; 144 case ARTIFACT_RESOLVING: 145 listener.artifactResolving( event ); 146 break; 147 case METADATA_DEPLOYED: 148 listener.metadataDeployed( event ); 149 break; 150 case METADATA_DEPLOYING: 151 listener.metadataDeploying( event ); 152 break; 153 case METADATA_DOWNLOADED: 154 listener.metadataDownloaded( event ); 155 break; 156 case METADATA_DOWNLOADING: 157 listener.metadataDownloading( event ); 158 break; 159 case METADATA_INSTALLED: 160 listener.metadataInstalled( event ); 161 break; 162 case METADATA_INSTALLING: 163 listener.metadataInstalling( event ); 164 break; 165 case METADATA_INVALID: 166 listener.metadataInvalid( event ); 167 break; 168 case METADATA_RESOLVED: 169 listener.metadataResolved( event ); 170 break; 171 case METADATA_RESOLVING: 172 listener.metadataResolving( event ); 173 break; 174 default: 175 throw new IllegalStateException( "unknown repository event type " + event.getType() ); 176 } 177 } 178 catch ( Exception e ) 179 { 180 logError( e, listener ); 181 } 182 catch ( LinkageError e ) 183 { 184 logError( e, listener ); 185 } 186 } 187 188 private void logError( Throwable e, Object listener ) 189 { 190 String msg = 191 "Failed to dispatch repository event to " + listener.getClass().getCanonicalName() + ": " + e.getMessage(); 192 193 if ( logger.isDebugEnabled() ) 194 { 195 logger.warn( msg, e ); 196 } 197 else 198 { 199 logger.warn( msg ); 200 } 201 } 202 203}