how to make a implement a Language client using lsp4j

[subham008]

i have a language server running , so now how could i implement a Language client whihc will connect with that running language server , i read documentation but its incomplete for Language client .

Any help will be appreciated, Thank you

[pisv]

Depending on your needs, you could use either LSP4E or LXTK for this.

[subham008]

LSP4E is specially support Eclipse ide , am not working for Eclipse , am developing a IDE in Java just for learning , so i want LSP implementation in java and that is LSP4J

[pisv]

Basically, you need to implement the LanguageClient interface in LSP4J. However, it is not that simple as it may sound. That's why special language client frameworks such as LXTK have been created on top of LSP4J. Even if you prefer not to use them, I'd suggest taking a look at their code as an example, especially if your goal is learning.

[pisv]

I can also recommend this article as an introduction to the core concepts of LSP4J.

[subham008]

hey tried every thing its a pain I tried LSP4E and LXTKA too but i didnt achieve anything , can you please write a just to implment a client which wil get diagnostic , code completions , and get Documentation on hover , please help me in this

i am not using LSP43 or LXTK , am only using LSP4J now
here is my present code which is not working i dont know why :

public class client {

    public static void start()  {


        // Start the typescript-language-server as a subprocess
        ProcessBuilder processBuilder = new ProcessBuilder("typescript-language-server.cmd", "--stdio","--log-level=4" );
        processBuilder.redirectErrorStream(true);
        Process serverProcess = null;
        try {
            serverProcess = processBuilder.start();
            System.out.println("Server started");
        } catch (IOException exception) {
            System.err.println("Failed to create process :" + exception);
            System.exit(1);
        }


        // Obtain InputStream and OutputStream from the server process
        InputStream serverInput = serverProcess.getInputStream();
        OutputStream serverOutput = serverProcess.getOutputStream();

        LanguageClientImpl languageClient = new LanguageClientImpl();

        //  a launcher for the LSP client
        Launcher<LanguageServer> launcher = Launcher.createLauncher(languageClient, LanguageServer.class,serverInput,serverOutput);
        LanguageServer server = launcher.getRemoteProxy();
        launcher.startListening();

        InitializeParams params = new InitializeParams();
        List<WorkspaceFolder> folders = new ArrayList<>();
        folders.add(new WorkspaceFolder("file:///E:/languaug_server/LSP4jClient/app/src/main","resources"));
        params.setWorkspaceFolders(folders);
        params.setCapabilities(new ClientCapabilities());

        CompletableFuture<InitializeResult> initialized = server.initialize(params);

          

        try{

            initialized.get();
          // System.out.println("params initialized wait passed");
            // Open the document
            String fileUri = Paths.get("E:/languaug_server/LSP4jClient/app/src/main/resources/sample.ts").toAbsolutePath().toUri().toString();

            DidOpenTextDocumentParams openParams = new DidOpenTextDocumentParams();
            TextDocumentItem textDocumentItem = new TextDocumentItem(fileUri, "typescript", 1, "const num1 = 10;\n" +
                    "const num2 = 5;\n" +
                    "\n" +
                    "console.log(`${num1} + ${num2} = ${calculator.add(num1, num2)}`);\n" +
                "console.log(`${num1} - ${num2} = ${calculator.subtract(num1, num2)}`);\n" +
                    "console.log(`${num1} * ${num2} = ${calculator.multiply(num1, num2)}`);\n" +
                    "console.log(`${num1} / ${num2} = ${calculator.divide(num1, num2)}`);");
            openParams.setTextDocument(textDocumentItem);
        server.getTextDocumentService().didOpen(openParams);


     

            // Request diagnostics
            CompletableFuture<List<Diagnostic>> diagnosticsFuture = new CompletableFuture<>();
            languageClient.setDiagnosticsConsumer(diagnostics -> {
                System.out.println("Received diagnostics: " + diagnostics);
                diagnosticsFuture.complete(diagnostics);
            });



            // Wait for diagnostics
            List<Diagnostic> diagnostics = diagnosticsFuture.get();

          
            // Print diagnostics
            System.out.println("Diagnostics for " + fileUri + ":");
            for (Diagnostic diagnostic : diagnostics) {
                System.out.println(diagnostic.getSeverity() + ": " + diagnostic.getMessage() + " at " + diagnostic.getRange());
            }


        }catch (Exception e){
            System.out.println("Linting error :" + e.toString());

        }


        serverProcess.destroy();
    }// end of start

    private static class LanguageClientImpl implements LanguageClient, LanguageClientAware {
        private Consumer<List<Diagnostic>> diagnosticsConsumer;

        public void setDiagnosticsConsumer(Consumer<List<Diagnostic>> consumer) {
            this.diagnosticsConsumer = consumer;
        }

        @Override
        public void publishDiagnostics(PublishDiagnosticsParams diagnostics) {
            System.out.println("Diagnostics received: " + diagnostics.getDiagnostics().size() + " diagnostics");
            if (diagnosticsConsumer != null) {
                diagnosticsConsumer.accept(diagnostics.getDiagnostics());
            }
        }

        @Override
        public void telemetryEvent(Object object) {
              System.out.println("telemetry called:"+object.toString());
        }

        @Override
        public void showMessage(MessageParams messageParams) {
            System.out.println("Message received: " + messageParams.getMessage());
        }

        @Override
        public void logMessage(MessageParams messageParams) {
            System.out.println("Log received: " + messageParams.getMessage());
        }

        @Override
        public CompletableFuture<MessageActionItem> showMessageRequest(ShowMessageRequestParams requestParams) {
            System.out.println("showMessageRequest called:"+requestParams.getMessage());
           // throw new UnsupportedOperationException("Unimplemented method 'showMessageRequest'");
            return null;
        }

        @Override
        public void connect(LanguageClient client) {
            System.out.println("connect called");
        }
    }

}