1 package org.eclipse.aether.internal.impl;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.ArrayList;
23 import java.util.Collection;
24 import static java.util.Objects.requireNonNull;
25 import java.util.Set;
26
27 import javax.inject.Inject;
28 import javax.inject.Named;
29 import javax.inject.Singleton;
30
31 import org.eclipse.aether.RepositoryEvent;
32 import org.eclipse.aether.RepositoryListener;
33 import org.eclipse.aether.impl.RepositoryEventDispatcher;
34 import org.eclipse.aether.spi.locator.Service;
35 import org.eclipse.aether.spi.locator.ServiceLocator;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
38
39
40
41 @Singleton
42 @Named
43 public class DefaultRepositoryEventDispatcher
44 implements RepositoryEventDispatcher, Service
45 {
46
47 private static final Logger LOGGER = LoggerFactory.getLogger( DefaultRepositoryEventDispatcher.class );
48
49 private Collection<RepositoryListener> listeners = new ArrayList<>();
50
51 public DefaultRepositoryEventDispatcher()
52 {
53
54 }
55
56 @Inject
57 DefaultRepositoryEventDispatcher( Set<RepositoryListener> listeners )
58 {
59 setRepositoryListeners( listeners );
60 }
61
62 public DefaultRepositoryEventDispatcher addRepositoryListener( RepositoryListener listener )
63 {
64 this.listeners.add( requireNonNull( listener, "repository listener cannot be null" ) );
65 return this;
66 }
67
68 public DefaultRepositoryEventDispatcher setRepositoryListeners( Collection<RepositoryListener> listeners )
69 {
70 if ( listeners == null )
71 {
72 this.listeners = new ArrayList<>();
73 }
74 else
75 {
76 this.listeners = listeners;
77 }
78 return this;
79 }
80
81 public void initService( ServiceLocator locator )
82 {
83 setRepositoryListeners( locator.getServices( RepositoryListener.class ) );
84 }
85
86 public void dispatch( RepositoryEvent event )
87 {
88 if ( !listeners.isEmpty() )
89 {
90 for ( RepositoryListener listener : listeners )
91 {
92 dispatch( event, listener );
93 }
94 }
95
96 RepositoryListener listener = event.getSession().getRepositoryListener();
97
98 if ( listener != null )
99 {
100 dispatch( event, listener );
101 }
102 }
103
104 private void dispatch( RepositoryEvent event, RepositoryListener listener )
105 {
106 try
107 {
108 switch ( event.getType() )
109 {
110 case ARTIFACT_DEPLOYED:
111 listener.artifactDeployed( event );
112 break;
113 case ARTIFACT_DEPLOYING:
114 listener.artifactDeploying( event );
115 break;
116 case ARTIFACT_DESCRIPTOR_INVALID:
117 listener.artifactDescriptorInvalid( event );
118 break;
119 case ARTIFACT_DESCRIPTOR_MISSING:
120 listener.artifactDescriptorMissing( event );
121 break;
122 case ARTIFACT_DOWNLOADED:
123 listener.artifactDownloaded( event );
124 break;
125 case ARTIFACT_DOWNLOADING:
126 listener.artifactDownloading( event );
127 break;
128 case ARTIFACT_INSTALLED:
129 listener.artifactInstalled( event );
130 break;
131 case ARTIFACT_INSTALLING:
132 listener.artifactInstalling( event );
133 break;
134 case ARTIFACT_RESOLVED:
135 listener.artifactResolved( event );
136 break;
137 case ARTIFACT_RESOLVING:
138 listener.artifactResolving( event );
139 break;
140 case METADATA_DEPLOYED:
141 listener.metadataDeployed( event );
142 break;
143 case METADATA_DEPLOYING:
144 listener.metadataDeploying( event );
145 break;
146 case METADATA_DOWNLOADED:
147 listener.metadataDownloaded( event );
148 break;
149 case METADATA_DOWNLOADING:
150 listener.metadataDownloading( event );
151 break;
152 case METADATA_INSTALLED:
153 listener.metadataInstalled( event );
154 break;
155 case METADATA_INSTALLING:
156 listener.metadataInstalling( event );
157 break;
158 case METADATA_INVALID:
159 listener.metadataInvalid( event );
160 break;
161 case METADATA_RESOLVED:
162 listener.metadataResolved( event );
163 break;
164 case METADATA_RESOLVING:
165 listener.metadataResolving( event );
166 break;
167 default:
168 throw new IllegalStateException( "unknown repository event type " + event.getType() );
169 }
170 }
171 catch ( Exception | LinkageError e )
172 {
173 logError( e, listener );
174 }
175 }
176
177 private void logError( Throwable e, Object listener )
178 {
179 LOGGER.warn( "Failed to dispatch repository event to {}", listener.getClass().getCanonicalName(), e );
180 }
181
182 }