Skip to content

G2-1757 Support dryrun for issue creation #17

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
gdgib merged 1 commit into from
May 24, 2025
Merged

G2-1757 Support dryrun for issue creation #17

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
73 changes: 38 additions & 35 deletions pj-create/src/main/java/com/g2forge/project/plan/create/Create.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -215,10 +215,10 @@ protected static void verifyChanges(final Changes changes) {

protected final Map<String, Map<String, BasicComponent>> projectComponentsCache = new LinkedHashMap<>();

public List<String> createIssues(IDataSource serverDataSource, IDataSource configDataSource) throws JsonParseException, JsonMappingException, IOException, URISyntaxException, InterruptedException, ExecutionException {
public Map<String, String> createIssues(IDataSource serverDataSource, IDataSource configDataSource) throws JsonParseException, JsonMappingException, IOException, URISyntaxException, InterruptedException, ExecutionException {
// Load the config, but if it's empty, don't bother
final CreateConfig config = HConfig.load(configDataSource, CreateConfig.class);
if ((config.getIssues() == null) || config.getIssues().isEmpty()) return Collections.emptyList();
if ((config.getIssues() == null) || config.getIssues().isEmpty()) return Collections.emptyMap();

// Load the server if one is specified;
final Server server = (serverDataSource != null) ? HConfig.load(serverDataSource, Server.class) : null;
Expand All @@ -245,7 +245,8 @@ protected Map<String, BasicComponent> getProjectComponents(final ExtendedJiraRes
});
}

protected List<String> implementChanges(Server server, Changes changes) throws IOException, URISyntaxException, InterruptedException, ExecutionException {
protected Map<String, String> implementChanges(Server server, Changes changes) throws IOException, URISyntaxException, InterruptedException, ExecutionException {
final boolean dryrun = ProjectCreateFlag.DRYRUN.getAccessor().get();
HLog.getLogControl().setLogLevel(Level.INFO);
try (final ExtendedJiraRestClient client = JiraAPI.createFromPropertyInput(server == null ? null : server.getApi(), null).connect(true)) {
final Map<String, LinkType> linkTypes = new HashMap<>();
Expand Down Expand Up @@ -283,51 +284,54 @@ protected List<String> implementChanges(Server server, Changes changes) throws I
}
if ((issue.getLabels() != null) && !issue.getLabels().isEmpty()) builder.setFieldInput(new FieldInput(IssueFieldId.LABELS_FIELD, issue.getLabels()));

BasicIssue created = null;
{
final List<Throwable> throwables = new ArrayList<>();
for (int i = 0; i < 5; i++) {
final Promise<BasicIssue> promise = issueClient.createIssue(builder.build());
try {
created = promise.get();
} catch (ExecutionException e) {
throwables.add(e);
continue;
if (dryrun) issues.put(issue.getSummary(), "DRYRUN");
else {
BasicIssue created = null;
{
final List<Throwable> throwables = new ArrayList<>();
for (int i = 0; i < 5; i++) {
final Promise<BasicIssue> promise = issueClient.createIssue(builder.build());
try {
created = promise.get();
} catch (ExecutionException e) {
throwables.add(e);
continue;
}
issues.put(issue.getSummary(), created.getKey());
throwables.clear();
break;
}
issues.put(issue.getSummary(), created.getKey());
throwables.clear();
break;
if (!throwables.isEmpty()) HError.withSuppressed(new RuntimeException(String.format("Failed to create issue: %1$s", issue.getSummary())), throwables).printStackTrace(System.err);
}
if (!throwables.isEmpty()) HError.withSuppressed(new RuntimeException(String.format("Failed to create issue: %1$s", issue.getSummary())), throwables).printStackTrace(System.err);
}

final String transitionName = issue.getTransition();
if (transitionName != null) {
final List<Throwable> throwables = new ArrayList<>();
for (int i = 0; i < 5; i++) {
try {
final Issue actualIssue = issueClient.getIssue(created.getKey()).get();
final Iterable<Transition> transitions = issueClient.getTransitions(actualIssue).get();
final Transition transition = StreamSupport.stream(transitions.spliterator(), false).filter(t -> Objects.equal(t.getName(), transitionName)).findFirst().orElse(null);
issueClient.transition(actualIssue, new TransitionInput(transition.getId())).get();
} catch (ExecutionException e) {
throwables.add(e);
continue;
final String transitionName = issue.getTransition();
if (transitionName != null) {
final List<Throwable> throwables = new ArrayList<>();
for (int i = 0; i < 5; i++) {
try {
final Issue actualIssue = issueClient.getIssue(created.getKey()).get();
final Iterable<Transition> transitions = issueClient.getTransitions(actualIssue).get();
final Transition transition = StreamSupport.stream(transitions.spliterator(), false).filter(t -> Objects.equal(t.getName(), transitionName)).findFirst().orElse(null);
issueClient.transition(actualIssue, new TransitionInput(transition.getId())).get();
} catch (ExecutionException e) {
throwables.add(e);
continue;
}
}
if (!throwables.isEmpty()) HError.withSuppressed(new RuntimeException(String.format("Failed to transition issue: %1$s %2$s", created.getKey(), issue.getSummary())), throwables).printStackTrace(System.err);
}
if (!throwables.isEmpty()) HError.withSuppressed(new RuntimeException(String.format("Failed to transition issue: %1$s %2$s", created.getKey(), issue.getSummary())), throwables).printStackTrace(System.err);
}
}

for (LinkIssuesInput link : changes.getLinks()) {
if (!dryrun) for (LinkIssuesInput link : changes.getLinks()) {
final LinkType linkType = linkTypes.get(link.getLinkType());
final String from = issues.get(link.getFromIssueKey());
final String to = issues.getOrDefault(link.getToIssueKey(), link.getToIssueKey());
// TODO: Handle it when an issue we're linking wasn't created
issueClient.linkIssue(new LinkIssuesInput(linkType.isReverse() ? to : from, linkType.isReverse() ? from : to, linkType.getName(), link.getComment())).get();
}

return new ArrayList<>(issues.values());
return issues;
}
}

Expand All @@ -337,8 +341,7 @@ public IExit invoke(CommandInvocation<InputStream, PrintStream> invocation) thro
final boolean hasServer = invocation.getArguments().size() > 1;
final IDataSource server = hasServer ? new PathDataSource(Paths.get(invocation.getArguments().get(0))) : null;
final IDataSource config = new PathDataSource(Paths.get(invocation.getArguments().get(hasServer ? 1 : 0)));
createIssues(server, config).forEach(System.out::println);
createIssues(server, config).entrySet().forEach(entry -> System.out.println(String.format("%1$s %2$s", entry.getValue(), entry.getKey())));
return IStandardCommand.SUCCESS;
}

}
12 changes: 12 additions & 0 deletions pj-create/src/main/java/com/g2forge/project/plan/create/ProjectCreateFlag.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
package com.g2forge.project.plan.create;

import com.g2forge.alexandria.java.core.properties.IKnownPropertyBoolean;

public enum ProjectCreateFlag implements IKnownPropertyBoolean {
DRYRUN {
@Override
public Boolean getDefault() {
return false;
}
};
}