1 /*
2 * #%L
3 * JavaHg
4 * %%
5 * Copyright (C) 2011 aragost Trifork ag
6 * %%
7 * Permission is hereby granted, free of charge, to any person obtaining a copy
8 * of this software and associated documentation files (the "Software"), to deal
9 * in the Software without restriction, including without limitation the rights
10 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
11 * copies of the Software, and to permit persons to whom the Software is
12 * furnished to do so, subject to the following conditions:
13 *
14 * The above copyright notice and this permission notice shall be included in
15 * all copies or substantial portions of the Software.
16 *
17 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
18 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
19 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
20 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
21 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
22 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
23 * THE SOFTWARE.
24 * #L%
25 */
26 package com.aragost.javahg.commands;
27
28 import java.io.File;
29 import java.util.List;
30
31 import com.aragost.javahg.Bundle;
32 import com.aragost.javahg.Changeset;
33 import com.aragost.javahg.Repository;
34 import com.aragost.javahg.commands.flags.IncomingCommandFlags;
35 import com.aragost.javahg.internals.HgInputStream;
36 import com.aragost.javahg.internals.Utils;
37
38 /**
39 * Command class for executing <tt>hg incoming</tt>. Set flags from
40 * {@link IncomingCommandFlags} and call the {@link #execute} method.
41 */
42 public class IncomingCommand extends IncomingCommandFlags {
43
44 private File bundleFile;
45
46 /**
47 * @param repository
48 * the repository associated with this command.
49 */
50 public IncomingCommand(Repository repository) {
51 super(repository);
52 withDebugAndChangesetStyle();
53 cmdAppend("-y");
54 }
55
56 @Override
57 public IncomingCommand bundle(String file) {
58 this.bundleFile = new File(file);
59 return this;
60 }
61
62 /**
63 * @param src
64 * the source repository.
65 * @return bundle with incoming changesets
66 */
67 public Bundle execute(String src) {
68 if (this.bundleFile == null) {
69 this.bundleFile = Utils.createTempFile(".bundle");
70 cmdAppend("--bundle", this.bundleFile.getPath());
71 }
72 HgInputStream stream = launchStream(src);
73 Bundle bundle = new Bundle(getRepository().getBaseRepository(), this.bundleFile, true);
74 List<Changeset> changesets = Changeset.readListFromStream(bundle.getOverlayRepository(), stream);
75 if (changesets.isEmpty()) {
76 bundle.close();
77 return null;
78 }
79 bundle.init(changesets);
80 return bundle;
81 }
82
83 public Bundle execute(File directory) {
84 return execute(directory.getPath());
85 }
86
87 public Bundle execute(Repository repository) {
88 return execute(repository.getDirectory());
89 }
90
91 @Override
92 public boolean isSuccessful() {
93 return super.isSuccessful() || getReturnCode() == 1;
94 }
95 }