Merge pull request #2758 from digma-ai/show-error-api-service

Support new action GoToError in the REST Plugin API Closes #2756

Author: shalom938

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

@@ -174,4 +174,5 @@ public interface AnalyticsProvider extends Closeable {
     DiscoveredDataResponse getDiscoveredData();
 
     SpanInfoByUid resolveSpanByUid(String uid);
+    EnvironmentInfoByErrorId resolveEnvironmentByErrorId(String errorId);
 }

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

@@ -495,6 +495,11 @@ public SpanInfoByUid resolveSpanByUid(String uid) {
         return execute(() -> client.analyticsProvider.resolveSpanByUid(uid));
     }
 
+    @Override
+    public EnvironmentInfoByErrorId resolveEnvironmentByErrorId(String errorId) {
+        return execute(() -> client.analyticsProvider.resolveEnvironmentByErrorId(errorId));
+    }
+
     @Override
     public HttpResponse proxyCall(HttpRequest request) {
 
@@ -1314,5 +1319,12 @@ Call<Void> setInsightCustomStartTime(
         })
         @GET("spans/spanCodeObjectId/{uid}")
         Call<SpanInfoByUid> resolveSpanByUid(@Path("uid") String uid);
+
+        @Headers({
+                "Content-Type:application/json"
+        })
+        @GET("CodeAnalytics/codeObjects/error_environment")
+        Call<EnvironmentInfoByErrorId> resolveEnvironmentByErrorId(@Query("errorId") String errorId);
+
     }
 }

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

@@ -564,7 +564,7 @@ public HttpResponse proxyCall(HttpRequest request) throws AnalyticsServiceExcept
 
 
     @Nullable
