Proof of concept #1026

Paul Martin

2016-04-16 eecaad8b8e2c447429c31a01d49260ddd6b4ee03

 src/main/java/com/gitblit/manager/GitblitManager.java

@@ -21,6 +21,7 @@
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.lang.reflect.Type;
import java.text.MessageFormat;
import java.util.ArrayList;
@@ -54,9 +55,11 @@
import com.gitblit.Constants.Role;
import com.gitblit.GitBlitException;
import com.gitblit.IStoredSettings;
import com.gitblit.extensions.RepositoryLifeCycleListener;
import com.gitblit.models.FederationModel;
import com.gitblit.models.FederationProposal;
import com.gitblit.models.FederationSet;
import com.gitblit.models.FilestoreModel;
import com.gitblit.models.ForkModel;
import com.gitblit.models.GitClientApplication;
import com.gitblit.models.Mailing;
@@ -77,7 +80,6 @@
import com.gitblit.transport.ssh.IPublicKeyManager;
import com.gitblit.transport.ssh.SshKey;
import com.gitblit.utils.ArrayUtils;
import com.gitblit.utils.HttpUtils;
import com.gitblit.utils.JsonUtils;
import com.gitblit.utils.ObjectCache;
import com.gitblit.utils.StringUtils;
@@ -88,8 +90,8 @@
import com.google.gson.reflect.TypeToken;
import com.google.inject.Inject;
import com.google.inject.Injector;
import com.google.inject.Singleton;
import com.google.inject.Provider;
import com.google.inject.Singleton;

/**
 * GitblitManager is an aggregate interface delegate.  It implements all the manager
@@ -132,6 +134,8 @@

   protected final IFederationManager federationManager;

   protected final IFilestoreManager filestoreManager;

   @Inject
   public GitblitManager(
         Provider<IPublicKeyManager> publicKeyManagerProvider,
@@ -143,7 +147,8 @@
         IAuthenticationManager authenticationManager,
         IRepositoryManager repositoryManager,
         IProjectManager projectManager,
         IFederationManager federationManager) {
         IFederationManager federationManager,
         IFilestoreManager filestoreManager) {

      this.publicKeyManagerProvider = publicKeyManagerProvider;
      this.ticketServiceProvider = ticketServiceProvider;
@@ -157,6 +162,7 @@
      this.repositoryManager = repositoryManager;
      this.projectManager = projectManager;
      this.federationManager = federationManager;
      this.filestoreManager = filestoreManager;
   }

   @Override
@@ -277,6 +283,16 @@

      // add this clone to the cached model
      repositoryManager.addToCachedRepositoryList(cloneModel);

      if (pluginManager != null) {
         for (RepositoryLifeCycleListener listener : pluginManager.getExtensions(RepositoryLifeCycleListener.class)) {
            try {
               listener.onFork(repository, cloneModel);
            } catch (Throwable t) {
               logger.error(String.format("failed to call plugin onFork %s", repository.name), t);
            }
         }
      }
      return cloneModel;
   }

@@ -441,7 +457,7 @@
         // Read bundled Gitblit properties to extract setting descriptions.
         // This copy is pristine and only used for populating the setting
         // models map.
         InputStream is = GitblitManager.class.getResourceAsStream("/reference.properties");
         InputStream is = GitblitManager.class.getResourceAsStream("/defaults.properties");
         BufferedReader propertiesReader = new BufferedReader(new InputStreamReader(is));
         StringBuilder description = new StringBuilder();
         SettingModel setting = new SettingModel();
@@ -486,9 +502,9 @@
         }
         propertiesReader.close();
      } catch (NullPointerException e) {
         logger.error("Failed to find resource copy of gitblit.properties");
         logger.error("Failed to find classpath resource 'defaults.properties'");
      } catch (IOException e) {
         logger.error("Failed to load resource copy of gitblit.properties");
         logger.error("Failed to load classpath resource 'defaults.properties'");
      }
   }

@@ -633,8 +649,8 @@
    */

   @Override
   public UserModel authenticate(String username, char[] password) {
      return authenticationManager.authenticate(username, password);
   public UserModel authenticate(String username, char[] password, String remoteIP) {
      return authenticationManager.authenticate(username, password, remoteIP);
   }

   @Override
@@ -649,6 +665,11 @@
   @Override
   public UserModel authenticate(String username, SshKey key) {
      return authenticationManager.authenticate(username, key);
   }

   @Override
   public UserModel authenticate(String username) {
      return authenticationManager.authenticate(username);
   }

   @Override
@@ -1224,6 +1245,70 @@
   }

   /*
    * FILE STORAGE MANAGER
    */
	
   @Override
   public boolean isValidOid(String oid) {
      return filestoreManager.isValidOid(oid);
   }
	
   @Override
   public FilestoreModel.Status addObject(String oid, long size, UserModel user, RepositoryModel repo) {
      return filestoreManager.addObject(oid, size, user, repo);
   }
	
   @Override
   public FilestoreModel getObject(String oid, UserModel user, RepositoryModel repo) {
      return filestoreManager.getObject(oid, user, repo);
   };
	
   @Override
   public FilestoreModel.Status uploadBlob(String oid, long size, UserModel user, RepositoryModel repo, InputStream streamIn ) {
      return filestoreManager.uploadBlob(oid, size, user, repo, streamIn);
   }
	
   @Override
   public FilestoreModel.Status downloadBlob(String oid, UserModel user, RepositoryModel repo, OutputStream streamOut ) {
      return filestoreManager.downloadBlob(oid, user, repo, streamOut);
   }
	
   @Override
   public List<FilestoreModel> getAllObjects(List<RepositoryModel> viewableRepositories) {
      return filestoreManager.getAllObjects(viewableRepositories);
   }
	
   @Override
   public File getStorageFolder() {
      return filestoreManager.getStorageFolder();
   }
	
   @Override
   public File getStoragePath(String oid) {
      return filestoreManager.getStoragePath(oid);
   }
	
   @Override
   public long getMaxUploadSize() {
      return filestoreManager.getMaxUploadSize();
   };
	
   @Override
   public void clearFilestoreCache() {
      filestoreManager.clearFilestoreCache();
   };

   @Override
   public long getFilestoreUsedByteCount() {
      return filestoreManager.getFilestoreUsedByteCount();
   };
	
   @Override
   public long getFilestoreAvailableByteCount() {
      return filestoreManager.getFilestoreAvailableByteCount();
   };
	
   /*
    * PLUGIN MANAGER
    */

@@ -1326,4 +1411,5 @@
   public PluginRelease lookupRelease(String pluginId, String version) {
      return pluginManager.lookupRelease(pluginId, version);
   }
	
}