| | |
| | | import java.io.InputStreamReader;
|
| | | import java.lang.reflect.Field;
|
| | | import java.text.MessageFormat;
|
| | | import java.text.SimpleDateFormat;
|
| | | import java.util.ArrayList;
|
| | | import java.util.Arrays;
|
| | | import java.util.Collection;
|
| | | import java.util.Collections;
|
| | | import java.util.Date;
|
| | | import java.util.HashMap;
|
| | | import java.util.LinkedHashSet;
|
| | | import java.util.List;
|
| | | import java.util.Map;
|
| | | import java.util.Map.Entry;
|
| | | import java.util.Set;
|
| | | import java.util.TimeZone;
|
| | | import java.util.TreeSet;
|
| | | import java.util.concurrent.ConcurrentHashMap;
|
| | | import java.util.concurrent.Executors;
|
| | |
| | | import com.gitblit.models.FederationSet;
|
| | | import com.gitblit.models.Metric;
|
| | | import com.gitblit.models.RepositoryModel;
|
| | | import com.gitblit.models.SearchResult;
|
| | | import com.gitblit.models.ServerSettings;
|
| | | import com.gitblit.models.ServerStatus;
|
| | | import com.gitblit.models.SettingModel;
|
| | | import com.gitblit.models.TeamModel;
|
| | | import com.gitblit.models.UserModel;
|
| | | import com.gitblit.utils.ArrayUtils;
|
| | | import com.gitblit.utils.ByteFormat;
|
| | | import com.gitblit.utils.FederationUtils;
|
| | | import com.gitblit.utils.JGitUtils;
|
| | |
| | | public class GitBlit implements ServletContextListener {
|
| | |
|
| | | private static GitBlit gitblit;
|
| | |
|
| | | |
| | | private final Logger logger = LoggerFactory.getLogger(GitBlit.class);
|
| | |
|
| | | private final ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(5);
|
| | |
| | |
|
| | | private File repositoriesFolder;
|
| | |
|
| | | private boolean exportAll = true;
|
| | |
|
| | | private IUserService userService;
|
| | |
|
| | | private IStoredSettings settings;
|
| | |
| | | private ServerStatus serverStatus;
|
| | |
|
| | | private MailExecutor mailExecutor;
|
| | | |
| | | private LuceneExecutor luceneExecutor;
|
| | | |
| | | private TimeZone timezone;
|
| | |
|
| | | public GitBlit() {
|
| | | if (gitblit == null) {
|
| | |
| | | public static boolean isGO() {
|
| | | return self().settings instanceof FileSettings;
|
| | | }
|
| | | |
| | | /**
|
| | | * Returns the preferred timezone for the Gitblit instance.
|
| | | * |
| | | * @return a timezone
|
| | | */
|
| | | public static TimeZone getTimezone() {
|
| | | if (self().timezone == null) {
|
| | | String tzid = getString("web.timezone", null);
|
| | | if (StringUtils.isEmpty(tzid)) {
|
| | | self().timezone = TimeZone.getDefault();
|
| | | return self().timezone;
|
| | | }
|
| | | self().timezone = TimeZone.getTimeZone(tzid);
|
| | | }
|
| | | return self().timezone;
|
| | | }
|
| | | |
| | |
|
| | | /**
|
| | | * Returns the boolean value for the specified key. If the key does not
|
| | |
| | | */
|
| | | public List<String> getAllUsernames() {
|
| | | List<String> names = new ArrayList<String>(userService.getAllUsernames());
|
| | | Collections.sort(names);
|
| | | return names;
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns the list of all users available to the login service.
|
| | | * |
| | | * @see IUserService.getAllUsernames()
|
| | | * @return list of all usernames
|
| | | */
|
| | | public List<UserModel> getAllUsers() {
|
| | | List<UserModel> users = userService.getAllUsers();
|
| | | return users;
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | */
|
| | | public List<String> getAllTeamnames() {
|
| | | List<String> teams = new ArrayList<String>(userService.getAllTeamNames());
|
| | | Collections.sort(teams);
|
| | | return teams;
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns the list of available teams that a user or repository may be
|
| | | * assigned to.
|
| | | * |
| | | * @return the list of teams
|
| | | */
|
| | | public List<TeamModel> getAllTeams() {
|
| | | List<TeamModel> teams = userService.getAllTeams();
|
| | | return teams;
|
| | | }
|
| | |
|
| | |
| | | * @return list of all repositories
|
| | | */
|
| | | public List<String> getRepositoryList() {
|
| | | return JGitUtils.getRepositoryList(repositoriesFolder, exportAll,
|
| | | return JGitUtils.getRepositoryList(repositoriesFolder, |
| | | settings.getBoolean(Keys.git.onlyAccessBareRepositories, false),
|
| | | settings.getBoolean(Keys.git.searchRepositoriesSubfolders, true));
|
| | | }
|
| | |
|
| | |
| | | * @return repository or null
|
| | | */
|
| | | public Repository getRepository(String repositoryName) {
|
| | | return getRepository(repositoryName, true);
|
| | | }
|
| | |
|
| | | /**
|
| | | * Returns the JGit repository for the specified name.
|
| | | * |
| | | * @param repositoryName
|
| | | * @param logError
|
| | | * @return repository or null
|
| | | */
|
| | | public Repository getRepository(String repositoryName, boolean logError) {
|
| | | Repository r = null;
|
| | | try {
|
| | | r = repositoryResolver.open(null, repositoryName);
|
| | | } catch (RepositoryNotFoundException e) {
|
| | | r = null;
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath());
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath());
|
| | | }
|
| | | } catch (ServiceNotAuthorizedException e) {
|
| | | r = null;
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | }
|
| | | } catch (ServiceNotEnabledException e) {
|
| | | r = null;
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | }
|
| | | }
|
| | | return r;
|
| | | }
|
| | |
| | | RepositoryModel model = new RepositoryModel();
|
| | | model.name = repositoryName;
|
| | | model.hasCommits = JGitUtils.hasCommits(r);
|
| | | model.lastChange = JGitUtils.getLastChange(r, null);
|
| | | model.lastChange = JGitUtils.getLastChange(r);
|
| | | model.isBare = r.isBare();
|
| | | StoredConfig config = JGitUtils.readConfig(r);
|
| | | if (config != null) {
|
| | | model.description = getConfig(config, "description", "");
|
| | |
| | | "gitblit", null, "postReceiveScript")));
|
| | | model.mailingLists = new ArrayList<String>(Arrays.asList(config.getStringList(
|
| | | "gitblit", null, "mailingList")));
|
| | | model.indexedBranches = new ArrayList<String>(Arrays.asList(config.getStringList(
|
| | | "gitblit", null, "indexBranch")));
|
| | | }
|
| | | model.HEAD = JGitUtils.getHEADRef(r);
|
| | | model.availableRefs = JGitUtils.getAvailableHeadTargets(r);
|
| | | r.close();
|
| | | return model;
|
| | | }
|
| | |
| | | repository.close();
|
| | | }
|
| | | }
|
| | | |
| | | // close any open index writer/searcher in the Lucene executor
|
| | | luceneExecutor.close(repositoryName);
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | if (repositoryMetricsCache.hasCurrent(model.name, model.lastChange)) {
|
| | | return new ArrayList<Metric>(repositoryMetricsCache.getObject(model.name));
|
| | | }
|
| | | List<Metric> metrics = MetricUtils.getDateMetrics(repository, null, true, null);
|
| | | List<Metric> metrics = MetricUtils.getDateMetrics(repository, null, true, null, getTimezone());
|
| | | repositoryMetricsCache.updateObject(model.name, model.lastChange, metrics);
|
| | | return new ArrayList<Metric>(metrics);
|
| | | }
|
| | |
| | | // update settings
|
| | | if (r != null) {
|
| | | updateConfiguration(r, repository);
|
| | | // only update symbolic head if it changes
|
| | | String currentRef = JGitUtils.getHEADRef(r);
|
| | | if (!StringUtils.isEmpty(repository.HEAD) && !repository.HEAD.equals(currentRef)) {
|
| | | logger.info(MessageFormat.format("Relinking {0} HEAD from {1} to {2}", |
| | | repository.name, currentRef, repository.HEAD));
|
| | | if (JGitUtils.setHEADtoRef(r, repository.HEAD)) {
|
| | | // clear the cache
|
| | | clearRepositoryCache(repository.name);
|
| | | }
|
| | | }
|
| | |
|
| | | // close the repository object
|
| | | r.close();
|
| | | }
|
| | | }
|
| | |
| | | config.setString("gitblit", null, "federationStrategy",
|
| | | repository.federationStrategy.name());
|
| | | config.setBoolean("gitblit", null, "isFederated", repository.isFederated);
|
| | | if (repository.preReceiveScripts != null) {
|
| | | if (!ArrayUtils.isEmpty(repository.preReceiveScripts)) {
|
| | | config.setStringList("gitblit", null, "preReceiveScript", repository.preReceiveScripts);
|
| | | }
|
| | | if (repository.postReceiveScripts != null) {
|
| | | if (!ArrayUtils.isEmpty(repository.postReceiveScripts)) {
|
| | | config.setStringList("gitblit", null, "postReceiveScript",
|
| | | repository.postReceiveScripts);
|
| | | }
|
| | | if (repository.mailingLists != null) {
|
| | | if (!ArrayUtils.isEmpty(repository.mailingLists)) {
|
| | | config.setStringList("gitblit", null, "mailingList", repository.mailingLists);
|
| | | }
|
| | | if (!ArrayUtils.isEmpty(repository.indexedBranches)) {
|
| | | config.setStringList("gitblit", null, "indexBranch", repository.indexedBranches);
|
| | | }
|
| | | try {
|
| | | config.save();
|
| | |
| | | case PULL_TEAMS:
|
| | | return token.equals(all) || token.equals(unr);
|
| | | case PULL_SETTINGS:
|
| | | case PULL_SCRIPTS:
|
| | | return token.equals(all);
|
| | | }
|
| | | return false;
|
| | |
| | | }
|
| | | return scripts;
|
| | | }
|
| | | |
| | | /**
|
| | | * Search the specified repositories using the Lucene query.
|
| | | * |
| | | * @param query
|
| | | * @param page
|
| | | * @param pageSize
|
| | | * @param repositories
|
| | | * @return
|
| | | */
|
| | | public List<SearchResult> search(String query, int page, int pageSize, List<String> repositories) { |
| | | List<SearchResult> srs = luceneExecutor.search(query, page, pageSize, repositories);
|
| | | return srs;
|
| | | }
|
| | |
|
| | | /**
|
| | | * Notify the administrators by email.
|
| | |
| | | this.settings = settings;
|
| | | repositoriesFolder = getRepositoriesFolder();
|
| | | logger.info("Git repositories folder " + repositoriesFolder.getAbsolutePath());
|
| | | repositoryResolver = new FileResolver<Void>(repositoriesFolder, exportAll);
|
| | | repositoryResolver = new FileResolver<Void>(repositoriesFolder, true);
|
| | | |
| | | logTimezone("JVM", TimeZone.getDefault());
|
| | | logTimezone(Constants.NAME, getTimezone());
|
| | |
|
| | | serverStatus = new ServerStatus(isGO());
|
| | | String realm = settings.getString(Keys.realm.userService, "users.properties");
|
| | | IUserService loginService = null;
|
| | | try {
|
| | | // check to see if this "file" is a login service class
|
| | | Class<?> realmClass = Class.forName(realm);
|
| | | if (IUserService.class.isAssignableFrom(realmClass)) {
|
| | | loginService = (IUserService) realmClass.newInstance();
|
| | | }
|
| | | loginService = (IUserService) realmClass.newInstance();
|
| | | } catch (Throwable t) {
|
| | | loginService = new GitblitUserService();
|
| | | }
|
| | | setUserService(loginService);
|
| | | mailExecutor = new MailExecutor(settings);
|
| | | if (mailExecutor.isReady()) {
|
| | | logger.info("Mail executor is scheduled to process the message queue every 2 minutes.");
|
| | | scheduledExecutor.scheduleAtFixedRate(mailExecutor, 1, 2, TimeUnit.MINUTES);
|
| | | } else {
|
| | | logger.warn("Mail server is not properly configured. Mail services disabled.");
|
| | | }
|
| | | luceneExecutor = new LuceneExecutor(settings, repositoriesFolder);
|
| | | logger.info("Lucene executor is scheduled to process indexed branches every 2 minutes.");
|
| | | scheduledExecutor.scheduleAtFixedRate(luceneExecutor, 1, 2, TimeUnit.MINUTES);
|
| | | if (startFederation) {
|
| | | configureFederation();
|
| | | }
|
| | | } |
| | | }
|
| | | |
| | | private void logTimezone(String type, TimeZone zone) {
|
| | | SimpleDateFormat df = new SimpleDateFormat("z Z");
|
| | | df.setTimeZone(zone);
|
| | | String offset = df.format(new Date());
|
| | | logger.info(type + " timezone is " + zone.getID() + " (" + offset + ")");
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | WebXmlSettings webxmlSettings = new WebXmlSettings(context);
|
| | |
|
| | | // 0.7.0 web.properties in the deployed war folder
|
| | | File overrideFile = new File(context.getRealPath("/WEB-INF/web.properties"));
|
| | | if (overrideFile.exists()) {
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | String webProps = context.getRealPath("/WEB-INF/web.properties");
|
| | | if (!StringUtils.isEmpty(webProps)) {
|
| | | File overrideFile = new File(webProps);
|
| | | if (overrideFile.exists()) {
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | }
|
| | | }
|
| | | |
| | |
|
| | | // 0.8.0 gitblit.properties file located outside the deployed war
|
| | | // folder lie, for example, on RedHat OpenShift.
|
| | | overrideFile = getFileOrFolder("gitblit.properties");
|
| | | File overrideFile = getFileOrFolder("gitblit.properties");
|
| | | if (!overrideFile.getPath().equals("gitblit.properties")) {
|
| | | webxmlSettings.applyOverrides(overrideFile);
|
| | | }
|
| | | configureContext(webxmlSettings, true);
|
| | |
|
| | | // 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));
|
| | | }
|
| | | }
|
| | | }
|
| | | }
|
| | |
|
| | | serverStatus.servletContainer = servletContext.getServerInfo();
|
| | |
| | | public void contextDestroyed(ServletContextEvent contextEvent) {
|
| | | logger.info("Gitblit context destroyed by servlet container.");
|
| | | scheduledExecutor.shutdownNow();
|
| | | luceneExecutor.close();
|
| | | }
|
| | | }
|