| | |
| | | import javax.servlet.http.Cookie;
|
| | |
|
| | | import org.apache.wicket.protocol.http.WebResponse;
|
| | | import org.eclipse.jgit.errors.RepositoryNotFoundException;
|
| | | import org.eclipse.jgit.lib.Repository;
|
| | | import org.eclipse.jgit.lib.RepositoryCache;
|
| | | import org.eclipse.jgit.lib.RepositoryCache.FileKey;
|
| | | import org.eclipse.jgit.lib.StoredConfig;
|
| | | import org.eclipse.jgit.storage.file.FileBasedConfig;
|
| | | import org.eclipse.jgit.storage.file.WindowCache;
|
| | | import org.eclipse.jgit.storage.file.WindowCacheConfig;
|
| | | import org.eclipse.jgit.transport.ServiceMayNotContinueException;
|
| | | import org.eclipse.jgit.transport.resolver.FileResolver;
|
| | | import org.eclipse.jgit.transport.resolver.RepositoryResolver;
|
| | | import org.eclipse.jgit.transport.resolver.ServiceNotAuthorizedException;
|
| | | import org.eclipse.jgit.transport.resolver.ServiceNotEnabledException;
|
| | | import org.eclipse.jgit.util.FS;
|
| | | import org.eclipse.jgit.util.FileUtils;
|
| | | import org.slf4j.Logger;
|
| | |
| | | private final Map<String, ProjectModel> projectCache = new ConcurrentHashMap<String, ProjectModel>();
|
| | |
|
| | | private final AtomicReference<String> repositoryListSettingsChecksum = new AtomicReference<String>("");
|
| | |
|
| | | private RepositoryResolver<Void> repositoryResolver;
|
| | |
|
| | | private ServletContext servletContext;
|
| | |
|
| | |
| | | * @return repository or null
|
| | | */
|
| | | public Repository getRepository(String repositoryName, boolean logError) {
|
| | | File dir = FileKey.resolve(new File(repositoriesFolder, repositoryName), FS.DETECTED);
|
| | | if (dir == null)
|
| | | return null;
|
| | |
|
| | | Repository r = null;
|
| | | try {
|
| | | r = repositoryResolver.open(null, repositoryName);
|
| | | } catch (RepositoryNotFoundException e) {
|
| | | r = null;
|
| | | FileKey key = FileKey.exact(dir, FS.DETECTED);
|
| | | r = RepositoryCache.open(key, true);
|
| | | } catch (IOException e) {
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath());
|
| | | }
|
| | | } catch (ServiceNotAuthorizedException e) {
|
| | | r = null;
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | }
|
| | | } catch (ServiceNotEnabledException e) {
|
| | | r = null;
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | }
|
| | | } catch (ServiceMayNotContinueException e) {
|
| | | r = null;
|
| | | if (logError) {
|
| | | logger.error("GitBlit.getRepository(String) failed to find "
|
| | | + new File(repositoriesFolder, repositoryName).getAbsolutePath(), e);
|
| | | }
|
| | | }
|
| | | return r;
|
| | |
| | | */
|
| | | private void closeRepository(String repositoryName) {
|
| | | Repository repository = getRepository(repositoryName);
|
| | | RepositoryCache.close(repository);
|
| | |
|
| | | // assume 2 uses in case reflection fails
|
| | | int uses = 2;
|
| | | try {
|
| | |
| | | public void updateRepositoryModel(String repositoryName, RepositoryModel repository,
|
| | | boolean isCreate) throws GitBlitException {
|
| | | Repository r = null;
|
| | | String projectPath = StringUtils.getFirstPathElement(repository.name);
|
| | | if (!StringUtils.isEmpty(projectPath)) {
|
| | | if (projectPath.equalsIgnoreCase(getString(Keys.web.repositoryRootGroupName, "main"))) {
|
| | | // strip leading group name
|
| | | repository.name = repository.name.substring(projectPath.length() + 1);
|
| | | }
|
| | | }
|
| | | if (isCreate) {
|
| | | // ensure created repository name ends with .git
|
| | | if (!repository.name.toLowerCase().endsWith(org.eclipse.jgit.lib.Constants.DOT_GIT_EXT)) {
|
| | |
| | | rf.close();
|
| | | }
|
| | | }
|
| | | |
| | | // remove this repository from any origin model's fork list
|
| | | if (!StringUtils.isEmpty(repository.originRepository)) {
|
| | | RepositoryModel origin = repositoryListCache.get(repository.originRepository);
|
| | | if (origin != null && !ArrayUtils.isEmpty(origin.forks)) {
|
| | | origin.forks.remove(repositoryName);
|
| | | }
|
| | | }
|
| | |
|
| | | // clear the cache
|
| | | clearRepositoryMetadataCache(repositoryName);
|
| | |
| | |
|
| | | // load repository
|
| | | logger.info("edit repository " + repository.name);
|
| | | try {
|
| | | r = repositoryResolver.open(null, repository.name);
|
| | | } catch (RepositoryNotFoundException e) {
|
| | | logger.error("Repository not found", e);
|
| | | } catch (ServiceNotAuthorizedException e) {
|
| | | logger.error("Service not authorized", e);
|
| | | } catch (ServiceNotEnabledException e) {
|
| | | logger.error("Service not enabled", e);
|
| | | } catch (ServiceMayNotContinueException e) {
|
| | | logger.error("Service may not continue", e);
|
| | | }
|
| | | r = getRepository(repository.name);
|
| | | }
|
| | |
|
| | | // update settings
|
| | |
| | | this.settings = settings;
|
| | | repositoriesFolder = getRepositoriesFolder();
|
| | | logger.info("Git repositories folder " + repositoriesFolder.getAbsolutePath());
|
| | | repositoryResolver = new FileResolver<Void>(repositoriesFolder, true);
|
| | |
|
| | | // calculate repository list settings checksum for future config changes
|
| | | repositoryListSettingsChecksum.set(getRepositoryListSettingsChecksum());
|