private def serializeSnapshot()

in core/src/main/scala/org/apache/pekko/persistence/jdbc/snapshot/dao/DefaultSnapshotDao.scala [59:74]

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

  private def serializeSnapshot(meta: SnapshotMetadata, snapshot: Any): Try[SnapshotRow] = {
    val serializedMetadata = meta.metadata.flatMap(m => PekkoSerialization.serialize(serialization, m).toOption)
    PekkoSerialization
      .serialize(serialization, payload = snapshot)
      .map(serializedSnapshot =>
        SnapshotRow(
          meta.persistenceId,
          meta.sequenceNr,
          meta.timestamp,
          serializedSnapshot.serId,
          serializedSnapshot.serManifest,
          serializedSnapshot.payload,
          serializedMetadata.map(_.serId),
          serializedMetadata.map(_.serManifest),
          serializedMetadata.map(_.payload)))
  }