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.repository.RemoteRepository;
32 import org.eclipse.aether.spi.connector.transport.Transporter;
33 import org.eclipse.aether.spi.connector.transport.TransporterFactory;
34 import org.eclipse.aether.spi.connector.transport.TransporterProvider;
35 import org.eclipse.aether.spi.locator.Service;
36 import org.eclipse.aether.spi.locator.ServiceLocator;
37 import org.eclipse.aether.transfer.NoTransporterException;
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 final class DefaultTransporterProvider implements TransporterProvider, Service {
48
49 private static final Logger LOGGER = LoggerFactory.getLogger(DefaultTransporterProvider.class);
50
51 private Collection<TransporterFactory> factories = new ArrayList<>();
52
53 public DefaultTransporterProvider() {
54
55 }
56
57 @Inject
58 DefaultTransporterProvider(Set<TransporterFactory> transporterFactories) {
59 setTransporterFactories(transporterFactories);
60 }
61
62 public void initService(ServiceLocator locator) {
63 setTransporterFactories(locator.getServices(TransporterFactory.class));
64 }
65
66 public DefaultTransporterProvider addTransporterFactory(TransporterFactory factory) {
67 factories.add(requireNonNull(factory, "transporter factory cannot be null"));
68 return this;
69 }
70
71 public DefaultTransporterProvider setTransporterFactories(Collection<TransporterFactory> factories) {
72 if (factories == null) {
73 this.factories = new ArrayList<>();
74 } else {
75 this.factories = factories;
76 }
77 return this;
78 }
79
80 public Transporter newTransporter(RepositorySystemSession session, RemoteRepository repository)
81 throws NoTransporterException {
82 requireNonNull(session, "session cannot be null");
83 requireNonNull(repository, "repository cannot be null");
84
85 PrioritizedComponents<TransporterFactory> factories = new PrioritizedComponents<>(session);
86 for (TransporterFactory factory : this.factories) {
87 factories.add(factory, factory.getPriority());
88 }
89
90 List<NoTransporterException> errors = new ArrayList<>();
91 for (PrioritizedComponent<TransporterFactory> factory : factories.getEnabled()) {
92 try {
93 Transporter transporter = factory.getComponent().newInstance(session, repository);
94
95 if (LOGGER.isDebugEnabled()) {
96 StringBuilder buffer = new StringBuilder(256);
97 buffer.append("Using transporter ")
98 .append(transporter.getClass().getSimpleName());
99 Utils.appendClassLoader(buffer, transporter);
100 buffer.append(" with priority ").append(factory.getPriority());
101 buffer.append(" for ").append(repository.getUrl());
102 LOGGER.debug(buffer.toString());
103 }
104
105 return transporter;
106 } catch (NoTransporterException 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 transporter factory for {}", repository, e);
114 }
115 }
116
117 StringBuilder buffer = new StringBuilder(256);
118 if (factories.isEmpty()) {
119 buffer.append("No transporter factories registered");
120 } else {
121 buffer.append("Cannot access ").append(repository.getUrl());
122 buffer.append(" using the registered transporter factories: ");
123 factories.list(buffer);
124 }
125
126 throw new NoTransporterException(repository, buffer.toString(), errors.size() == 1 ? errors.get(0) : null);
127 }
128 }