Merge pull request #2562 from digma-ai/feature/error-timelines-data

Add new messages load data from error time line

Author: kshmidt-digma

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);
+
     String getGlobalErrorsFilters(String payload);
 
     void setInsightCustomStartTime(CustomStartTimeInsightRequest customStartTimeInsightRequest);

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

@@ -176,6 +176,11 @@ public String getGlobalErrorsFilters(String payload) {
         return execute(() -> client.analyticsProvider.getGlobalErrorsFilters(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));
@@ -813,6 +818,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({
                 "Accept: application/+json",
                 "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 getGlobalErrorsFilters(String payload) throws AnalyticsServiceException {
         return executeCatching(() -> analyticsProviderProxy.getGlobalErrorsFilters(payload));
     }

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

@@ -8,12 +8,15 @@ 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.errors.model.SetGlobalErrorsFiltersDataMessage
 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) {
@@ -26,6 +29,7 @@ class ErrorsMessageRouterHandler(project: Project) : BaseCommonMessageRouterHand
             "ERRORS/GET_ERRORS_DATA" -> getErrorsData(project, browser, requestJsonNode)
             "ERRORS/GET_GLOBAL_ERRORS_DATA" -> getGlobalErrorsData(project, browser, requestJsonNode)
             "ERRORS/GET_GLOBAL_ERRORS_FILTERS_DATA" -> getGlobalErrorsFiltersData(project, browser, requestJsonNode)
+            "ERRORS/GET_ERROR_TIME_SERIES_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)
@@ -64,6 +68,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 getGlobalErrorsFiltersData(project: Project, browser: CefBrowser, requestJsonNode: JsonNode) {
         getPayloadFromRequest(requestJsonNode)?.let { payload ->
             val errorsData = ErrorsService.getInstance(project).getGlobalErrorsFiltersData(payload.toString())

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

@@ -56,6 +56,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_TIME_SERIES_DATA"
+}