Getting lvgmc csv files in frontend

src/main/scala/fetch/lvgmc/FetchService.scala

@@ -63,7 +63,7 @@ class FetchService(log: Logger[IO]) {
     }
   }
 
-  private def retrieveFileAsString(ftpClient: FTPClient, remotePath: String): IO[String] = IO.blocking {
+  private def retrieveFileAsBytes(ftpClient: FTPClient, remotePath: String): IO[Array[Byte]] = IO.blocking {
     val outputStream = new ByteArrayOutputStream()
 
     val success = ftpClient.retrieveFile(remotePath, outputStream)
@@ -71,16 +71,16 @@ class FetchService(log: Logger[IO]) {
       throw new RuntimeException(s"Failed to retrieve file: $remotePath, reply: ${ftpClient.getReplyString}")
     }
 
-    outputStream.toString("UTF-8")
+    outputStream.toByteArray()
   }.onError(e => log.error(e)(s"Error retrieving file $remotePath"))
 
-  def fetchFile(fileName: String): IO[String] = {
+  def fetchFile(fileName: String): IO[Array[Byte]] = {
     val remotePath = s"/ltv/tabulas/$fileName"
 
     createFtpClient.use { ftpClient =>
       for {
         _ <- log.info(s"Fetching file: $remotePath")
-        content <- retrieveFileAsString(ftpClient, remotePath)
+        content <- retrieveFileAsBytes(ftpClient, remotePath)
         _ <- log.info(s"Successfully fetched file: $fileName")
       } yield content
     }

src/main/scala/fetch/lvgmc/FetchServiceTest.scala

@@ -18,7 +18,7 @@ object FetchServiceTest {
     val program = for {
       fetch <- FetchService.of
       result <- fetch.fetchFile("Latvija_LTV_pilsetas_tekosa_dn.csv")
-      _ <- IO.println(result)
+      _ <- IO.println(s"fetched file, size: ${result.length}")
     } yield ()
     program
   }

src/main/scala/server/Server.scala

@@ -6,6 +6,7 @@ import com.comcast.ip4s.IpLiteralSyntax
 import data.DataService
 import db.PostgresService
 import fetch.csv.FetchService
+import fetch.lvgmc
 import fs2.io.file.Files
 import server.ValidateRoutes.{AggFieldList, AggKey, CityList, DateTimeRange, Granularity, ValidateDate, ValidateDateTime, ValidateInt, ValidateMonths, ValidateZonedDateTime}
 import io.circe.{Encoder, Json, Printer}
@@ -28,6 +29,7 @@ import org.typelevel.log4cats.Logger
 import org.typelevel.log4cats.slf4j.Slf4jLogger
 import parse.csv.Aggregate
 import fs2.io.file.{Files, Path}
+import org.http4s.headers.`Content-Type`
 
 import java.time.{ZoneOffset, ZonedDateTime}
 import scala.concurrent.duration.DurationInt
@@ -54,6 +56,13 @@ class Server(postgresService: PostgresService, dataService: DataService, fetch:
   private case class ResponseWrapper(result: Map[String, Option[Aggregate.AggregateValue]], query: UserQuery)
 
   private val apiRoutes = HttpRoutes.of[IO] {
+    // http://0.0.0.0:8080/api/show/lvgmc-forecast/Latvija_LTV_pilsetas_tekosa_dn.csv
+    case GET -> Root / "show" / "lvgmc-forecast" / fileName =>
+      println("lvgmc-forecast GET")
+      lvgmc.FetchService.of.flatMap(f => f.fetchFile(fileName)).flatMap(bytes =>
+        Ok(bytes).map(_.withContentType(`Content-Type`(MediaType.text.csv)))
+      )
+
     case GET -> Root / "show" / "gribName" => Ok("{\"fileName\":\"TODO replace this fake name\"}")
 
     // http://0.0.0.0:8080/api/show/grib-all-structure
@@ -198,6 +207,7 @@ class Server(postgresService: PostgresService, dataService: DataService, fetch:
     "/latvia" -> staticcontent.fileService[IO](FileService.Config("./web/dist")),
     "/database" -> staticcontent.fileService[IO](FileService.Config("./web/dist")),
     "/harmonie" -> staticcontent.fileService[IO](FileService.Config("./web/dist")),
+    "/lvgmc-forecast" -> staticcontent.fileService[IO](FileService.Config("./web/dist")),
   ).orNotFound
 
   def run: IO[ExitCode] =