forked from palantir/python-language-server
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
59 lines (57 loc) · 2.06 KB
/
Copy pathserver.js
File metadata and controls
59 lines (57 loc) · 2.06 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
#!/usr/bin/env node
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const ws = require("ws");
const rpcServer = require("@sourcegraph/vscode-ws-jsonrpc/lib/server");
let serverPort = 3000;
let languageServers = {
pythonServer: [ 'pyls' ],
python3Server: [ 'pyls' ],
// go: [ '/usr/local/bin/go', 'langserver.go' ],
cppServer: [ 'clangd', '--all-scopes-completion=true' ],
cServer: [ 'clangd', '--all-scopes-completion=true' ],
// ts: [ 'typescript-language-server.cmd', '--stdio' ],
javaServer: [ '/home/ubuntu/java-language-server/dist/lang_server_linux.sh' ],
java8Server: [ '/home/ubuntu/java-language-server/dist/lang_server_linux.sh' ]
};
const wss = new ws.Server({
port: serverPort,
perMessageDeflate: false
}, () => {
console.log(`Listening to http and ws requests on ${serverPort}`);
});
function toSocket(webSocket) {
return {
send: content => webSocket.send(content),
onMessage: cb => webSocket.onmessage = event => cb(event.data),
onError: cb => webSocket.onerror = event => {
if ('message' in event) {
cb(event.message);
}
},
onClose: cb => webSocket.onclose = event => cb(event.code, event.reason),
dispose: () => webSocket.close()
};
}
wss.on('connection', (client, request) => {
let langServer;
Object.keys(languageServers).forEach((key) => {
if (request.url === '/' + key) {
langServer = languageServers[key];
}
});
if (!langServer || !langServer.length) {
console.error('Invalid language server', request.url);
client.close();
return;
}
let localConnection = rpcServer.createServerProcess('Example', langServer[0], langServer.slice(1));
let socket = toSocket(client);
let connection = rpcServer.createWebSocketConnection(socket);
rpcServer.forward(connection, localConnection);
console.log(`Forwarding new client`);
socket.onClose((code, reason) => {
console.log('Client closed', reason);
localConnection.dispose();
});
});