2023-05-14 15:48:52 +03:00
|
|
|
package server
|
|
|
|
|
import cats.effect._
|
2023-05-17 01:20:01 +03:00
|
|
|
import cats.implicits.catsSyntaxTuple2Parallel
|
2023-05-14 15:48:52 +03:00
|
|
|
import db.DBService
|
|
|
|
|
import fetch.{FetchService, FileNameService}
|
|
|
|
|
|
|
|
|
|
object Main extends IOApp {
|
|
|
|
|
def run(args: List[String]): IO[ExitCode] = {
|
2023-05-17 16:28:56 +03:00
|
|
|
// TODO looks like fetchTask fails server if no csv on meteo server
|
2023-05-14 15:48:52 +03:00
|
|
|
val fetchTask = FileNameService.generateCurrentHour.flatMap(FetchService.fetchSingleFile)
|
2023-05-17 01:20:01 +03:00
|
|
|
val scheduler = Scheduler.scheduleTask(fetchTask)
|
|
|
|
|
.evalMap { case (name, content) =>
|
|
|
|
|
IO(println(s"fetched: $name")) *>
|
|
|
|
|
DBService.save(name, content).attempt.flatMap {
|
|
|
|
|
case Right(savedName) => IO(println(s"File saved: $savedName"))
|
|
|
|
|
case Left(err) => IO(println(s"Error: $err"))
|
|
|
|
|
}
|
|
|
|
|
}.compile.drain // Convert Stream[IO, Unit] to IO[Unit]
|
|
|
|
|
|
|
|
|
|
val server = Server.run // This is an IO[Server]
|
|
|
|
|
|
|
|
|
|
(server, scheduler).parMapN((_, _) => ExitCode.Success)
|
2023-05-14 15:48:52 +03:00
|
|
|
}
|
|
|
|
|
}
|