Reformat with scalafmt 3.7.15

Executed command: scalafmt --non-interactive
softwaremill · Oct 25, 2023 · 23f5d3f · 23f5d3f
1 parent 41aaa17
commit 23f5d3f
Show file tree

Hide file tree

Showing 7 changed files with 60 additions and 11 deletions.
diff --git a/core/src/main/scala/org/elasticmq/util/OffsetDateTimeUtil.scala b/core/src/main/scala/org/elasticmq/util/OffsetDateTimeUtil.scala
@@ -4,5 +4,6 @@ import java.time.{Instant, OffsetDateTime, ZoneOffset}
 
 object OffsetDateTimeUtil {
 
-  def ofEpochMilli(millis: Long): OffsetDateTime = OffsetDateTime.ofInstant(Instant.ofEpochMilli(millis), ZoneOffset.UTC)
+  def ofEpochMilli(millis: Long): OffsetDateTime =
+    OffsetDateTime.ofInstant(Instant.ofEpochMilli(millis), ZoneOffset.UTC)
 }
diff --git a/core/src/test/scala/org/elasticmq/actor/QueueActorMsgOpsTest.scala b/core/src/test/scala/org/elasticmq/actor/QueueActorMsgOpsTest.scala
@@ -292,8 +292,12 @@ class QueueActorMsgOpsTest extends ActorTest with QueueManagerForEachTest with D
     } yield {
       // Then
       lookupResult.statistics should be(MessageStatistics.empty)
-      receiveResult1.statistics should be(MessageStatistics(OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(100L)), 1))
-      receiveResult2.statistics should be(MessageStatistics(OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(100L)), 2))
+      receiveResult1.statistics should be(
+        MessageStatistics(OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(100L)), 1)
+      )
+      receiveResult2.statistics should be(
+        MessageStatistics(OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(100L)), 2)
+      )
     }
   }
 

diff --git a/performance-tests/src/test/scala/org/elasticmq/performance/LocalPerformanceTest.scala b/performance-tests/src/test/scala/org/elasticmq/performance/LocalPerformanceTest.scala
@@ -4,7 +4,12 @@ import akka.actor.{ActorRef, ActorSystem, Props}
 import akka.util.Timeout
 import com.amazonaws.auth.{AWSStaticCredentialsProvider, BasicAWSCredentials}
 import com.amazonaws.client.builder.AwsClientBuilder.EndpointConfiguration
-import com.amazonaws.services.sqs.model.{CreateQueueRequest, DeleteMessageRequest, ReceiveMessageRequest, SendMessageRequest}
+import com.amazonaws.services.sqs.model.{
+  CreateQueueRequest,
+  DeleteMessageRequest,
+  ReceiveMessageRequest,
+  SendMessageRequest
+}
 import com.amazonaws.services.sqs.{AmazonSQS, AmazonSQSClientBuilder}
 import org.elasticmq._
 import org.elasticmq.actor.QueueManagerActor

