Issues and Users to Quboo

Author: mechero

src/main/java/io/tpd/quboo/sonarplugin/QubooPlugin.java

@@ -1,6 +1,7 @@
 package io.tpd.quboo.sonarplugin;
 
 import io.tpd.quboo.sonarplugin.hooks.QubooConnector;
+import io.tpd.quboo.sonarplugin.hooks.QubooSensor;
 import io.tpd.quboo.sonarplugin.settings.QubooProperties;
 import org.sonar.api.Plugin;
 
@@ -9,13 +10,14 @@
  */
 public class QubooPlugin implements Plugin {
 
-  public static final String QUBOO_SERVER = "";
+  public static final String QUBOO_SERVER = "http://localhost:8080";
   public static final String QUBOO_HEADER_ACCESS_KEY = "x-quboo-access-key";
   public static final String QUBOO_HEADER_SECRET_KEY = "x-quboo-secret-key";
 
   @Override
   public void define(Context context) {
     context.addExtension(QubooConnector.class);
+    context.addExtension(QubooSensor.class);
     context.addExtensions(QubooProperties.getProperties());
   }
 }

src/main/java/io/tpd/quboo/sonarplugin/hooks/QubooConnector.java

@@ -2,17 +2,15 @@
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.tpd.quboo.sonarplugin.QubooPlugin;
-import io.tpd.quboo.sonarplugin.pojos.Issue;
 import io.tpd.quboo.sonarplugin.pojos.Issues;
+import io.tpd.quboo.sonarplugin.pojos.Users;
 import io.tpd.quboo.sonarplugin.settings.QubooProperties;
 import okhttp3.*;
 import org.sonar.api.ce.posttask.PostProjectAnalysisTask;
 import org.sonar.api.platform.Server;
 import org.sonar.api.utils.log.Logger;
 import org.sonar.api.utils.log.Loggers;
 
-import java.util.List;
-
 /**
  * Sends stats to the Quboo server
  */
@@ -21,8 +19,10 @@ public class QubooConnector implements PostProjectAnalysisTask {
   private final Server server;
   private final Logger log = Loggers.get(getClass());
   private final ObjectMapper mapper;
+  private final OkHttpClient http;
 
   public QubooConnector(final Server server) {
+    this.http = new OkHttpClient();
     this.server = server;
     this.mapper = new ObjectMapper();
   }
@@ -33,15 +33,16 @@ public void finished(ProjectAnalysis analysis) {
     final String qubooSecret = analysis.getScannerContext().getProperties().get(QubooProperties.SECRET_KEY);
     log.info("Connecting to Quboo with quboo key: " + qubooKey);
     try {
-      final List<Issue> allIssues = getIssues();
+      final Users allUsers = getUsers();
+      sendUsersToQuboo(allUsers, qubooKey, qubooSecret);
+      final Issues allIssues = getIssues();
       sendIssuesToQuboo(allIssues, qubooKey, qubooSecret);
     } catch (final Exception e) {
       log.error("Error while trying to connect to Quboo", e);
     }
   }
 
-  private void sendIssuesToQuboo(final List<Issue> allIssues, final String qubooKey, final String qubooSecret) throws Exception {
-    final OkHttpClient http = new OkHttpClient();
+  private void sendIssuesToQuboo(final Issues allIssues, final String qubooKey, final String qubooSecret) throws Exception {
     final Request request = new Request.Builder()
       .url(QubooPlugin.QUBOO_SERVER + "/updater/issues")
       .header(QubooPlugin.QUBOO_HEADER_ACCESS_KEY, qubooKey)
@@ -53,13 +54,34 @@ private void sendIssuesToQuboo(final List<Issue> allIssues, final String qubooKe
     log.info("Response " + body);
   }
 
-  private List<Issue> getIssues() throws Exception {
-    final OkHttpClient http = new OkHttpClient();
+  private Issues getIssues() throws Exception {
     final Request request = new Request.Builder().url(server.getPublicRootUrl() + "/api/issues/search").get().build();
     final Response response = http.newCall(request).execute();
     final String body = response.body().string();
     final Issues issues = mapper.readValue(body, Issues.class);
     log.info("There are " + issues.getIssues().size() + " issues");
-    return issues.getIssues();
+    return issues;
   }
+
+  private void sendUsersToQuboo(final Users allUsers, final String qubooKey, final String qubooSecret) throws Exception {
+    final Request request = new Request.Builder()
+      .url(QubooPlugin.QUBOO_SERVER + "/updater/users")
+      .header(QubooPlugin.QUBOO_HEADER_ACCESS_KEY, qubooKey)
+      .header(QubooPlugin.QUBOO_HEADER_SECRET_KEY, qubooSecret)
+      .post(RequestBody.create(MediaType.get("application/json"), mapper.writeValueAsString(allUsers)))
+      .build();
+    final Response response = http.newCall(request).execute();
+    final String body = response.body().string();
+    log.info("Response " + body);
+  }
+
+  private Users getUsers() throws Exception {
+    final Request request = new Request.Builder().url(server.getPublicRootUrl() + "/api/users/search").get().build();
+    final Response response = http.newCall(request).execute();
+    final String body = response.body().string();
+    final Users users = mapper.readValue(body, Users.class);
+    log.info("There are " + users.getUsers().size() + " users");
+    return users;
+  }
+
 }

src/main/java/io/tpd/quboo/sonarplugin/hooks/QubooSensor.java

@@ -0,0 +1,29 @@
+package io.tpd.quboo.sonarplugin.hooks;
+
+import io.tpd.quboo.sonarplugin.settings.QubooProperties;
+import org.sonar.api.batch.sensor.Sensor;
+import org.sonar.api.batch.sensor.SensorContext;
+import org.sonar.api.batch.sensor.SensorDescriptor;
+import org.sonar.api.utils.log.Logger;
+import org.sonar.api.utils.log.Loggers;
+
+import java.util.Optional;
+
+public class QubooSensor implements Sensor {
+
+  private final Logger log = Loggers.get(getClass());
+
+  @Override
+  public void describe(final SensorDescriptor descriptor) {
+    descriptor.name("Quboo Sensor");
+  }
+
+  @Override
+  public void execute(final SensorContext context) {
+    final Optional<String> key = context.config().get(QubooProperties.ACCESS_KEY);
+    final Optional<String> secret = context.config().get(QubooProperties.SECRET_KEY);
+    key.ifPresent(accessKey -> context.addContextProperty(QubooProperties.ACCESS_KEY, accessKey));
+    secret.ifPresent(s -> context.addContextProperty(QubooProperties.SECRET_KEY, s));
+    log.info("Access key is "+key.orElse("NOT PRESENT"));
+  }
+}