import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    UIContext uiContext = context.getUIContext();
    Map<Object, Object> attributeMap = uiContext.getAttributeMap();

    List<GitClonedRepoDetails> clonedRepos = (List<GitClonedRepoDetails>) attributeMap.get(AttributeMapKeys.GIT_CLONED_REPOS);
    if (clonedRepos != null) {
        for (GitClonedRepoDetails clonedRepo : clonedRepos) {
            Git git = clonedRepo.getGit();
            String gitUrl = clonedRepo.getGitUrl();
            UserDetails userDetails = clonedRepo.getUserDetails();
            File basedir = clonedRepo.getDirectory();
            String message = "Adding pipeline";
            try {
                LOG.info("Performing a git commit and push on URI " + gitUrl);
                gitAddCommitAndPush(git, gitUrl, userDetails, basedir, message);
            } catch (GitAPIException e) {
                return Results.fail("Failed to commit and push repository " + clonedRepo.getGitRepoName() + " due to " + e, e);
            } finally {
                removeTemporaryFiles(basedir);
            }
        }
    }
    return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(final UIExecutionContext context) throws Exception
{
   final UIContext uiContext = context.getUIContext();
   applyUIValues(uiContext);

   // add driver dependency
   final Project project = helper.getProject(uiContext);
   final DatabaseType database = dbType.getValue();
   final Coordinate driverCoordinate = database.getDriverCoordinate();
   SpringBootHelper.addDependency(project, driverCoordinate.getGroupId(), driverCoordinate.getArtifactId())
            .setScopeType("runtime");
   SpringBootHelper.addSpringBootDependency(project, SpringBootFacet.SPRING_BOOT_STARTER_DATA_JPA_ARTIFACT)
            .setScopeType("runtime");

   return Results.success("Spring Boot JPA successfully set up!");
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public NavigationResult next(UINavigationContext context) throws Exception
{
   applyUIValues(context.getUIContext());

   final DatabaseType database = dbType.getValue();
   if (!isNotEmbeddedDB(database))
   {
      return Results.navigateTo(FinishJPASetupCommand.class);
   }
   else
   {
      if (dataSourceName.hasValue())
      {
         // if we specified a datasource, use it
         return Results.navigateTo(AddJNDIDatasourceCommand.class);
      }
      else
      {
         // otherwise, we're using the DB URL, so deal with it
         return Results.navigateTo(AddDBURLCommand.class);
      }
   }
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    String buildConfigName = buildName.getValue();
    Objects.assertNotNull(buildConfigName, "buildName");
    Map<String, String> labels = BuildConfigs.createBuildLabels(buildConfigName);
    String gitUrlText = getOrFindGitUrl(context, gitUri.getValue());
    String imageText = image.getValue();
    List<EnvVar> envVars = createEnvVars(buildConfigName, gitUrlText, mavenCommand.getValue());
    BuildConfig buildConfig = BuildConfigs.createIntegrationTestBuildConfig(buildConfigName, labels, gitUrlText, imageText, envVars);

    LOG.info("Generated BuildConfig: " + toJson(buildConfig));

    ImageStream imageRepository = BuildConfigs.imageRepository(buildConfigName, labels);

    Controller controller = createController();
    controller.applyImageStream(imageRepository, "generated ImageStream: " + toJson(imageRepository));
    controller.applyBuildConfig(buildConfig, "generated BuildConfig: " + toJson(buildConfig));
    return Results.success("Added BuildConfig: " + Builds.getName(buildConfig) + " to OpenShift at master: " + getKubernetes().getMasterUrl());
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    StopWatch watch = new StopWatch();

    log.debug("Starting to setup fabric8 project");

    Project project = getSelectedProject(context.getUIContext());
    if (project == null) {
        return Results.fail("No pom.xml available so cannot edit the project!");
    }

    // setup fabric8-maven-plugin
    setupFabricMavenPlugin(project);
    log.debug("fabric8-maven-plugin now setup");

    // make sure we have resources as we need it later
    facetFactory.install(project, ResourcesFacet.class);

    log.info("execute took " + watch.taken());
    return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
public static Result ensureCamelArtifactIdAdded(Project project, CamelComponentDetails details, DependencyInstaller dependencyInstaller) {
    String groupId = details.getGroupId();
    String artifactId = details.getArtifactId();
    Dependency core = CamelProjectHelper.findCamelCoreDependency(project);
    if (core == null) {
        return Results.fail("The project does not include camel-core");
    }

    // we want to use same version as camel-core if its a camel component
    // otherwise use the version from the dto
    String version;
    if ("org.apache.camel".equals(groupId)) {
        version = core.getCoordinate().getVersion();
    } else {
        version = details.getVersion();
    }
    DependencyBuilder component = DependencyBuilder.create().setGroupId(groupId)
            .setArtifactId(artifactId).setVersion(version);

    // install the component
    dependencyInstaller.install(project, component);
    return null;
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
private Result editEndpointXml(List<String> lines, String lineNumber, String endpointUrl, String uri, FileResource file, String xml) {
    // the list is 0-based, and line number is 1-based
    int idx = Integer.valueOf(lineNumber) - 1;
    String line = lines.get(idx);

    // replace uri with new value
    line = StringHelper.replaceAll(line, endpointUrl, uri);
    lines.set(idx, line);

    LOG.info("Updating " + endpointUrl + " to " + uri + " at line " + lineNumber + " in file " + xml);

    // and save the file back
    String content = LineNumberHelper.linesToString(lines);
    file.setContents(content);

    return Results.success("Update endpoint uri: " + uri + " in file " + xml);
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
protected Result editEndpointOther(Project project, ResourcesFacet facet, FileResource file, String uri, String endpointUrl,
                                  String currentFile, String lineNumber) throws Exception {

    List<String> lines = LineNumberHelper.readLines(file.getResourceInputStream());

    // the list is 0-based, and line number is 1-based
    int idx = Integer.valueOf(lineNumber) - 1;
    String line = lines.get(idx);

    // replace uri with new value
    line = StringHelper.replaceAll(line, endpointUrl, uri);
    lines.set(idx, line);

    LOG.info("Updating " + endpointUrl + " to " + uri + " at line " + lineNumber + " in file " + currentFile);

    // and save the file back
    String content = LineNumberHelper.linesToString(lines);
    file.setContents(content);

    return Results.success("Update endpoint uri: " + uri + " in file " + currentFile);
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    String url = getJolokiaUrl();
    if (url == null) {
        return Results.fail("Not connected to remote jolokia agent. Use camel-connect command first");
    }

    boolean val = "true".equals(decode.getValue());
    String[] val2 = null;
    if (filter.getValue() != null) {
        String s = filter.getValue().toString();
        val2 = s.split(",");
    }

    org.apache.camel.commands.EndpointStatisticCommand command = new org.apache.camel.commands.EndpointStatisticCommand(name.getValue(), val, val2);
    command.execute(getController(), getOutput(context), getError(context));

    return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext uiExecutionContext) throws Exception {
    configuration.setProperty("CamelJolokiaUrl", url.getValue());
    // username and password is optional
    configuration.setProperty("CamelJolokiaUsername", username.getValue());
    configuration.setProperty("CamelJolokiaPassword", password.getValue());

    // ping to see if the connection works
    JolokiaCamelController controller = new DefaultJolokiaCamelController();
    controller.connect(url.getValue(), username.getValue(), password.getValue());

    boolean ok = controller.ping();
    if (ok) {
        return Results.success("Connected to " + url.getValue() + (username.getValue() != null ? " using " + username.getValue() : ""));
    } else {
        return Results.fail("Error connecting to " + url.getValue());
    }
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    String url = getJolokiaUrl();
    if (url == null) {
        return Results.fail("Not connected to remote jolokia agent. Use camel-connect command first");
    }

    boolean val = "true".equals(decode.getValue());
    boolean val2 = "true".equals(verbose.getValue());
    boolean val3 = "true".equals(explain.getValue());

    org.apache.camel.commands.EndpointListCommand command = new org.apache.camel.commands.EndpointListCommand(name.getValue(), val, val2, val3);
    command.execute(getController(), getOutput(context), getError(context));

    return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext uiExecutionContext) throws Exception {
    String url = getJolokiaUrl();
    if (url == null) {
        return Results.fail("Not connected to remote jolokia agent. Use camel-connect command first");
    }

    String username = configuration.getString("CamelJolokiaUsername");

    JolokiaCamelController controller = getController();

    // ping to see if the connection works
    boolean ok = controller.ping();
    if (ok) {
        return Results.success("Connected to " + url + (username != null ? " using " + username : ""));
    } else {
        return Results.fail("Error connecting to " + url);
    }
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    String scheme = name.getValue();

    // maybe the connector has already been added to the catalog
    String json = camelCatalog.componentJSonSchema(scheme);
    if (json == null) {
        // discover classpath and find all the connectors and add them to the catalog
        Project project = getSelectedProjectOrNull(context.getUIContext());
        if (project != null) {
            discoverCustomCamelComponentsOnClasspathAndAddToCatalog(camelCatalog, project);
        }
        // load schema again
        json = camelCatalog.componentJSonSchema(scheme);
    }

    if (json != null) {
        return Results.success(json);
    } else {
        return Results.fail("Connector " + scheme + " not found");
    }
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
    String text = labels.getValue();

    if (text != null && !text.isEmpty()) {
        dto.setLabels(text.split(","));
    } else {
        dto.setLabels(null);
    }

    // marshal DTO
    String json = toJson(dto);

    // write the connector json file
    FileResource<?> fileResource = getCamelConnectorFile(context);
    fileResource.setContents(json);

    return Results.success("Updated labels on Connector: " + dto.getName());
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception
{
   ConnectionProfileManager manager = managerProvider.getConnectionProfileManager();
   if (connectionProfile != null)
   {
      ConnectionProfile connection = manager.loadConnectionProfiles().get(connectionProfile.getValue());
      if (!connection.isSavePassword())
      {
         String password = connectionProfilePassword.getValue();
         if (password == null)
            password = "";
         connection.setPassword(password);
      }
      Project selectedProj = getSelectedProject(context);
      if (selectedProj.getFacet(DatabaseMigrationFacet.class).isInstalled())
         selectedProj.getFacet(DatabaseMigrationFacet.class).setPropertiesFile(connection);
   }
   return Results
            .success("Properties stored!");
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception
{
   Project selectedProj = getSelectedProject(context);
   ChangeLogFileGenerator generator = new ChangeLogFileGenerator(selectedProj);

   String mode = generationMode.getValue();
   if (mode.equals(Constants.MODE_EMPTY_CHANGELOG))
   {
      generator.generateEmptyMasterChangeLog();
   }
   else
   {
      //generator.generateChangeLogFromDatabase();
   }
   return Results
            .success("Master ChangeLog File has been created");
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext executionContext) throws Exception
{
   UIProvider provider = executionContext.getUIContext().getProvider();
   UIOutput output = provider.getOutput();
   PrintStream out = output.out();
   for (FractionDescriptor fraction : WildFlySwarmFacet.getAllFractionDescriptors())
   {
      if (!fraction.isInternal())
      {
         String msg = String.format("%s: %s (%s)", fraction.getArtifactId(), fraction.getName(),
                  fraction.getDescription());
         out.println(msg);
      }
   }
   return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception
{
   Project project = getSelectedProject(context);
   UIOutput output = context.getUIContext().getProvider().getOutput();
   PackagingFacet packagingFacet = project.getFacet(PackagingFacet.class);
   try
   {
      packagingFacet.createBuilder().addArguments("wildfly-swarm:run").runTests(false).build(output.out(),
               output.err());
   }
   catch (BuildException ie)
   {
      if (!(ie.getCause() instanceof InterruptedException))
      {
         return Results.fail("Error while running the build", ie.getCause());
      }
   }
   return Results.success();
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception {
   Project project = getSelectedProject(context);

   final DependencyFacet dependencyFacet = project.getFacet(DependencyFacet.class);
   if (!isArquillianWildflySwarmDependencyInstalled(dependencyFacet)) {
      installArquillianWildflySwarmDependency(dependencyFacet);
   }

   JavaClassSource test = Roaster.create(JavaClassSource.class)
           .setPackage(targetPackage.getValue())
           .setName(named.getValue());

   addArquillianRunner(test);
   addDefaultDeploymentAnnotation(test, project);
   addArquillianResourceEnricher(test);
   addTestMethod(test);

   JavaSourceFacet facet = project.getFacet(JavaSourceFacet.class);
   facet.saveTestJavaSource(test);

   return Results.success(String.format("Test Class %s.%s was created", targetPackage.getValue(), named.getValue()));
}
 

import org.jboss.forge.addon.ui.result.Results; //导入依赖的package包/类
@Override
public Result execute(UIExecutionContext context) throws Exception
{
    Project project = getSelectedProject(context);
    WildFlySwarmFacet facet = project.getFacet(WildFlySwarmFacet.class);
    if (fractionElements.hasValue())
    {
        List<FractionDescriptor> fractions = Lists.toList(fractionElements.getValue());
        facet.installFractions(fractions);
        List<String> artifactIds = fractions.stream().map(FractionDescriptor::getArtifactId)
                    .collect(Collectors.toList());
        return Results.success("Wildfly Swarm Fractions '"
                    + artifactIds
                    + "' were successfully added to the project descriptor");
    }
    return Results.success();
}