Merge pull request #2561 from digma-ai/feature/errors-filter

Add new messages for filters load

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 getGlobalErrorsFilters(String 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 getGlobalErrorsFilters(String payload) {
+        return execute(() -> client.analyticsProvider.getGlobalErrorsFilters(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"
+        })
+        @POST("errors/filters")
+        Call<String> getGlobalErrorsFilters(@Body String payload);
+
         @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 getGlobalErrorsFilters(String payload) throws AnalyticsServiceException {
+        return executeCatching(() -> analyticsProviderProxy.getGlobalErrorsFilters(payload));
+    }
+
     public String getErrorDetails(String errorUid) throws AnalyticsServiceException {
         return executeCatching(() -> analyticsProviderProxy.getErrorDetails(errorUid));
     }

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

@@ -12,6 +12,7 @@ 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.serializeAndExecuteWindowPostMessageJavaScript
 
@@ -24,6 +25,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_GLOBAL_ERRORS_FILTERS_DATA" -> getGlobalErrorsFiltersData(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 +64,14 @@ class ErrorsMessageRouterHandler(project: Project) : BaseCommonMessageRouterHand
         }
     }
 
+    private fun getGlobalErrorsFiltersData(project: Project, browser: CefBrowser, requestJsonNode: JsonNode) {
+        getPayloadFromRequest(requestJsonNode)?.let { payload ->
+            val errorsData = ErrorsService.getInstance(project).getGlobalErrorsFiltersData(payload.toString())
+            val setErrorsDataMessage = SetGlobalErrorsFiltersDataMessage(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 getGlobalErrorsFiltersData(payload: String): String? {
+        try {
+            return AnalyticsService.getInstance(project).getGlobalErrorsFilters(payload)
+        } catch (e: Throwable) {
+            Log.warnWithException(logger, project, e, "error fetching errors/filters")
+            return null
+        }
+    }
+
     fun getErrorDetails(errorId: String): String {
         try {
             return AnalyticsService.getInstance(project).getErrorDetails(errorId)

src/main/kotlin/org/digma/intellij/plugin/ui/errors/model/SetGlobalErrorsFiltersDataMessage.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 SetGlobalErrorsFiltersDataMessage(@JsonRawValue val payload: String?) {
+    val type = JCEFGlobalConstants.REQUEST_MESSAGE_TYPE
+    val action = "ERRORS/SET_GLOBAL_ERRORS_FILTERS_DATA"
+}