-    public SpanInfoByUid resolveSpanByUid(String uid) throws AnalyticsServiceException {
+    public SpanInfoByUid resolveSpanByUid(@NotNull String uid) throws AnalyticsServiceException {
 
         if (backendVersionOlderThen("0.3.155")) {
             return null;
@@ -574,6 +574,15 @@ public SpanInfoByUid resolveSpanByUid(String uid) throws AnalyticsServiceExcepti
 
     }
 
+    @Nullable
+    public EnvironmentInfoByErrorId resolveEnvironmentByErrorId(@NotNull String errorId) throws AnalyticsServiceException {
+        if (backendVersionOlderThen("0.3.318")) {
+            return null;
+        }
+
+        return executeCatching(() -> analyticsProviderProxy.resolveEnvironmentByErrorId(errorId));
+    }
+
 
     private boolean backendVersionOlderThen(String version) {
         String backendVersion = BackendInfoHolder.getInstance(project).getAbout().getApplicationVersion();
@@ -659,6 +668,8 @@ private AnalyticsProvider newAnalyticsProviderProxy(AnalyticsProvider obj) {
                 new AnalyticsInvocationHandler(obj));
     }
 
+
+
     /**
      * A proxy for cross-cutting concerns across all api methods.
      * In a proxy it's easier to log events, we have the method name, parameters etc.

ide-common/src/main/kotlin/org/digma/intellij/plugin/api/ApiProjectService.kt

@@ -37,6 +37,7 @@ class ApiProjectService(val project: Project) : DisposableAdaptor {
             ACTION_GO_TO_HOME_PARAM_VALUE -> GoToHomeCommand()
             ACTION_GO_TO_SPAN_PARAM_VALUE -> GoToSpanCommand()
             ACTION_OPEN_REPORT_PARAM_VALUE -> OpenReportCommand()
+            ACTION_GO_TO_ERROR_PARAM_VALUE -> GoToErrorCommand()
             else -> {
                 throw RuntimeException("unknown action $action")
             }

ide-common/src/main/kotlin/org/digma/intellij/plugin/api/GoToErrorCommand.kt

@@ -0,0 +1,55 @@
+package org.digma.intellij.plugin.api
+
+import com.intellij.openapi.project.Project
+import io.netty.handler.codec.http.QueryStringDecoder
+import org.digma.intellij.plugin.analytics.AnalyticsService
+import org.digma.intellij.plugin.common.objectToJsonNode
+import org.digma.intellij.plugin.log.Log
+import org.digma.intellij.plugin.scope.ScopeContext
+import org.digma.intellij.plugin.scope.ScopeManager
+import org.jetbrains.ide.RestService.Companion.getStringParameter
+import java.util.Objects
+
+class GoToErrorCommand : AbstractApiCommand() {
+
+    override fun execute(project: Project, urlDecoder: QueryStringDecoder) {
+        val errorId = getStringParameter(ERROR_ID_PARAM_NAME, urlDecoder)
+        Objects.requireNonNull(errorId, "errorId parameter must not be null")
+
+        Log.log(
+            logger::trace,
+            "GoToError called with errorId={}, projectName={}, thread={}",
+            errorId,
+            project.name,
+            Thread.currentThread().name
+        )
+
+        //checked non-null above
+        errorId!!
+
+        val environmentByErrorIdResponse = AnalyticsService.getInstance(project).resolveEnvironmentByErrorId(errorId)
+            ?: throw RuntimeException("could not find environment by error id $errorId")
+
+        val environmentId = environmentByErrorIdResponse.environmentId
+        if (environmentId.isBlank()) {
+            throw RuntimeException("could not find environment id for error id $errorId")
+        }
+        val contextPayload = objectToJsonNode(GoToErrorContextPayload(errorId = errorId))
+        val scopeContext = ScopeContext("IDE/REST_API_CALL", contextPayload)
+
+        Log.log(
+            logger::trace,
+            "calling ScopeManager.changeToHome with ,scopeContext='{}',environmentId='{}', thread='{}'",
+            scopeContext,
+            environmentId,
+            Thread.currentThread().name
+        )
+
+        ScopeManager.getInstance(project).changeToHome(true, scopeContext, environmentId)
+
+    }
+
+
+    data class GoToErrorContextPayload(val targetTab: String = "errors", val errorId: String)
+
+}

ide-common/src/main/kotlin/org/digma/intellij/plugin/api/GoToSpanCommand.kt

@@ -28,6 +28,8 @@ class GoToSpanCommand : AbstractApiCommand() {
             Thread.currentThread().name
         )
 
+        //checked non-null above
+        spanUid!!
 
         val spanInfoByUid = AnalyticsService.getInstance(project).resolveSpanByUid(spanUid)
             ?: throw RuntimeException("could not find span by uid $spanUid")

ide-common/src/main/kotlin/org/digma/intellij/plugin/api/ShowAssetsHttpService.kt

@@ -9,6 +9,7 @@ import org.digma.intellij.plugin.log.Log
 import java.util.Objects
 
 //http://localhost:63344/api/digma/show?action=GoToSpan&spanUid=995822fa-9d0d-11ef-9d3e-0adc1d604f09&targetTab=assets&projectName=spring-petclinic
+//http://localhost:63344/api/digma/show?action=GoToError&errorId=6dc7a826-fb37-11ef-8a3f-7215f134c660&projectName=spring-petclinic
 //http://localhost:63344/api/digma/show?action=GoToHome&environment_id=LOCAL%23ID%2325A68508-B8A3-4DF2-ACA3-ECDAAB203793&targetTab=assets&projectName=spring-petclinic
 //http://localhost:63344/api/digma/show?action=OpenReport&projectName=spring-petclinic
 class ShowAssetsHttpService : AbstractHttpService() {

ide-common/src/main/kotlin/org/digma/intellij/plugin/api/api-utils.kt

@@ -10,12 +10,14 @@ import org.digma.intellij.plugin.common.findActiveProject
 const val ACTION_PARAM_NAME = "action"
 const val TARGET_TAB_PARAM_NAME = "targetTab"
 const val SPAN_UID_PARAM_NAME = "spanUid"
+const val ERROR_ID_PARAM_NAME = "errorId"
 const val ENVIRONMENT_ID_PARAM_NAME = "environment_id"
 const val PROJECT_NAME_PARAM_NAME = "projectName"
 
 const val ACTION_GO_TO_HOME_PARAM_VALUE = "GoToHome"
 const val ACTION_GO_TO_SPAN_PARAM_VALUE = "GoToSpan"
 const val ACTION_OPEN_REPORT_PARAM_VALUE = "OpenReport"
+const val ACTION_GO_TO_ERROR_PARAM_VALUE = "GoToError"
 
 
 fun findProjectOrNull(projectName: String): Project? {

model/src/main/kotlin/org/digma/intellij/plugin/model/rest/common/EnvironmentInfoByErrorId.kt

@@ -0,0 +1,11 @@
+package org.digma.intellij.plugin.model.rest.common
+
+import com.fasterxml.jackson.annotation.JsonCreator
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties
+import java.beans.ConstructorProperties
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+data class EnvironmentInfoByErrorId
+@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
+@ConstructorProperties("environmentId")
+constructor(val environmentId: String)

ui-version

@@ -1 +1 @@
-14.2.4
+14.2.5