Fix migration to PSH

.github/workflows/standard-workflow.yml

@@ -135,7 +135,7 @@ jobs:
         working-directory: examples/akka-persistence-app
 
   # <PEKKO-REMOVE-START>
-  patch-and-push-to-ash:
+  patch-and-push-to-psh:
     if: github.event_name != 'pull_request'
     needs: [code-style-check, test-212, test-213-1, test-213-2, test-sbt-plugin, run-examples]
     runs-on: ubuntu-latest

.scala-steward.conf

@@ -12,7 +12,6 @@ buildRoots = [
 ]
 
 # <PEKKO-UNCOMMENT> updates.allow  = [ { groupId = "org.apache.pekko" } ]
-
 # <PEKKO-REMOVE-START>
 updates.pin = [
   # 	* org.scala-lang.modules:scala-xml_2.12:2.1.0 (early-semver) is selected over 1.2.0

.scalafix.conf

@@ -2,12 +2,15 @@ rules = [
   OrganizeImports
 ]
 
-OrganizeImports.expandRelative = true
-OrganizeImports.removeUnused = true
-OrganizeImports.groupedImports = Explode
-OrganizeImports.groups = [
-  "java.",
-  "scala.",
-  "*",
-  "org.virtuslab.ash"
-]
+OrganizeImports {
+  expandRelative = true
+  removeUnused = true
+  groupedImports = Explode
+  groups = [
+    "java.",
+    "scala.",
+    "akka.",
+    "*",
+    "org.virtuslab.ash"
+  ]
+}

.scalafmt.conf

@@ -5,7 +5,7 @@ style = defaultWithAlign
 runner.dialect = scala213
 docstrings.style = Asterisk
 indentOperator.preset      = spray
-maxColumn                  = 120
+maxColumn                  = 128
 rewrite.rules              = [RedundantParens, AvoidInfix]
 align.tokens               = [{code = "=>", owner = "Case"}]
 align.openParenDefnSite    = false

README.md

@@ -1,6 +1,6 @@
 # Akka Serialization Helper
 
-[![Maven Central](https://maven-badges.herokuapp.com/maven-central/org.virtuslab.ash/sbt-akka-serialization-helper/badge.svg)](https://mvnrepository.com/artifact/org.virtuslab.ash)
+[![Maven Central](https://maven-badges.herokuapp.com/maven-central/org.virtuslab.ash/annotation_2.13/badge.svg)](https://mvnrepository.com/artifact/org.virtuslab.ash)
 [![GitHub Actions](https://github.com/VirtusLab/akka-serialization-helper/actions/workflows/ci.yml/badge.svg?branch=main)](https://github.com/VirtusLab/akka-serialization-helper/actions)
 [![License: MIT](https://img.shields.io/github/license/VirtusLab/akka-serialization-helper)](LICENSE)
 

annotation/src/main/scala/org/virtuslab/ash/annotation/SerializabilityTrait.scala

@@ -1,8 +1,8 @@
 package org.virtuslab.ash.annotation
 
 /**
- * This annotation is used as a marker for Codec Registration Checker and Serializability Checker. Annotate Akka
- * serialization marker-trait, and the rest is done by compiler plugins.
+ * This annotation is used as a marker for Codec Registration Checker and Serializability Checker. Annotate Akka serialization
+ * marker-trait, and the rest is done by compiler plugins.
  *
  * {{{
  *   @SerializabilityTrait

annotation/src/main/scala/org/virtuslab/ash/annotation/Serializer.scala

@@ -5,16 +5,16 @@ import scala.annotation.nowarn
 /**
  * This annotation is used by Codec Registration Checker for marking serializers.
  *
- * Compiler plugin takes the body of a marked class, collects all types that are present, filters them with provided
- * regex and extracts type parameters. Then filtered types and extracted type parameters are checked against all direct
- * subtypes of `clazz`.
+ * Compiler plugin takes the body of a marked class, collects all types that are present, filters them with provided regex and
+ * extracts type parameters. Then filtered types and extracted type parameters are checked against all direct subtypes of
+ * `clazz`.
  *
  * Sometimes types appear unexpectedly during type class derivation leading to false negatives, i.e. a codec reported as
- * registered even though it's NOT registered. The role of `typeRegexPattern` is to filter detected types, ensuring they
- * are used in the right context.
+ * registered even though it's NOT registered. The role of `typeRegexPattern` is to filter detected types, ensuring they are
+ * used in the right context.
  *
- * For example, if we want to serialize `trait Command`, then type `Registration[Command]` is relevant, while
- * `Option[Command]` is not.
+ * For example, if we want to serialize `trait Command`, then type `Registration[Command]` is relevant, while `Option[Command]`
+ * is not.
  *
  * If you are using `circe-akka-serializer`, set `typeRegexPattern` to `Register.REGISTRATION_REGEX`
  *

build.sbt

@@ -32,15 +32,10 @@ ThisBuild / organization := "org.virtuslab.ash"
 ThisBuild / organizationName := "VirtusLab"
 ThisBuild / versionScheme := Some("early-semver")
 ThisBuild / homepage := Some(url("https://github.com/VirtusLab/akka-serialization-helper"))
-ThisBuild / licenses := List(
-  "MIT License" -> url("https://github.com/VirtusLab/akka-serialization-helper/blob/main/LICENSE"))
+ThisBuild / licenses := List("MIT License" -> url("https://github.com/VirtusLab/akka-serialization-helper/blob/main/LICENSE"))
 ThisBuild / developers := List(
   Developer("MarconZet", "Marcin Złakowski", "mzlakowski@virtuslab.com", url("https://github.com/MarconZet")),
-  Developer(
-    "LukaszKontowski",
-    "Łukasz Kontowski",
-    "lkontowski@virtuslab.com",
-    url("https://github.com/LukaszKontowski")),
+  Developer("LukaszKontowski", "Łukasz Kontowski", "lkontowski@virtuslab.com", url("https://github.com/LukaszKontowski")),
   Developer("PawelLipski", "Paweł Lipski", "plipski@virtuslab.com", url("https://github.com/PawelLipski")))
 
 sonatypeProfileName := "org.virtuslab"

circe-akka-serializer/src/main/scala/org/virtuslab/ash/circe/CirceAkkaSerializer.scala

@@ -8,6 +8,7 @@ import scala.reflect.ClassTag
 import akka.actor.ExtendedActorSystem
 import akka.event.Logging
 import akka.serialization.SerializerWithStringManifest
+
 import io.circe._
 import io.circe.jawn.JawnParser
 
@@ -98,19 +99,17 @@ abstract class CirceAkkaSerializer[Ser <: AnyRef: ClassTag](system: ExtendedActo
   /**
    * The intended usage of this method is to provide any form of support for generic classes.
    *
-   * Because of type erasure, it's impossible to [[org.virtuslab.ash.circe.Register]] one generic class two times with
-   * different type parameters.
+   * Because of type erasure, it's impossible to [[org.virtuslab.ash.circe.Register]] one generic class two times with different
+   * type parameters.
    *
-   * The trick for combating type erasure is to register generic class only once with type parameter being its upper
-   * bound, and provide custom made [[io.circe.Codec]] that can serialize/deserialize all classes that are used as a
-   * type parameter.
+   * The trick for combating type erasure is to register generic class only once with type parameter being its upper bound, and
+   * provide custom made [[io.circe.Codec]] that can serialize/deserialize all classes that are used as a type parameter.
    *
-   * For example, if the upper bound is `Any`, but you know that only `Int` and `String` are used as a type parameter,
-   * then you can create a custom [[io.circe.Codec]] for `Any` that handles `Int` and `String` and throws `Exception`
-   * otherwise.
+   * For example, if the upper bound is `Any`, but you know that only `Int` and `String` are used as a type parameter, then you
+   * can create a custom [[io.circe.Codec]] for `Any` that handles `Int` and `String` and throws `Exception` otherwise.
    *
-   * To use this method correctly, set the upper bound for the type parameter of generic class to `Ser` and put the
-   * returned Codec as implicit in a place that can be seen by type derivation.
+   * To use this method correctly, set the upper bound for the type parameter of generic class to `Ser` and put the returned
+   * Codec as implicit in a place that can be seen by type derivation.
    *
    * Example of generic class:
    * {{{
@@ -129,12 +128,7 @@ abstract class CirceAkkaSerializer[Ser <: AnyRef: ClassTag](system: ExtendedActo
   private def logDuration(action: String, obj: AnyRef, startTime: Long, bytes: Array[Byte]): Unit = {
     if (isDebugEnabled) {
       val durationMicros = (System.nanoTime - startTime) / 1000
-      log.debug(
-        "{} of [{}] took [{}] microsecond, size [{}] bytes",
-        action,
-        obj.getClass.getName,
-        durationMicros,
-        bytes.length)
+      log.debug("{} of [{}] took [{}] microsecond, size [{}] bytes", action, obj.getClass.getName, durationMicros, bytes.length)
     }
   }
 

circe-akka-serializer/src/main/scala/org/virtuslab/ash/circe/CirceTraitCodec.scala

@@ -17,22 +17,21 @@ trait CirceTraitCodec[Ser <: AnyRef] extends Codec[Ser] {
   /**
    * Sequence that must contain [[org.virtuslab.ash.circe.Registration]] for all direct subclasses of Ser.
    *
-   * Each `Registration` is created using [[org.virtuslab.ash.circe.Register]]s
-   * [[org.virtuslab.ash.circe.Register#apply]] method.
+   * Each `Registration` is created using [[org.virtuslab.ash.circe.Register]]s [[org.virtuslab.ash.circe.Register#apply]]
+   * method.
    *
    * To check if all needed classes are registered, use Codec Registration Checker.
    *
    * @see
-   *   [[org.virtuslab.ash.circe.Register]][[org.virtuslab.ash.circe.Register#apply]] for more information about type
-   *   derivation
+   *   [[org.virtuslab.ash.circe.Register]][[org.virtuslab.ash.circe.Register#apply]] for more information about type derivation
    */
   val codecs: Seq[Registration[_ <: Ser]]
 
   /**
    * A sequence containing information used in type migration.
    *
-   * If you ever change the name of a class that is a direct descendant of `Ser` and is persisted in any way, you must
-   * append new pair to this field.
+   * If you ever change the name of a class that is a direct descendant of `Ser` and is persisted in any way, you must append
+   * new pair to this field.
    *   - The first element of the pair is a String with the value of old FQCN.
    *   - The second element of the pair is a Class that had its name changed
    *

circe-akka-serializer/src/main/scala/org/virtuslab/ash/circe/Compression.scala

@@ -14,10 +14,7 @@ object Compression {
   // TODO (#159): add support for LZ4 java compression
   // case class LZ4(greaterThan: Long) extends Algorithm
 
-  private[circe] def compressIfNeeded(
-      bytes: Array[Byte],
-      bufferSize: Int,
-      compressionAlgorithm: Algorithm): Array[Byte] =
+  private[circe] def compressIfNeeded(bytes: Array[Byte], bufferSize: Int, compressionAlgorithm: Algorithm): Array[Byte] =
     compressionAlgorithm match {
       case Compression.Off => bytes
       case Compression.GZip(largerThan) =>

circe-akka-serializer/src/main/scala/org/virtuslab/ash/circe/Register.scala

@@ -10,11 +10,11 @@ object Register {
 
   /**
    * This method takes three implicit arguments: [[scala.reflect.api.TypeTags.TypeTag]], [[io.circe.Encoder]] and
-   * [[io.circe.Decoder]]. TypeTag is provided by the compiler, Encoder and Decoder are derived using Shapeless. There
-   * are several scenarios, in which derivation may fail, requiring defining custom codecs in a separate trait.
+   * [[io.circe.Decoder]]. TypeTag is provided by the compiler, Encoder and Decoder are derived using Shapeless. There are
+   * several scenarios, in which derivation may fail, requiring defining custom codecs in a separate trait.
    *
-   * Type class derivation will fail if the type or any of its fields don't have custom-defined Encoder/Decoder and at
-   * least one of the following statements about any of them is true:
+   * Type class derivation will fail if the type or any of its fields don't have custom-defined Encoder/Decoder and at least one
+   * of the following statements about any of them is true:
    *   - is a non-sealed trait
    *   - is a sealed trait but two or more subtypes have the same name (in different packages)
    *   - is a non-case class
@@ -35,14 +35,14 @@ object Register {
   def REGISTRATION_REGEX: String = macro regexImpl
 
   /**
-   * `circeRegex` is the preferred typeRegexPattern for Circe Akka Serializer usage. It contains leading and trailing
-   * `.*` - so that it matches both single Registration and multiple Registrations in a collection. It is used by the
+   * `circeRegex` is the preferred typeRegexPattern for Circe Akka Serializer usage. It contains leading and trailing `.*` - so
+   * that it matches both single Registration and multiple Registrations in a collection. It is used by the
    * codec-registration-checker-compiler-plugin to collect properly registered codecs.
    *
-   * As codec-registration-checker-compiler-plugin searches for `circeRegex` occurrences in the generated AST - and
-   * detects proper registrations if detected type contains the regex - there might be some rare corner cases, where
-   * something like `Option[Register[User_Defined_Type]]` is in the AST and codec-registration-checker-compiler-plugin
-   * would still treat it as proper registration. However, such situations have not been encountered in real usages.
+   * As codec-registration-checker-compiler-plugin searches for `circeRegex` occurrences in the generated AST - and detects
+   * proper registrations if detected type contains the regex - there might be some rare corner cases, where something like
+   * `Option[Register[User_Defined_Type]]` is in the AST and codec-registration-checker-compiler-plugin would still treat it as
+   * proper registration. However, such situations have not been encountered in real usages.
    */
   private val circeRegex = """.*org\.virtuslab\.ash\.circe\.Registration\[.*\].*"""
 

circe-akka-serializer/src/test/scala/org/virtuslab/ash/circe/CirceAkkaSerializerSpec.scala

@@ -5,6 +5,7 @@ import scala.io.Source
 import akka.actor.testkit.typed.scaladsl.ActorTestKit
 import akka.actor.testkit.typed.scaladsl.SerializationTestKit
 import akka.actor.typed.ActorSystem
+
 import com.typesafe.config.ConfigFactory
 import com.typesafe.config.ConfigValueFactory
 import org.scalatest.matchers.should

circe-akka-serializer/src/test/scala/org/virtuslab/ash/circe/CustomSerializer.scala

@@ -4,14 +4,14 @@ import scala.annotation.nowarn
 import scala.reflect.runtime.{universe => ru}
 
 import akka.actor.ExtendedActorSystem
+
 import io.circe._
 import io.circe.generic.auto._
 
 import org.virtuslab.ash.circe.data.ModifiedCodec._
 import org.virtuslab.ash.circe.data._
 
-class CustomSerializer(actorSystem: ExtendedActorSystem)
-    extends CirceAkkaSerializer[CirceSerializabilityTrait](actorSystem) {
+class CustomSerializer(actorSystem: ExtendedActorSystem) extends CirceAkkaSerializer[CirceSerializabilityTrait](actorSystem) {
 
   @nowarn implicit private val serializabilityCodec: Codec[CirceSerializabilityTrait] = genericCodec
 

codec-registration-checker-compiler-plugin/src/main/scala/org/virtuslab/ash/CodecRegistrationCheckerOptions.scala

@@ -7,17 +7,17 @@ import java.io.File
  *
  * @param directClassDescendantsCacheFile
  *   \- CSV file where all Fully Qualified Class Names (FQCNs) for: a) detected classes/traits annotated with the
- *   'serializability trait' and b) their direct descendants are saved as pairs of comma-separated values (two values
- *   per row) according to following pattern: <PARENT_FQCN>,<DESCENDANT_FQCN>
+ *   'serializability trait' and b) their direct descendants are saved as pairs of comma-separated values (two values per row)
+ *   according to following pattern: <PARENT_FQCN>,<DESCENDANT_FQCN>
  *
  * @param oldParentChildFQCNPairs
- *   \- collection that holds String pairs representing the content of the `directClassDescendantsCacheFile`. Each
- *   String pair is wrapped inside `ParentChildFQCNPair` instance. `oldParentChildFQCNPairs` variable is needed to catch
- *   missing codec registrations when using sbt incremental compilation (so - these are FQCNs that were found during
- *   previous compilation). Without using `oldParentChildFQCNPairs` we wouldn't be able to detect situations, where
- *   codec registration for a serializable type has been removed from the code (when `sbt compile` was incremental). And
- *   if we can't detect it - this would lead to runtime errors (see README for more details). `oldParentChildFQCNPairs`
- *   gets declared on the plugin's init by invoking the `CodecRegistrationCheckerCompilerPlugin.parseCacheFile` method.
+ *   \- collection that holds String pairs representing the content of the `directClassDescendantsCacheFile`. Each String pair
+ *   is wrapped inside `ParentChildFQCNPair` instance. `oldParentChildFQCNPairs` variable is needed to catch missing codec
+ *   registrations when using sbt incremental compilation (so - these are FQCNs that were found during previous compilation).
+ *   Without using `oldParentChildFQCNPairs` we wouldn't be able to detect situations, where codec registration for a
+ *   serializable type has been removed from the code (when `sbt compile` was incremental). And if we can't detect it - this
+ *   would lead to runtime errors (see README for more details). `oldParentChildFQCNPairs` gets declared on the plugin's init by
+ *   invoking the `CodecRegistrationCheckerCompilerPlugin.parseCacheFile` method.
  */
 case class CodecRegistrationCheckerOptions(
     var directClassDescendantsCacheFile: File = null,

codec-registration-checker-compiler-plugin/src/main/scala/org/virtuslab/ash/SerializerCheckCompilerPluginComponent.scala

@@ -96,7 +96,7 @@ class SerializerCheckCompilerPluginComponent(
             val typeRegexPatternOption =
               regexTree match {
                 case Select(_, TermName("$lessinit$greater$default$2")) => Some(".*")
-                case other => extractValueOfLiteralConstantFromTree[String](other)
+                case other                                              => extractValueOfLiteralConstantFromTree[String](other)
               }
 
             (fqcnOption, typeRegexPatternOption) match {
@@ -129,9 +129,7 @@ class SerializerCheckCompilerPluginComponent(
               .filter(_.toString.matches(typeRegexPattern))
           } catch {
             case e: PatternSyntaxException =>
-              reporter.error(
-                serializerImplDef.pos,
-                "Exception throw during the use of type regex pattern: " + e.getMessage)
+              reporter.error(serializerImplDef.pos, "Exception throw during the use of type regex pattern: " + e.getMessage)
               return
           }
         }
@@ -157,8 +155,7 @@ class SerializerCheckCompilerPluginComponent(
         if (possibleMissingFullyQualifiedClassNames.nonEmpty) {
           // Due to the way how incremental compilation works - `possibleMissingFullyQualifiedClassNames` could contain
           // "false-positives" - that's why additional check in `collectMissingClassNames` is needed.
-          val actuallyMissingFullyQualifiedClassNames = collectMissingClassNames(
-            possibleMissingFullyQualifiedClassNames)
+          val actuallyMissingFullyQualifiedClassNames = collectMissingClassNames(possibleMissingFullyQualifiedClassNames)
           if (actuallyMissingFullyQualifiedClassNames.nonEmpty) {
             reporter.error(
               serializerImplDef.pos,
@@ -188,9 +185,7 @@ class SerializerCheckCompilerPluginComponent(
                 None
             }
           case other =>
-            reporter.error(
-              other.pos,
-              s"Annotation argument must be a literal constant. Currently: ${other.summaryString}")
+            reporter.error(other.pos, s"Annotation argument must be a literal constant. Currently: ${other.summaryString}")
             None
         }
       }

codec-registration-checker-compiler-plugin/src/test/scala/org/virtuslab/ash/CodecRegistrationCheckerCompilerPluginSpec.scala

@@ -141,9 +141,7 @@ class CodecRegistrationCheckerCompilerPluginSpec extends AnyWordSpecLike with sh
       "path in argument contains in invalid" in {
         assertThrows[RuntimeException] {
           File.usingTemporaryDirectory() { directory =>
-            CodecRegistrationCheckerCompiler.compileCode(
-              dataSourceCode,
-              List(s"${directory.toJava.getAbsolutePath}\u0000"))
+            CodecRegistrationCheckerCompiler.compileCode(dataSourceCode, List(s"${directory.toJava.getAbsolutePath}\u0000"))
           }
         }
       }

dump-persistence-schema-compiler-plugin/src/main/scala/org/virtuslab/ash/CrossVersionReporter.scala

@@ -4,8 +4,8 @@ import scala.tools.nsc.Global
 import scala.tools.nsc.reporters.Reporter
 
 /**
- * In update 2.12.12 -> 2.12.13 reporter was changed from method to value. This code creates a reporter, regardless
- * whether it is a value or a method
+ * In update 2.12.12 -> 2.12.13 reporter was changed from method to value. This code creates a reporter, regardless whether it
+ * is a value or a method
  */
 object CrossVersionReporter {
   def apply(global: Global): Reporter = {

dump-persistence-schema-compiler-plugin/src/main/scala/org/virtuslab/ash/DumpPersistenceSchemaCompilerPlugin.scala

@@ -13,8 +13,7 @@ class DumpPersistenceSchemaCompilerPlugin(override val global: Global) extends P
   // Placeholder options
   private val pluginOptions = new DumpPersistenceSchemaOptions("/tmp", verbose = false)
 
-  override val components: List[PluginComponent] = List(
-    new DumpPersistenceSchemaCompilerPluginComponent(pluginOptions, global))
+  override val components: List[PluginComponent] = List(new DumpPersistenceSchemaCompilerPluginComponent(pluginOptions, global))
 
   override def init(options: List[String], error: String => Unit): Boolean = {
     if (options.contains("--disable"))