diff --git a/persistence/persistence-sql/src/main/scala/org/elasticmq/persistence/sql/DBMessage.scala b/persistence/persistence-sql/src/main/scala/org/elasticmq/persistence/sql/DBMessage.scala
@@ -39,7 +39,8 @@ case class DBMessage(
 
     val serializedDeliveryReceipts = new String(deliveryReceipts).parseJson.convertTo[List[String]]
 
-    val firstReceive = received.map(time => OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(time))).getOrElse(NeverReceived)
+    val firstReceive =
+      received.map(time => OnDateTimeReceived(OffsetDateTimeUtil.ofEpochMilli(time))).getOrElse(NeverReceived)
 
     InternalMessage(
       messageId,

diff --git a/rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/QueueAttributesOps.scala b/rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/QueueAttributesOps.scala
@@ -61,7 +61,10 @@ trait QueueAttributesOps extends AttributesModule {
           () => stats.map(_.approximateNumberOfMessagesDelayed.toString)
         ),
         AttributeValuesCalculator
-          .Rule(CreatedTimestampAttribute, () => Future.successful((queueData.created.toInstant.toEpochMilli / 1000L).toString)),
+          .Rule(
+            CreatedTimestampAttribute,
+            () => Future.successful((queueData.created.toInstant.toEpochMilli / 1000L).toString)
+          ),
         AttributeValuesCalculator.Rule(
           LastModifiedTimestampAttribute,
           () => Future.successful((queueData.lastModified.toInstant.toEpochMilli / 1000L).toString)

diff --git a/rest/rest-sqs/src/test/scala/org/elasticmq/rest/sqs/directives/QueueDirectivesTest.scala b/rest/rest-sqs/src/test/scala/org/elasticmq/rest/sqs/directives/QueueDirectivesTest.scala
@@ -43,7 +43,14 @@ class QueueDirectivesTest
   "queueActorFromUrl" should "return correct queue name based on QueueName" in {
     val future = queueManagerActor ? CreateQueue(
       CreateQueueData.from(
-        QueueData("lol", MillisVisibilityTimeout(1L), Duration.ZERO, Duration.ZERO, OffsetDateTime.now(), OffsetDateTime.now())
+        QueueData(
+          "lol",
+          MillisVisibilityTimeout(1L),
+          Duration.ZERO,
+          Duration.ZERO,
+          OffsetDateTime.now(),
+          OffsetDateTime.now()
+        )
       )
     )
     future.value
@@ -61,7 +68,14 @@ class QueueDirectivesTest
   "queueActorAndNameFromUrl" should "return correct queue name based on QueueUrl" in {
     val future = queueManagerActor ? CreateQueue(
       CreateQueueData.from(
-        QueueData("lol", MillisVisibilityTimeout(1L), Duration.ZERO, Duration.ZERO, OffsetDateTime.now(), OffsetDateTime.now())
+        QueueData(
+          "lol",
+          MillisVisibilityTimeout(1L),
+          Duration.ZERO,
+          Duration.ZERO,
+          OffsetDateTime.now(),
+          OffsetDateTime.now()
+        )
       )
     )
     future.value
@@ -79,7 +93,14 @@ class QueueDirectivesTest
   "queueActorAndNameFromUrl" should "return error when invalid QueueUrl" in {
     val future = queueManagerActor ? CreateQueue(
       CreateQueueData.from(
-        QueueData("lol", MillisVisibilityTimeout(1L), Duration.ZERO, Duration.ZERO, OffsetDateTime.now(), OffsetDateTime.now())
+        QueueData(
+          "lol",
+          MillisVisibilityTimeout(1L),
+          Duration.ZERO,
+          Duration.ZERO,
+          OffsetDateTime.now(),
+          OffsetDateTime.now()
+        )
       )
     )
     future.value

diff --git a/...src/test/scala/org/elasticmq/rest/sqs/directives/QueueDirectivesWithContextPathTest.scala b/...src/test/scala/org/elasticmq/rest/sqs/directives/QueueDirectivesWithContextPathTest.scala
@@ -42,7 +42,14 @@ class QueueDirectivesWithContextPathTest
   "queueActorAndNameFromUrl" should "return correct queue name based on QueueName" in {
     val future = queueManagerActor ? CreateQueue(
       CreateQueueData.from(
-        QueueData("lol", MillisVisibilityTimeout(1L), Duration.ZERO, Duration.ZERO, OffsetDateTime.now(), OffsetDateTime.now())
+        QueueData(
+          "lol",
+          MillisVisibilityTimeout(1L),
+          Duration.ZERO,
+          Duration.ZERO,
+          OffsetDateTime.now(),
+          OffsetDateTime.now()
+        )
       )
     )
     Await.result(future, maxDuration)
@@ -60,7 +67,14 @@ class QueueDirectivesWithContextPathTest
   "queueActorAndNameFromUrl" should "return correct queue name based on QueueUrl" in {
     val future = queueManagerActor ? CreateQueue(
       CreateQueueData.from(
-        QueueData("lol", MillisVisibilityTimeout(1L), Duration.ZERO, Duration.ZERO, OffsetDateTime.now(), OffsetDateTime.now())
+        QueueData(
+          "lol",
+          MillisVisibilityTimeout(1L),
+          Duration.ZERO,
+          Duration.ZERO,
+          OffsetDateTime.now(),
+          OffsetDateTime.now()
+        )
       )
     )
     Await.result(future, maxDuration)