Base proxy-ing setup

Author: Stefterv

java/build.gradle.kts

@@ -1,5 +1,6 @@
 plugins {
     id("java")
+    kotlin("jvm") version libs.versions.kotlin
 }
 
 repositories{

java/src/processing/mode/java/lsp/proxy/BaseLanguageClient.kt

@@ -0,0 +1,35 @@
+package processing.mode.java.lsp.proxy
+
+import org.eclipse.lsp4j.MessageActionItem
+import org.eclipse.lsp4j.MessageParams
+import org.eclipse.lsp4j.PublishDiagnosticsParams
+import org.eclipse.lsp4j.ShowMessageRequestParams
+import org.eclipse.lsp4j.services.LanguageClient
+import org.eclipse.lsp4j.services.LanguageServer
+import java.util.concurrent.CompletableFuture
+
+class BaseLanguageClient: LanguageClient {
+    var downstream: LanguageServer? = null
+
+    override fun telemetryEvent(`object`: Any?) {
+        println("Telemetry: $`object`")
+    }
+
+    override fun publishDiagnostics(diagnostics: PublishDiagnosticsParams?) {
+        println("Diagnostics: $diagnostics")
+    }
+
+    override fun showMessage(messageParams: MessageParams?) {
+        println("Message: $messageParams")
+    }
+
+    override fun showMessageRequest(requestParams: ShowMessageRequestParams?): CompletableFuture<MessageActionItem?>? {
+        println("Message request: $requestParams")
+        return CompletableFuture.completedFuture(null)
+    }
+
+    override fun logMessage(message: MessageParams?) {
+        TODO("Not yet implemented")
+    }
+
+}

java/src/processing/mode/java/lsp/proxy/BaseLanguageServer.kt

@@ -0,0 +1,33 @@
+package processing.mode.java.lsp.proxy
+
+import org.eclipse.lsp4j.InitializeParams
+import org.eclipse.lsp4j.InitializeResult
+import org.eclipse.lsp4j.services.LanguageClient
+import org.eclipse.lsp4j.services.LanguageServer
+import org.eclipse.lsp4j.services.TextDocumentService
+import org.eclipse.lsp4j.services.WorkspaceService
+import java.util.concurrent.CompletableFuture
+
+class BaseLanguageServer(val downstream: LanguageServer) : LanguageServer {
+    var upstream: LanguageClient? = null
+
+    override fun initialize(params: InitializeParams?): CompletableFuture<InitializeResult?>? {
+        return downstream.initialize(params)
+    }
+
+    override fun shutdown(): CompletableFuture<in Any>? {
+        return downstream.shutdown()
+    }
+
+    override fun exit() {
+        return downstream.exit()
+    }
+
+    override fun getTextDocumentService(): TextDocumentService? {
+        return downstream.textDocumentService
+    }
+
+    override fun getWorkspaceService(): WorkspaceService? {
+        return downstream.workspaceService
+    }
+}

java/src/processing/mode/java/lsp/proxy/PdeLanguageServerProxy.java

@@ -1,60 +1,32 @@
 package processing.mode.java.lsp.proxy;
 
-import org.eclipse.lsp4j.InitializeParams;
-import org.eclipse.lsp4j.InitializeResult;
-import org.eclipse.lsp4j.launch.LSPLauncher;
-import org.eclipse.lsp4j.services.*;
-
-import java.util.concurrent.CompletableFuture;
-
-public class PdeLanguageServerProxy implements LanguageServer, LanguageClientAware {
-    static public void main(String[] args) {
-        var input = System.in;
-        var output = System.out;
-        System.setOut(System.err);
-
-        var server = new PdeLanguageServerProxy();
-        var launcher =
-                LSPLauncher.createServerLauncher(
-                        server,
-                        input,
-                        output
-                );
-        var client = launcher.getRemoteProxy();
-        server.connect(client);
-        launcher.startListening();
-
-        //        Approach 1: Start the PdeProxy and pipe everything else through to the Eclipse JDT LS and modify paths and such at runtime
-        //        Approach 2: Manually write the actions that will send the correct data the Eclipse JDT LS
-    }
 
-    @Override
-    public void connect(LanguageClient client) {
+import org.eclipse.lsp4j.launch.LSPLauncher;
 
-    }
+import java.io.IOException;
 
-    @Override
-    public CompletableFuture<InitializeResult> initialize(InitializeParams params) {
-        return null;
-    }
+public class PdeLanguageServerProxy {
+    static public void main(String[] args) throws IOException {
+        var processBuilder = new ProcessBuilder()
+                .command("bash", "-c", "/Applications/Processing.app/Contents/MacOS/Processing lsp");
+        var baseLSP = processBuilder.start();
 
-    @Override
-    public CompletableFuture<Object> shutdown() {
-        return null;
-    }
+        var baseIn = baseLSP.getInputStream();
+        var baseOut = baseLSP.getOutputStream();
+        var baseErr = baseLSP.getErrorStream();
 
-    @Override
-    public void exit() {
+        var baseClient = new BaseLanguageClient();
+        var baseServerLauncher = LSPLauncher.createClientLauncher(baseClient, baseIn, baseOut);
+        var downstreamServer = baseServerLauncher.getRemoteProxy();
+        baseClient.setDownstream(downstreamServer);
+        baseServerLauncher.startListening();
 
-    }
+        var baseServer = new BaseLanguageServer(downstreamServer);
 
-    @Override
-    public TextDocumentService getTextDocumentService() {
-        return null;
-    }
+        var baseClientLauncher = LSPLauncher.createServerLauncher(baseServer, System.in, System.out);
+        var upstreamClient = baseClientLauncher.getRemoteProxy();
+        baseServer.setUpstream(upstreamClient);
 
-    @Override
-    public WorkspaceService getWorkspaceService() {
-        return null;
+        baseClientLauncher.startListening();
     }
 }