Take out IO from parser

src/main/scala/parse/Main.scala

@@ -0,0 +1,28 @@
+package parse
+
+import cats.effect.IO
+import cats.effect.unsafe.implicits.global
+
+import java.time.LocalDateTime
+import java.time.format.DateTimeFormatter
+
+object Main {
+  private def run: IO[Unit] = {
+    println("================ start parser")
+
+    val formatter = DateTimeFormatter.ofPattern("yyyyMMdd_HHmm")
+    val from = LocalDateTime.parse("20230414_2200", formatter)
+    val to = LocalDateTime.parse("20230501_1230", formatter)
+
+    for {
+      lines <- db.DBService.getInRange(from, to)
+      parsed <- IO.pure(Parser.queryData(lines, List("Liepāja", "Rēzekne", "randomstr"), AggregateMeteo.tempAvg))
+      _ <- IO.println(parsed)
+    } yield ()
+  }
+
+  def main(args: Array[String]): Unit = {
+    run.unsafeRunSync()
+  }
+
+}

src/main/scala/parse/Parser.scala

@@ -1,8 +1,5 @@
 package parse
 
-import cats.effect.IO
-import cats.effect.unsafe.implicits.global
-
 import java.time.LocalDateTime
 import java.time.format.DateTimeFormatter
 import scala.util.Try
@@ -58,34 +55,12 @@ object Parser {
     }
   }
 
+  // TODO move out
   def queryData(
      data: List[String],
      cities: List[String],
      aggregator: AggregateMeteo,
-   ): IO[Map[String, Double]] = {
+   ): Map[String, Double] = {
-    for {
+    aggregateLines(data, cities, aggregator)
-
-      weatherLines <- IO.pure(aggregateLines(data, cities, aggregator))
-//      _ <- IO.println(weatherLines)
-    } yield weatherLines
-  }
-
-  // TODO remove this. Just for testing
-  private def run: IO[Unit] = {
-    println("================ start parser")
-
-    val formatter = DateTimeFormatter.ofPattern("yyyyMMdd_HHmm")
-    val from = LocalDateTime.parse("20230414_2200", formatter)
-    val to = LocalDateTime.parse("20230501_1230", formatter)
-
-    for {
-      lines <- db.DBService.getInRange(from, to)
-      parsed <- queryData(lines, List("Liepāja", "Rēzekne", "randomstr"), AggregateMeteo.tempAvg)
-      _ <- IO.println(parsed)
-    } yield ()
-  }
-
-  def main(args: Array[String]): Unit = {
-    run.unsafeRunSync()
   }
 }

src/main/scala/server/Server.scala

@@ -44,7 +44,7 @@ object Server extends IOApp {
         case Some((from, to, cityList, aggregate)) => {
           val res = for {
             lines <- db.DBService.getInRange(from, to)
-            parsedData <- parse.Parser.queryData(lines, cityList, aggregate)
+            parsedData <- IO.pure(parse.Parser.queryData(lines, cityList, aggregate))
           } yield parsedData
 
           Ok(res.map(_.toString()))