sigmasternchen/xtext-core
1
0
Fork 0
mirror of https://github.com/sigmasternchen/xtext-core synced 2025-03-16 00:38:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[lsi][launcher] log json messages

Browse source 
Change-Id: I448a773b66c52e6e1e8f8bfb2169b4c3c176f87e
Signed-off-by: akosyakov <anton.kosyakov@typefox.io>
This commit is contained in:
akosyakov 2016-06-02 14:53:46 +02:00
parent 4bb2b8be60
commit 2f9a805926
1 changed files with 55 additions and 82 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

137
plugins/org.eclipse.xtext.ide/src/org/eclipse/xtext/ide/server/ServerLauncher.xtend
View file

@ -9,96 +9,69 @@ package org.eclipse.xtext.ide.server
import com.google.inject.Guice
import com.google.inject.Inject
import io.typefox.lsapi.NotificationMessage
import io.typefox.lsapi.services.json.LanguageServerToJsonAdapter
import io.typefox.lsapi.services.json.LoggingJsonAdapter
import java.io.ByteArrayInputStream
import java.io.ByteArrayOutputStream
import java.io.FileOutputStream
import java.io.PrintStream
import java.io.OutputStream
import java.io.InputStream
import java.io.OutputStream
import java.io.PrintStream
import java.io.PrintWriter
/**
* @author Sven Efftinge - Initial contribution and API
*/
class ServerLauncher {
private static boolean IS_DEBUG = false
def static void main(String[] args) {
IS_DEBUG = args.exists[it == 'debug']
val stdin = System.in
val stdout = System.out
redirectStandardStreams()
val launcher = Guice.createInjector(new ServerModule).getInstance(ServerLauncher)
launcher.start(stdin, stdout)
}
@Inject LanguageServerImpl languageServer
def void start(InputStream in, OutputStream out) {
System.err.println("Starting Xtext Language Server.")
val messageAcceptor = new LanguageServerToJsonAdapter(languageServer) {
override protected _doAccept(NotificationMessage message) {
if (IS_DEBUG) {
println(message)
}
super._doAccept(message)
}
override protected sendResponse(String responseId, Object resultValue) {
if (IS_DEBUG) {
println("response : "+resultValue)
}
super.sendResponse(responseId, resultValue)
}
override protected sendNotification(String methodId, Object parameter) {
if (IS_DEBUG) {
println("id"+methodId)
println("notification : "+parameter)
}
super.sendNotification(methodId, parameter)
}
override protected sendResponseError(String responseId, String errorMessage, int errorCode, Object errorData) {
if (IS_DEBUG) {
println("id"+responseId)
println("error : "+errorMessage)
}
super.sendResponseError(responseId, errorMessage, errorCode, errorData)
}
override exit() {
System.err.println("Exit notification received. Good Bye!")
super.exit()
private static boolean IS_DEBUG = false
def static void main(String[] args) {
IS_DEBUG = args.exists[it == 'debug']
val stdin = System.in
val stdout = System.out
redirectStandardStreams()
val launcher = Guice.createInjector(new ServerModule).getInstance(ServerLauncher)
launcher.start(stdin, stdout)
}
@Inject LanguageServerImpl languageServer
def void start(InputStream in, OutputStream out) {
System.err.println("Starting Xtext Language Server.")
val messageAcceptor = if (IS_DEBUG) {
new LoggingJsonAdapter(languageServer) => [
errorLog = new PrintWriter(System.err)
messageLog = new PrintWriter(System.out)
]
} else {
new LanguageServerToJsonAdapter(languageServer) => [
protocol.addErrorListener [ p1, p2 |
p2.printStackTrace(System.err)
]
]
}
}
messageAcceptor.protocol.addErrorListener[p1, p2|
p2.printStackTrace(System.err)
]
messageAcceptor.connect(in, out)
System.err.println("started.")
messageAcceptor.join
while (true) {
Thread.sleep(10_000l)
}
}
def static redirectStandardStreams() {
System.setIn(new ByteArrayInputStream(newByteArrayOfSize(0)))
val id = ServerLauncher.name+"-"+System.currentTimeMillis
if (IS_DEBUG) {
val stdFileOut = new FileOutputStream("out-"+id+".log")
System.setOut(new PrintStream(stdFileOut))
val stdFileErr = new FileOutputStream("error-"+id+".log")
System.setErr(new PrintStream(stdFileErr))
} else {
System.setOut(new PrintStream(new ByteArrayOutputStream()))
System.setErr(new PrintStream(new ByteArrayOutputStream()))
}
}
}
messageAcceptor.connect(in, out)
System.err.println("started.")
messageAcceptor.join
while (true) {
Thread.sleep(10_000l)
}
}
def static redirectStandardStreams() {
System.setIn(new ByteArrayInputStream(newByteArrayOfSize(0)))
val id = ServerLauncher.name + "-" + System.currentTimeMillis
if (IS_DEBUG) {
val stdFileOut = new FileOutputStream("out-" + id + ".log")
System.setOut(new PrintStream(stdFileOut))
val stdFileErr = new FileOutputStream("error-" + id + ".log")
System.setErr(new PrintStream(stdFileErr))
} else {
System.setOut(new PrintStream(new ByteArrayOutputStream()))
System.setErr(new PrintStream(new ByteArrayOutputStream()))
}
}
}