public static void main(final String[] args) { try { ServerModule _serverModule = new ServerModule(); final Injector injector = Guice.createInjector(_serverModule); final LanguageServer languageServer = injector.<LanguageServer>getInstance(LanguageServer.class); final ServerSocketChannel serverSocket = ServerSocketChannel.open(); InetSocketAddress _inetSocketAddress = new InetSocketAddress("localhost", 5007); serverSocket.bind(_inetSocketAddress); final SocketChannel socketChannel = serverSocket.accept(); InputStream _newInputStream = Channels.newInputStream(socketChannel); OutputStream _newOutputStream = Channels.newOutputStream(socketChannel); PrintWriter _printWriter = new PrintWriter(System.out); final Launcher<LanguageClient> launcher = LSPLauncher.createServerLauncher(languageServer, _newInputStream, _newOutputStream, true, _printWriter); launcher.startListening().get(); } catch (Throwable _e) { throw Exceptions.sneakyThrow(_e); } }
@Before public void setup() throws IOException { PipedInputStream inClient = new PipedInputStream(); PipedOutputStream outClient = new PipedOutputStream(); PipedInputStream inServer = new PipedInputStream(); PipedOutputStream outServer = new PipedOutputStream(); inClient.connect(outServer); outClient.connect(inServer); server = new AssertingEndpoint(); serverLauncher = LSPLauncher.createServerLauncher(ServiceEndpoints.toServiceObject(server, LanguageServer.class), inServer, outServer); serverListening = serverLauncher.startListening(); client = new AssertingEndpoint(); clientLauncher = LSPLauncher.createClientLauncher(ServiceEndpoints.toServiceObject(client, LanguageClient.class), inClient, outClient); clientListening = clientLauncher.startListening(); }
@Override public LanguageServer launch(String projectPath, LanguageClient client) throws LanguageServerException { try { Socket socket = new Socket(host, port); socket.setKeepAlive(true); InputStream inputStream = socket.getInputStream(); OutputStream outputStream = socket.getOutputStream(); Launcher<LanguageServer> launcher = Launcher.createLauncher(client, LanguageServer.class, inputStream, outputStream); launcher.startListening(); return launcher.getRemoteProxy(); } catch (IOException e) { throw new LanguageServerException( "Can't launch language server for project: " + projectPath, e); } }
public PomReconciler( MavenProjectManager mavenProjectManager, EditorWorkingCopyManager editorWorkingCopyManager, EventService eventService, LanguageClient client) { this.mavenProjectManager = mavenProjectManager; this.editorWorkingCopyManager = editorWorkingCopyManager; this.eventService = eventService; this.client = client; editorContentUpdateEventSubscriber = new EventSubscriber<EditorWorkingCopyUpdatedEvent>() { @Override public void onEvent(EditorWorkingCopyUpdatedEvent event) { onEditorContentUpdated(event); } }; eventService.subscribe(editorContentUpdateEventSubscriber); }
/** * Listen for requests from the parent node process. Send replies asynchronously. When the * request stream is closed, wait for 5s for all outstanding responses to compute, then return. */ public static void run(Socket connection) throws IOException { JavaLanguageServer server = new JavaLanguageServer(); Launcher<LanguageClient> launcher = LSPLauncher.createServerLauncher( server, connection.getInputStream(), connection.getOutputStream()); server.installClient(launcher.getRemoteProxy()); launcher.startListening(); LOG.info(String.format("java.version is %s", System.getProperty("java.version"))); }
void installClient(LanguageClient client) { this.client.complete(client); Handler sendToClient = new Handler() { @Override public void publish(LogRecord record) { String message = record.getMessage(); if (record.getThrown() != null) { StringWriter trace = new StringWriter(); record.getThrown().printStackTrace(new PrintWriter(trace)); message += "\n" + trace; } client.logMessage( new MessageParams( messageType(record.getLevel().intValue()), message)); } private MessageType messageType(int level) { if (level >= Level.SEVERE.intValue()) return MessageType.Error; else if (level >= Level.WARNING.intValue()) return MessageType.Warning; else if (level >= Level.INFO.intValue()) return MessageType.Info; else return MessageType.Log; } @Override public void flush() {} @Override public void close() throws SecurityException {} }; Logger.getLogger("").addHandler(sendToClient); }
JavaWorkspaceService( CompletableFuture<LanguageClient> client, JavaLanguageServer server, JavaTextDocumentService textDocuments) { this.client = client; this.server = server; this.textDocuments = textDocuments; }
private static JavaLanguageServer getJavaLanguageServer( Path workspaceRoot, LanguageClient client) { JavaLanguageServer server = new JavaLanguageServer(); InitializeParams init = new InitializeParams(); init.setRootPath(workspaceRoot.toString()); server.initialize(init); server.installClient(client); server.maxItems = 100; return server; }
@Override public void initialize(final ILanguageServerAccess access) { this.access = access; this.access.addBuildListener(this); LanguageClient _languageClient = access.getLanguageClient(); this.client = ServiceEndpoints.<TestLangLSPExtension.CustomClient>toServiceObject(((Endpoint) _languageClient), TestLangLSPExtension.CustomClient.class); }
public void initialize(final Iterable<? extends IResourceServiceProvider> allLanguages, final ClientCapabilities capabilities, final LanguageClient client) { this.client = client; this.registeredCommands = HashMultimap.<String, IExecutableCommandService>create(); Boolean _elvis = null; WorkspaceClientCapabilities _workspace = capabilities.getWorkspace(); ExecuteCommandCapabilities _executeCommand = null; if (_workspace!=null) { _executeCommand=_workspace.getExecuteCommand(); } Boolean _dynamicRegistration = null; if (_executeCommand!=null) { _dynamicRegistration=_executeCommand.getDynamicRegistration(); } if (_dynamicRegistration != null) { _elvis = _dynamicRegistration; } else { _elvis = Boolean.valueOf(false); } final boolean hasDynamicRegistration = (boolean) _elvis; for (final IResourceServiceProvider lang : allLanguages) { { final IExecutableCommandService service = lang.<IExecutableCommandService>get(IExecutableCommandService.class); if ((service != null)) { final List<String> commands = service.initialize(); for (final String c : commands) { this.registeredCommands.put(c, service); } if (hasDynamicRegistration) { final Function1<String, IDisposable> _function = (String command) -> { return this.register(command, service); }; service.initializeDynamicRegistration(_function); } } } } }
@Before public void setup() { final Map<String, JsonRpcMethod> methods = ServiceEndpoints.getSupportedMethods(LanguageServer.class); final Map<String, JsonRpcMethod> clientMethods = ServiceEndpoints.getSupportedMethods(LanguageClient.class); final HashMap<String, JsonRpcMethod> all = new HashMap<String, JsonRpcMethod>(); all.putAll(methods); all.putAll(clientMethods); MessageJsonHandler _messageJsonHandler = new MessageJsonHandler(all); this.jsonHandler = _messageJsonHandler; }
@Override public final LanguageServer launch(String projectPath, LanguageClient client) throws LanguageServerException { Process languageServerProcess = startLanguageServerProcess(projectPath); waitCheckProcess(languageServerProcess); return connectToLanguageServer(languageServerProcess, client); }
@Override protected LanguageServer connectToLanguageServer( Process languageServerProcess, LanguageClient client) throws LanguageServerException { Launcher<LanguageServer> launcher = Launcher.createLauncher( client, LanguageServer.class, languageServerProcess.getInputStream(), languageServerProcess.getOutputStream()); launcher.startListening(); return launcher.getRemoteProxy(); }
@Test public void testFindServer() throws Exception { ServerCapabilities cap = registry.initialize(PREFIX + FILE_PATH); assertNotNull(cap); assertEquals(cap, serverCapabilities); Mockito.verify(initializer) .initialize(eq(languageServerLauncher), any(LanguageClient.class), eq(PROJECT_PATH)); }
@Override protected LanguageServer connectToLanguageServer( final Process languageServerProcess, LanguageClient client) { Launcher<LanguageServer> launcher = Launcher.createLauncher( client, LanguageServer.class, languageServerProcess.getInputStream(), languageServerProcess.getOutputStream()); launcher.startListening(); return launcher.getRemoteProxy(); }
protected LanguageServer connectToLanguageServer( final Process languageServerProcess, LanguageClient client) { Launcher<LanguageServer> launcher = Launcher.createLauncher( client, LanguageServer.class, languageServerProcess.getInputStream(), languageServerProcess.getOutputStream()); launcher.startListening(); return launcher.getRemoteProxy(); }
protected LanguageServer connectToLanguageServer( final Process languageServerProcess, LanguageClient client) { Launcher<LanguageServer> launcher = Launcher.createLauncher( client, LanguageServer.class, languageServerProcess.getInputStream(), languageServerProcess.getOutputStream()); launcher.startListening(); setYamlLanguageServer(launcher.getRemoteProxy()); return launcher.getRemoteProxy(); }
public static void main(String[] args) { CamelLanguageServer server = new CamelLanguageServer(); Launcher<LanguageClient> launcher = Launcher.createLauncher(server, LanguageClient.class, System.in, System.out); server.connect(launcher.getRemoteProxy()); launcher.startListening(); }
@Override public void connect(LanguageClient client) { this.client = client; sendLogMessageNotification(MessageType.Info, "Connected to Language Server..."); }
JavaTextDocumentService(CompletableFuture<LanguageClient> client, JavaLanguageServer server) { this.client = client; this.server = server; }
public static Launcher<LanguageClient> createServerLauncher(LanguageServer server, InputStream in, OutputStream out) { return Launcher.createLauncher(server, LanguageClient.class, in, out); }
public static Launcher<LanguageClient> createServerLauncher(LanguageServer server, InputStream in, OutputStream out, boolean validate, PrintWriter trace) { return Launcher.createLauncher(server, LanguageClient.class, in, out, validate, trace); }
public static Launcher<LanguageClient> createServerLauncher(LanguageServer server, InputStream in, OutputStream out, ExecutorService executorService, Function<MessageConsumer, MessageConsumer> wrapper) { return Launcher.createLauncher(server, LanguageClient.class, in, out, executorService, wrapper); }
public static Launcher<LanguageServer> createClientLauncher(LanguageClient client, InputStream in, OutputStream out) { return Launcher.createLauncher(client, LanguageServer.class, in, out); }
public static Launcher<LanguageServer> createClientLauncher(LanguageClient client, InputStream in, OutputStream out, boolean validate, PrintWriter trace) { return Launcher.createLauncher(client, LanguageServer.class, in, out, validate, trace); }
public static Launcher<LanguageServer> createClientLauncher(LanguageClient client, InputStream in, OutputStream out, ExecutorService executorService, Function<MessageConsumer, MessageConsumer> wrapper) { return Launcher.createLauncher(client, LanguageServer.class, in, out, executorService, wrapper); }
@Override public void connect(final LanguageClient client) { this.som.connect(client); this.client = client; }
public void connect(final LanguageClient client) { this.client = client; }
@Override public void connect(final LanguageClient client) { this.client = client; }
@Override public LanguageClient getLanguageClient() { return LanguageServerImpl.this.client; }
