import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
/**
 * Check the validity of the supplied repository fields. It does a syntax
 * check. It does not check if the repository is available. It checks if the
 * repository contains unwanted fields.
 *
 * NOTE: A package in Go is the repository from Docker.
 *
 * @param repositoryConfiguration
 * @return ValidationResult
 */
@Override
public ValidationResult isRepositoryConfigurationValid(
        final RepositoryConfiguration repositoryConfiguration) {

    LOG.info("Validating repository: " + repositoryConfiguration.get(Constants.REGISTRY).getValue());
    ValidationResult validationResult = new ValidationResult();
    this.validateKeys(getRepositoryConfiguration(), repositoryConfiguration, validationResult);

    Property registry = repositoryConfiguration.get(Constants.REGISTRY);
    if (registry == null) {
        validationResult.addError(new ValidationError(Constants.REGISTRY, "Registry url not specified"));
        return validationResult;
    }

    DockerRegistry.getInstance(registry.getValue()).validate(validationResult);
    return validationResult;
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldConstructPackageConfigurationFromApiRepositoryConfiguration() throws Exception {

    RepositoryConfiguration configuration = new RepositoryConfiguration();
    configuration.add(new PackageMaterialProperty("k1", "v1").with(Property.SECURE, Boolean.TRUE));

    PackageConfigurations packageConfigurations = new PackageConfigurations(configuration);
    assertThat(packageConfigurations.list().size(), is(1));
    assertThat(packageConfigurations.list().get(0).getKey(), is("k1"));
    assertThat(packageConfigurations.list().get(0).getValue(), is("v1"));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.REQUIRED), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.PART_OF_IDENTITY), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.SECURE), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.DISPLAY_NAME), is(""));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldConstructPackageConfigurationFromApiPackageConfiguration() throws Exception {

    com.thoughtworks.go.plugin.api.material.packagerepository.PackageConfiguration configuration = new com.thoughtworks.go.plugin.api.material.packagerepository.PackageConfiguration();
    configuration.add(new PackageMaterialProperty("k1", "v1").with(Property.SECURE, Boolean.TRUE));

    PackageConfigurations packageConfigurations = new PackageConfigurations(configuration);
    assertThat(packageConfigurations.list().size(), is(1));
    assertThat(packageConfigurations.list().get(0).getKey(), is("k1"));
    assertThat(packageConfigurations.list().get(0).getValue(), is("v1"));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.REQUIRED), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.PART_OF_IDENTITY), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.SECURE), is(true));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.DISPLAY_NAME), is(""));
    assertThat(packageConfigurations.list().get(0).getOption(PackageConfiguration.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldConstructSCMConfiguration() throws Exception {
    SCMPropertyConfiguration scmPropertyConfiguration = new SCMPropertyConfiguration();
    scmPropertyConfiguration.add(new SCMProperty("k1", "v1").with(Property.SECURE, Boolean.TRUE));

    SCMConfigurations scmConfigurations = new SCMConfigurations(scmPropertyConfiguration);

    assertThat(scmConfigurations.list().size(), is(1));
    SCMConfiguration scmConfiguration = scmConfigurations.list().get(0);
    assertThat(scmConfiguration.getKey(), is("k1"));
    assertThat(scmConfiguration.getValue(), is("v1"));
    assertThat(scmConfiguration.getOption(SCMConfiguration.REQUIRED), is(true));
    assertThat(scmConfiguration.getOption(SCMConfiguration.PART_OF_IDENTITY), is(true));
    assertThat(scmConfiguration.getOption(SCMConfiguration.SECURE), is(true));
    assertThat(scmConfiguration.getOption(SCMConfiguration.DISPLAY_NAME), is(""));
    assertThat(scmConfiguration.getOption(SCMConfiguration.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void validateSCMPropertyDefaults() throws Exception {
    SCMProperty scmProperty = new SCMProperty("Test-Property");

    assertThat(scmProperty.getOptions().size(), is(5));
    assertThat(scmProperty.getOption(Property.REQUIRED), is(true));
    assertThat(scmProperty.getOption(Property.PART_OF_IDENTITY), is(true));
    assertThat(scmProperty.getOption(Property.SECURE), is(false));
    assertThat(scmProperty.getOption(Property.DISPLAY_NAME), is(""));
    assertThat(scmProperty.getOption(Property.DISPLAY_ORDER), is(0));

    scmProperty = new SCMProperty("Test-Property", "Dummy Value");

    assertThat(scmProperty.getOptions().size(), is(5));
    assertThat(scmProperty.getOption(Property.REQUIRED), is(true));
    assertThat(scmProperty.getOption(Property.PART_OF_IDENTITY), is(true));
    assertThat(scmProperty.getOption(Property.SECURE), is(false));
    assertThat(scmProperty.getOption(Property.DISPLAY_NAME), is(""));
    assertThat(scmProperty.getOption(Property.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    extension = mock(PackageRepositoryExtension.class);

    com.thoughtworks.go.plugin.api.material.packagerepository.PackageConfiguration packageSettings = new com.thoughtworks.go.plugin.api.material.packagerepository.PackageConfiguration();
    packageSettings.add(new PackageMaterialProperty("username", null).with(Property.REQUIRED, true).with(Property.SECURE, false).with(Property.PART_OF_IDENTITY, false).with(Property.DISPLAY_NAME, "foo").with(Property.DISPLAY_ORDER, 1));
    packageSettings.add(new PackageMaterialProperty("password", null).with(Property.REQUIRED, true).with(Property.SECURE, true).with(Property.DISPLAY_ORDER, 2));

    RepositoryConfiguration repoSettings = new RepositoryConfiguration();
    repoSettings.add(new PackageMaterialProperty("foo", null).with(Property.REQUIRED, true).with(Property.SECURE, false).with(Property.DISPLAY_ORDER, 1));
    repoSettings.add(new PackageMaterialProperty("bar", null).with(Property.REQUIRED, true).with(Property.SECURE, true).with(Property.DISPLAY_ORDER, 2));

    stub(extension.getPackageConfiguration("plugin1")).toReturn(packageSettings);
    stub(extension.getRepositoryConfiguration("plugin1")).toReturn(repoSettings);
    stub(extension.getPluginSettingsView("plugin1")).toReturn("some-html");
    PluginSettingsConfiguration pluginSettingsConfiguration = new PluginSettingsConfiguration();
    pluginSettingsConfiguration.add(new PluginSettingsProperty("k1", null).with(Property.REQUIRED, true).with(Property.SECURE, false).with(Property.DISPLAY_ORDER, 3));
    stub(extension.getPluginSettingsConfiguration("plugin1")).toReturn(pluginSettingsConfiguration);
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
    extension = mock(SCMExtension.class);

    SCMPropertyConfiguration value = new SCMPropertyConfiguration();
    value.add(new SCMProperty("username", null).with(Property.REQUIRED, true).with(Property.SECURE, false).with(Property.PART_OF_IDENTITY, true).with(Property.DISPLAY_ORDER, 1));
    value.add(new SCMProperty("password", null).with(Property.REQUIRED, true).with(Property.SECURE, true).with(Property.PART_OF_IDENTITY, false).with(Property.DISPLAY_ORDER, 2));
    stub(extension.getSCMConfiguration("plugin1")).toReturn(value);
    stub(extension.getSCMView("plugin1")).toReturn(new SCMView() {
        @Override
        public String displayValue() {
            return "some scm plugin";
        }

        @Override
        public String template() {
            return "some html";
        }
    });
    PluginSettingsConfiguration pluginSettingsConfiguration = new PluginSettingsConfiguration();
    pluginSettingsConfiguration.add(new PluginSettingsProperty("k1", null).with(Property.REQUIRED, true).with(Property.SECURE, false).with(Property.DISPLAY_ORDER, 3));
    stub(extension.getPluginSettingsConfiguration("plugin1")).toReturn(pluginSettingsConfiguration);
    stub(extension.getPluginSettingsView("plugin1")).toReturn("settings view");
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
private TaskConfig config() {
    TaskConfig taskConfig = new TaskConfig();
    TaskConfigProperty p1 = new TaskConfigProperty("k1", "value1");
    p1.with(Property.DISPLAY_ORDER, 10);
    p1.with(Property.SECURE, true);
    p1.with(Property.DISPLAY_NAME, "display name for k1");
    p1.with(Property.REQUIRED, true);
    TaskConfigProperty p2 = new TaskConfigProperty("k2", "value1");
    p2.with(Property.DISPLAY_ORDER, 1);
    p2.with(Property.SECURE, false);
    p2.with(Property.DISPLAY_NAME, "display name for k2");
    p2.with(Property.REQUIRED, true);
    p2.with(Property.REQUIRED, true);
    taskConfig.add(p1);
    taskConfig.add(p2);
    return taskConfig;
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldConvertJsonResponseToValidationResultWhenValidationFails() {
    String jsonResponse = "{\"errors\":{\"key1\":\"err1\",\"key2\":\"err2\"}}";

    TaskConfig configuration = new TaskConfig();
    TaskConfigProperty property = new TaskConfigProperty("URL", "http://foo");
    property.with(Property.SECURE, false);
    property.with(Property.REQUIRED, true);
    configuration.add(property);

    ValidationResult result = new JsonBasedTaskExtensionHandler_V1().toValidationResult(jsonResponse);

    Assert.assertThat(result.isSuccessful(), CoreMatchers.is(false));


    ValidationError error1 = result.getErrors().get(0);
    ValidationError error2 = result.getErrors().get(1);

    Assert.assertThat(error1.getKey(), CoreMatchers.is("key1"));
    Assert.assertThat(error1.getMessage(), CoreMatchers.is("err1"));
    Assert.assertThat(error2.getKey(), CoreMatchers.is("key2"));
    Assert.assertThat(error2.getMessage(), CoreMatchers.is("err2"));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldBuildPluginInfoWithPluginSettingsConfiguration() throws Exception {
    GoPluginDescriptor descriptor = new GoPluginDescriptor("plugin1", null, null, null, null, false);
    PluginSettingsConfiguration value = new PluginSettingsConfiguration();
    value.add(new PluginSettingsProperty("username", null).with(Property.REQUIRED, true).with(Property.SECURE, false));
    value.add(new PluginSettingsProperty("password", null).with(Property.REQUIRED, true).with(Property.SECURE, true));

    stub(extension.getPluginSettingsConfiguration("plugin1")).toReturn(value);
    stub(extension.getPluginSettingsView("plugin1")).toReturn("some-html");

    AnalyticsPluginInfo pluginInfo = new AnalyticsPluginInfoBuilder(extension).pluginInfoFor(descriptor);

    List<PluginConfiguration> pluginConfigurations = Arrays.asList(
            new PluginConfiguration("username", new Metadata(true, false)),
            new PluginConfiguration("password", new Metadata(true, true))
    );
    PluginView pluginView = new PluginView("some-html");

    assertThat(pluginInfo.getDescriptor(), is(descriptor));
    assertThat(pluginInfo.getExtensionName(), is("analytics"));
    assertThat(pluginInfo.getPluginSettings(), is(new PluggableInstanceSettings(pluginConfigurations, pluginView)));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void validatePropertyDefaults() {
    PluginSettingsProperty property = new PluginSettingsProperty("Test-Property");
    assertThat(property.getOptions().size(), is(4));
    assertThat(property.getOption(Property.REQUIRED), is(true));
    assertThat(property.getOption(Property.SECURE), is(false));
    assertThat(property.getOption(Property.DISPLAY_NAME), is("Test-Property"));
    assertThat(property.getOption(Property.DISPLAY_ORDER), is(0));

    property = new PluginSettingsProperty("Test-Property", "Dummy Value");
    assertThat(property.getOptions().size(), is(4));
    assertThat(property.getOption(Property.REQUIRED), is(true));
    assertThat(property.getOption(Property.SECURE), is(false));
    assertThat(property.getOption(Property.DISPLAY_NAME), is("Test-Property"));
    assertThat(property.getOption(Property.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldFetchPluginSettingsMetadataForPluginBasedOnPluginId() throws Exception {
    for (GoPluginExtension extension : extensions) {

        PluginSettingsConfiguration configuration = new PluginSettingsConfiguration();
        configuration.add(new PluginSettingsProperty("k1").with(Property.REQUIRED, true).with(Property.SECURE, false));

        pluginDescriptor = new GoPluginDescriptor(UUID.randomUUID().toString(), "1.0", null, null, null, true);

        when(extension.canHandlePlugin(pluginDescriptor.id())).thenReturn(true);
        when(extension.extensionName()).thenReturn("extension-name");
        when(extension.getPluginSettingsConfiguration(pluginDescriptor.id())).thenReturn(configuration);
        when(extension.getPluginSettingsView(pluginDescriptor.id())).thenReturn("template");

        metadataLoader.fetchPluginSettingsMetaData(pluginDescriptor);

        verifyMetadataForPlugin(pluginDescriptor.id());
    }
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldNotFetchPluginSettingsMetadataForTaskPlugin() throws Exception {
    PluginSettingsConfiguration configuration = new PluginSettingsConfiguration();
    configuration.add(new PluginSettingsProperty("k1").with(Property.REQUIRED, true).with(Property.SECURE, false));

    pluginDescriptor = new GoPluginDescriptor(UUID.randomUUID().toString(), "1.0", null, null, null, true);

    when(taskExtension.canHandlePlugin(pluginDescriptor.id())).thenReturn(true);
    when(taskExtension.extensionName()).thenReturn("task");
    when(taskExtension.getPluginSettingsView(pluginDescriptor.id())).thenReturn("template");

    metadataLoader.fetchPluginSettingsMetaData(pluginDescriptor);

    verify(taskExtension, never()).getPluginSettingsConfiguration(pluginDescriptor.id());
    PluginSettingsConfiguration configurationInStore = PluginSettingsMetadataStore.getInstance().configuration(pluginDescriptor.id());
    assertNull(configurationInStore);
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldSortConfigurationPropertiesBasedOnDisplayOrder() {
    PluginSettingsProperty p3 = createProperty("k3", 3);
    PluginSettingsProperty p0 = createProperty("k0", 0);
    PluginSettingsProperty p2 = createProperty("k2", 2);
    PluginSettingsProperty p1 = createProperty("k1", 1);
    PluginSettingsConfiguration configuration = new PluginSettingsConfiguration();
    configuration.add(p3);
    configuration.add(p0);
    configuration.add(p2);
    configuration.add(p1);

    List<? extends Property> properties = configuration.list();
    assertThat(properties.get(0).getKey(), is("k0"));
    assertThat(properties.get(1).getKey(), is("k1"));
    assertThat(properties.get(2).getKey(), is("k2"));
    assertThat(properties.get(3).getKey(), is("k3"));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void validatePackagePropertyDefaults() throws Exception {
    PackageMaterialProperty packageMaterialProperty = new PackageMaterialProperty("Test-Property");
    assertThat(packageMaterialProperty.getOptions().size(), is(5));
    assertThat(packageMaterialProperty.getOption(Property.REQUIRED), is(true));
    assertThat(packageMaterialProperty.getOption(Property.PART_OF_IDENTITY), is(true));
    assertThat(packageMaterialProperty.getOption(Property.SECURE), is(false));
    assertThat(packageMaterialProperty.getOption(Property.DISPLAY_NAME), is(""));
    assertThat(packageMaterialProperty.getOption(Property.DISPLAY_ORDER), is(0));

    packageMaterialProperty = new PackageMaterialProperty("Test-Property", "Dummy Value");
    assertThat(packageMaterialProperty.getOptions().size(), is(5));
    assertThat(packageMaterialProperty.getOption(Property.REQUIRED), is(true));
    assertThat(packageMaterialProperty.getOption(Property.PART_OF_IDENTITY), is(true));
    assertThat(packageMaterialProperty.getOption(Property.SECURE), is(false));
    assertThat(packageMaterialProperty.getOption(Property.DISPLAY_NAME), is(""));
    assertThat(packageMaterialProperty.getOption(Property.DISPLAY_ORDER), is(0));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldAddPropertyWithGiveName() throws Exception {
    String abcd = "Abcd";
    String abcdDefault = "first of alphabets";
    String wxyz = "wxyz";
    String wxyzDefault = "last of alphabets";

    taskConfig.addProperty(wxyz).withDefault(wxyzDefault);
    taskConfig.addProperty(abcd).withDefault(abcdDefault);
    List<? extends Property> properties = taskConfig.list();
    assertThat(properties.size(), is(2));
    for (Property property : properties) {
        assertThat(property != null, is(true));
        assertThat(property instanceof TaskConfigProperty, is(true));
    }
    assertThat(taskConfig.get(abcd) != null, is(true));
    assertThat(taskConfig.get(abcd).getValue(), is(abcdDefault));
    assertThat(taskConfig.get(wxyz) != null, is(true));
    assertThat(taskConfig.get(wxyz).getValue(), is(wxyzDefault));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldValidateSCM() {
    SCMConfiguration scmConfig = new SCMConfiguration(new SCMProperty("KEY2").with(Property.REQUIRED, false));
    scmConfigurations.add(scmConfig);

    Configuration configuration = new Configuration(ConfigurationPropertyMother.create("KEY1"));
    SCM modifiedSCM = new SCM("scm-id", new PluginConfiguration(pluginId, "1"), configuration);
    ValidationResult validationResult = new ValidationResult();
    validationResult.addError(new ValidationError("KEY1", "error message"));
    when(scmExtension.isSCMConfigurationValid(eq(modifiedSCM.getPluginConfiguration().getId()), any(SCMPropertyConfiguration.class))).thenReturn(validationResult);

    pluggableScmService.validate(modifiedSCM);

    assertFalse(modifiedSCM.getConfiguration().getProperty("KEY1").errors().isEmpty());
    assertThat(modifiedSCM.getConfiguration().getProperty("KEY1").errors().firstError(), is("error message"));
    verify(scmExtension).isSCMConfigurationValid(eq(modifiedSCM.getPluginConfiguration().getId()), any(SCMPropertyConfiguration.class));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Test
public void shouldValidateMandatoryAndSecureFieldsForSCM() {
    SCMConfiguration scmConfig = new SCMConfiguration(new SCMProperty("KEY2").with(Property.REQUIRED, true).with(Property.SECURE, true));
    scmConfigurations.add(scmConfig);

    Configuration configuration = new Configuration(ConfigurationPropertyMother.create("KEY1"), ConfigurationPropertyMother.create("KEY2", true, ""));
    SCM modifiedSCM = new SCM("scm-id", new PluginConfiguration(pluginId, "1"), configuration);
    ValidationResult validationResult = new ValidationResult();
    when(scmExtension.isSCMConfigurationValid(eq(modifiedSCM.getPluginConfiguration().getId()), any(SCMPropertyConfiguration.class))).thenReturn(validationResult);
    when(localizer.localize("MANDATORY_CONFIGURATION_FIELD")).thenReturn("MANDATORY_CONFIGURATION_FIELD");

    pluggableScmService.validate(modifiedSCM);

    final List<ValidationError> validationErrors = validationResult.getErrors();
    assertFalse(validationErrors.isEmpty());
    final ValidationError validationErrorForKey1 = getValidationErrorFor(validationErrors, "KEY1");
    assertNotNull(validationErrorForKey1);
    assertThat(validationErrorForKey1.getMessage(), is("MANDATORY_CONFIGURATION_FIELD"));
    final ValidationError validationErrorForKey2 = getValidationErrorFor(validationErrors, "KEY2");
    assertNotNull(validationErrorForKey2);
    assertThat(validationErrorForKey2.getMessage(), is("MANDATORY_CONFIGURATION_FIELD"));
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
@Override
public List<TaskProperty> getPropertiesForDisplay() {
    ArrayList<TaskProperty> taskProperties = new ArrayList<>();
    if (PluggableTaskConfigStore.store().hasPreferenceFor(pluginConfiguration.getId())) {
        TaskPreference preference = taskPreference();
        List<? extends Property> propertyDefinitions = preference.getConfig().list();
        for (Property propertyDefinition : propertyDefinitions) {
            ConfigurationProperty configuredProperty = configuration.getProperty(propertyDefinition.getKey());
            if (configuredProperty == null) continue;
            taskProperties.add(new TaskProperty(propertyDefinition.getOption(Property.DISPLAY_NAME), configuredProperty.getDisplayValue(), configuredProperty.getConfigKeyName()));
        }
        return taskProperties;
    }

    for (ConfigurationProperty property : configuration) {
        taskProperties.add(new TaskProperty(property.getConfigKeyName(), property.getDisplayValue()));
    }
    return taskProperties;
}
 

import com.thoughtworks.go.plugin.api.config.Property; //导入依赖的package包/类
protected void setPluginConfigurationAttributes(Map attributes) {
    SCMConfigurations scmConfigurations = SCMMetadataStore.getInstance().getConfigurationMetadata(pluginConfiguration.getId());
    if (scmConfigurations == null) {
        throw new RuntimeException("metadata unavailable for plugin: " + pluginConfiguration.getId());
    }
    for (SCMConfiguration scmConfiguration : scmConfigurations.list()) {
        String key = scmConfiguration.getKey();
        if (attributes.containsKey(key)) {
            if (configuration.getProperty(key) == null) {
                configuration.addNewConfiguration(scmConfiguration.getKey(), scmConfiguration.getOption(Property.SECURE));
            }
            configuration.getProperty(key).setConfigurationValue(new ConfigurationValue((String) attributes.get(key)));
            configuration.getProperty(key).handleSecureValueConfiguration(scmConfiguration.getOption(Property.SECURE));
        }
    }
}