1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.eclipse.aether.internal.impl;
20
21 import javax.inject.Inject;
22 import javax.inject.Named;
23 import javax.inject.Singleton;
24
25 import java.util.ArrayList;
26 import java.util.Collection;
27 import java.util.List;
28 import java.util.Set;
29
30 import org.eclipse.aether.RepositorySystemSession;
31 import org.eclipse.aether.impl.LocalRepositoryProvider;
32 import org.eclipse.aether.repository.LocalRepository;
33 import org.eclipse.aether.repository.LocalRepositoryManager;
34 import org.eclipse.aether.repository.NoLocalRepositoryManagerException;
35 import org.eclipse.aether.spi.localrepo.LocalRepositoryManagerFactory;
36 import org.eclipse.aether.spi.locator.Service;
37 import org.eclipse.aether.spi.locator.ServiceLocator;
38 import org.slf4j.Logger;
39 import org.slf4j.LoggerFactory;
40
41 import static java.util.Objects.requireNonNull;
42
43
44
45 @Singleton
46 @Named
47 public class DefaultLocalRepositoryProvider implements LocalRepositoryProvider, Service {
48
49 private static final Logger LOGGER = LoggerFactory.getLogger(DefaultLocalRepositoryProvider.class);
50
51 private Collection<LocalRepositoryManagerFactory> managerFactories = new ArrayList<>();
52
53 public DefaultLocalRepositoryProvider() {
54
55 }
56
57 @Inject
58 DefaultLocalRepositoryProvider(Set<LocalRepositoryManagerFactory> factories) {
59 setLocalRepositoryManagerFactories(factories);
60 }
61
62 public void initService(ServiceLocator locator) {
63 setLocalRepositoryManagerFactories(locator.getServices(LocalRepositoryManagerFactory.class));
64 }
65
66 public DefaultLocalRepositoryProvider addLocalRepositoryManagerFactory(LocalRepositoryManagerFactory factory) {
67 managerFactories.add(requireNonNull(factory, "local repository manager factory cannot be null"));
68 return this;
69 }
70
71 public DefaultLocalRepositoryProvider setLocalRepositoryManagerFactories(
72 Collection<LocalRepositoryManagerFactory> factories) {
73 if (factories == null) {
74 managerFactories = new ArrayList<>(2);
75 } else {
76 managerFactories = factories;
77 }
78 return this;
79 }
80
81 public LocalRepositoryManager newLocalRepositoryManager(RepositorySystemSession session, LocalRepository repository)
82 throws NoLocalRepositoryManagerException {
83 requireNonNull(session, "session cannot be null");
84 requireNonNull(repository, "repository cannot be null");
85 PrioritizedComponents<LocalRepositoryManagerFactory> factories = new PrioritizedComponents<>(session);
86 for (LocalRepositoryManagerFactory factory : this.managerFactories) {
87 factories.add(factory, factory.getPriority());
88 }
89
90 List<NoLocalRepositoryManagerException> errors = new ArrayList<>();
91 for (PrioritizedComponent<LocalRepositoryManagerFactory> factory : factories.getEnabled()) {
92 try {
93 LocalRepositoryManager manager = factory.getComponent().newInstance(session, repository);
94
95 if (LOGGER.isDebugEnabled()) {
96 StringBuilder buffer = new StringBuilder(256);
97 buffer.append("Using manager ").append(manager.getClass().getSimpleName());
98 Utils.appendClassLoader(buffer, manager);
99 buffer.append(" with priority ").append(factory.getPriority());
100 buffer.append(" for ").append(repository.getBasedir());
101
102 LOGGER.debug(buffer.toString());
103 }
104
105 return manager;
106 } catch (NoLocalRepositoryManagerException e) {
107
108 errors.add(e);
109 }
110 }
111 if (LOGGER.isDebugEnabled() && errors.size() > 1) {
112 for (Exception e : errors) {
113 LOGGER.debug("Could not obtain local repository manager for {}", repository, e);
114 }
115 }
116
117 StringBuilder buffer = new StringBuilder(256);
118 if (factories.isEmpty()) {
119 buffer.append("No local repository managers registered");
120 } else {
121 buffer.append("Cannot access ").append(repository.getBasedir());
122 buffer.append(" with type ").append(repository.getContentType());
123 buffer.append(" using the available factories ");
124 factories.list(buffer);
125 }
126
127 throw new NoLocalRepositoryManagerException(
128 repository, buffer.toString(), errors.size() == 1 ? errors.get(0) : null);
129 }
130 }