f Legger til publisering av domeneevents i Arbeidssøkermodellen

Sørger for å publsiere en ArbeidssøkerperiodeStartetEvent eller ArbeidssøkerperiodeAvsluttetEvent når vi starter en ny periode, eller avslutter en eksisterende periode.
Konsumenter av Arbeissøker kan legge seg til og lytte på hendelser som publiseres.

src/main/kotlin/no/nav/fo/veilarbregistrering/arbeidssoker/Arbeidssoker.kt

@@ -8,7 +8,9 @@ import java.time.format.DateTimeFormatter
 /**
  * Root aggregate - all kommunikasjon mot Arbeidssøker og underliggende elementer skal gå via dette objektet.
  */
-class Arbeidssoker(private val foedselsnummer: Foedselsnummer) {
+class Arbeidssoker(private val foedselsnummer: Foedselsnummer): Observable {
+
+    private val observers: MutableList<Observer> = mutableListOf()
 
     private var id: Int = 0
     private var tilstand: ArbeidssokerState = IkkeArbeidssokerState
@@ -31,10 +33,13 @@ class Arbeidssoker(private val foedselsnummer: Foedselsnummer) {
 
     private fun startPeriode(fraDato: LocalDateTime) {
         this.arbeidssokerperioder.add(Arbeidssokerperiode(fraDato, null))
+        this.observers.forEach { it.update(ArbeidssøkerperiodeStartetEvent(foedselsnummer, fraDato.toLocalDate()))}
     }
 
     private fun avsluttPeriode(tilDato: LocalDateTime) {
-        sistePeriode()?.avslutt(atTheEndOfYesterday(tilDato)) ?: throw IllegalStateException("Kan ikke avslutte en periode som ikke finnes")
+        val tilOgMedDato = atTheEndOfYesterday(tilDato)
+        sistePeriode()?.avslutt(tilOgMedDato) ?: throw IllegalStateException("Kan ikke avslutte en periode som ikke finnes")
+        this.observers.forEach { it.update(ArbeidssøkerperiodeAvsluttetEvent(foedselsnummer, tilOgMedDato.toLocalDate()))}
     }
 
     private fun atTheEndOfYesterday(localDateTime: LocalDateTime): LocalDateTime {
@@ -65,6 +70,14 @@ class Arbeidssoker(private val foedselsnummer: Foedselsnummer) {
         this.tilstand = tilstand
     }
 
+    override fun add(observer: Observer) {
+        this.observers.add(observer)
+    }
+
+    override fun remove(observer: Observer) {
+        this.observers.remove(observer)
+    }
+
     /**
      * Ikke arbeidssøker betyr at du aldri har vært arbeidssøker.
      */

src/main/kotlin/no/nav/fo/veilarbregistrering/arbeidssoker/ArbeidssøkerDomainEvent.kt

@@ -0,0 +1,24 @@
+package no.nav.fo.veilarbregistrering.arbeidssoker
+
+import no.nav.fo.veilarbregistrering.bruker.Foedselsnummer
+import java.time.LocalDate
+
+interface ArbeidssøkerDomainEvent {
+
+    fun fødselsnummer(): Foedselsnummer
+}
+
+class ArbeidssøkerperiodeStartetEvent(
+    private val foedselsnummer: Foedselsnummer,
+    private val fraOgMedDato: LocalDate
+): ArbeidssøkerDomainEvent {
+
+    override fun fødselsnummer(): Foedselsnummer = foedselsnummer
+}
+
+class ArbeidssøkerperiodeAvsluttetEvent(
+    private val foedselsnummer: Foedselsnummer,
+    private val tilOgMedDato: LocalDate): ArbeidssøkerDomainEvent {
+
+    override fun fødselsnummer(): Foedselsnummer = foedselsnummer
+}

src/main/kotlin/no/nav/fo/veilarbregistrering/arbeidssoker/Observable.kt

@@ -0,0 +1,7 @@
+package no.nav.fo.veilarbregistrering.arbeidssoker
+
+interface Observable {
+
+    fun add(observer: Observer)
+    fun remove(observer: Observer)
+}

src/main/kotlin/no/nav/fo/veilarbregistrering/arbeidssoker/Observer.kt

@@ -0,0 +1,6 @@
+package no.nav.fo.veilarbregistrering.arbeidssoker
+
+interface Observer {
+
+    fun update(event: ArbeidssøkerDomainEvent)
+}