Support for hidden dependencies #12

src/main/java/org/jboss/fuse/mvnd/builder/DependencyGraph.java

@@ -1,7 +1,25 @@
+/*
+ * Copyright 2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.jboss.fuse.mvnd.builder;
 
+import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
@@ -10,12 +28,51 @@ import org.apache.maven.project.MavenProject;
 
 interface DependencyGraph<K> {
 
-    static DependencyGraph<MavenProject> fromMaven(ProjectDependencyGraph graph) {
+    static DependencyGraph<MavenProject> fromMaven(ProjectDependencyGraph graph, String rules) {
         List<MavenProject> projects = graph.getAllProjects();
         Map<MavenProject, List<MavenProject>> upstreams = projects.stream()
                 .collect(Collectors.toMap(p -> p, p -> graph.getUpstreamProjects(p, false)));
         Map<MavenProject, List<MavenProject>> downstreams = projects.stream()
                 .collect(Collectors.toMap(p -> p, p -> graph.getDownstreamProjects(p, false)));
+
+        if (rules != null) {
+            for (String rule : rules.split("\\s*;\\s*|\n")) {
+                String[] parts = rule.split("\\s*->\\s*|\\s+before\\s+");
+                if (parts.length != 2) {
+                    throw new IllegalArgumentException("Invalid rule: " + rule);
+                }
+                List<Set<MavenProject>> deps = Stream.of(parts).map(s ->
+                        Pattern.compile(
+                            Arrays.stream(s.split("\\s*,\\s*|\\s+and\\s+"))
+                            .map(String::trim)
+                            .map(r -> r.contains(":") ? r : "*:" + r)
+                            .map(r -> r.replaceAll("\\.", "\\.")
+                                .replaceAll("\\*", ".*"))
+                            .collect(Collectors.joining("|"))))
+                        .map(t -> projects.stream()
+                            .filter(p -> t.matcher(p.getGroupId() + ":" + p.getArtifactId()).matches())
+                            .collect(Collectors.toSet()))
+                        .collect(Collectors.toList());
+
+                Set<MavenProject> common = deps.get(0).stream().filter(deps.get(1)::contains).collect(Collectors.toSet());
+                if (!common.isEmpty()) {
+                    boolean leftWildcard = parts[0].contains("*");
+                    boolean rightWildcard = parts[1].contains("*");
+                    if (leftWildcard && rightWildcard) {
+                        throw new IllegalArgumentException("Invalid rule: " + rule + ".  Both left and right parts have wildcards and match the same project.");
+                    } else if (leftWildcard) {
+                        deps.get(0).removeAll(common);
+                    } else if (rightWildcard) {
+                        deps.get(1).removeAll(common);
+                    } else {
+                        throw new IllegalArgumentException("Invalid rule: " + rule + ". Both left and right parts match the same project.");
+                    }
+                }
+
+                deps.get(1).forEach(p -> upstreams.get(p).addAll(deps.get(0)));
+                deps.get(0).forEach(p -> downstreams.get(p).addAll(deps.get(1)));
+            }
+        }
         return new DependencyGraph<MavenProject>() {
             @Override
             public Stream<MavenProject> getDownstreamProjects(MavenProject project) {

src/main/java/org/jboss/fuse/mvnd/builder/SmartBuilder.java

@@ -35,6 +35,7 @@ import org.slf4j.LoggerFactory;
 public class SmartBuilder implements Builder {
 
     public static final String PROP_PROFILING = "smartbuilder.profiling";
+    public static final String MVND_BUILDER_RULES = "mvnd.builder.rules";
 
     private final Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -51,7 +52,10 @@ public class SmartBuilder implements Builder {
                       ProjectBuildList projectBuilds, final List<TaskSegment> taskSegments,
                       ReactorBuildStatus reactorBuildStatus) throws ExecutionException, InterruptedException {
 
-        DependencyGraph<MavenProject> graph = DependencyGraph.fromMaven(session.getProjectDependencyGraph());
+        String rules = session.getTopLevelProject().getProperties()
+                .getProperty(MVND_BUILDER_RULES);
+
+        DependencyGraph<MavenProject> graph = DependencyGraph.fromMaven(session.getProjectDependencyGraph(), rules);
 
         // log overall build info
         final int degreeOfConcurrency = session.getRequest().getDegreeOfConcurrency();