#259 | New Widget - Jira Buckets

cogboard-app/src/main/kotlin/com/cognifide/cogboard/CogboardConstants.kt

@@ -28,6 +28,7 @@ class CogboardConstants {
         const val PROP_SCHEDULE_PERIOD_DEFAULT = 120L // 120 seconds
         const val PROP_SCHEDULE_DELAY_DEFAULT = 10L // 10 seconds
         const val PROP_URL = "url"
+        const val PROP_REQUEST_ID = "requestId"
         const val PROP_PUBLIC_URL = "publicUrl"
         const val PROP_USER = "user"
         const val PROP_PASSWORD = "password"
@@ -46,7 +47,12 @@ class CogboardConstants {
         const val PROP_TEXT_SIZE = "textSize"
         const val PROP_BOARD_COLUMN_MAX = 20
         const val PROP_BOARD_COLUMN_MIN = 4
+        const val PROP_NAME = "name"
         const val PROP_RELEASE_NAME = "releaseName"
+        const val PROP_JQL_QUERY = "jqlQuery"
+        const val PROP_ISSUE_LIMIT = "issueLimit"
+        const val PROP_BUCKET_QUERIES = "bucketQueries"
+        const val PROP_BUCKET_NAME = "bucketName"
 
         const val EVENT_SEND_MESSAGE_TO_WEBSOCKET = "cogboard.websocket.message"
         const val EVENT_VERSION_CONFIG = "cogboard.config.handler.version"

cogboard-app/src/main/kotlin/com/cognifide/cogboard/http/HttpClient.kt

@@ -74,11 +74,12 @@ class HttpClient : AbstractVerticle() {
         val request = initRequest(httpRequest, config)
         val address = config.getString(CogboardConstants.PROP_EVENT_ADDRESS)
         val body = config.getJsonObject(CogboardConstants.PROP_BODY)
+        val requestId = config.getString(CogboardConstants.PROP_REQUEST_ID) ?: ""
 
         body?.let {
             executeCheckRequest(request, address, body)
         } ?: run {
-            executeRequest(request, address)
+            executeRequest(request, address, requestId)
         }
     }
 
@@ -111,17 +112,19 @@ class HttpClient : AbstractVerticle() {
         }
     }
 
-    private fun executeRequest(request: HttpRequest<Buffer>, address: String?) {
+    private fun executeRequest(request: HttpRequest<Buffer>, address: String?, requestId: String) {
         request.send {
             if (!it.succeeded()) {
                 vertx.eventBus().send(address, JsonObject()
                         .put(CogboardConstants.PROP_ERROR_MESSAGE, "Http Error")
-                        .put(CogboardConstants.PROP_ERROR_CAUSE, it.cause()?.message))
+                        .put(CogboardConstants.PROP_ERROR_CAUSE, it.cause()?.message)
+                        .put(CogboardConstants.PROP_REQUEST_ID, requestId))
                 LOGGER.error(it.cause()?.message)
             } else {
                 toJson(it.result()).let { json ->
                     json.put(PROP_STATUS_CODE, it.result().statusCode())
                     json.put(PROP_STATUS_MESSAGE, it.result().statusMessage())
+                    json.put(CogboardConstants.PROP_REQUEST_ID, requestId)
                     vertx.eventBus().send(address, json)
                 }
             }

cogboard-app/src/main/kotlin/com/cognifide/cogboard/widget/AsyncWidget.kt

@@ -49,10 +49,11 @@ abstract class AsyncWidget(
      */
     abstract fun handleResponse(responseBody: JsonObject)
 
-    protected fun httpGet(url: String) {
+    protected fun httpGet(url: String, requestId: String = "") {
         vertx.eventBus().send(CogboardConstants.EVENT_HTTP_GET,
                 JsonObject()
                         .put(CogboardConstants.PROP_URL, url)
+                        .put(CogboardConstants.PROP_REQUEST_ID, requestId)
                         .put(CogboardConstants.PROP_EVENT_ADDRESS, eventBusAddress)
                         .put(CogboardConstants.PROP_USER, user)
                         .put(CogboardConstants.PROP_PASSWORD, password)

cogboard-app/src/main/kotlin/com/cognifide/cogboard/widget/WidgetIndex.kt

@@ -12,6 +12,7 @@ import com.cognifide.cogboard.widget.type.persondraw.PersonDrawWidget
 import com.cognifide.cogboard.widget.type.ServiceCheckWidget
 import com.cognifide.cogboard.widget.type.sonarqube.SonarQubeWidget
 import com.cognifide.cogboard.widget.type.TextWidget
+import com.cognifide.cogboard.widget.type.JiraBucketWidget
 import com.cognifide.cogboard.widget.type.WorldClockWidget
 import com.cognifide.cogboard.widget.type.AemBundleInfoWidget
 import io.vertx.core.Vertx
@@ -33,6 +34,7 @@ class WidgetIndex {
             BambooPlanWidget::class.java.simpleName -> BambooPlanWidget(vertx, config)
             AemHealthcheckWidget::class.java.simpleName -> AemHealthcheckWidget(vertx, config)
             TextWidget::class.java.simpleName -> TextWidget(vertx, config)
+            JiraBucketWidget::class.java.simpleName -> JiraBucketWidget(vertx, config)
             IframeEmbedWidget::class.java.simpleName -> IframeEmbedWidget(vertx, config)
             WorldClockWidget::class.java.simpleName -> WorldClockWidget(vertx, config)
             CheckboxWidget::class.java.simpleName -> CheckboxWidget(vertx, config)

cogboard-app/src/main/kotlin/com/cognifide/cogboard/widget/type/JiraBucketWidget.kt

@@ -0,0 +1,56 @@
+package com.cognifide.cogboard.widget.type
+
+import com.cognifide.cogboard.widget.AsyncWidget
+import io.vertx.core.Vertx
+import io.vertx.core.json.JsonArray
+import io.vertx.core.json.JsonObject
+import com.cognifide.cogboard.CogboardConstants as CC
+
+class JiraBucketWidget(vertx: Vertx, config: JsonObject) : AsyncWidget(vertx, config) {
+
+    private val bucketQueries: JsonArray = config.getJsonArray(CC.PROP_BUCKET_QUERIES)
+    private val buckets: JsonArray = prepareBuckets()
+
+    private fun prepareBuckets(): JsonArray {
+        val preparedBuckets = JsonArray()
+        bucketQueries.forEach {
+            if (it is JsonObject) {
+                preparedBuckets.add(JsonObject()
+                        .put(CC.PROP_ID, it.getString(CC.PROP_ID))
+                        .put(CC.PROP_NAME, it.getString(CC.PROP_BUCKET_NAME)))
+            }
+        }
+        return preparedBuckets
+    }
+
+    override fun handleResponse(responseBody: JsonObject) {
+        val response = JsonObject()
+        val issues = responseBody.getJsonArray("issues").size()
+        val bucketId = responseBody.getString(CC.PROP_REQUEST_ID)
+
+        buckets.forEach {
+            val key = (it as JsonObject).getString(CC.PROP_ID)
+            if (bucketId == key) {
+                it.put("issueCounts", issues)
+            }
+        }
+        response.put("buckets", buckets)
+        send(JsonObject()
+                .put(CC.PROP_CONTENT, response))
+    }
+
+    override fun updateState() {
+        if (url.isNotBlank()) {
+            for (bucketQuery in bucketQueries.list) {
+                if (bucketQuery is JsonObject) {
+                    val bucketId = bucketQuery.getString(CC.PROP_ID)
+                    val jqlQuery = bucketQuery.getString(CC.PROP_JQL_QUERY)
+                    val issueLimit = config.getInteger(CC.PROP_ISSUE_LIMIT)
+                    httpGet(url = "$url/jira/rest/api/2/search?jql=$jqlQuery&maxResults=$issueLimit", requestId = bucketId)
+                }
+            }
+        } else {
+            sendConfigurationError("Endpoint URL is blank.")
+        }
+    }
+}