Reformat with scalafmt 3.7.14

Executed command: scalafmt --non-interactive
yarhrn · Sep 11, 2023 · 05c4987 · 05c4987
1 parent 3aceac0
commit 05c4987
Show file tree

Hide file tree

Showing 7 changed files with 18 additions and 24 deletions.
diff --git a/src/main/scala/rozklad/api/MaintenanceService.scala b/src/main/scala/rozklad/api/MaintenanceService.scala
@@ -1,6 +1,5 @@
 package rozklad.api
 
-
 trait MaintenanceService[F[_]] {
 
   def remove(id: Id[ScheduledTask]): F[RemovedScheduledTask]

diff --git a/src/main/scala/rozklad/api/ScheduledTaskService.scala b/src/main/scala/rozklad/api/ScheduledTaskService.scala
@@ -22,13 +22,13 @@ trait ScheduledTaskService[F[_]] {
 case class TaskIsNotInExpectedStatusException(id: Id[ScheduledTask]) extends RuntimeException(s"Task ${id} is not in acquired state")
 
 case class ScheduledTaskLog(
-                             id: Id[ScheduledTaskLog],
-                             taskId: Id[ScheduledTask],
-                             status: Status,
-                             createdAt: Instant,
-                             failedReason: Option[FailedReason],
-                             payload: JsValue,
-                             triggerAt: Option[Instant])
+    id: Id[ScheduledTaskLog],
+    taskId: Id[ScheduledTask],
+    status: Status,
+    createdAt: Instant,
+    failedReason: Option[FailedReason],
+    payload: JsValue,
+    triggerAt: Option[Instant])
 
 object ScheduledTaskLog {
   def from(task: ScheduledTask): ScheduledTaskLog = {
@@ -43,4 +43,4 @@ object ScheduledTaskLog {
       Some(triggerAt)
     )
   }
-}
+}
diff --git a/src/main/scala/rozklad/db/DoobieScheduledTaskRepository.scala b/src/main/scala/rozklad/db/DoobieScheduledTaskRepository.scala
@@ -151,4 +151,4 @@ class DoobieScheduledTaskRepository(table: String) extends ScheduledTaskReposito
     query.query[ScheduledTask].to[List]
   }
 
-}
+}
diff --git a/src/main/scala/rozklad/db/DoobieTaskScheduler.scala b/src/main/scala/rozklad/db/DoobieTaskScheduler.scala
@@ -18,7 +18,8 @@ class DoobieTaskScheduler[F[_]](
     xa: Transactor[F],
     observer: Observer[F],
     scheduledTaskRepository: ScheduledTaskRepository = new DoobieScheduledTaskRepository(DefaultScheduledTasksTableName),
-    scheduledTaskLogsRepository: ScheduledTaskLogRepository = new DoobieScheduledTaskLogRepository(DefaultScheduledTasksLogsTableName))(implicit ME: MonadCancel[F, Throwable])
+    scheduledTaskLogsRepository: ScheduledTaskLogRepository = new DoobieScheduledTaskLogRepository(DefaultScheduledTasksLogsTableName))(
+    implicit ME: MonadCancel[F, Throwable])
     extends TaskScheduler[F] {
 
   override def schedule(id: Id[ScheduledTask], triggerAt: Instant, scheduledAt: Instant, payload: JsValue): F[ScheduledTask] = {

diff --git a/src/main/scala/rozklad/db/ScheduledTaskLogRepository.scala b/src/main/scala/rozklad/db/ScheduledTaskLogRepository.scala
@@ -6,4 +6,4 @@ trait ScheduledTaskLogRepository {
   def insert(tasks: List[ScheduledTask]): doobie.ConnectionIO[Unit]
   def select(id: Id[ScheduledTask]): doobie.ConnectionIO[List[ScheduledTaskLog]]
   def delete(id: Id[ScheduledTask]): doobie.ConnectionIO[List[ScheduledTaskLog]]
-}
+}
diff --git a/src/main/scala/rozklad/db/ScheduledTaskRepository.scala b/src/main/scala/rozklad/db/ScheduledTaskRepository.scala
@@ -21,5 +21,4 @@ trait ScheduledTaskRepository {
       updatedPayload: Option[JsValue]): doobie.ConnectionIO[List[ScheduledTask]]
 }
 
-
-case class InsertDuplicate() extends RuntimeException
+case class InsertDuplicate() extends RuntimeException
diff --git a/src/test/scala/rozklad/impl/ExecutorServiceServiceTest.scala b/src/test/scala/rozklad/impl/ExecutorServiceServiceTest.scala
@@ -20,8 +20,7 @@ import scala.reflect.ClassTag
 class ExecutorServiceServiceTest extends AnyFlatSpec with ScheduledTaskLogMatchers with MockFactory {
 
   "ExecutorService" should "report failing" in new ctx {
-    self =>
-    val e = new RuntimeException("test")
+    self => val e = new RuntimeException("test")
     (tasks.acquireBatch _).expects(*, *).returning(IO.raiseError(e)).once()
     val es = createExecutor
     eventually {
@@ -49,8 +48,7 @@ class ExecutorServiceServiceTest extends AnyFlatSpec with ScheduledTaskLogMatche
   }
 
   it should "report successful execution" in new ctx {
-    s =>
-    (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
+    s => (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
     (executor.execute _).expects(*).returning(IO(ScheduledTaskOutcome.Succeeded.empty))
     (tasks.succeeded _).expects(*, *, *).returning(IO(task))
 
@@ -65,8 +63,7 @@ class ExecutorServiceServiceTest extends AnyFlatSpec with ScheduledTaskLogMatche
   }
 
   it should "report failed execution" in new ctx {
-    self =>
-    (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
+    self => (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
     val reason: FailedReason.Exception.type = FailedReason.Exception
     val payload: JsObject = Json.obj("Hui" -> "no")
     (executor.execute _).expects(*).returning(IO(ScheduledTaskOutcome.Failed(Option(reason), Some(payload))))
@@ -85,8 +82,7 @@ class ExecutorServiceServiceTest extends AnyFlatSpec with ScheduledTaskLogMatche
   }
 
   it should "report errored execution" in new ctx {
-    self =>
-    (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
+    self => (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
     (tasks.failed _).expects(*, *, *, *).returning(IO(task))
     val e = new RuntimeException("error")
     (executor.execute _).expects(*).returning(IO.raiseError(e))
@@ -114,8 +110,7 @@ class ExecutorServiceServiceTest extends AnyFlatSpec with ScheduledTaskLogMatche
   }
 
   it should "propagate error during handling execution result" in new ctx {
-    s =>
-    val ex = new RuntimeException("dsfsdf")
+    s => val ex = new RuntimeException("dsfsdf")
 
     (tasks.acquireBatch _).expects(*, *).returning(IO(List(task)))
     (executor.execute _).expects(*).returning(IO(ScheduledTaskOutcome.Succeeded.empty))
-Original file line number
+Diff line change
@@ Expand Up @@
         query.query[ScheduledTask].to[List]
       }
-    }
+    }