1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.maven.plugins.dependency;
20
21 import java.util.Collection;
22 import java.util.Collections;
23 import java.util.HashMap;
24 import java.util.HashSet;
25 import java.util.List;
26 import java.util.Map;
27 import java.util.Optional;
28 import java.util.Set;
29 import java.util.stream.Collectors;
30
31 import org.apache.maven.RepositoryUtils;
32 import org.apache.maven.model.DependencyManagement;
33 import org.apache.maven.plugin.MojoExecutionException;
34 import org.apache.maven.plugins.annotations.Component;
35 import org.apache.maven.plugins.annotations.Mojo;
36 import org.eclipse.aether.RepositorySystem;
37 import org.eclipse.aether.artifact.ArtifactTypeRegistry;
38 import org.eclipse.aether.collection.CollectRequest;
39 import org.eclipse.aether.collection.CollectResult;
40 import org.eclipse.aether.collection.DependencyCollectionException;
41 import org.eclipse.aether.graph.DependencyNode;
42 import org.eclipse.aether.graph.DependencyVisitor;
43 import org.eclipse.aether.repository.RemoteRepository;
44 import org.eclipse.aether.util.graph.visitor.TreeDependencyVisitor;
45
46
47
48
49
50
51
52
53 @Mojo(name = "list-repositories", threadSafe = true)
54 public class ListRepositoriesMojo extends AbstractDependencyMojo {
55
56 @Component
57 RepositorySystem repositorySystem;
58
59
60
61
62
63
64 @Override
65 protected void doExecute() throws MojoExecutionException {
66
67 CollectRequest request = new CollectRequest();
68 request.setRepositories(getProject().getRemoteProjectRepositories());
69 request.setRootArtifact(RepositoryUtils.toArtifact(getProject().getArtifact()));
70
71 ArtifactTypeRegistry artifactTypeRegistry =
72 session.getRepositorySession().getArtifactTypeRegistry();
73
74 request.setDependencies(getProject().getDependencies().stream()
75 .map(d -> RepositoryUtils.toDependency(d, artifactTypeRegistry))
76 .collect(Collectors.toList()));
77
78 request.setManagedDependencies(Optional.ofNullable(getProject().getDependencyManagement())
79 .map(DependencyManagement::getDependencies)
80 .orElseGet(Collections::emptyList)
81 .stream()
82 .map(d -> RepositoryUtils.toDependency(d, artifactTypeRegistry))
83 .collect(Collectors.toList()));
84
85 try {
86 CollectResult collectResult = repositorySystem.collectDependencies(session.getRepositorySession(), request);
87 Set<RemoteRepository> repositories = new HashSet<>();
88 collectResult.getRoot().accept(new TreeDependencyVisitor(new DependencyVisitor() {
89 @Override
90 public boolean visitEnter(DependencyNode node) {
91 repositories.addAll(node.getRepositories());
92 return true;
93 }
94
95 @Override
96 public boolean visitLeave(DependencyNode node) {
97 return true;
98 }
99 }));
100
101 StringBuilder message = new StringBuilder();
102
103 Map<Boolean, List<RemoteRepository>> repoGroupByMirrors = repositories.stream()
104 .collect(Collectors.groupingBy(
105 repo -> repo.getMirroredRepositories().isEmpty()));
106
107 prepareRemoteRepositoriesList(message, repoGroupByMirrors.get(Boolean.TRUE));
108 prepareRemoteMirrorRepositoriesList(message, repoGroupByMirrors.get(Boolean.FALSE));
109
110 getLog().info(message);
111
112 } catch (DependencyCollectionException e) {
113 throw new MojoExecutionException(e.getMessage(), e);
114 }
115 }
116
117 private void prepareRemoteMirrorRepositoriesList(
118 StringBuilder message, Collection<RemoteRepository> remoteProjectRepositories) {
119
120 Map<RemoteRepository, RemoteRepository> mirrorMap = new HashMap<>();
121 remoteProjectRepositories.forEach(repo -> {
122 repo.getMirroredRepositories().forEach(mrepo -> mirrorMap.put(mrepo, repo));
123 });
124
125 mirrorMap.forEach((repo, mirror) -> message.append(" * ")
126 .append(repo)
127 .append(" mirrored by ")
128 .append(mirror)
129 .append(System.lineSeparator()));
130 }
131
132 private void prepareRemoteRepositoriesList(
133 StringBuilder message, Collection<RemoteRepository> remoteProjectRepositories) {
134
135 message.append("Project remote repositories used by this build:").append(System.lineSeparator());
136
137 remoteProjectRepositories.forEach(
138 repo -> message.append(" * ").append(repo).append(System.lineSeparator()));
139 }
140
141 private Map<RemoteRepository, RemoteRepository> getMirroredRepo(Set<RemoteRepository> repositories) {
142 Map<RemoteRepository, RemoteRepository> mirrorMap = new HashMap<>();
143
144 repositories.stream()
145 .filter(repo -> !repo.getMirroredRepositories().isEmpty())
146 .forEach(repo -> repo.getMirroredRepositories().forEach(mrepo -> mirrorMap.put(mrepo, repo)));
147
148 return mirrorMap;
149 }
150 }