| | |
| | |
|
| | | import java.io.File;
|
| | | import java.io.FileOutputStream;
|
| | | import java.io.IOException;
|
| | | import java.net.InetAddress;
|
| | | import java.text.MessageFormat;
|
| | | import java.util.ArrayList;
|
| | |
| | |
|
| | | import com.gitblit.Constants.FederationPullStatus;
|
| | | import com.gitblit.Constants.FederationStrategy;
|
| | | import com.gitblit.GitBlitException.ForbiddenException;
|
| | | import com.gitblit.models.FederationModel;
|
| | | import com.gitblit.models.RepositoryModel;
|
| | | import com.gitblit.models.UserModel;
|
| | |
| | | *
|
| | | * @param registrations
|
| | | * @param isDaemon
|
| | | * if true, registrations are rescheduled in perpetuity. if false,
|
| | | * the federation pull operation is executed once.
|
| | | * if true, registrations are rescheduled in perpetuity. if
|
| | | * false, the federation pull operation is executed once.
|
| | | */
|
| | | public FederationPullExecutor(List<FederationModel> registrations, boolean isDaemon) {
|
| | | this.registrations = registrations;
|
| | |
| | | } else {
|
| | | repositoryName = registrationFolder + "/" + repository.name;
|
| | | }
|
| | | |
| | |
|
| | | if (registration.bare) {
|
| | | // bare repository, ensure .git suffix
|
| | | if (!repositoryName.toLowerCase().endsWith(DOT_GIT_EXT)) {
|
| | |
| | | } else {
|
| | | // normal repository, strip .git suffix
|
| | | if (repositoryName.toLowerCase().endsWith(DOT_GIT_EXT)) {
|
| | | repositoryName = repositoryName.substring(0, repositoryName.indexOf(DOT_GIT_EXT));
|
| | | repositoryName = repositoryName.substring(0,
|
| | | repositoryName.indexOf(DOT_GIT_EXT));
|
| | | }
|
| | | }
|
| | |
|
| | |
| | | StoredConfig config = existingRepository.getConfig();
|
| | | config.load();
|
| | | String origin = config.getString("remote", "origin", "url");
|
| | | RevCommit commit = JGitUtils.getCommit(existingRepository, "refs/remotes/origin/master");
|
| | | RevCommit commit = JGitUtils.getCommit(existingRepository,
|
| | | "refs/remotes/origin/master");
|
| | | if (commit != null) {
|
| | | fetchHead = commit.getName();
|
| | | }
|
| | |
| | | Constants.FEDERATION_USER, registration.token);
|
| | | logger.info(MessageFormat.format("Pulling federated repository {0} from {1} @ {2}",
|
| | | repository.name, registration.name, registration.url));
|
| | | |
| | |
|
| | | CloneResult result = JGitUtils.cloneRepository(registrationFolderFile, repository.name,
|
| | | cloneUrl, registration.bare, credentials);
|
| | | Repository r = GitBlit.self().getRepository(repositoryName);
|
| | |
| | | // preserve local settings
|
| | | repository.isFrozen = rm.isFrozen;
|
| | | repository.federationStrategy = rm.federationStrategy;
|
| | | |
| | |
|
| | | // merge federation sets
|
| | | Set<String> federationSets = new HashSet<String>();
|
| | | if (rm.federationSets != null) {
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | // a 403 error code is normal for a PULL_REPOSITORIES token
|
| | | if (!e.getMessage().contains("403")) {
|
| | | logger.warn(MessageFormat.format(
|
| | | "Failed to retrieve USERS from federated gitblit ({0} @ {1})",
|
| | | registration.name, registration.url), e);
|
| | | }
|
| | | } catch (ForbiddenException e) {
|
| | | // ignore forbidden exceptions
|
| | | } catch (IOException e) {
|
| | | logger.warn(MessageFormat.format(
|
| | | "Failed to retrieve USERS from federated gitblit ({0} @ {1})",
|
| | | registration.name, registration.url), e);
|
| | | }
|
| | |
|
| | | try {
|
| | |
| | | properties.store(os, null);
|
| | | os.close();
|
| | | }
|
| | | } catch (Exception e) {
|
| | | // a 403 error code is normal for a PULL_REPOSITORIES token
|
| | | if (!e.getMessage().contains("403")) {
|
| | | logger.warn(MessageFormat.format(
|
| | | "Failed to retrieve SETTINGS from federated gitblit ({0} @ {1})",
|
| | | registration.name, registration.url), e);
|
| | | }
|
| | | } catch (ForbiddenException e) {
|
| | | // ignore forbidden exceptions
|
| | | } catch (IOException e) {
|
| | | logger.warn(MessageFormat.format(
|
| | | "Failed to retrieve SETTINGS from federated gitblit ({0} @ {1})",
|
| | | registration.name, registration.url), e);
|
| | | }
|
| | | }
|
| | |
|