Commit bb0734c3 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade al ciclo un paso para procesar borrado

parent 6327f904

src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java

+13 −4
Original line number Diff line number Diff line
@@ -29,10 +29,13 @@ public abstract class EventSourcingStreams extends BaseStreams { 
		KStream<String, Event> events = builder.stream(topic);



		// Create Success

		processCreatedStream(events);

		processCreateSuccessStream(events);



		// Update Success

		processUpdatedStream(events);

		processUpdateSuccessStream(events);



		// Comprueba si el elemento está referenciado para cancelar el borrado

		processDeleteStream(events);



		// Failed change

		processFailedChangeStream(events);
@@ -55,7 +58,7 @@ public abstract class EventSourcingStreams extends BaseStreams { 
	 * envía evento creado

	 */



	protected void processCreatedStream(KStream<String, Event> events) {

	protected void processCreateSuccessStream(KStream<String, Event> events) {



		// Stream filtrado por eventos de confirmación al crear

		KStream<String, Event> createConfirmedEvents = events
@@ -84,7 +87,7 @@ public abstract class EventSourcingStreams extends BaseStreams { 
	 * de la vista, manda a procesar las ediciones parciales

	 */



	protected void processUpdatedStream(KStream<String, Event> events) {

	protected void processUpdateSuccessStream(KStream<String, Event> events) {



		// Stream filtrado por eventos de confirmación al modificar

		KStream<String, Event> updateConfirmedEvents = events
@@ -109,6 +112,12 @@ public abstract class EventSourcingStreams extends BaseStreams { 


	protected abstract Event getUpdatedEvent(Event confirmedEvent, Event requestEvent);



	/*

	 * Procesa peticiones de borrado para comprobar si está referenciado

	 */



	protected abstract void processDeleteStream(KStream<String, Event> events);



	/*

	 * Función que a partir del último evento correcto + el evento de edición

	 * parcial + la confirmación de la vista, envía evento modificado.