Use ToolEvent for inspect elements (#6881)

Fixes #6875

Some things I'm not sure about:
- I'm currently using the custom VM service stream 'ToolEvent' directly.
VS Code is using the DAP forwarding of events from this stream; is this
a point where it would make sense to use DAP from DDS?
- This skips large portions of previous architecture to listen for
changes in selections, e.g. classes like `InspectorObjectGroupManager` -
is that okay?

Author: helin24

flutter-idea/src/io/flutter/inspector/InspectorService.java

@@ -21,6 +21,7 @@
 import com.intellij.openapi.roots.ModuleRootManager;
 import com.intellij.openapi.util.Disposer;
 import com.intellij.openapi.util.SystemInfo;
+import com.intellij.openapi.vfs.LocalFileSystem;
 import com.intellij.openapi.vfs.VirtualFile;
 import com.intellij.psi.PsiDocumentManager;
 import com.intellij.psi.PsiElement;
@@ -55,7 +56,10 @@
 import java.awt.*;
 import java.awt.image.BufferedImage;
 import java.io.ByteArrayInputStream;
+import java.io.File;
 import java.io.IOException;
+import java.net.MalformedURLException;
+import java.net.URL;
 import java.util.List;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
@@ -418,6 +422,37 @@ private void onVmServiceReceived(String streamId, Event event) {
         }
         break;
       }
+      case "ToolEvent": {
+        Optional<Event> eventOrNull = Optional.ofNullable(event);
+        if ("navigate".equals(eventOrNull.map(Event::getExtensionKind).orElse(null))) {
+          JsonObject json = eventOrNull.map(Event::getExtensionData).map(ExtensionData::getJson).orElse(null);
+          if (json == null) return;
+
+          String fileUri = JsonUtils.getStringMember(json, "fileUri");
+          if (fileUri == null) return;
+
+          String path;
+          try {
+            path = new URL(fileUri).getFile();
+          }
+          catch (MalformedURLException e) {
+            return;
+          }
+          if (path == null) return;
+
+          VirtualFile file = LocalFileSystem.getInstance().findFileByPath(path);
+          final Integer line = JsonUtils.getIntMember(json, "line");
+          final Integer column = JsonUtils.getIntMember(json, "column");;
+
+          ApplicationManager.getApplication().invokeLater(() -> {
+            if (file != null && line >= 0 && column >= 0) {
+              XSourcePositionImpl position = XSourcePositionImpl.create(file, line - 1, column - 1);
+              position.createNavigatable(app.getProject()).navigate(false);
+            }
+          });
+        }
+        break;
+      }
       default:
     }
   }

flutter-idea/src/io/flutter/vmService/VmServiceWrapper.java

@@ -174,6 +174,17 @@ public void received(final Isolate isolate) {
         });
       }
     });
+
+    streamListen("ToolEvent", new SuccessConsumer() {
+      @Override
+      public void received(Success response) {
+      }
+
+      @Override
+      public void onError(RPCError error) {
+        LOG.error("Error listening to ToolEvent stream: " + error);
+      }
+    });
   }
 
   private void streamListen(@NotNull String streamId, @NotNull SuccessConsumer consumer) {