debugger paused resume events (#181)

Author: shalom938

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

@@ -1,5 +1,6 @@
 package org.digma.intellij.plugin.analytics;
 
+import org.digma.intellij.plugin.model.rest.debugger.DebuggerEventRequest;
 import org.digma.intellij.plugin.model.rest.errordetails.CodeObjectErrorDetails;
 import org.digma.intellij.plugin.model.rest.errors.CodeObjectError;
 import org.digma.intellij.plugin.model.rest.insights.CodeObjectInsight;
@@ -18,6 +19,8 @@ public interface AnalyticsProvider extends Closeable {
 
     List<String> getEnvironments();
 
+    void sendDebuggerEvent(DebuggerEventRequest debuggerEventRequest);
+
     List<CodeObjectSummary> getSummaries(CodeObjectSummaryRequest summaryRequest);
 
     List<CodeObjectInsight> getInsights(InsightsRequest insightsRequest);

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

@@ -6,6 +6,7 @@
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
 import okhttp3.ResponseBody;
+import org.digma.intellij.plugin.model.rest.debugger.DebuggerEventRequest;
 import org.digma.intellij.plugin.model.rest.errordetails.CodeObjectErrorDetails;
 import org.digma.intellij.plugin.model.rest.errors.CodeObjectError;
 import org.digma.intellij.plugin.model.rest.insights.CodeObjectInsight;
@@ -54,6 +55,10 @@ public List<String> getEnvironments() {
     }
 
 
+    public void sendDebuggerEvent(DebuggerEventRequest debuggerEventRequest){
+        execute(() -> client.analyticsProvider.sendDebuggerEvent(debuggerEventRequest));
+    }
+
     public List<CodeObjectSummary> getSummaries(CodeObjectSummaryRequest summaryRequest) {
         return execute(() -> client.analyticsProvider.getSummaries(summaryRequest));
     }
@@ -246,6 +251,13 @@ public boolean verify(String s, SSLSession sslSession) {
     //both have the same methods with different return type.
     private interface AnalyticsProviderRetrofit {
 
+        @Headers({
+                "Accept: application/+json",
+                "Content-Type:application/json"
+        })
+        @POST("/CodeAnalytics/instrumentation/event")
+        Call<Void> sendDebuggerEvent(@Body DebuggerEventRequest debuggerEventRequest);
+
 
         @Headers({
                 "Accept: application/+json",

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

@@ -7,7 +7,9 @@
 import com.intellij.ui.JBColor;
 import org.apache.commons.lang3.time.StopWatch;
 import org.digma.intellij.plugin.common.Backgroundable;
+import org.digma.intellij.plugin.common.CommonUtils;
 import org.digma.intellij.plugin.log.Log;
+import org.digma.intellij.plugin.model.rest.debugger.DebuggerEventRequest;
 import org.digma.intellij.plugin.model.rest.errordetails.CodeObjectErrorDetails;
 import org.digma.intellij.plugin.model.rest.errors.CodeObjectError;
 import org.digma.intellij.plugin.model.rest.insights.CodeObjectInsight;
@@ -152,6 +154,14 @@ private String getCurrentEnvironment() throws AnalyticsServiceException {
     }
 
 
+    public void sendDebuggerEvent(int eventType) throws AnalyticsServiceException {
+        executeCatching(() -> {
+            analyticsProviderProxy.sendDebuggerEvent(new DebuggerEventRequest(String.valueOf(eventType), CommonUtils.getLocalHostname(), String.valueOf(System.currentTimeMillis())));
+            return null;
+        });
+    }
+
+
     public List<CodeObjectSummary> getSummaries(List<String> objectIds) throws AnalyticsServiceException {
         var env = getCurrentEnvironment();
         return executeCatching(() -> analyticsProviderProxy.getSummaries(new CodeObjectSummaryRequest(env, objectIds)));
@@ -230,6 +240,8 @@ private AnalyticsProvider newAnalyticsProviderProxy(AnalyticsProvider 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/debugger/DebuggerListener.kt

@@ -0,0 +1,33 @@
+package org.digma.intellij.plugin.debugger
+
+import com.intellij.openapi.project.Project
+import com.intellij.xdebugger.XDebugSession
+import com.intellij.xdebugger.XDebuggerManagerListener
+
+class DebuggerListener(private val project: Project): XDebuggerManagerListener {
+
+    private var currentSessionListener: SessionListener? = null
+
+    override fun currentSessionChanged(previousSession: XDebugSession?, currentSession: XDebugSession?) {
+
+        //if debugger paused on breakpoint and user kills the debug session without resuming then
+        //sessionResumed will not be called. here we track the state of SessionListener,
+        //if it was paused but never resumed and now the debug session changed then call sessionResumed.
+        //on session start isPaused will return false
+        currentSessionListener?.let {
+            if (it.isPaused()){
+                it.sessionResumed()
+            }
+        }
+
+        currentSessionListener?.let {
+            previousSession?.removeSessionListener(it)
+        }
+
+
+        currentSession?.let {
+            currentSessionListener = SessionListener(project)
+            it.addSessionListener(currentSessionListener!!)
+        }
+    }
+}

ide-common/src/main/kotlin/org/digma/intellij/plugin/debugger/SessionListener.kt

@@ -0,0 +1,39 @@
+package org.digma.intellij.plugin.debugger
+
+import com.intellij.openapi.diagnostic.Logger
+import com.intellij.openapi.project.Project
+import com.intellij.xdebugger.XDebugSessionListener
+import org.digma.intellij.plugin.analytics.AnalyticsService
+import org.digma.intellij.plugin.log.Log
+
+class SessionListener(project: Project) : XDebugSessionListener {
+
+    private val logger: Logger = Logger.getInstance(SessionListener::class.java)
+
+    private val analyticsService = project.getService(AnalyticsService::class.java)
+
+    private var paused = false
+
+    fun isPaused():Boolean{
+        return paused
+    }
+
+    override fun sessionPaused() {
+        paused = true
+        try {
+            analyticsService.sendDebuggerEvent(0)
+        }catch (e:Exception){
+            Log.log(logger::debug, "exception calling sendDebuggerEvent {}. ", e.message)
+        }
+    }
+
+    override fun sessionResumed() {
+        paused = false
+        try {
+            analyticsService.sendDebuggerEvent(1)
+        }catch (e:Exception){
+            Log.log(logger::debug, "exception calling sendDebuggerEvent {}. ", e.message)
+        }
+    }
+
+}

model/src/main/kotlin/org/digma/intellij/plugin/model/rest/debugger/DebuggerEventRequest.kt

@@ -0,0 +1,7 @@
+package org.digma.intellij.plugin.model.rest.debugger
+
+import com.fasterxml.jackson.annotation.JsonCreator
+
+data class DebuggerEventRequest
+@JsonCreator(mode = JsonCreator.Mode.PROPERTIES)
+constructor(val event: String, val machineName: String,val timestamp: String)

src/main/resources/META-INF/plugin.xml

@@ -94,6 +94,8 @@
         <listener
                 class="org.digma.intellij.plugin.emvironment.EnvironmentChangeHandler"
                 topic="org.digma.intellij.plugin.analytics.EnvironmentChanged"/>
+        <listener class="org.digma.intellij.plugin.debugger.DebuggerListener"
+                  topic="com.intellij.xdebugger.XDebuggerManagerListener"/>
     </projectListeners>