Scalafmtv0.1.2v0.1.1

3 files changed, 13 insertions, 14 deletions

diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueue.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueue.scala
index 320666d..feb3774 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueue.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueue.scala
@@ -28,7 +28,8 @@ object BridgeUploadQueue {
                         dependencyTag: Option[String]) {
 
     def dependency: Option[Dependency] = {
-      dependencyKind.zip(dependencyTag)
+      dependencyKind
+        .zip(dependencyTag)
         .headOption
         .map(Function.tupled(Dependency.apply))
     }
diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
index 8c87b60..a98d2cd 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/BridgeUploadQueueRepositoryAdapter.scala
@@ -30,8 +30,9 @@ object BridgeUploadQueueRepositoryAdapter {
       */
     final case class LimitExponential(startInterval: FiniteDuration,
                                       intervalFactor: Double,
-                                        maxInterval: FiniteDuration,
-                                      onComplete: OnComplete) extends Strategy {
+                                      maxInterval: FiniteDuration,
+                                      onComplete: OnComplete)
+        extends Strategy {
 
       override def on(attempt: Int): OnAttempt = {
         OnAttempt.Continue(intervalFor(attempt).min(maxInterval))
@@ -67,14 +68,14 @@ object BridgeUploadQueueRepositoryAdapter {
     sealed trait OnComplete
     object OnComplete {
       case object Delete extends OnComplete
-      case object Mark extends OnComplete
+      case object Mark   extends OnComplete
 
       implicit def toPhiString(x: OnAttempt): PhiString = Unsafe(x.toString)
     }
 
     sealed trait OnAttempt
     object OnAttempt {
-      case object Complete extends OnAttempt
+      case object Complete                    extends OnAttempt
       case class Continue(interval: Duration) extends OnAttempt
 
       implicit def toPhiString(x: OnAttempt): PhiString = Unsafe(x.toString)
@@ -84,9 +85,8 @@ object BridgeUploadQueueRepositoryAdapter {
 
 class BridgeUploadQueueRepositoryAdapter(strategy: Strategy,
                                          repository: BridgeUploadQueueRepository,
-                                         transactions: Transactions)
-                                        (implicit executionContext: ExecutionContext)
-  extends BridgeUploadQueue with PhiLogging {
+                                         transactions: Transactions)(implicit executionContext: ExecutionContext)
+    extends BridgeUploadQueue with PhiLogging {
 
   override def add(item: Item): Future[Unit] = transactions.run { _ =>
     repository.add(item)
@@ -104,7 +104,7 @@ class BridgeUploadQueueRepositoryAdapter(strategy: Strategy,
       case Mark =>
         repository.getById(item) match {
           case Some(x) => repository.update(x.copy(completed = true))
-          case None => throw new RuntimeException(s"Can not find the $item task")
+          case None    => throw new RuntimeException(s"Can not find the $item task")
         }
     }
   }
@@ -115,7 +115,7 @@ class BridgeUploadQueueRepositoryAdapter(strategy: Strategy,
     logger.trace(phi"tryRetry($item)")
 
     val newAttempts = item.attempts + 1
-    val action = strategy.on(newAttempts)
+    val action      = strategy.on(newAttempts)
     logger.debug(phi"Action for ${Unsafe(newAttempts)}: $action")
 
     action match {
diff --git a/src/main/scala/xyz/driver/pdsuicommon/concurrent/Cron.scala b/src/main/scala/xyz/driver/pdsuicommon/concurrent/Cron.scala
index a6e9d2c..dd84beb 100644
--- a/src/main/scala/xyz/driver/pdsuicommon/concurrent/Cron.scala
+++ b/src/main/scala/xyz/driver/pdsuicommon/concurrent/Cron.scala
@@ -62,10 +62,8 @@ object Cron {
 
   case class Settings(disable: String, intervals: Map[String, FiniteDuration])
 
-  private class SingletonTask(taskName: String,
-                              job: () => Future[Unit])
-                             (implicit ec: ExecutionContext)
-    extends TimerTask with StrictLogging {
+  private class SingletonTask(taskName: String, job: () => Future[Unit])(implicit ec: ExecutionContext)
+      extends TimerTask with StrictLogging {
 
     private val isWorking = new AtomicBoolean(false)