luke
/
sbt
mirror of https://github.com/sbt/sbt.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Extract serializeResponse

This commit is contained in:
Dale Wijnand 2018-03-09 12:06:29 +00:00
parent d3ef452a5f
commit 5f56fa9f14
No known key found for this signature in database
GPG Key ID: 4F256E3D151DF5EF
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
protocol/src/main/scala/sbt/protocol/Serialization.scala
View File

@ -8,7 +8,7 @@
package sbt package sbt
package protocol package protocol
import sjsonnew.JsonFormat import sjsonnew.{ JsonFormat, JsonWriter }
import sjsonnew.support.scalajson.unsafe.{ Parser, Converter, CompactPrinter } import sjsonnew.support.scalajson.unsafe.{ Parser, Converter, CompactPrinter }
import sjsonnew.shaded.scalajson.ast.unsafe.{ JValue, JObject, JString } import sjsonnew.shaded.scalajson.ast.unsafe.{ JValue, JObject, JString }
import java.nio.ByteBuffer import java.nio.ByteBuffer
@ -44,28 +44,28 @@ object Serialization {
/** This formats the message according to JSON-RPC. http://www.jsonrpc.org/specification */ /** This formats the message according to JSON-RPC. http://www.jsonrpc.org/specification */
private[sbt] def serializeResponseMessage(message: JsonRpcResponseMessage): Array[Byte] = { private[sbt] def serializeResponseMessage(message: JsonRpcResponseMessage): Array[Byte] = {
import sbt.internal.protocol.codec.JsonRPCProtocol._ import sbt.internal.protocol.codec.JsonRPCProtocol._
val json: JValue = Converter.toJson[JsonRpcResponseMessage](message).get serializeResponse(message)
val body = CompactPrinter(json)
val bodyBytes = body.getBytes("UTF-8")
(s"Content-Length: ${bodyBytes.size}\r\n" +
s"Content-Type: $VsCode\r\n" +
"\r\n" +
body).getBytes("UTF-8")
} }
/** This formats the message according to JSON-RPC. http://www.jsonrpc.org/specification */ /** This formats the message according to JSON-RPC. http://www.jsonrpc.org/specification */
private[sbt] def serializeNotificationMessage( private[sbt] def serializeNotificationMessage(
message: JsonRpcNotificationMessage): Array[Byte] = { message: JsonRpcNotificationMessage,
): Array[Byte] = {
import sbt.internal.protocol.codec.JsonRPCProtocol._ import sbt.internal.protocol.codec.JsonRPCProtocol._
val json: JValue = Converter.toJson[JsonRpcNotificationMessage](message).get serializeResponse(message)
val body = CompactPrinter(json) }
val bodyBytes = body.getBytes("UTF-8")
(s"Content-Length: ${bodyBytes.size}\r\n" + private[sbt] def serializeResponse[A: JsonWriter](message: A): Array[Byte] = {
s"Content-Type: $VsCode\r\n" + val json: JValue = Converter.toJson[A](message).get
"\r\n" + val body = CompactPrinter(json)
body).getBytes("UTF-8") val bodyLength = body.getBytes("UTF-8").length
Iterator(
s"Content-Length: $bodyLength",
s"Content-Type: $VsCode",
"",
body
).mkString("\r\n").getBytes("UTF-8")
} }
/** /**