A suite of scala libraries for building and consuming RESTful web services on top of Akka: lightweight, asynchronous, non-blocking, actor-based, testable
thanks!
although, looks like it's still eager in akka-http, but will upgrade first
@shankarshastri you can use spray-json.
import spray.json._
val jsonString: String = ???
val json: JsObject = jsonString.parseJson.asJsObjector you can declare a class describing this json and declare format for it and then convert to it directly:
class JsonRepr(???)
implicit object ReprFormat extends RootJsonFormat[JsonRepr]{
???
}
import spray.json._
val jsonString: String = ???
jsonString.parseJson.convertTo[ReprFormat]
to specify them in case class
you can then get Map[String, JsValue] of the fields of the JsObject
jsonString.parseJson.asJsObject.fields will return Map[String, JsValue]
I meant code.
@VladislavRybin in akka-http you can use
concat instead of ~ which might be less prone to confusing IntelliJ - not sure if that was in Spray already though (https://doc.akka.io/docs/akka-http/current/routing-dsl/directives/index.html)
please upgrade to akka-http; spray has been end-of-life for years
the upgrade is rather straight forward
@vito-c most people have moved to akka-http and discuss it in akka/akka or https://discuss.akka.io I think
@vito-c for marshalling case classes in akka-http I think both spray-json and play-json are still popular
I'm not sure about websockets specifically but still https://doc.akka.io/docs/akka-http/current/common/json-support.html#json-support might help?
@raboof how would one marshal to a just a Message? I can do it automatically to a MessageEntity
could not find implicit value for parameter m: akka.http.scaladsl.marshalling.Marshal
ler[eneovim.EnMessage,akka.http.scaladsl.model.ws.Message]
[error] val outgoing = Source.fromFuture(Marshal(myMsg).to[Message])
[error] ^
@vito-c do you mean
HttpEntity? It works for those because of the implicit conversion at https://github.com/akka/akka-http/blob/master/akka-http-marshallers-scala/akka-http-spray-json/src/main/scala/akka/http/scaladsl/marshallers/sprayjson/SprayJsonSupport.scala#L65, you might want to introduce a similar one for Message
(you're writing a Scala plugin for neovim? that sounds pretty cool)
@vito-c not really... not sure I understand exactly what you need but something like
implicit def sprayJsonToWsMessageMarshaller[T](implicit writer: RootJsonWriter[T], printer: JsonPrinter = CompactPrinter): Marshaller[T, Message] =
Marshaller.strict(t => Marshalling.Opaque(() => TextMessage(writer.write(t)))) might work?
Hi. The spray testkit doesn't seem to work with contentType. I have an example here: https://github.com/JoeCordingley/spray-marshallersExample where if you hit localhost:8080 with either application/json or application/myJson in the running service it returns the correct contentType but testing the route using spray testkit it always returns application/json
Hey I know spray is EOL'd but I'm wondering if there would be any concerns w/ setting a request timeout at a per-request level
httpExtension ! connect
def receive = {
case akka.io.Tcp.Connected(_, _) =>
// The client should then respond with Connected.
// We take the sender of that Connected response (which is an HttpClientConnection)
val httpClientConnection = sender()
sender() ! SetRequestTimeout(timeout.duration)
sender() ! request
case res: HttpResponse =>
// HttpResponse is the expected response from sending the HttpRequest.
promise.success(res)
context.stop(self)
// handle errorsI feel like this may not work
because the HttpClientConnection may receive another request in between
Or that will just ignore pooling and always create additional connections?
I guess my question is really: how do I set a request timeout per request
That's what I came up with ^
there are host connectors that are created by host, port and config.
Above is the connection configuration
Hi guys! I can't get the JsonFormats for recursive Types section of the README.md compiling. Literally copy pasting
case class Foo(i: Int, foo: Foo)
implicit val fooFormat: JsonFormat[Foo] = lazyFormat(jsonFormat(Foo, "i", "foo"))leads to
[error] /Users/thomasvogel/sandbox/scala-sandbox/akka-http-sandbox/src/main/scala/tom/vogel/Example.scala:57:68: forward reference extends over definition of value fooFormat
[error] implicit val fooFormat: JsonFormat[Foo] = lazyFormat(jsonFormat(Foo, "i", "foo"))Any ideas?
@thomas-vogel444 Hi, Thomas! We use the
jsonFormatRec derivation macro from the kebs library for that, like here: https://github.com/plokhotnyuk/jsoniter-scala/blob/master/jsoniter-scala-benchmark/src/main/scala/com/github/plokhotnyuk/jsoniter_scala/benchmark/SprayFormats.scala#L133
Does spay supports application/problem+json context Type?
content*
