homework_7 - Васильева Анна

homeworks/homework_7/src/main/scala/Breakfast.scala

@@ -1,7 +1,8 @@
 package ru.dru
 
 import zio.CanFail.canFailAmbiguous1
-import zio.{Duration, Exit, Fiber, Scope, ZIO, ZIOApp, ZIOAppArgs, ZIOAppDefault, durationInt}
+import zio.Clock.{currentDateTime, sleep}
+import zio.{Duration, Exit, Fiber, Scope, ZIO, ZIOApp, ZIOAppArgs, ZIOAppDefault, durationLong}
 
 import java.time.LocalDateTime
 import scala.concurrent.TimeoutException
@@ -32,9 +33,25 @@ object Breakfast extends ZIOAppDefault {
   def makeBreakfast(eggsFiringTime: Duration,
                     waterBoilingTime: Duration,
                     saladInfoTime: SaladInfoTime,
-                    teaBrewingTime: Duration): ZIO[Any, Throwable, Map[String, LocalDateTime]] = ???
-
-
+                    teaBrewingTime: Duration): ZIO[Any, Throwable, Map[String, LocalDateTime]] = {
+    val totalTimeSalad = durationLong(saladInfoTime.cucumberTime.toSeconds + saladInfoTime.tomatoTime.toSeconds)
+
+    for {
+      startTime <- ZIO.succeed(LocalDateTime.now())
+      eggsFryFiber <- ZIO.sleep(eggsFiringTime).as(startTime.plusSeconds(eggsFiringTime.toSeconds)).fork
+      waterBoilFiber <- ZIO.sleep(waterBoilingTime).as(startTime.plusSeconds(waterBoilingTime.toSeconds)).fork
+      saladWithSourCreamTime <- ZIO.sleep(totalTimeSalad.seconds)
+        .as(startTime.plusSeconds(saladInfoTime.cucumberTime.toSeconds).plusSeconds(saladInfoTime.tomatoTime.toSeconds))
+      waterBoiledTime <- waterBoilFiber.join
+      teaTime <- ZIO.sleep(teaBrewingTime).as(waterBoiledTime.plusSeconds(teaBrewingTime.toSeconds))
+      eggsFriedTime <- eggsFryFiber.join
+    } yield Map(
+      "eggs" -> eggsFriedTime,
+      "water" -> waterBoiledTime,
+      "saladWithSourCream" -> saladWithSourCreamTime,
+      "tea" -> teaTime
+    )
+  }
 
   override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] = ZIO.succeed(println("Done"))
 

homeworks/homework_7/src/main/scala/ResuourceTraining.scala

@@ -13,9 +13,18 @@ import java.io.{BufferedReader, BufferedWriter, FileReader, FileWriter}
 
 object ResuourceTraining extends ZIOAppDefault {
 
-  def readData(filePath: String): IO[Throwable, String] = ???
-
-  def writeData(filePath: String, data: String): ZIO[Any, Nothing, Unit] = ???
+  def readData(filePath: String): IO[Throwable, String] =
+    ZIO.acquireReleaseWith(ZIO.attempt(new BufferedReader(new FileReader(filePath)))
+    )(reader => ZIO.attempt(reader.close()).orDie)(reader => ZIO.attempt(reader.readLine()))
+
+  def writeData(filePath: String, data: String): ZIO[Any, Nothing, Unit] =
+    ZIO.acquireReleaseWith(ZIO.attempt(new BufferedWriter(new FileWriter(filePath)))
+    )(writer => ZIO.attempt(writer.close()).orDie)(
+      writer => ZIO.attempt {
+        writer.write(data)
+        writer.flush()
+      }
+    ).orDie
 
   override def run: ZIO[Any with ZIOAppArgs with Scope, Any, Any] = ZIO.succeed("Done")
 }