fluencelabs/cosmos-hackathon-backend
1
0
Fork 0
mirror of https://github.com/fluencelabs/cosmos-hackathon-backend synced 2025-05-29 15:41:27 +00:00
Code Issues Projects Releases Wiki Activity

fix /block

Browse Source
This commit is contained in:
folex 2019-06-16 10:30:28 +02:00
parent 795689cc92
commit 4cb583810c
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/scala/hackhack/AppRegistry.scala
View File

@ -181,14 +181,14 @@ class AppRegistry[F[_]: Monad: Concurrent: ContextShift: Timer: LiftIO](
}
}
def getBlock(name: String, height: Long) =
def getBlock(name: String, height: Long): EitherT[F, Throwable, String] =
for {
appOpt <- EitherT.right(apps.get.flatMap(map =>
Traverse[Option].sequence(map.get(name).map(_.get))))
app <- appOpt
.fold(new Exception(s"There is no app $name").asLeft[App])(_.asRight)
.toEitherT[F]
block <- rpc(name, app.peer, s"/block?height=$height")
block <- rpc(name, app.peer, s"/block", "height" -> "10")
} yield block.spaces2
private def log(str: String) = EitherT(IO(println(str)).attempt.to[F])
@ -227,10 +227,11 @@ class AppRegistry[F[_]: Monad: Concurrent: ContextShift: Timer: LiftIO](
private def rpc(appName: String,
peer: Peer,
path: String): EitherT[F, Throwable, Json] =
path: String,
params: (String, String)*): EitherT[F, Throwable, Json] =
Backoff.default.retry(
sttp
.get(peer.RpcUri.path(path))
.get(peer.RpcUri.path(path).params(params : _*))
.send[EitherT[F, Throwable, ?]]
.subflatMap(
_.body