Add new messages load data from error time line

Author: opoliarush

analytics-provider/src/main/java/org/digma/intellij/plugin/analytics/AnalyticsProvider.java

@@ -46,6 +46,8 @@ public interface AnalyticsProvider extends Closeable {
 
     String getGlobalErrors(String payload);
 
+    String getErrorTimeseries(String errorId, Map<String, Object> payload);
+
     void setInsightCustomStartTime(CustomStartTimeInsightRequest customStartTimeInsightRequest);
 
     String getErrorDetails(String errorSourceId);

analytics-provider/src/main/java/org/digma/intellij/plugin/analytics/RestAnalyticsProvider.java

@@ -171,6 +171,11 @@ public String getGlobalErrors(String payload) {
         return execute(() -> client.analyticsProvider.getGlobalErrors(payload));
     }
 
+    @Override
+    public String getErrorTimeseries(String errorId, Map<String, Object> payload) {
+        return execute(() -> client.analyticsProvider.getErrorTimeseries( errorId, payload));
+    }
+
     @Override
     public void setInsightCustomStartTime(CustomStartTimeInsightRequest customStartTimeInsightRequest) {
         execute(() -> client.analyticsProvider.setInsightCustomStartTime(customStartTimeInsightRequest));
@@ -808,6 +813,13 @@ private interface AnalyticsProviderRetrofit {
         @POST("errors")
         Call<String> getGlobalErrors(@Body String payload);
 
+        @Headers({
+                "Accept: application/+json",
+                "Content-Type:application/json"
+        })
+        @GET("errors/{errorId}/timeseries")
+        Call<String> getErrorTimeseries(@Path("errorId") String errorSourceId, @QueryMap Map<String, Object> fields);
+
         @Headers({
                 "Content-Type:application/json"
         })

ide-common/src/main/java/org/digma/intellij/plugin/analytics/AnalyticsService.java

@@ -236,6 +236,10 @@ public String getGlobalErrors(String payload) throws AnalyticsServiceException {
         return executeCatching(() -> analyticsProviderProxy.getGlobalErrors(payload));
     }
 
+    public String getErrorTimeseries(String error_id, Map<String, Object> payload) throws AnalyticsServiceException {
+        return executeCatching(() -> analyticsProviderProxy.getErrorTimeseries(error_id, payload));
+    }
+
     public String getErrorDetails(String errorUid) throws AnalyticsServiceException {
         return executeCatching(() -> analyticsProviderProxy.getErrorDetails(errorUid));
     }

src/main/kotlin/org/digma/intellij/plugin/ui/errors/ErrorsMessageRouterHandler.kt

@@ -8,11 +8,14 @@ import com.fasterxml.jackson.databind.node.ObjectNode
 import com.intellij.openapi.project.Project
 import org.cef.browser.CefBrowser
 import org.digma.intellij.plugin.log.Log
+import org.digma.intellij.plugin.ui.errors.model.SetErrorTimeseriesDataMessage
 import org.digma.intellij.plugin.ui.errors.model.SetErrorsDataMessage
 import org.digma.intellij.plugin.ui.errors.model.SetErrorsDetailsMessage
 import org.digma.intellij.plugin.ui.errors.model.SetFilesUrlsMessage
 import org.digma.intellij.plugin.ui.errors.model.SetGlobalErrorsDataMessage
 import org.digma.intellij.plugin.ui.jcef.BaseCommonMessageRouterHandler
+import org.digma.intellij.plugin.ui.jcef.getMapFromNode
+import org.digma.intellij.plugin.ui.jcef.getQueryMapFromPayload
 import org.digma.intellij.plugin.ui.jcef.serializeAndExecuteWindowPostMessageJavaScript
 
 class ErrorsMessageRouterHandler(project: Project) : BaseCommonMessageRouterHandler(project) {
@@ -24,6 +27,7 @@ class ErrorsMessageRouterHandler(project: Project) : BaseCommonMessageRouterHand
         when (action) {
             "ERRORS/GET_ERRORS_DATA" -> getErrorsData(project, browser, requestJsonNode)
             "ERRORS/GET_GLOBAL_ERRORS_DATA" -> getGlobalErrorsData(project, browser, requestJsonNode)
+            "ERRORS/GET_ERROR_TIMESERIES_DATA" -> getErrorTimeseriesData(project, browser, requestJsonNode)
             "ERRORS/GET_ERROR_DETAILS" -> getErrorDetails(project, browser, requestJsonNode)
             "ERRORS/OPEN_RAW_ERROR_STACK_TRACE_IN_EDITOR" -> openStackTrace(project, requestJsonNode)
             "ERRORS/GO_TO_CODE_LOCATION" -> navigateToCode(project, requestJsonNode)
@@ -62,6 +66,18 @@ class ErrorsMessageRouterHandler(project: Project) : BaseCommonMessageRouterHand
         }
     }
 
+    private fun getErrorTimeseriesData(project: Project, browser: CefBrowser, requestJsonNode: JsonNode) {
+        getPayloadFromRequest(requestJsonNode)?.let { payload ->
+            val errorId = payload.get("errorId")?.takeIf { it !is NullNode }?.asText()
+            if (errorId != null) {
+                var queryMap = getMapFromNode(payload.get("scope"), objectMapper)
+                val errorsData = ErrorsService.getInstance(project).getErrorTimeseries(errorId, queryMap)
+                val setErrorsDataMessage = SetErrorTimeseriesDataMessage(errorsData)
+                serializeAndExecuteWindowPostMessageJavaScript(browser, setErrorsDataMessage, project)
+            }
+        }
+    }
+
     private fun getErrorDetails(project: Project, browser: CefBrowser, requestJsonNode: JsonNode) {
         getPayloadFromRequest(requestJsonNode)?.let { payload ->
             val errorId = payload.get("errorId")?.takeIf { it !is NullNode }?.asText()

src/main/kotlin/org/digma/intellij/plugin/ui/errors/ErrorsService.kt

@@ -47,6 +47,15 @@ class ErrorsService(val project: Project) : Disposable {
         }
     }
 
+    fun getErrorTimeseries( errorId: String, payload:Map<String, Any>): String? {
+        try {
+            return AnalyticsService.getInstance(project).getErrorTimeseries(errorId, payload)
+        } catch (e: Throwable) {
+            Log.warnWithException(logger, project, e, "error fetching errors")
+            return null
+        }
+    }
+
     fun getErrorDetails(errorId: String): String {
         try {
             return AnalyticsService.getInstance(project).getErrorDetails(errorId)

src/main/kotlin/org/digma/intellij/plugin/ui/errors/model/SetErrorTimeseriesDataMessage.kt

@@ -0,0 +1,9 @@
+package org.digma.intellij.plugin.ui.errors.model
+
+import com.fasterxml.jackson.annotation.JsonRawValue
+import org.digma.intellij.plugin.ui.jcef.JCEFGlobalConstants
+
+class SetErrorTimeseriesDataMessage(@JsonRawValue val payload: String?) {
+    val type = JCEFGlobalConstants.REQUEST_MESSAGE_TYPE
+    val action = "ERRORS/SET_ERROR_TIMESERIES_DATA"
+}