Skip to content

Commit

Permalink
Fix getCurrentProject, #fixes apache#262
Browse files Browse the repository at this point in the history
  • Loading branch information
gnodet committed Dec 15, 2020
1 parent 6c12c98 commit a1d65a0
Showing 1 changed file with 14 additions and 1 deletion.
15 changes: 14 additions & 1 deletion daemon/src/main/java/org/mvndaemon/mvnd/daemon/Server.java
Expand Up @@ -42,6 +42,7 @@
import java.util.stream.Collectors;
import org.apache.maven.cli.DaemonMavenCli;
import org.apache.maven.execution.MavenSession;
import org.apache.maven.project.MavenProject;
import org.mvndaemon.mvnd.builder.SmartBuilder;
import org.mvndaemon.mvnd.common.DaemonConnection;
import org.mvndaemon.mvnd.common.DaemonException;
Expand Down Expand Up @@ -651,10 +652,22 @@ public void fail(Throwable t) throws Exception {

@Override
protected void onStartSession(MavenSession session) {
queue.add(new BuildStarted(session.getCurrentProject().getName(), session.getProjects().size(),
queue.add(new BuildStarted(getCurrentProject(session).getName(), session.getProjects().size(),
session.getRequest().getDegreeOfConcurrency()));
}

private MavenProject getCurrentProject(MavenSession mavenSession) {
// MavenSession.getCurrentProject() does not return the correct value in some cases
String executionRootDirectory = mavenSession.getExecutionRootDirectory();
if (executionRootDirectory == null) {
return mavenSession.getCurrentProject();
}
return mavenSession.getProjects().stream()
.filter(p -> (p.getFile() != null && executionRootDirectory.equals(p.getFile().getParent())))
.findFirst()
.orElse(mavenSession.getCurrentProject());
}

@Override
protected void onStartProject(String projectId, String display) {
queue.add(Message.projectStarted(projectId, display));
Expand Down

0 comments on commit a1d65a0

Please sign in to comment.