| | |
| | | import com.gitblit.Constants.FederationToken;
|
| | | import com.gitblit.Constants.PermissionType;
|
| | | import com.gitblit.Constants.RegistrantType;
|
| | | import com.gitblit.fanout.FanoutNioService;
|
| | | import com.gitblit.fanout.FanoutService;
|
| | | import com.gitblit.fanout.FanoutSocketService;
|
| | | import com.gitblit.models.FederationModel;
|
| | | import com.gitblit.models.FederationProposal;
|
| | | import com.gitblit.models.FederationSet;
|
| | |
| | | private final ObjectCache<String> projectRepositoriesMarkdownCache = new ObjectCache<String>();
|
| | |
|
| | | private ServletContext servletContext;
|
| | | |
| | | private File baseFolder;
|
| | |
|
| | | private File repositoriesFolder;
|
| | |
|
| | |
| | | private TimeZone timezone;
|
| | |
|
| | | private FileBasedConfig projectConfigs;
|
| | | |
| | | private FanoutService fanoutService;
|
| | |
|
| | | public GitBlit() {
|
| | | if (gitblit == null) {
|
| | |
| | | * @return the file
|
| | | */
|
| | | public static File getFileOrFolder(String fileOrFolder) {
|
| | | String openShift = System.getenv("OPENSHIFT_DATA_DIR");
|
| | | if (!StringUtils.isEmpty(openShift)) {
|
| | | // running on RedHat OpenShift
|
| | | return new File(openShift, fileOrFolder);
|
| | | }
|
| | | return new File(fileOrFolder);
|
| | | return com.gitblit.utils.FileUtils.resolveParameter(Constants.baseFolder$,
|
| | | self().baseFolder, fileOrFolder);
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @return the repositories folder path
|
| | | */
|
| | | public static File getRepositoriesFolder() {
|
| | | return getFileOrFolder(Keys.git.repositoriesFolder, "git");
|
| | | return getFileOrFolder(Keys.git.repositoriesFolder, "${baseFolder}/git");
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @return the proposals folder path
|
| | | */
|
| | | public static File getProposalsFolder() {
|
| | | return getFileOrFolder(Keys.federation.proposalsFolder, "proposals");
|
| | | return getFileOrFolder(Keys.federation.proposalsFolder, "${baseFolder}/proposals");
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @return the Groovy scripts folder path
|
| | | */
|
| | | public static File getGroovyScriptsFolder() {
|
| | | return getFileOrFolder(Keys.groovy.scriptsFolder, "groovy");
|
| | | return getFileOrFolder(Keys.groovy.scriptsFolder, "${baseFolder}/groovy");
|
| | | }
|
| | |
|
| | | |
| | | /**
|
| | | * Updates the list of server settings.
|
| | | *
|
| | |
| | | this.userService.setup(settings);
|
| | | }
|
| | |
|
| | | public boolean supportsAddUser() {
|
| | | return supportsCredentialChanges(new UserModel(""));
|
| | | }
|
| | | |
| | | /**
|
| | | * Returns true if the user's credentials can be changed.
|
| | | *
|
| | | * @param user
|
| | | * @return true if the user service supports credential changes
|
| | | */
|
| | | public boolean supportsCredentialChanges() {
|
| | | return userService.supportsCredentialChanges();
|
| | | public boolean supportsCredentialChanges(UserModel user) {
|
| | | return (user != null && user.isLocalAccount()) || userService.supportsCredentialChanges();
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns true if the user's display name can be changed.
|
| | | *
|
| | | * @param user
|
| | | * @return true if the user service supports display name changes
|
| | | */
|
| | | public boolean supportsDisplayNameChanges() {
|
| | | return userService.supportsDisplayNameChanges();
|
| | | public boolean supportsDisplayNameChanges(UserModel user) {
|
| | | return (user != null && user.isLocalAccount()) || userService.supportsDisplayNameChanges();
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns true if the user's email address can be changed.
|
| | | *
|
| | | * @param user
|
| | | * @return true if the user service supports email address changes
|
| | | */
|
| | | public boolean supportsEmailAddressChanges() {
|
| | | return userService.supportsEmailAddressChanges();
|
| | | public boolean supportsEmailAddressChanges(UserModel user) {
|
| | | return (user != null && user.isLocalAccount()) || userService.supportsEmailAddressChanges();
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns true if the user's team memberships can be changed.
|
| | | *
|
| | | * @param user
|
| | | * @return true if the user service supports team membership changes
|
| | | */
|
| | | public boolean supportsTeamMembershipChanges() {
|
| | | return userService.supportsTeamMembershipChanges();
|
| | | public boolean supportsTeamMembershipChanges(UserModel user) {
|
| | | return (user != null && user.isLocalAccount()) || userService.supportsTeamMembershipChanges();
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * @return the effective list of permissions for the user
|
| | | */
|
| | | public List<RegistrantAccessPermission> getUserAccessPermissions(UserModel user) {
|
| | | if (StringUtils.isEmpty(user.username)) {
|
| | | // new user
|
| | | return new ArrayList<RegistrantAccessPermission>();
|
| | | }
|
| | | Set<RegistrantAccessPermission> set = new LinkedHashSet<RegistrantAccessPermission>();
|
| | | set.addAll(user.getRepositoryPermissions());
|
| | | // Flag missing repositories
|
| | |
| | | if (config.isOutdated()) {
|
| | | // reload model
|
| | | logger.info(MessageFormat.format("Config for \"{0}\" has changed. Reloading model and updating cache.", repositoryName));
|
| | | model = loadRepositoryModel(repositoryName);
|
| | | removeFromCachedRepositoryList(repositoryName);
|
| | | model = loadRepositoryModel(model.name);
|
| | | removeFromCachedRepositoryList(model.name);
|
| | | addToCachedRepositoryList(model);
|
| | | } else {
|
| | | // update a few repository parameters
|
| | |
| | | }
|
| | | RepositoryModel model = new RepositoryModel();
|
| | | model.isBare = r.isBare();
|
| | | File basePath = getFileOrFolder(Keys.git.repositoriesFolder, "git");
|
| | | File basePath = getFileOrFolder(Keys.git.repositoriesFolder, "${baseFolder}/git");
|
| | | if (model.isBare) {
|
| | | model.name = com.gitblit.utils.FileUtils.getRelativePath(basePath, r.getDirectory());
|
| | | } else {
|
| | |
| | | }
|
| | | model.HEAD = JGitUtils.getHEADRef(r);
|
| | | model.availableRefs = JGitUtils.getAvailableHeadTargets(r);
|
| | | model.sparkleshareId = JGitUtils.getSparkleshareId(r);
|
| | | r.close();
|
| | |
|
| | | if (model.origin != null && model.origin.startsWith("file://")) {
|
| | |
| | |
|
| | | private ForkModel getForkModelFromCache(String repository) {
|
| | | RepositoryModel model = repositoryListCache.get(repository.toLowerCase());
|
| | | if (model == null) {
|
| | | return null;
|
| | | }
|
| | | ForkModel fork = new ForkModel(model);
|
| | | if (!ArrayUtils.isEmpty(model.forks)) {
|
| | | for (String aFork : model.forks) {
|
| | | ForkModel fm = getForkModelFromCache(aFork);
|
| | | fork.forks.add(fm);
|
| | | if (fm != null) {
|
| | | fork.forks.add(fm);
|
| | | }
|
| | | }
|
| | | }
|
| | | return fork;
|
| | |
| | |
|
| | | private ForkModel getForkModel(String repository) {
|
| | | RepositoryModel model = getRepositoryModel(repository.toLowerCase());
|
| | | if (model == null) {
|
| | | return null;
|
| | | }
|
| | | ForkModel fork = new ForkModel(model);
|
| | | if (!ArrayUtils.isEmpty(model.forks)) {
|
| | | for (String aFork : model.forks) {
|
| | | ForkModel fm = getForkModel(aFork);
|
| | | fork.forks.add(fm);
|
| | | if (fm != null) {
|
| | | fork.forks.add(fm);
|
| | | }
|
| | | }
|
| | | }
|
| | | return fork;
|
| | |
| | | *
|
| | | * @param settings
|
| | | */
|
| | | public void configureContext(IStoredSettings settings, boolean startFederation) {
|
| | | logger.info("Reading configuration from " + settings.toString());
|
| | | public void configureContext(IStoredSettings settings, File folder, boolean startFederation) {
|
| | | this.settings = settings;
|
| | | this.baseFolder = folder;
|
| | |
|
| | | repositoriesFolder = getRepositoriesFolder();
|
| | | logger.info("Git repositories folder " + repositoriesFolder.getAbsolutePath());
|
| | |
|
| | | logger.info("Gitblit base folder = " + folder.getAbsolutePath());
|
| | | logger.info("Git repositories folder = " + repositoriesFolder.getAbsolutePath());
|
| | | logger.info("Gitblit settings = " + settings.toString());
|
| | |
|
| | | // prepare service executors
|
| | | mailExecutor = new MailExecutor(settings);
|
| | |
| | | serverStatus = new ServerStatus(isGO());
|
| | |
|
| | | if (this.userService == null) {
|
| | | String realm = settings.getString(Keys.realm.userService, "users.properties");
|
| | | String realm = settings.getString(Keys.realm.userService, "${baseFolder}/users.properties");
|
| | | IUserService loginService = null;
|
| | | try {
|
| | | // check to see if this "file" is a login service class
|
| | |
| | | }
|
| | |
|
| | | // load and cache the project metadata
|
| | | projectConfigs = new FileBasedConfig(getFileOrFolder(Keys.web.projectsFile, "projects.conf"), FS.detect());
|
| | | projectConfigs = new FileBasedConfig(getFileOrFolder(Keys.web.projectsFile, "${baseFolder}/projects.conf"), FS.detect());
|
| | | getProjectConfigs();
|
| | |
|
| | | // schedule mail engine
|
| | |
| | | }
|
| | |
|
| | | ContainerUtils.CVE_2007_0450.test();
|
| | | |
| | | // startup Fanout PubSub service
|
| | | if (settings.getInteger(Keys.fanout.port, 0) > 0) {
|
| | | String bindInterface = settings.getString(Keys.fanout.bindInterface, null);
|
| | | int port = settings.getInteger(Keys.fanout.port, FanoutService.DEFAULT_PORT);
|
| | | boolean useNio = settings.getBoolean(Keys.fanout.useNio, true);
|
| | | int limit = settings.getInteger(Keys.fanout.connectionLimit, 0);
|
| | | |
| | | if (useNio) {
|
| | | if (StringUtils.isEmpty(bindInterface)) {
|
| | | fanoutService = new FanoutNioService(port);
|
| | | } else {
|
| | | fanoutService = new FanoutNioService(bindInterface, port);
|
| | | }
|
| | | } else {
|
| | | if (StringUtils.isEmpty(bindInterface)) {
|
| | | fanoutService = new FanoutSocketService(port);
|
| | | } else {
|
| | | fanoutService = new FanoutSocketService(bindInterface, port);
|
| | | }
|
| | | }
|
| | | |
| | | fanoutService.setConcurrentConnectionLimit(limit);
|
| | | fanoutService.setAllowAllChannelAnnouncements(false);
|
| | | fanoutService.start();
|
| | | }
|
| | | }
|
| | |
|
| | | private void logTimezone(String type, TimeZone zone) {
|
| | |
| | | public void contextInitialized(ServletContextEvent contextEvent, InputStream referencePropertiesInputStream) {
|
| | | servletContext = contextEvent.getServletContext();
|
| | | if (settings == null) {
|
| | | // Gitblit WAR is running in a servlet container
|
| | | // Gitblit is running in a servlet container
|
| | | ServletContext context = contextEvent.getServletContext();
|
| | | WebXmlSettings webxmlSettings = new WebXmlSettings(context);
|
| | |
|
| | | // gitblit.properties file located within the webapp
|
| | | String webProps = context.getRealPath("/WEB-INF/gitblit.properties");
|
| | | if (!StringUtils.isEmpty(webProps)) {
|
| | | File overrideFile = new File(webProps);
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | }
|
| | | File contextFolder = new File(context.getRealPath("/"));
|
| | | String openShift = System.getenv("OPENSHIFT_DATA_DIR");
|
| | |
|
| | | // gitblit.properties file located outside the deployed war
|
| | | // folder lie, for example, on RedHat OpenShift.
|
| | | File overrideFile = getFileOrFolder("gitblit.properties");
|
| | | if (!overrideFile.getPath().equals("gitblit.properties")) {
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | }
|
| | | |
| | | configureContext(webxmlSettings, true);
|
| | | if (!StringUtils.isEmpty(openShift)) {
|
| | | // Gitblit is running in OpenShift/JBoss
|
| | | File base = new File(openShift);
|
| | |
|
| | | // Copy the included scripts to the configured groovy folder
|
| | | File localScripts = getFileOrFolder(Keys.groovy.scriptsFolder, "groovy");
|
| | | if (!localScripts.exists()) {
|
| | | File includedScripts = new File(context.getRealPath("/WEB-INF/groovy"));
|
| | | if (!includedScripts.equals(localScripts)) {
|
| | | try {
|
| | | com.gitblit.utils.FileUtils.copy(localScripts, includedScripts.listFiles());
|
| | | } catch (IOException e) {
|
| | | logger.error(MessageFormat.format(
|
| | | "Failed to copy included Groovy scripts from {0} to {1}",
|
| | | includedScripts, localScripts));
|
| | | // gitblit.properties setting overrides
|
| | | File overrideFile = new File(base, "gitblit.properties");
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | |
| | | // Copy the included scripts to the configured groovy folder
|
| | | File localScripts = new File(base, webxmlSettings.getString(Keys.groovy.scriptsFolder, "groovy"));
|
| | | if (!localScripts.exists()) {
|
| | | File warScripts = new File(contextFolder, "/WEB-INF/data/groovy");
|
| | | if (!warScripts.equals(localScripts)) {
|
| | | try {
|
| | | com.gitblit.utils.FileUtils.copy(localScripts, warScripts.listFiles());
|
| | | } catch (IOException e) {
|
| | | logger.error(MessageFormat.format(
|
| | | "Failed to copy included Groovy scripts from {0} to {1}",
|
| | | warScripts, localScripts));
|
| | | }
|
| | | }
|
| | | }
|
| | | |
| | | // configure context using the web.xml
|
| | | configureContext(webxmlSettings, base, true);
|
| | | } else {
|
| | | // Gitblit is running in a standard servlet container
|
| | | logger.info("WAR contextFolder is " + contextFolder.getAbsolutePath());
|
| | | |
| | | String path = webxmlSettings.getString(Constants.baseFolder, Constants.contextFolder$ + "/WEB-INF/data");
|
| | | File base = com.gitblit.utils.FileUtils.resolveParameter(Constants.contextFolder$, contextFolder, path);
|
| | | base.mkdirs();
|
| | | |
| | | // try to copy the data folder contents to the baseFolder
|
| | | File localSettings = new File(base, "gitblit.properties");
|
| | | if (!localSettings.exists()) {
|
| | | File contextData = new File(contextFolder, "/WEB-INF/data");
|
| | | if (!base.equals(contextData)) {
|
| | | try {
|
| | | com.gitblit.utils.FileUtils.copy(base, contextData.listFiles());
|
| | | } catch (IOException e) {
|
| | | logger.error(MessageFormat.format(
|
| | | "Failed to copy included data from {0} to {1}",
|
| | | contextData, base));
|
| | | }
|
| | | }
|
| | | }
|
| | | |
| | | // delegate all config to baseFolder/gitblit.properties file
|
| | | FileSettings settings = new FileSettings(localSettings.getAbsolutePath()); |
| | | configureContext(settings, base, true);
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | scheduledExecutor.shutdownNow();
|
| | | luceneExecutor.close();
|
| | | gcExecutor.close();
|
| | | if (fanoutService != null) {
|
| | | fanoutService.stop();
|
| | | }
|
| | | }
|
| | |
|
| | | /**
|