Add button test connection in global configuration

src/main/java/jenkinsci/plugins/influxdb/models/Target.java

@@ -1,19 +1,38 @@
 package jenkinsci.plugins.influxdb.models;
 
+import com.cloudbees.plugins.credentials.CredentialsMatchers;
+import com.cloudbees.plugins.credentials.CredentialsProvider;
 import com.cloudbees.plugins.credentials.common.StandardCredentials;
 import com.cloudbees.plugins.credentials.common.StandardListBoxModel;
 import com.cloudbees.plugins.credentials.common.StandardUsernamePasswordCredentials;
 import com.cloudbees.plugins.credentials.domains.URIRequirementBuilder;
+import com.influxdb.client.InfluxDBClient;
+import com.influxdb.client.InfluxDBClientFactory;
+import com.influxdb.client.InfluxDBClientOptions;
+import com.influxdb.client.domain.Bucket;
+import com.influxdb.client.domain.User;
+import com.influxdb.exceptions.InfluxException;
+
 import hudson.Extension;
 import hudson.model.AbstractDescribableImpl;
 import hudson.model.Descriptor;
+import hudson.model.Item;
 import hudson.security.ACL;
 import hudson.util.FormValidation;
 import hudson.util.ListBoxModel;
 import jenkins.model.Jenkins;
+
+import java.util.List;
+
 import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.jenkinsci.plugins.plaincredentials.StringCredentials;
+import org.kohsuke.accmod.Restricted;
+import org.kohsuke.accmod.restrictions.NoExternalUse;
+import org.kohsuke.stapler.AncestorInPath;
 import org.kohsuke.stapler.DataBoundConstructor;
 import org.kohsuke.stapler.QueryParameter;
+import org.kohsuke.stapler.verb.POST;
+import org.springframework.security.access.AccessDeniedException;
 
 public class Target extends AbstractDescribableImpl<Target> implements java.io.Serializable {
 
@@ -181,5 +200,63 @@ public FormValidation doCheckUrl(@QueryParameter String value) {
         public FormValidation doCheckDatabase(@QueryParameter String value) {
             return FormValidation.validateRequired(value);
         }
+
+        @POST
+        public FormValidation doVerifyConnection(@QueryParameter String url, @QueryParameter String credentialsId,
+                                                 @QueryParameter String organization, @QueryParameter String database,
+                                                 @QueryParameter String retentionPolicy, @AncestorInPath Item context) {
+            InfluxDBClient influxDB = null;
+            doCheckUrl(url);
+            doCheckDatabase(database);
+            try {
+                Jenkins.get().checkPermission(Jenkins.ADMINISTER);
+
+                List<StandardUsernamePasswordCredentials> lookupCredentials = CredentialsProvider.lookupCredentials(
+                        StandardUsernamePasswordCredentials.class,
+                        context,
+                        ACL.SYSTEM,
+                        URIRequirementBuilder.fromUri(url).build());
+
+                StandardUsernamePasswordCredentials credentials = CredentialsMatchers.firstOrNull(lookupCredentials, CredentialsMatchers.withId(null == credentialsId ? "" : credentialsId));
+
+                if (organization != null && !organization.trim().isEmpty()) {
+                    InfluxDBClientOptions.Builder options = InfluxDBClientOptions.builder().url(url).org(organization).bucket(database);
+
+                    if (credentials != null) { // basic auth
+                        options.authenticate(credentials.getUsername(), credentials.getPassword().getPlainText().toCharArray());
+                    } else { // token auth
+                        List<StringCredentials> lookupTokenCredentials = CredentialsProvider.lookupCredentials(//
+                                StringCredentials.class,
+                                context,
+                                ACL.SYSTEM,
+                                URIRequirementBuilder.fromUri(url).build());
+                        StringCredentials c = CredentialsMatchers.firstOrNull(lookupTokenCredentials, CredentialsMatchers.withId(null == credentialsId ? "" : credentialsId));
+                        assert c != null;
+                        options.authenticateToken(c.getSecret().getPlainText().toCharArray());
+                    }
+
+                    influxDB = InfluxDBClientFactory.create(options.build());
+
+                } else {
+                    influxDB = credentials == null
+                            ? InfluxDBClientFactory.createV1(url, "", "".toCharArray(), database, retentionPolicy)
+                            : InfluxDBClientFactory.createV1(url, credentials.getUsername(),
+                                    credentials.getPassword().getPlainText().toCharArray(), database, retentionPolicy);
+                }
+
+                boolean connected = influxDB.ping();
+                if(connected) {
+                    return FormValidation.ok("Connection success");
+                } else {
+                    return FormValidation.ok("Connection Failed");
+                }
+            } catch (InfluxException | AccessDeniedException e) {
+                return FormValidation.error(e, "Connection Failed");
+            } finally {
+                if (influxDB != null) {
+                    influxDB.close();
+                }
+            }
+        }
     }
 }

src/main/resources/jenkinsci/plugins/influxdb/models/Target/config.jelly

@@ -18,6 +18,8 @@
     </f:entry>
     <f:entry title="Retention Policy" field="retentionPolicy">
         <f:textbox default="autogen"/>
+    <f:validateButton title="Test Connection" progress="Testing..." method="verifyConnection"
+        with="url,credentialsId,organization,database,retentionPolicy"/>
     </f:entry>
     <f:entry title="Job scheduled time as timestamp" field="jobScheduledTimeAsPointsTimestamp">
         <f:checkbox default="false"/>