private def serialize()

in migrator/src/main/scala/org/apache/pekko/persistence/jdbc/migrator/JournalMigrator.scala [116:142]

• 24 lines of code
• 1 McCabe index (conditional complexity)

  private def serialize(
      repr: PersistentRepr,
      tags: Set[String],
      ordering: Long): (JournalPekkoSerializationRow, Set[String]) = {

    val serializedPayload: PekkoSerialization.PekkoSerialized =
      PekkoSerialization.serialize(serialization, repr.payload).get

    val serializedMetadata: Option[PekkoSerialization.PekkoSerialized] =
      repr.metadata.flatMap(m => PekkoSerialization.serialize(serialization, m).toOption)
    val row: JournalPekkoSerializationRow = JournalPekkoSerializationRow(
      ordering,
      repr.deleted,
      repr.persistenceId,
      repr.sequenceNr,
      repr.writerUuid,
      repr.timestamp,
      repr.manifest,
      serializedPayload.payload,
      serializedPayload.serId,
      serializedPayload.serManifest,
      serializedMetadata.map(_.payload),
      serializedMetadata.map(_.serId),
      serializedMetadata.map(_.serManifest))

    (row, tags)
  }