From 692594dcad57f5f87be081bb864708706aca1945 Mon Sep 17 00:00:00 2001
From: Guntis Smaukstelis <gsmaukstelis@evolution.com>
Date: Sun, 16 Feb 2025 16:42:35 +0200
Subject: [PATCH] Save csv to postgres after fetching

---
 src/main/scala/Main.scala | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/scala/Main.scala b/src/main/scala/Main.scala
index c793f43..d8045d1 100644
--- a/src/main/scala/Main.scala
+++ b/src/main/scala/Main.scala
@@ -18,7 +18,12 @@ object Main extends IOApp {
       dataService <- DataService.of
       fetchService <- FetchService.of
 
-      fetchCsvList = new FileNameService().generateCurrentHour.flatMap(fetchService.fetchSingleFile)
+      fetchCsvList = new FileNameService().generateCurrentHour
+        .flatMap(fetchService.fetchSingleFile)
+        .flatMap {
+          case Right((name, content)) => postgresService.save(name, content)
+          case Left(error) => IO.raiseError(error)
+        }
       fetchCsvTask = scheduler.scheduleTask("Fetch CSV", List(31), fetchCsvList).compile.drain
 
       cleanupTask = scheduler.scheduleTask("Cleanup", List(1), dataService.deleteOldForecasts()).compile.drain