Add Google repo tool for syncing

Author: JeromeParrot

opengrok-tools/src/main/python/opengrok_tools/scm/__init__.py

@@ -4,6 +4,7 @@
 from .repository import Repository
 from .svn import SubversionRepository
 from .teamware import TeamwareRepository
+from .repo import RepoRepository
 
 __all__ = [
     'CVSRepository',
@@ -12,4 +13,5 @@
     'SubversionRepository',
     'TeamwareRepository',
     'Repository',
+    'RepoRepository',
 ]

opengrok-tools/src/main/python/opengrok_tools/scm/repo.py

@@ -0,0 +1,68 @@
+#
+# CDDL HEADER START
+#
+# The contents of this file are subject to the terms of the
+# Common Development and Distribution License (the "License").
+# You may not use this file except in compliance with the License.
+#
+# See LICENSE.txt included in this distribution for the specific
+# language governing permissions and limitations under the License.
+#
+# When distributing Covered Code, include this CDDL HEADER in each
+# file and include the License file at LICENSE.txt.
+# If applicable, add the following below this CDDL HEADER, with the
+# fields enclosed by brackets "[]" replaced with your own identifying
+# information: Portions Copyright [yyyy] [name of copyright owner]
+#
+# CDDL HEADER END
+#
+
+#
+# Copyright (c) 2018, Oracle and/or its affiliates. All rights reserved.
+#
+
+from ..utils.command import Command
+from .repository import Repository, RepositoryException
+from shutil import which
+
+
+class RepoRepository(Repository):
+    def __init__(self, logger, path, project, command, env, hooks, timeout):
+
+        super().__init__(logger, path, project, command, env, hooks, timeout)
+
+        if command:
+            self.command = command
+        else:
+            self.command = which("repo")
+
+        if not self.command:
+            self.logger.error("Cannot get repo command")
+            raise OSError
+
+    def reposync(self):
+        repo_command = [self.command, "sync", "-cf"]
+        cmd = self.getCommand(repo_command, work_dir=self.path,
+                              env_vars=self.env, logger=self.logger)
+        cmd.execute()
+        self.logger.info(cmd.getoutputstr())
+        if cmd.getretcode() != 0 or cmd.getstate() != Command.FINISHED:
+            cmd.log_error("failed to perform sync")
+            return 1
+
+        return 0
+
+    def incoming(self):
+        repo_command = [self.command, "sync", "-n"]
+        cmd = self.getCommand(repo_command, work_dir=self.path,
+                              env_vars=self.env, logger=self.logger)
+        cmd.execute()
+        if cmd.getretcode() != 0 or cmd.getstate() != Command.FINISHED:
+            cmd.log_error("failed to perform sync")
+            raise RepositoryException('failed to check for incoming in '
+                                      'repository {}'.format(self))
+
+        if len(cmd.getoutput()) == 0:
+            return False
+        else:
+            return True

opengrok-tools/src/main/python/opengrok_tools/utils/repofactory.py

@@ -26,6 +26,7 @@
 from ..scm.mercurial import MercurialRepository
 from ..scm.svn import SubversionRepository
 from ..scm.teamware import TeamwareRepository
+from ..scm.repo import RepoRepository
 
 
 def get_repository(logger, path, repo_type, project, commands, env, hooks,
@@ -62,5 +63,9 @@ def get_repository(logger, path, repo_type, project, commands, env, hooks,
         return GitRepository(logger, path, project,
                              commands.get("git"),
                              env, hooks, timeout)
+    elif repo_lower == "repo":
+        return RepoRepository(logger, path, project,
+                              commands.get("repo"),
+                              env, hooks, timeout)
     else:
         return None