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.slf4j.Logger; 036import org.slf4j.LoggerFactory; 037 038/** 039 */ 040@Named 041public class DefaultRepositoryEventDispatcher 042 implements RepositoryEventDispatcher, Service 043{ 044 045 private static final Logger LOGGER = LoggerFactory.getLogger( DefaultRepositoryEventDispatcher.class ); 046 047 private Collection<RepositoryListener> listeners = new ArrayList<>(); 048 049 public DefaultRepositoryEventDispatcher() 050 { 051 // enables no-arg constructor 052 } 053 054 @Inject 055 DefaultRepositoryEventDispatcher( Set<RepositoryListener> listeners ) 056 { 057 setRepositoryListeners( listeners ); 058 } 059 060 public DefaultRepositoryEventDispatcher addRepositoryListener( RepositoryListener listener ) 061 { 062 this.listeners.add( requireNonNull( listener, "repository listener cannot be null" ) ); 063 return this; 064 } 065 066 public DefaultRepositoryEventDispatcher setRepositoryListeners( Collection<RepositoryListener> listeners ) 067 { 068 if ( listeners == null ) 069 { 070 this.listeners = new ArrayList<>(); 071 } 072 else 073 { 074 this.listeners = listeners; 075 } 076 return this; 077 } 078 079 public void initService( ServiceLocator locator ) 080 { 081 setRepositoryListeners( locator.getServices( RepositoryListener.class ) ); 082 } 083 084 public void dispatch( RepositoryEvent event ) 085 { 086 if ( !listeners.isEmpty() ) 087 { 088 for ( RepositoryListener listener : listeners ) 089 { 090 dispatch( event, listener ); 091 } 092 } 093 094 RepositoryListener listener = event.getSession().getRepositoryListener(); 095 096 if ( listener != null ) 097 { 098 dispatch( event, listener ); 099 } 100 } 101 102 private void dispatch( RepositoryEvent event, RepositoryListener listener ) 103 { 104 try 105 { 106 switch ( event.getType() ) 107 { 108 case ARTIFACT_DEPLOYED: 109 listener.artifactDeployed( event ); 110 break; 111 case ARTIFACT_DEPLOYING: 112 listener.artifactDeploying( event ); 113 break; 114 case ARTIFACT_DESCRIPTOR_INVALID: 115 listener.artifactDescriptorInvalid( event ); 116 break; 117 case ARTIFACT_DESCRIPTOR_MISSING: 118 listener.artifactDescriptorMissing( event ); 119 break; 120 case ARTIFACT_DOWNLOADED: 121 listener.artifactDownloaded( event ); 122 break; 123 case ARTIFACT_DOWNLOADING: 124 listener.artifactDownloading( event ); 125 break; 126 case ARTIFACT_INSTALLED: 127 listener.artifactInstalled( event ); 128 break; 129 case ARTIFACT_INSTALLING: 130 listener.artifactInstalling( event ); 131 break; 132 case ARTIFACT_RESOLVED: 133 listener.artifactResolved( event ); 134 break; 135 case ARTIFACT_RESOLVING: 136 listener.artifactResolving( event ); 137 break; 138 case METADATA_DEPLOYED: 139 listener.metadataDeployed( event ); 140 break; 141 case METADATA_DEPLOYING: 142 listener.metadataDeploying( event ); 143 break; 144 case METADATA_DOWNLOADED: 145 listener.metadataDownloaded( event ); 146 break; 147 case METADATA_DOWNLOADING: 148 listener.metadataDownloading( event ); 149 break; 150 case METADATA_INSTALLED: 151 listener.metadataInstalled( event ); 152 break; 153 case METADATA_INSTALLING: 154 listener.metadataInstalling( event ); 155 break; 156 case METADATA_INVALID: 157 listener.metadataInvalid( event ); 158 break; 159 case METADATA_RESOLVED: 160 listener.metadataResolved( event ); 161 break; 162 case METADATA_RESOLVING: 163 listener.metadataResolving( event ); 164 break; 165 default: 166 throw new IllegalStateException( "unknown repository event type " + event.getType() ); 167 } 168 } 169 catch ( Exception | LinkageError e ) 170 { 171 logError( e, listener ); 172 } 173 } 174 175 private void logError( Throwable e, Object listener ) 176 { 177 LOGGER.warn( "Failed to dispatch repository event to {}", listener.getClass().getCanonicalName(), e ); 178 } 179 180}