Mercurial > hg > mercurial
annotate mercurial-server/src/jetbrains/buildServer/buildTriggers/vcs/mercurial/MercurialVcsSupport.java @ 71:4c15e7de1f9d
do not show password in test connection popup
| author | Pavel.Sher |
|---|---|
| date | Thu, 23 Jul 2009 17:08:43 +0400 |
| parents | e6971dc6b17c |
| children | 2e57d4e3f7b7 |
| rev | line source |
|---|---|
| 25 | 1 /* |
| 2 * Copyright 2000-2007 JetBrains s.r.o. | |
| 3 * | |
| 4 * Licensed under the Apache License, Version 2.0 (the "License"); | |
| 5 * you may not use this file except in compliance with the License. | |
| 6 * You may obtain a copy of the License at | |
| 7 * | |
| 8 * http://www.apache.org/licenses/LICENSE-2.0 | |
| 9 * | |
| 10 * Unless required by applicable law or agreed to in writing, software | |
| 11 * distributed under the License is distributed on an "AS IS" BASIS, | |
| 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| 13 * See the License for the specific language governing permissions and | |
| 14 * limitations under the License. | |
| 15 */ | |
| 0 | 16 package jetbrains.buildServer.buildTriggers.vcs.mercurial; |
| 17 | |
| 48 | 18 import jetbrains.buildServer.AgentSideCheckoutAbility; |
| 0 | 19 import jetbrains.buildServer.CollectChangesByIncludeRule; |
| 20 import jetbrains.buildServer.Used; | |
| 21 import jetbrains.buildServer.buildTriggers.vcs.AbstractVcsPropertiesProcessor; | |
| 22 import jetbrains.buildServer.buildTriggers.vcs.mercurial.command.*; | |
| 23 import jetbrains.buildServer.log.Loggers; | |
| 24 import jetbrains.buildServer.serverSide.InvalidProperty; | |
| 25 import jetbrains.buildServer.serverSide.PropertiesProcessor; | |
| 21 | 26 import jetbrains.buildServer.serverSide.SBuildServer; |
| 0 | 27 import jetbrains.buildServer.serverSide.ServerPaths; |
| 28 import jetbrains.buildServer.util.FileUtil; | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
29 import jetbrains.buildServer.util.StringUtil; |
| 0 | 30 import jetbrains.buildServer.vcs.*; |
| 31 import jetbrains.buildServer.vcs.patches.PatchBuilder; | |
| 32 import org.jetbrains.annotations.NotNull; | |
| 33 import org.jetbrains.annotations.Nullable; | |
| 34 | |
| 1 | 35 import java.io.File; |
| 36 import java.io.FileFilter; | |
| 37 import java.io.FileInputStream; | |
| 38 import java.io.IOException; | |
| 39 import java.util.*; | |
| 21 | 40 import java.util.concurrent.ConcurrentHashMap; |
| 41 import java.util.concurrent.ConcurrentMap; | |
| 42 import java.util.concurrent.TimeUnit; | |
| 43 import java.util.concurrent.locks.Lock; | |
| 44 import java.util.concurrent.locks.ReentrantLock; | |
| 1 | 45 |
| 19 | 46 /** |
| 47 * Mercurial VCS plugin for TeamCity works as follows: | |
| 48 * <ul> | |
| 49 * <li>clones repository to internal storage | |
| 50 * <li>before any operation with working copy of repository pulls changes from the original repository | |
| 51 * <li>executes corresponding hg command | |
| 52 * </ul> | |
| 53 * | |
| 57 | 54 * <p>Working copy of repository is created in the $TEAMCITY_DATA_PATH/system/caches/hg_<hash code> folder. |
| 19 | 55 * <p>Personal builds (remote runs) are not yet supported, they require corresponding functionality from the IDE. |
| 56 */ | |
| 48 | 57 public class MercurialVcsSupport extends VcsSupport implements CollectChangesByIncludeRule, LabelingSupport, AgentSideCheckoutAbility { |
| 21 | 58 private ConcurrentMap<String, Lock> myWorkDirLocks= new ConcurrentHashMap<String, Lock>(); |
| 59 private static final int OLD_WORK_DIRS_CLEANUP_PERIOD = 600; | |
| 60 private VcsManager myVcsManager; | |
|
27
7944e8985ebd
prepare modules structure for agent side checkout
Pavel.Sher
parents:
25
diff
changeset
|
61 private File myDefaultWorkFolderParent; |
| 0 | 62 |
| 21 | 63 public MercurialVcsSupport(@NotNull final VcsManager vcsManager, |
| 64 @NotNull ServerPaths paths, | |
| 65 @NotNull SBuildServer server) { | |
| 0 | 66 vcsManager.registerVcsSupport(this); |
| 21 | 67 myVcsManager = vcsManager; |
| 68 server.getExecutor().scheduleAtFixedRate(new Runnable() { | |
| 69 public void run() { | |
| 70 removeOldWorkFolders(); | |
| 71 } | |
| 72 }, 0, OLD_WORK_DIRS_CLEANUP_PERIOD, TimeUnit.SECONDS); | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
73 myDefaultWorkFolderParent = new File(paths.getCachesDir(), "mercurial"); |
| 0 | 74 } |
| 75 | |
| 76 public List<ModificationData> collectBuildChanges(final VcsRoot root, | |
| 77 @NotNull final String fromVersion, | |
| 78 @NotNull final String currentVersion, | |
| 79 final CheckoutRules checkoutRules) throws VcsException { | |
| 44 | 80 syncClonedRepository(root); |
| 0 | 81 return VcsSupportUtil.collectBuildChanges(root, fromVersion, currentVersion, checkoutRules, this); |
| 82 } | |
| 83 | |
| 84 public List<ModificationData> collectBuildChanges(final VcsRoot root, | |
| 85 final String fromVersion, | |
| 86 final String currentVersion, | |
| 87 final IncludeRule includeRule) throws VcsException { | |
| 19 | 88 // first obtain changes between specified versions |
| 0 | 89 List<ModificationData> result = new ArrayList<ModificationData>(); |
| 44 | 90 Settings settings = createSettings(root); |
| 0 | 91 LogCommand lc = new LogCommand(settings); |
| 57 | 92 String fromId = new ChangeSet(fromVersion).getId(); |
| 93 lc.setFromRevId(fromId); | |
| 0 | 94 lc.setToRevId(new ChangeSet(currentVersion).getId()); |
| 95 List<ChangeSet> changeSets = lc.execute(); | |
| 96 if (changeSets.isEmpty()) { | |
| 97 return result; | |
| 98 } | |
| 99 | |
| 19 | 100 // invoke status command for each changeset and determine what files were modified in these changesets |
| 0 | 101 StatusCommand st = new StatusCommand(settings); |
| 57 | 102 ChangeSet prev = new ChangeSet(fromVersion); |
| 103 for (int i=0; i<changeSets.size(); i++) { | |
| 104 ChangeSet cur = changeSets.get(i); | |
| 105 if (cur.getId().equals(fromId)) continue; // skip already reported changeset | |
| 106 | |
| 0 | 107 st.setFromRevId(prev.getId()); |
| 108 st.setToRevId(cur.getId()); | |
| 109 List<ModifiedFile> modifiedFiles = st.execute(); | |
| 19 | 110 // changeset full version will be set into VcsChange structure and |
| 20 | 111 // stored in database (note that getContent method will be invoked with this version) |
| 0 | 112 List<VcsChange> files = toVcsChanges(modifiedFiles, prev.getFullVersion(), cur.getFullVersion(), includeRule); |
| 113 if (files.isEmpty()) continue; | |
|
59
30cc10fe9479
accept version in two formats: with rev number and without
Pavel.Sher
parents:
58
diff
changeset
|
114 ModificationData md = new ModificationData(cur.getTimestamp(), files, cur.getSummary(), cur.getUser(), root, cur.getFullVersion(), cur.getId()); |
| 0 | 115 result.add(md); |
| 116 prev = cur; | |
| 117 } | |
| 118 | |
| 119 return result; | |
| 120 } | |
| 121 | |
| 122 private List<VcsChange> toVcsChanges(final List<ModifiedFile> modifiedFiles, String prevVer, String curVer, final IncludeRule includeRule) { | |
| 123 List<VcsChange> files = new ArrayList<VcsChange>(); | |
| 124 for (ModifiedFile mf: modifiedFiles) { | |
| 21 | 125 String normalizedPath = PathUtil.normalizeSeparator(mf.getPath()); |
| 12 | 126 if (!normalizedPath.startsWith(includeRule.getFrom())) continue; // skip files which do not match include rule |
| 0 | 127 |
| 128 VcsChangeInfo.Type changeType = getChangeType(mf.getStatus()); | |
| 129 if (changeType == null) { | |
| 130 Loggers.VCS.warn("Unable to convert status: " + mf.getStatus() + " to VCS change type"); | |
| 131 changeType = VcsChangeInfo.Type.NOT_CHANGED; | |
| 132 } | |
| 12 | 133 files.add(new VcsChange(changeType, mf.getStatus().getName(), normalizedPath, normalizedPath, prevVer, curVer)); |
| 0 | 134 } |
| 135 return files; | |
| 136 } | |
| 137 | |
| 138 private VcsChangeInfo.Type getChangeType(final ModifiedFile.Status status) { | |
| 139 switch (status) { | |
| 140 case ADDED:return VcsChangeInfo.Type.ADDED; | |
| 141 case MODIFIED:return VcsChangeInfo.Type.CHANGED; | |
| 142 case REMOVED:return VcsChangeInfo.Type.REMOVED; | |
| 143 } | |
| 144 return null; | |
| 145 } | |
| 146 | |
| 147 @NotNull | |
| 148 public byte[] getContent(final VcsModification vcsModification, | |
| 149 final VcsChangeInfo change, | |
| 150 final VcsChangeInfo.ContentType contentType, | |
| 151 final VcsRoot vcsRoot) throws VcsException { | |
| 44 | 152 syncClonedRepository(vcsRoot); |
| 12 | 153 String version = contentType == VcsChangeInfo.ContentType.AFTER_CHANGE ? change.getAfterChangeRevisionNumber() : change.getBeforeChangeRevisionNumber(); |
| 154 return getContent(change.getRelativeFileName(), vcsRoot, version); | |
| 0 | 155 } |
| 156 | |
| 157 @NotNull | |
| 12 | 158 public byte[] getContent(final String filePath, final VcsRoot vcsRoot, final String version) throws VcsException { |
| 44 | 159 syncClonedRepository(vcsRoot); |
| 160 Settings settings = createSettings(vcsRoot); | |
| 12 | 161 CatCommand cc = new CatCommand(settings); |
|
59
30cc10fe9479
accept version in two formats: with rev number and without
Pavel.Sher
parents:
58
diff
changeset
|
162 cc.setRevId(new ChangeSet(version).getId()); |
| 12 | 163 File parentDir = cc.execute(Collections.singletonList(filePath)); |
| 30 | 164 try { |
| 165 File file = new File(parentDir, filePath); | |
| 166 if (file.isFile()) { | |
| 167 try { | |
| 168 return FileUtil.loadFileBytes(file); | |
| 169 } catch (IOException e) { | |
| 170 throw new VcsException("Failed to load content of file: " + file.getAbsolutePath(), e); | |
| 171 } | |
| 172 } else { | |
| 173 Loggers.VCS.warn("Unable to obtain content of the file: " + filePath); | |
| 12 | 174 } |
| 30 | 175 } finally { |
| 176 FileUtil.delete(parentDir); | |
| 12 | 177 } |
| 0 | 178 return new byte[0]; |
| 179 } | |
| 180 | |
| 181 public String getName() { | |
|
28
a7cab5083ada
libraries moved on top level, dummy implementation of agent side checkout interface
Pavel.Sher
parents:
27
diff
changeset
|
182 return Constants.VCS_NAME; |
| 0 | 183 } |
| 184 | |
| 185 @Used("jsp") | |
| 186 public String getDisplayName() { | |
| 187 return "Mercurial"; | |
| 188 } | |
| 189 | |
| 190 @Nullable | |
| 191 public PropertiesProcessor getVcsPropertiesProcessor() { | |
| 192 return new AbstractVcsPropertiesProcessor() { | |
| 193 public Collection<InvalidProperty> process(final Map<String, String> properties) { | |
| 194 List<InvalidProperty> result = new ArrayList<InvalidProperty>(); | |
| 195 if (isEmpty(properties.get(Constants.HG_COMMAND_PATH_PROP))) { | |
| 196 result.add(new InvalidProperty(Constants.HG_COMMAND_PATH_PROP, "Path to 'hg' command must be specified")); | |
| 197 } | |
| 198 if (isEmpty(properties.get(Constants.REPOSITORY_PROP))) { | |
| 199 result.add(new InvalidProperty(Constants.REPOSITORY_PROP, "Repository must be specified")); | |
| 200 } | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
201 if (isEmpty(properties.get(Constants.SERVER_CLONE_PATH_PROP))) { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
202 properties.put(Constants.SERVER_CLONE_PATH_PROP, myDefaultWorkFolderParent.getAbsolutePath()); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
203 } |
| 0 | 204 return result; |
| 205 } | |
| 206 }; | |
| 207 } | |
| 208 | |
| 209 public String getVcsSettingsJspFilePath() { | |
| 210 return "mercurialSettings.jsp"; | |
| 211 } | |
| 212 | |
| 213 @NotNull | |
| 214 public String getCurrentVersion(final VcsRoot root) throws VcsException { | |
| 19 | 215 // we will return full version of the most recent change as current version |
| 44 | 216 syncClonedRepository(root); |
| 217 Settings settings = createSettings(root); | |
| 57 | 218 BranchesCommand branches = new BranchesCommand(settings); |
| 219 Map<String, ChangeSet> result = branches.execute(); | |
| 220 if (!result.containsKey(settings.getBranchName())) { | |
| 221 throw new VcsException("Unable to find current version for the branch: " + settings.getBranchName()); | |
| 222 } | |
| 223 | |
| 224 return result.get(settings.getBranchName()).getFullVersion(); | |
| 0 | 225 } |
| 226 | |
| 227 public String describeVcsRoot(final VcsRoot vcsRoot) { | |
| 228 return "mercurial: " + vcsRoot.getProperty(Constants.REPOSITORY_PROP); | |
| 229 } | |
| 230 | |
| 231 public boolean isTestConnectionSupported() { | |
|
16
7aa397165fa0
identify command added, test connection now uses identify command
Pavel.Sher
parents:
13
diff
changeset
|
232 return true; |
| 0 | 233 } |
| 234 | |
| 235 @Nullable | |
| 236 public String testConnection(final VcsRoot vcsRoot) throws VcsException { | |
| 44 | 237 Settings settings = createSettings(vcsRoot); |
|
16
7aa397165fa0
identify command added, test connection now uses identify command
Pavel.Sher
parents:
13
diff
changeset
|
238 IdentifyCommand id = new IdentifyCommand(settings); |
|
7aa397165fa0
identify command added, test connection now uses identify command
Pavel.Sher
parents:
13
diff
changeset
|
239 StringBuilder res = new StringBuilder(); |
| 17 | 240 res.append(quoteIfNeeded(settings.getHgCommandPath())); |
| 241 res.append(" identify "); | |
| 71 | 242 final String obfuscatedUrl = CommandUtil.removePrivateData(settings.getRepositoryUrl(), Collections.singleton(settings.getPassword())); |
| 243 res.append(quoteIfNeeded(obfuscatedUrl)); | |
|
16
7aa397165fa0
identify command added, test connection now uses identify command
Pavel.Sher
parents:
13
diff
changeset
|
244 res.append('\n').append(id.execute()); |
|
7aa397165fa0
identify command added, test connection now uses identify command
Pavel.Sher
parents:
13
diff
changeset
|
245 return res.toString(); |
| 0 | 246 } |
| 247 | |
| 17 | 248 private String quoteIfNeeded(@NotNull String str) { |
| 249 if (str.indexOf(' ') != -1) { | |
| 250 return "\"" + str + "\""; | |
| 251 } | |
| 252 | |
| 253 return str; | |
| 254 } | |
| 255 | |
| 0 | 256 @Nullable |
| 257 public Map<String, String> getDefaultVcsProperties() { | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
258 Map<String, String> defaults = new HashMap<String, String>(); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
259 defaults.put(Constants.HG_COMMAND_PATH_PROP, "hg"); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
260 defaults.put(Constants.SERVER_CLONE_PATH_PROP, myDefaultWorkFolderParent.getAbsolutePath()); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
261 return defaults; |
| 0 | 262 } |
| 263 | |
| 264 public String getVersionDisplayName(final String version, final VcsRoot root) throws VcsException { | |
|
59
30cc10fe9479
accept version in two formats: with rev number and without
Pavel.Sher
parents:
58
diff
changeset
|
265 return new ChangeSet(version).getId(); |
| 0 | 266 } |
| 267 | |
| 268 @NotNull | |
| 269 public Comparator<String> getVersionComparator() { | |
| 19 | 270 // comparator is called when TeamCity needs to sort modifications in the order of their appearance, |
| 271 // currently we sort changes by revision number, not sure however that this is a good idea, | |
| 272 // probably it would be better to sort them by timestamp (and to add timestamp into the version). | |
| 0 | 273 return new Comparator<String>() { |
| 274 public int compare(final String o1, final String o2) { | |
| 275 try { | |
| 276 return new ChangeSet(o1).getRevNumber() - new ChangeSet(o2).getRevNumber(); | |
| 277 } catch (Exception e) { | |
| 278 return 1; | |
| 279 } | |
| 280 } | |
| 281 }; | |
| 282 } | |
| 283 | |
| 284 public void buildPatch(final VcsRoot root, | |
| 285 @Nullable final String fromVersion, | |
| 286 @NotNull final String toVersion, | |
| 287 final PatchBuilder builder, | |
| 288 final CheckoutRules checkoutRules) throws IOException, VcsException { | |
| 44 | 289 syncClonedRepository(root); |
| 290 Settings settings = createSettings(root); | |
| 0 | 291 if (fromVersion == null) { |
| 292 buildFullPatch(settings, new ChangeSet(toVersion), builder); | |
| 293 } else { | |
| 294 buildIncrementalPatch(settings, new ChangeSet(fromVersion), new ChangeSet(toVersion), builder); | |
| 295 } | |
| 296 } | |
| 297 | |
| 19 | 298 // builds patch from version to version |
| 0 | 299 private void buildIncrementalPatch(final Settings settings, @NotNull final ChangeSet fromVer, @NotNull final ChangeSet toVer, final PatchBuilder builder) |
| 300 throws VcsException, IOException { | |
| 301 StatusCommand st = new StatusCommand(settings); | |
| 302 st.setFromRevId(fromVer.getId()); | |
| 303 st.setToRevId(toVer.getId()); | |
| 304 List<ModifiedFile> modifiedFiles = st.execute(); | |
| 305 List<String> notDeletedFiles = new ArrayList<String>(); | |
| 306 for (ModifiedFile f: modifiedFiles) { | |
| 307 if (f.getStatus() != ModifiedFile.Status.REMOVED) { | |
| 308 notDeletedFiles.add(f.getPath()); | |
| 309 } | |
| 310 } | |
| 311 | |
|
47
c785bc4c5f39
minor fix: do not call cat command if there are no files to export
Pavel.Sher
parents:
46
diff
changeset
|
312 if (notDeletedFiles.isEmpty()) return; |
|
c785bc4c5f39
minor fix: do not call cat command if there are no files to export
Pavel.Sher
parents:
46
diff
changeset
|
313 |
| 0 | 314 CatCommand cc = new CatCommand(settings); |
| 315 cc.setRevId(toVer.getId()); | |
| 316 File parentDir = cc.execute(notDeletedFiles); | |
| 317 | |
| 318 try { | |
| 319 for (ModifiedFile f: modifiedFiles) { | |
| 320 final File virtualFile = new File(f.getPath()); | |
| 321 if (f.getStatus() == ModifiedFile.Status.REMOVED) { | |
| 322 builder.deleteFile(virtualFile, true); | |
| 323 } else { | |
| 324 File realFile = new File(parentDir, f.getPath()); | |
| 325 FileInputStream is = new FileInputStream(realFile); | |
| 326 try { | |
| 11 | 327 builder.changeOrCreateBinaryFile(virtualFile, null, is, realFile.length()); |
| 0 | 328 } finally { |
| 329 is.close(); | |
| 330 } | |
| 331 } | |
| 332 } | |
| 333 } finally { | |
| 334 FileUtil.delete(parentDir); | |
| 335 } | |
| 336 } | |
| 337 | |
| 19 | 338 // builds patch by exporting files using specified version |
| 0 | 339 private void buildFullPatch(final Settings settings, @NotNull final ChangeSet toVer, final PatchBuilder builder) |
| 340 throws IOException, VcsException { | |
| 341 CloneCommand cl = new CloneCommand(settings); | |
| 57 | 342 // clone from the local repository |
|
67
e6971dc6b17c
always use url with credentials if username/password are specified
Pavel.Sher
parents:
62
diff
changeset
|
343 cl.setRepository(settings.getLocalRepositoryDir().getAbsolutePath()); |
| 0 | 344 cl.setToId(toVer.getId()); |
| 57 | 345 cl.setUpdateWorkingDir(false); |
| 0 | 346 File tempDir = FileUtil.createTempDirectory("mercurial", toVer.getId()); |
| 347 try { | |
| 348 final File repRoot = new File(tempDir, "rep"); | |
| 349 cl.setDestDir(repRoot.getAbsolutePath()); | |
| 350 cl.execute(); | |
| 57 | 351 |
| 352 UpdateCommand up = new UpdateCommand(settings); | |
| 353 up.setWorkDirectory(repRoot.getAbsolutePath()); | |
| 354 up.setToId(toVer.getId()); | |
| 355 up.execute(); | |
| 356 | |
| 0 | 357 buildPatchFromDirectory(builder, repRoot, new FileFilter() { |
| 358 public boolean accept(final File file) { | |
| 359 return !(file.isDirectory() && ".hg".equals(file.getName())); | |
| 360 } | |
| 361 }); | |
| 362 } finally { | |
| 363 FileUtil.delete(tempDir); | |
| 364 } | |
| 365 } | |
| 366 | |
| 367 private void buildPatchFromDirectory(final PatchBuilder builder, final File repRoot, final FileFilter filter) throws IOException { | |
| 368 buildPatchFromDirectory(repRoot, builder, repRoot, filter); | |
| 369 } | |
| 370 | |
| 371 private void buildPatchFromDirectory(File curDir, final PatchBuilder builder, final File repRoot, final FileFilter filter) throws IOException { | |
| 372 File[] files = curDir.listFiles(filter); | |
| 373 if (files != null) { | |
| 374 for (File realFile: files) { | |
| 375 String relPath = realFile.getAbsolutePath().substring(repRoot.getAbsolutePath().length()); | |
| 376 final File virtualFile = new File(relPath); | |
| 377 if (realFile.isDirectory()) { | |
| 378 builder.createDirectory(virtualFile); | |
| 379 buildPatchFromDirectory(realFile, builder, repRoot, filter); | |
| 380 } else { | |
| 381 final FileInputStream is = new FileInputStream(realFile); | |
| 382 try { | |
| 383 builder.createBinaryFile(virtualFile, null, is, realFile.length()); | |
| 384 } finally { | |
| 385 is.close(); | |
| 386 } | |
| 387 } | |
| 388 } | |
| 389 } | |
| 390 } | |
| 391 | |
| 19 | 392 // updates current working copy of repository by pulling changes from the repository specified in VCS root |
| 44 | 393 private void syncClonedRepository(final VcsRoot root) throws VcsException { |
| 394 Settings settings = createSettings(root); | |
| 57 | 395 File workDir = settings.getLocalRepositoryDir(); |
| 21 | 396 lockWorkDir(workDir); |
| 397 try { | |
| 29 | 398 if (settings.hasCopyOfRepository()) { |
| 0 | 399 // update |
| 8 | 400 PullCommand pull = new PullCommand(settings); |
| 401 pull.execute(); | |
| 0 | 402 } else { |
| 403 // clone | |
| 404 CloneCommand cl = new CloneCommand(settings); | |
| 22 | 405 cl.setDestDir(workDir.getAbsolutePath()); |
| 18 | 406 cl.setUpdateWorkingDir(false); |
| 0 | 407 cl.execute(); |
| 408 } | |
| 21 | 409 } finally { |
| 410 unlockWorkDir(workDir); | |
| 0 | 411 } |
| 412 } | |
| 413 | |
| 44 | 414 @Override |
| 415 public LabelingSupport getLabelingSupport() { | |
| 416 return this; | |
| 417 } | |
| 418 | |
| 22 | 419 private void lockWorkDir(@NotNull File workDir) { |
| 21 | 420 getWorkDirLock(workDir).lock(); |
| 421 } | |
| 422 | |
| 22 | 423 private void unlockWorkDir(@NotNull File workDir) { |
| 21 | 424 getWorkDirLock(workDir).unlock(); |
| 425 } | |
| 426 | |
| 31 | 427 @Override |
| 428 public boolean ignoreServerCachesFor(final VcsRoot root) { | |
| 429 // since a copy of repository for each VCS root is already stored on disk | |
| 430 // we do not need separate cache for our patches | |
| 431 return true; | |
| 432 } | |
| 433 | |
| 22 | 434 private Lock getWorkDirLock(final File workDir) { |
| 435 String path = workDir.getAbsolutePath(); | |
| 436 Lock lock = myWorkDirLocks.get(path); | |
| 21 | 437 if (lock == null) { |
| 438 lock = new ReentrantLock(); | |
| 22 | 439 Lock curLock = myWorkDirLocks.putIfAbsent(path, lock); |
| 21 | 440 if (curLock != null) { |
| 441 lock = curLock; | |
| 442 } | |
| 443 } | |
| 444 return lock; | |
| 445 } | |
| 446 | |
| 23 | 447 private void removeOldWorkFolders() { |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
448 File workFoldersParent = myDefaultWorkFolderParent; |
| 23 | 449 if (!workFoldersParent.isDirectory()) return; |
| 450 | |
| 451 Set<File> workDirs = new HashSet<File>(); | |
| 452 File[] files = workFoldersParent.listFiles(new FileFilter() { | |
| 453 public boolean accept(final File file) { | |
| 454 return file.isDirectory() && file.getName().startsWith(Settings.DEFAULT_WORK_DIR_PREFIX); | |
| 455 } | |
| 456 }); | |
| 457 if (files != null) { | |
| 458 for (File f: files) { | |
| 46 | 459 workDirs.add(PathUtil.getCanonicalFile(f)); |
| 23 | 460 } |
| 461 } | |
| 462 | |
| 463 for (VcsRoot vcsRoot: myVcsManager.getAllRegisteredVcsRoots()) { | |
| 464 if (getName().equals(vcsRoot.getVcsName())) { | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
465 try { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
466 Settings s = createSettings(vcsRoot); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
467 workDirs.remove(PathUtil.getCanonicalFile(s.getLocalRepositoryDir())); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
468 } catch (VcsException e) { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
469 Loggers.VCS.error(e); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
470 } |
| 23 | 471 } |
| 472 } | |
| 473 | |
| 474 for (File f: workDirs) { | |
| 475 lockWorkDir(f); | |
| 476 try { | |
| 477 FileUtil.delete(f); | |
| 478 } finally { | |
| 479 unlockWorkDir(f); | |
| 480 } | |
| 481 } | |
| 482 } | |
| 44 | 483 |
| 484 public String label(@NotNull String label, @NotNull String version, @NotNull VcsRoot root, @NotNull CheckoutRules checkoutRules) throws VcsException { | |
| 485 syncClonedRepository(root); | |
| 486 | |
| 487 Settings settings = createSettings(root); | |
| 488 | |
| 489 // I do not know why but hg tag does not work correctly if | |
| 490 // update command was not invoked for the current repo | |
| 491 // in such case if there were no tags before Mercurial attempts to | |
| 492 // create new head when tag is pushed to the parent repository | |
| 493 UpdateCommand uc = new UpdateCommand(settings); | |
| 494 uc.execute(); | |
| 495 | |
| 496 String fixedTagname = fixTagName(label); | |
| 497 TagCommand tc = new TagCommand(settings); | |
| 498 tc.setRevId(new ChangeSet(version).getId()); | |
| 499 tc.setTag(fixedTagname); | |
| 500 tc.execute(); | |
| 501 | |
| 502 PushCommand pc = new PushCommand(settings); | |
| 57 | 503 pc.setForce(true); |
| 44 | 504 pc.execute(); |
| 505 return fixedTagname; | |
| 506 } | |
| 507 | |
| 508 private String fixTagName(final String label) { | |
| 509 // according to Mercurial documentation http://hgbook.red-bean.com/hgbookch8.html#x12-1570008 | |
| 510 // tag name must not contain: | |
| 511 // Colon (ASCII 58, “:”) | |
| 512 // Carriage return (ASCII 13, “\r”) | |
| 513 // Newline (ASCII 10, “\n”) | |
| 514 // all these characters will be replaced with _ (underscore) | |
| 515 return label.replace(':', '_').replace('\r', '_').replace('\n', '_'); | |
| 516 } | |
| 517 | |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
518 private Settings createSettings(final VcsRoot root) throws VcsException { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
519 Settings settings = new Settings(myDefaultWorkFolderParent, root); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
520 String customClonePath = root.getProperty(Constants.SERVER_CLONE_PATH_PROP); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
521 if (!StringUtil.isEmptyOrSpaces(customClonePath) && !myDefaultWorkFolderParent.equals(new File(customClonePath).getAbsoluteFile())) { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
522 File parentDir = new File(customClonePath); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
523 createClonedRepositoryParentDir(parentDir); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
524 |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
525 // take last part of repository path |
|
67
e6971dc6b17c
always use url with credentials if username/password are specified
Pavel.Sher
parents:
62
diff
changeset
|
526 String repPath = settings.getRepositoryUrl(); |
|
62
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
527 String[] splitted = repPath.split("[/\\\\]"); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
528 if (splitted.length > 0) { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
529 repPath = splitted[splitted.length-1]; |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
530 } |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
531 |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
532 File customWorkingDir = new File(parentDir, repPath); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
533 settings.setWorkingDir(customWorkingDir); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
534 } else { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
535 createClonedRepositoryParentDir(myDefaultWorkFolderParent); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
536 } |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
537 return settings; |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
538 } |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
539 |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
540 private void createClonedRepositoryParentDir(final File parentDir) throws VcsException { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
541 if (!parentDir.exists() && !parentDir.mkdirs()) { |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
542 throw new VcsException("Failed to create parent directory for cloned repository: " + parentDir.getAbsolutePath()); |
|
b328c6b6526d
TW-5636: Mercurial plugin can easilly hit Windows MAX_PATH limitations
Pavel.Sher
parents:
59
diff
changeset
|
543 } |
| 44 | 544 } |
| 48 | 545 |
| 546 public boolean isAgentSideCheckoutAvailable() { | |
| 547 return true; | |
| 548 } | |
| 0 | 549 } |