Skip to content

Commit be8a583

Browse files
authored
Merge pull request #103 from SwissBorg/update-deps
Update dependencies
2 parents 64e0aaf + 3754274 commit be8a583

File tree

5 files changed

+17
-16
lines changed

5 files changed

+17
-16
lines changed

core/src/test/scala/akka/persistence/postgres/journal/JournalPartitioningSpec.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ abstract class JournalPartitioningSpec(schemaType: SchemaType)
103103
probe.expectMsg(WriteMessagesSuccessful)
104104
(fromSnr to toSnr).foreach { i =>
105105
probe.expectMsgPF() {
106-
case WriteMessageSuccess(PersistentImpl(payload, `i`, `pid`, _, _, `sender`, `writerUuid`, _), _) =>
106+
case WriteMessageSuccess(PersistentImpl(payload, `i`, `pid`, _, _, `sender`, `writerUuid`, _, None), _) =>
107107
payload should be(s"a-$i")
108108
}
109109
}
@@ -150,7 +150,7 @@ abstract class JournalPartitioningSpec(schemaType: SchemaType)
150150
pid: String,
151151
writerUuid: String,
152152
deleted: Boolean = false): ReplayedMessage =
153-
ReplayedMessage(PersistentImpl(s"a-$snr", snr, pid, "", deleted, Actor.noSender, writerUuid, 0L))
153+
ReplayedMessage(PersistentImpl(s"a-$snr", snr, pid, "", deleted, Actor.noSender, writerUuid, 0L, None))
154154

155155
}
156156

core/src/test/scala/akka/persistence/postgres/journal/PostgresJournalSpec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ trait PartitionedJournalSpecTestCases {
101101
}
102102

103103
def replayedPostgresMessage(snr: Long, pid: String, deleted: Boolean = false): ReplayedMessage =
104-
ReplayedMessage(PersistentImpl(s"a-$snr", snr, pid, "", deleted, Actor.noSender, writerUuid, 0L))
104+
ReplayedMessage(PersistentImpl(s"a-$snr", snr, pid, "", deleted, Actor.noSender, writerUuid, 0L, None))
105105
}
106106

107107
class NestedPartitionsJournalSpec extends PostgresJournalSpec("nested-partitions-application.conf", NestedPartitions)

migration/src/main/scala/akka/persistence/postgres/migration/AkkaPersistencePostgresMigration.scala

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,18 +11,19 @@ import com.typesafe.config.Config
1111
import javax.sql.DataSource
1212
import org.flywaydb.core.Flyway
1313
import org.flywaydb.core.api.configuration.FluentConfiguration
14+
import org.flywaydb.core.api.output.MigrateResult
1415
import slick.jdbc.JdbcBackend
1516

1617
import scala.concurrent.Future
1718
import scala.util.Try
1819

19-
class AkkaPersistencePostgresMigration private (flyway: Flyway, onComplete: Try[Int] => Unit)(
20+
class AkkaPersistencePostgresMigration private (flyway: Flyway, onComplete: Try[MigrateResult] => Unit)(
2021
implicit system: ActorSystem) {
2122

2223
/**
2324
* Perform journal & snapshot store migrations.
2425
*
25-
* @return Future containing a number of successfully applied migrations.
26+
* @return Future containing a number of executed migrations.
2627
*/
2728
def run: Future[Int] = {
2829
import system.dispatcher
@@ -35,7 +36,7 @@ class AkkaPersistencePostgresMigration private (flyway: Flyway, onComplete: Try[
3536

3637
migrationFut.onComplete(onComplete)
3738

38-
migrationFut
39+
migrationFut.map(_.migrationsExecuted)
3940
}
4041
}
4142

project/Dependencies.scala

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,22 @@
11
import sbt._
22

33
object Dependencies {
4-
val Scala212 = "2.12.11"
5-
val Scala213 = "2.13.1"
4+
val Scala212 = "2.12.12"
5+
val Scala213 = "2.13.3"
66
val ScalaVersions = Seq(Scala212, Scala213)
77

8-
val AkkaVersion = "2.6.5"
8+
val AkkaVersion = "2.6.10"
99
val AkkaBinaryVersion = "2.6"
1010

1111
val SlickVersion = "3.3.2"
12-
val ScalaTestVersion = "3.1.2"
13-
val SlickPgVersion = "0.19.2"
12+
val ScalaTestVersion = "3.2.0"
13+
val SlickPgVersion = "0.19.3"
1414

15-
val ScaffeineVersion = "4.0.1"
15+
val ScaffeineVersion = "4.0.2"
1616

1717
val LogbackVersion = "1.2.3"
1818

19-
val JdbcDrivers = Seq("org.postgresql" % "postgresql" % "42.2.12")
19+
val JdbcDrivers = Seq("org.postgresql" % "postgresql" % "42.2.17")
2020

2121
val Libraries: Seq[ModuleID] = Seq(
2222
"com.typesafe.akka" %% "akka-persistence-query" % AkkaVersion,
@@ -33,7 +33,7 @@ object Dependencies {
3333
"org.scalatest" %% "scalatest" % ScalaTestVersion % Test) ++ JdbcDrivers.map(_ % Test)
3434

3535
val Migration: Seq[ModuleID] = Seq(
36-
"org.flywaydb" % "flyway-core" % "6.5.6",
36+
"org.flywaydb" % "flyway-core" % "7.0.2",
3737
"ch.qos.logback" % "logback-classic" % LogbackVersion,
3838
"com.typesafe.akka" %% "akka-slf4j" % AkkaVersion) ++ JdbcDrivers
3939
}

project/plugins.sbt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
// compliance
2-
addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.4.0")
3-
addSbtPlugin("com.typesafe" % "sbt-mima-plugin" % "0.7.0")
2+
addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.4.2")
3+
addSbtPlugin("com.typesafe" % "sbt-mima-plugin" % "0.8.0")
44
// release
55
addSbtPlugin("com.geirsson" % "sbt-ci-release" % "1.5.3")
66
// docs

0 commit comments

Comments
 (0)