BlazeServerBuilder[IO](executionContext)
.bindHttp(serverConfig.port, serverConfig.host)
.withHttpApp(app)
.resource
.use(_ => IO.never)
.start
.as(ExitCode.Success)
Would that just be converting via scala object => json => string => Text?
yep
Is it possible to do something like this in my test :
val routes = HttpRoutes
.of[Id] { case _ =>
Ok(AccessTokenResponse("token", "bearer", 3600, "openid"))
}
.orNotFoundApparently Ok creates an IO and I don't know how to make it work. If it's even possible. It says it wants an Id[Response[Id]] when I give it IO[Response[IO]]
Temporal and Concurrent. Nevermind I guess
.of[IO] in this case
Hi, Just starting with Http4s, and right now I'm looking for examples that shows the different ways to use encoders. In the official doc, the only example shown is for decoder only
println(response.flatMap(_.as[Resp]).unsafeRunSync)could anyone point me to some examples that could help with this please ?
val s = "foo"
EntityEncoder[F, String].toEntity(s) // Entity[F]Ok(..) do this automatically
Hi, I am trying to send a Post Request as MultiPart Data. The difference with the examples provided in the repo, is that, i need to send the data from inputStreams that i do have in memory.
There is a function for that but it is not exposed publicly, and to be fair i do not really understand very well the reason explained in the comment. Ultimately, i ended reproducing the function externally for my use case.
object Part {
....
// The InputStream is passed by name, and we open it in the by-name
// argument in callers, so we can avoid lifting into an effect. Exposing
// this API publicly would invite unsafe use, and the `EntityBody` version
// should be safe.
private def fileData[F[_]](
name: String,
filename: String,
in: => InputStream,
headers: Header.ToRaw*)(implicit F: Sync[F]): Part[F] =
fileData(name, filename, readInputStream(F.delay(in), ChunkSize), headers: _*)
}What I ended doing in my code is:
def inputStreamAsFileData[F[_]](name: String, filename: String, in: => InputStream, headers: Header.ToRaw*) (implicit F: Sync[F]): Part[F] = {
val ChunkSize = 8192
fileData(name, filename, readInputStream(F.delay(in), ChunkSize), headers: _*)
}Hence my question is, what would be the unsafe way to use that function actually ? Just to make sure that i do not do anything i should not do ?
private so the author themselves are responsible that it is used properly. But for public methods, that inputStream would be taken as an in: IO[InputStream] argument.
InputStream here? You could use something from fs2-io. That's going to be safe.
On the second point, well, i am in my journey in making the most of the TypeLevel Stack. I started working with cats-effects and IO and all, about 2 months ago. So far i am using doobie, Cats-effect effectively, and now working on http4s, and slowly getting to fs2. So i guess change will be incremental, as it is a lot to take in.
readInputStream(F.delay(in), ChunkSize) make use of the interop capability of it.
readInputStream is from fs2-io. I missed a crucial portion in my answer - you need to wrap the creation of the inputStream in IO, so that it is created every time it is needed.
val in = F.delay(new Inputstream(..))
readInputStream(in, ChunkSize), headers: _*)val in = new Inputstream(..)
readInputStream(F.delay(in), ChunkSize), headers: _*)
3 replies
I've defined authenticated routes with:
private val httpRoutes: AuthedRoutes[User, JobTask] = AuthedRoutes.of[User, JobTask] {
case GET -> Root / ObjectIdVar(id) as user =>
...Prior to adding authentication, I used this construct to add a prefix to the paths for all those routes:
// val routes: HttpRoutes[JobTask] = Router(
// prefixPath -> httpRoutes
//)Now, I want to do the same but can't use Router. What do I use instead?
val routes: AuthedRoutes[User, JobTask] = Router(
prefixPath -> httpRoutes
)Doesn't compile.
