Skip to content

Commit 7739f01

Browse files
authored
Merge pull request #198 from SwissBorg/bump-deps
Update dependencies
2 parents 0260986 + 92c5e4d commit 7739f01

File tree

15 files changed

+169
-142
lines changed

15 files changed

+169
-142
lines changed

.scalafmt.conf

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,10 @@
1-
version = 2.7.5
1+
version = 3.0.5
22

33
style = defaultWithAlign
44

5-
docstrings = JavaDoc
6-
indentOperator = spray
5+
docstrings.style = Asterisk
6+
docstrings.wrap = no
7+
indentOperator.preset = spray
78
maxColumn = 120
89
rewrite.rules = [RedundantParens, SortImports, AvoidInfix]
910
unindentTopLevelOperators = true
@@ -12,7 +13,8 @@ align.openParenDefnSite = false
1213
align.openParenCallSite = false
1314
optIn.breakChainOnFirstMethodDot = false
1415
optIn.configStyleArguments = false
15-
danglingParentheses = false
16+
danglingParentheses.defnSite = false
17+
danglingParentheses.callSite = false
1618
spaces.inImportCurlyBraces = true
1719
rewrite.neverInfix.excludeFilters = [
1820
and
@@ -51,3 +53,4 @@ rewriteTokens = {
5153
"←": "<-"
5254
}
5355
newlines.afterCurlyLambda = preserve
56+
newlines.implicitParamListModifierPrefer = before

core/src/main/scala/akka/persistence/postgres/db/DbErrors.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,8 @@ object DbErrors {
2828
DBIO.successful(())
2929
}
3030

31-
def withHandledIndexErrors(logger: Logger, indexDetails: String)(dbio: DBIOAction[_, NoStream, Effect])(implicit
32-
ec: ExecutionContext): DBIOAction[Unit, NoStream, Effect] =
31+
def withHandledIndexErrors(logger: Logger, indexDetails: String)(dbio: DBIOAction[_, NoStream, Effect])(
32+
implicit ec: ExecutionContext): DBIOAction[Unit, NoStream, Effect] =
3333
dbio.asTry.flatMap {
3434
case Failure(ex: SQLException) if ex.getSQLState == PgUniqueViolation =>
3535
logger.debug(s"Index $indexDetails already exists")

core/src/main/scala/akka/persistence/postgres/journal/dao/ByteArrayJournalSerializer.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ import scala.collection.immutable._
1717
import scala.concurrent.{ ExecutionContext, Future }
1818
import scala.util.Try
1919

20-
class ByteArrayJournalSerializer(serialization: Serialization, tagConverter: TagIdResolver)(implicit
21-
val executionContext: ExecutionContext)
20+
class ByteArrayJournalSerializer(serialization: Serialization, tagConverter: TagIdResolver)(
21+
implicit val executionContext: ExecutionContext)
2222
extends FlowPersistentReprSerializer[JournalRow] {
2323

2424
override def serialize(persistentRepr: PersistentRepr, tags: Set[String]): Future[JournalRow] = {

core/src/main/scala/akka/persistence/postgres/journal/dao/FlatJournalDao.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@ import slick.jdbc.JdbcBackend._
99

1010
import scala.concurrent.ExecutionContext
1111

12-
class FlatJournalDao(val db: Database, val journalConfig: JournalConfig, serialization: Serialization)(implicit
13-
val ec: ExecutionContext,
12+
class FlatJournalDao(val db: Database, val journalConfig: JournalConfig, serialization: Serialization)(
13+
implicit val ec: ExecutionContext,
1414
val mat: Materializer)
1515
extends BaseByteArrayJournalDao {
1616
val queries = new JournalQueries(FlatJournalTable(journalConfig.journalTableConfiguration))

core/src/main/scala/akka/persistence/postgres/journal/dao/NestedPartitionsJournalDao.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,8 @@ import slick.jdbc.JdbcBackend.Database
1313
import scala.collection.immutable.{ List, Nil, Seq }
1414
import scala.concurrent.{ ExecutionContext, Future }
1515

16-
class NestedPartitionsJournalDao(db: Database, journalConfig: JournalConfig, serialization: Serialization)(implicit
17-
ec: ExecutionContext,
16+
class NestedPartitionsJournalDao(db: Database, journalConfig: JournalConfig, serialization: Serialization)(
17+
implicit ec: ExecutionContext,
1818
mat: Materializer)
1919
extends FlatJournalDao(db, journalConfig, serialization) {
2020
override val queries = new JournalQueries(NestedPartitionsJournalTable(journalConfig.journalTableConfiguration))

core/src/main/scala/akka/persistence/postgres/journal/dao/PartitionedJournalDao.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@ import slick.jdbc.JdbcBackend.Database
1212
import scala.collection.immutable.{ Nil, Seq }
1313
import scala.concurrent.{ ExecutionContext, Future }
1414

15-
class PartitionedJournalDao(db: Database, journalConfig: JournalConfig, serialization: Serialization)(implicit
16-
ec: ExecutionContext,
15+
class PartitionedJournalDao(db: Database, journalConfig: JournalConfig, serialization: Serialization)(
16+
implicit ec: ExecutionContext,
1717
mat: Materializer)
1818
extends FlatJournalDao(db, journalConfig, serialization) {
1919
override val queries = new JournalQueries(PartitionedJournalTable(journalConfig.journalTableConfiguration))

core/src/main/scala/akka/persistence/postgres/query/JournalSequenceActor.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ import scala.collection.immutable.NumericRange
1717
import scala.concurrent.duration.FiniteDuration
1818

1919
object JournalSequenceActor {
20-
def props(readJournalDao: ReadJournalDao, config: JournalSequenceRetrievalConfig)(implicit
21-
materializer: Materializer): Props = Props(new JournalSequenceActor(readJournalDao, config))
20+
def props(readJournalDao: ReadJournalDao, config: JournalSequenceRetrievalConfig)(
21+
implicit materializer: Materializer): Props = Props(new JournalSequenceActor(readJournalDao, config))
2222

2323
private case object QueryOrderingIds
2424
private case class NewOrderingIds(originalOffset: Long, elements: Seq[OrderingId])
@@ -56,8 +56,8 @@ object JournalSequenceActor {
5656
* This is required to guarantee the EventByTag does not skip any rows in case rows with a higher (ordering) id are
5757
* visible in the database before rows with a lower (ordering) id.
5858
*/
59-
class JournalSequenceActor(readJournalDao: ReadJournalDao, config: JournalSequenceRetrievalConfig)(implicit
60-
materializer: Materializer)
59+
class JournalSequenceActor(readJournalDao: ReadJournalDao, config: JournalSequenceRetrievalConfig)(
60+
implicit materializer: Materializer)
6161
extends Actor
6262
with ActorLogging
6363
with Timers {

core/src/main/scala/akka/persistence/postgres/snapshot/dao/ByteArraySnapshotDao.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,7 @@ import scala.concurrent.{ ExecutionContext, Future }
1717
import scala.util.{ Failure, Success }
1818

1919
class ByteArraySnapshotDao(db: JdbcBackend#Database, snapshotConfig: SnapshotConfig, serialization: Serialization)(
20-
implicit
21-
ec: ExecutionContext,
20+
implicit ec: ExecutionContext,
2221
val mat: Materializer)
2322
extends SnapshotDao {
2423
import akka.persistence.postgres.db.ExtendedPostgresProfile.api._

core/src/test/scala/akka/persistence/postgres/query/JournalSequenceActorTest.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -171,8 +171,8 @@ abstract class JournalSequenceActorTest(val schemaType: SchemaType) extends Quer
171171
* (since the actor queries every second by default,
172172
* this is effectively the number of seconds after which events are assumed missing)
173173
*/
174-
def withJournalSequenceActor(db: JdbcBackend.Database, maxTries: Int)(f: ActorRef => Unit)(implicit
175-
system: ActorSystem): Unit = {
174+
def withJournalSequenceActor(db: JdbcBackend.Database, maxTries: Int)(f: ActorRef => Unit)(
175+
implicit system: ActorSystem): Unit = {
176176
import system.dispatcher
177177
implicit val mat: Materializer = SystemMaterializer(system).materializer
178178
val readJournalDao =

core/src/test/scala/akka/persistence/postgres/query/QueryTestSpec.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ trait ReadJournalOperations {
4444
def countJournal: Future[Long]
4545
}
4646

47-
class ScalaPostgresReadJournalOperations(readJournal: PostgresReadJournal)(implicit
48-
system: ActorSystem,
47+
class ScalaPostgresReadJournalOperations(readJournal: PostgresReadJournal)(
48+
implicit system: ActorSystem,
4949
mat: Materializer)
5050
extends ReadJournalOperations {
5151
def this(system: ActorSystem) =
@@ -106,8 +106,8 @@ class ScalaPostgresReadJournalOperations(readJournal: PostgresReadJournal)(impli
106106
.map(_.sum)
107107
}
108108

109-
class JavaDslPostgresReadJournalOperations(readJournal: javadsl.PostgresReadJournal)(implicit
110-
system: ActorSystem,
109+
class JavaDslPostgresReadJournalOperations(readJournal: javadsl.PostgresReadJournal)(
110+
implicit system: ActorSystem,
111111
mat: Materializer)
112112
extends ReadJournalOperations {
113113
def this(system: ActorSystem) =
@@ -300,15 +300,15 @@ abstract class QueryTestSpec(config: String, configOverrides: Map[String, Config
300300
system.actorOf(Props(new TestActor(persistenceId, replyToMessages)))
301301
}
302302

303-
def withTestActors(seq: Int = 1, replyToMessages: Boolean = false)(f: (ActorRef, ActorRef, ActorRef) => Unit)(implicit
304-
system: ActorSystem): Unit = {
303+
def withTestActors(seq: Int = 1, replyToMessages: Boolean = false)(f: (ActorRef, ActorRef, ActorRef) => Unit)(
304+
implicit system: ActorSystem): Unit = {
305305
val refs = (seq until seq + 3).map(setupEmpty(_, replyToMessages)).toList
306306
try f(refs.head, refs.drop(1).head, refs.drop(2).head)
307307
finally killActors(refs: _*)
308308
}
309309

310-
def withManyTestActors(amount: Int, seq: Int = 1, replyToMessages: Boolean = false)(f: Seq[ActorRef] => Unit)(implicit
311-
system: ActorSystem): Unit = {
310+
def withManyTestActors(amount: Int, seq: Int = 1, replyToMessages: Boolean = false)(f: Seq[ActorRef] => Unit)(
311+
implicit system: ActorSystem): Unit = {
312312
val refs = (seq until seq + amount).map(setupEmpty(_, replyToMessages)).toList
313313
try f(refs)
314314
finally killActors(refs: _*)

0 commit comments

Comments
 (0)