Scala update adaptations

endless4s · Sep 5, 2024 · 23fea62 · 23fea62
1 parent 1848d1d
commit 23fea62
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 13 deletions.
diff --git a/example/src/main/scala/endless/transaction/example/data/AccountState.scala b/example/src/main/scala/endless/transaction/example/data/AccountState.scala
@@ -34,7 +34,7 @@ final case class AccountState(
           case Some(PendingTransfers.AtLeastOneIncoming(transfers)) =>
             NonEmptyList
               .fromList(transfers.filterNot(_.id === id))
-              .map(PendingTransfers.AtLeastOneIncoming)
+              .map(PendingTransfers.AtLeastOneIncoming.apply)
           case None => None
         },
         transferHistory = transferHistory + id
@@ -52,7 +52,7 @@ final case class AccountState(
           case Some(PendingTransfers.AtLeastOneIncoming(transfers)) =>
             NonEmptyList
               .fromList(transfers.filterNot(_.id === id))
-              .map(PendingTransfers.AtLeastOneIncoming)
+              .map(PendingTransfers.AtLeastOneIncoming.apply)
           case None => None
         },
         balance = pendingTransfers match {

diff --git a/example/src/main/scala/endless/transaction/example/logic/AccountEntityBehavior.scala b/example/src/main/scala/endless/transaction/example/logic/AccountEntityBehavior.scala
@@ -6,7 +6,6 @@ import cats.syntax.eq.*
 import cats.syntax.show.*
 import cats.syntax.functor.*
 import cats.syntax.flatMap.*
-import cats.conversions.all.*
 import endless.\/
 import endless.core.entity.Entity
 import endless.transaction.example.algebra.Account

diff --git a/example/src/test/scala/endless/transaction/example/Generators.scala b/example/src/test/scala/endless/transaction/example/Generators.scala
@@ -39,7 +39,7 @@ trait Generators {
   } yield AccountState.PendingTransfer.Incoming(id, amount)
 
   val pendingSingleOutgoingTransferGen: Gen[AccountState.PendingTransfers.SingleOutgoing] =
-    pendingOutgoingTransferGen.map(AccountState.PendingTransfers.SingleOutgoing)
+    pendingOutgoingTransferGen.map(AccountState.PendingTransfers.SingleOutgoing.apply)
 
   val pendingAtLeastOneIncomingTransferGen: Gen[AccountState.PendingTransfers.AtLeastOneIncoming] =
     for {

diff --git a/example/src/test/scala/endless/transaction/example/logic/AccountEventApplierSuite.scala b/example/src/test/scala/endless/transaction/example/logic/AccountEventApplierSuite.scala
@@ -104,7 +104,7 @@ class AccountEventApplierSuite extends munit.ScalaCheckSuite with Generators {
               case PendingTransfers.AtLeastOneIncoming(transfers) =>
                 NonEmptyList
                   .fromList(transfers.filterNot(_.id === pendingTransfer.id))
-                  .map(PendingTransfers.AtLeastOneIncoming)
+                  .map(PendingTransfers.AtLeastOneIncoming.apply)
             },
             transferHistory = Set(pendingTransfer.id)
           )
@@ -126,7 +126,7 @@ class AccountEventApplierSuite extends munit.ScalaCheckSuite with Generators {
         case PendingTransfers.AtLeastOneIncoming(transfers) =>
           NonEmptyList
             .fromList(transfers.filterNot(_.id === pendingTransfer.id))
-            .map(PendingTransfers.AtLeastOneIncoming)
+            .map(PendingTransfers.AtLeastOneIncoming.apply)
         case PendingTransfers.SingleOutgoing(_) => None
       }
       applier.apply(Some(state), AccountEvent.TransferAborted(pendingTransfer.id)) == Right(

diff --git a/lib/src/main/scala/endless/transaction/impl/logic/ShardedCoordinator.scala b/lib/src/main/scala/endless/transaction/impl/logic/ShardedCoordinator.scala
@@ -41,13 +41,14 @@ private[transaction] final class ShardedCoordinator[F[_]: Logger, TID, BID, Q, R
       branch: BID,
       otherBranches: BID*
   ): Resource[F, Transaction[F, BID, Q, R]] =
-    Resource.eval(
-      Logger[F].debug(show"Creating transaction $id") >>
-        sharding
-          .entityFor(id)
-          .create(id, query, NonEmptyList.of[BID](branch, otherBranches*))
-    )
-      >>= {
+    Resource
+      .eval(
+        Logger[F].debug(show"Creating transaction $id") >>
+          sharding
+            .entityFor(id)
+            .create(id, query, NonEmptyList.of[BID](branch, otherBranches*))
+      )
+      .flatMap {
         case Right(_) =>
           Resource.eval(
             Logger[F].debug(show"Transaction transaction $id successfully created")