James Moger
2014-03-07 4affd0a3a4fe086b31a87d56616f74093d2ac715
src/main/java/com/gitblit/FederationClient.java
@@ -17,13 +17,23 @@
import java.io.File;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import com.beust.jcommander.JCommander;
import com.beust.jcommander.Parameter;
import com.beust.jcommander.ParameterException;
import com.beust.jcommander.Parameters;
import com.gitblit.manager.FederationManager;
import com.gitblit.manager.GitblitManager;
import com.gitblit.manager.IGitblit;
import com.gitblit.manager.INotificationManager;
import com.gitblit.manager.RepositoryManager;
import com.gitblit.manager.RuntimeManager;
import com.gitblit.manager.UserManager;
import com.gitblit.models.FederationModel;
import com.gitblit.models.Mailing;
import com.gitblit.service.FederationPullService;
import com.gitblit.utils.FederationUtils;
import com.gitblit.utils.StringUtils;
@@ -53,7 +63,7 @@
      }
      File regFile = com.gitblit.utils.FileUtils.resolveParameter(Constants.baseFolder$, baseFolder, params.registrationsFile);
      IStoredSettings settings = new FileSettings(regFile.getAbsolutePath());
      FileSettings settings = new FileSettings(regFile.getAbsolutePath());
      List<FederationModel> registrations = new ArrayList<FederationModel>();
      if (StringUtils.isEmpty(params.url)) {
         registrations.addAll(FederationUtils.getFederationRegistrations(settings));
@@ -83,13 +93,23 @@
      }
      // configure the Gitblit singleton for minimal, non-server operation
      GitBlit.self().configureContext(settings, baseFolder, false);
      FederationPullExecutor executor = new FederationPullExecutor(registrations, params.isDaemon);
      executor.run();
      if (!params.isDaemon) {
         System.out.println("Finished.");
         System.exit(0);
      }
      RuntimeManager runtime = new RuntimeManager(settings, baseFolder).start();
      NoopNotificationManager notifications = new NoopNotificationManager().start();
      UserManager users = new UserManager(runtime).start();
      RepositoryManager repositories = new RepositoryManager(runtime, users).start();
      FederationManager federation = new FederationManager(runtime, notifications, repositories).start();
      IGitblit gitblit = new GitblitManager(runtime, notifications, users, null, repositories, null, federation);
      FederationPullService puller = new FederationPullService(gitblit, federation.getFederationRegistrations()) {
         @Override
         public void reschedule(FederationModel registration) {
            // NOOP
         }
      };
      puller.run();
      System.out.println("Finished.");
      System.exit(0);
   }
   private static void usage(JCommander jc, ParameterException t) {
@@ -115,9 +135,6 @@
      @Parameter(names = { "--registrations" }, description = "Gitblit Federation Registrations File", required = false)
      public String registrationsFile = "${baseFolder}/federation.properties";
      @Parameter(names = { "--daemon" }, description = "Runs in daemon mode to schedule and pull repositories", required = false)
      public boolean isDaemon;
      @Parameter(names = { "--url" }, description = "URL of Gitblit instance to mirror from", required = false)
      public String url;
@@ -140,4 +157,33 @@
      public String repositoriesFolder;
   }
   private static class NoopNotificationManager implements INotificationManager {
      @Override
      public NoopNotificationManager start() {
         return this;
      }
      @Override
      public NoopNotificationManager stop() {
         return this;
      }
      @Override
      public void sendMailToAdministrators(String subject, String message) {
      }
      @Override
      public void sendMail(String subject, String message, Collection<String> toAddresses) {
      }
      @Override
      public void sendHtmlMail(String subject, String message, Collection<String> toAddresses) {
      }
      @Override
      public void send(Mailing mailing) {
      }
   }
}