add get-repos Message

Author: vladak

src/org/opensolaris/opengrok/configuration/messages/ProjectMessage.java

@@ -257,6 +257,24 @@ protected byte[] applyMessage(RuntimeEnvironment env) throws Exception {
             case "list-indexed":
                 return (env.getProjectList().stream().filter(p -> p.isIndexed()).
                         map(p -> p.getName()).collect(Collectors.joining("\n")).getBytes());
+            case "get-repos":
+                List<String> repos = new ArrayList<>();
+
+                for (String projectName : getTags()) {
+                    Project project;
+                    if ((project = env.getProjects().get(projectName)) == null) {
+                        continue;
+                    }
+                    List<RepositoryInfo> infos = env.getProjectRepositoriesMap().
+                            get(project);
+                    if (infos != null) {
+                        repos.addAll(infos.stream().
+                                map(ri -> ri.getDirectoryNameRelative()).
+                                collect(Collectors.toList()));
+                    }
+                }
+
+                return repos.stream().collect(Collectors.joining("\n")).getBytes();
         }
 
         return ("command \"" + getText() + "\" for projects " +
@@ -280,8 +298,10 @@ public void validate() throws Exception {
             command.compareTo("delete") != 0 &&
             command.compareTo("list") != 0 &&
             command.compareTo("list-indexed") != 0 &&
+            command.compareTo("get-repos") != 0 &&
             command.compareTo("indexed") != 0) {
-            throw new Exception("The message must contain either 'add', 'delete' or 'indexed' text");
+            throw new Exception("The message must contain either 'add', " +
+                    "'delete', 'indexed', 'list', 'list-indexed' or 'get-repos' text");
         }
 
         if (!command.contains("list") && getTags().isEmpty()) {

test/org/opensolaris/opengrok/configuration/messages/ProjectMessageTest.java

@@ -391,4 +391,31 @@ public void testList() throws Exception {
         Assert.assertTrue(out.contains("mercurial"));
         Assert.assertFalse(out.contains("git"));
     }
+
+    @Test
+    public void testGetRepos() throws Exception {
+        // Create subrepository.
+        File mercurialRoot = new File(repository.getSourceRoot() + File.separator + "mercurial");
+        MercurialRepositoryTest.runHgCommand(mercurialRoot,
+            "clone", mercurialRoot.getAbsolutePath(),
+            mercurialRoot.getAbsolutePath() + File.separator + "closed");
+
+        // Add a project
+        Message m = new ProjectMessage();
+        m.setText("add");
+        m.addTag("mercurial");
+        m.apply(env);
+
+        // Get repositories of the project.
+        m.setText("get-repos");
+        String out = new String(m.apply(env));
+
+        // Perform cleanup of the subrepository in order not to interefere
+        // with other tests.
+        removeRecursive(new File(mercurialRoot.getAbsolutePath() +
+                File.separator + "closed").toPath());
+
+        // test
+        Assert.assertEquals("/mercurial\n/mercurial/closed", out);
+    }
 }