add institution state to serialization.conf

common/src/main/protobuf/institution.institutionstate.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+
+option java_package = "hmda.persistence.serialization";
+option optimize_for = SPEED;
+
+import "institution.proto";
+import "filing.proto";
+
+message InstitutionStateMessage {
+    InstitutionMessage institution = 1;
+    repeated FilingMessage filings = 2;
+}

common/src/main/resources/serialization.conf

@@ -6,6 +6,7 @@ akka {
       institution-commands = "hmda.serialization.institution.InstitutionCommandsSerializer"
       institution-events = "hmda.serialization.institution.InstitutionEventsSerializer"
       institution-detail = "hmda.serialization.institution.InstitutionDetailSerializer"
+      institution-state = "hmda.serialization.institution.InstitutionStateSerializer"
 
       submission-manager-commands = "hmda.serialization.submission.SubmissionManagerCommandsSerializer"
       submission-commands = "hmda.serialization.submission.SubmissionCommandsSerializer"
@@ -133,6 +134,7 @@ akka {
       "hmda.model.filing.FilingDetails" = filing-details
       "hmda.persistence.filing.FilingState" = filing-state
       "hmda.model.institution.InstitutionDetail" = institution-detail
+      "hmda.persistence.institution.InstitutionState" = institution-state
 
       "hmda.messages.submission.HmdaRawDataCommands$AddLines" = hmda-raw-commands
       "hmda.messages.submission.HmdaRawDataEvents$LineAdded" = hmda-raw-events

common/src/main/scala/hmda/serialization/institution/InstitutionStateProtobufConverter.scala

@@ -0,0 +1,27 @@
+package hmda.serialization.institution
+
+import hmda.persistence.institution.InstitutionState
+import hmda.persistence.serialization.institution.InstitutionMessage
+import hmda.persistence.serialization.institution.institutionstate.InstitutionStateMessage
+import hmda.serialization.filing.FilingProtobufConverter._
+import hmda.serialization.institution.InstitutionProtobufConverter._
+
+object InstitutionStateProtobufConverter {
+
+  def institutionStateToProtobuf(institutionState: InstitutionState): InstitutionStateMessage =
+    InstitutionStateMessage(
+      if (institutionState.institution.isEmpty) None
+      else Some(institutionToProtobuf(institutionState.institution.get)),
+      institutionState.filings.map(s => filingToProtobuf(s))
+    )
+
+  def institutionStateFromProtobuf(institutionStateMessage: InstitutionStateMessage): InstitutionState =
+    InstitutionState(
+      institution = Some(institutionFromProtobuf(institutionStateMessage.institution.getOrElse(InstitutionMessage()))),
+      filings = institutionStateMessage.filings
+        .map(s => filingFromProtobuf(s))
+        .toList
+    )
+
+}
+

common/src/main/scala/hmda/serialization/institution/InstitutionStateSerializer.scala

@@ -0,0 +1,33 @@
+package hmda.serialization.institution
+
+import java.io.NotSerializableException
+
+import akka.serialization.SerializerWithStringManifest
+import hmda.persistence.institution.InstitutionState
+import hmda.persistence.serialization.institution.institutionstate.InstitutionStateMessage
+import hmda.serialization.institution.InstitutionStateProtobufConverter._
+// $COVERAGE-OFF$
+class InstitutionStateSerializer extends SerializerWithStringManifest {
+  override def identifier: Int = 120
+
+  final val InstitutionStateManifest = classOf[InstitutionState].getName
+
+  override def manifest(o: AnyRef): String = o.getClass.getName
+
+  override def toBinary(o: AnyRef): Array[Byte] = o match {
+    case evt: InstitutionState =>
+      institutionStateToProtobuf(evt).toByteArray
+    case _ =>
+      throw new IllegalArgumentException(s"Cannot serialize object of type [${o.getClass.getName}]")
+  }
+
+  override def fromBinary(bytes: Array[Byte], manifest: String): AnyRef =
+    manifest match {
+      case InstitutionStateManifest =>
+        institutionStateFromProtobuf(InstitutionStateMessage.parseFrom(bytes))
+      case _ =>
+        throw new NotSerializableException(s"Unimplemented deserialization of message with manifest [$manifest] in [${getClass.getName}]")
+    }
+
+}
+// $COVERAGE-OFF$