Commit 793dfe47 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade compensación por cualquier tipo snapshot

parent ef6aa46b

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java

+8 −4
Original line number Diff line number Diff line
@@ -288,8 +288,7 @@ public class VesselEventStreams extends EventSourcingStreams { 
	@Override

	protected Event getUpdateCancelledEvent(Event failedEvent, Event lastSuccessEvent) {



		assert lastSuccessEvent.getType().equals(VesselEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		assert failedEvent.getType().equals(VesselEventTypes.UPDATE_FAILED);
@@ -312,8 +311,7 @@ public class VesselEventStreams extends EventSourcingStreams { 
	@Override

	protected Event getDeleteCancelledEvent(Event failedEvent, Event lastSuccessEvent) {



		assert lastSuccessEvent.getType().equals(VesselEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		assert failedEvent.getType().equals(VesselEventTypes.DELETE_FAILED);
@@ -325,6 +323,12 @@ public class VesselEventStreams extends EventSourcingStreams { 
				eventError.getExceptionType(), eventError.getArguments());

	}



	@Override

	protected boolean isSnapshot(String eventType) {



		return VesselEventTypes.isSnapshot(eventType);

	}



	/*

	 * Función para procesar modificaciones de referencias

	 */

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTrackingEventStreams.java

+9 −6
Original line number Diff line number Diff line
@@ -234,8 +234,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	private Event getUpdatedEventFromPartialUpdate(UpdateVesselInVesselTrackingEvent partialUpdateConfirmEvent,

			Event lastSuccessEvent) {



		assert (lastSuccessEvent.getType().equals(VesselTrackingEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselTrackingEventTypes.UPDATED));

		assert isSnapshot(lastSuccessEvent.getType());



		assert partialUpdateConfirmEvent.getType().equals(VesselTrackingEventTypes.UPDATE_VESSEL);
@@ -254,8 +253,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	@Override

	protected Event getUpdateCancelledEvent(Event failedEvent, Event lastSuccessEvent) {



		assert lastSuccessEvent.getType().equals(VesselTrackingEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselTrackingEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		assert failedEvent.getType().equals(VesselTrackingEventTypes.UPDATE_FAILED);
@@ -278,8 +276,7 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
	@Override

	protected Event getDeleteCancelledEvent(Event failedEvent, Event lastSuccessEvent) {



		assert lastSuccessEvent.getType().equals(VesselTrackingEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselTrackingEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		assert failedEvent.getType().equals(VesselTrackingEventTypes.DELETE_FAILED);
@@ -291,6 +288,12 @@ public class VesselTrackingEventStreams extends EventSourcingStreams { 
				vesselTracking, eventError.getExceptionType(), eventError.getArguments());

	}



	@Override

	protected boolean isSnapshot(String eventType) {



		return VesselTrackingEventTypes.isSnapshot(eventType);

	}



	/*

	 * Función para procesar modificaciones de referencias

	 */

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTypeEventStreams.java

+8 −4
Original line number Diff line number Diff line
@@ -135,8 +135,7 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 


		assert failedEvent.getType().equals(VesselTypeEventTypes.UPDATE_FAILED);



		assert lastSuccessEvent.getType().equals(VesselTypeEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselTypeEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		VesselTypeDTO vesselType = ((VesselTypeEvent) lastSuccessEvent).getVesselType();
@@ -156,8 +155,7 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 


		assert failedEvent.getType().equals(VesselTypeEventTypes.DELETE_FAILED);



		assert lastSuccessEvent.getType().equals(VesselTypeEventTypes.CREATED)

				|| lastSuccessEvent.getType().equals(VesselTypeEventTypes.UPDATED);

		assert isSnapshot(lastSuccessEvent.getType());



		VesselTypeDTO vesselType = ((VesselTypeEvent) lastSuccessEvent).getVesselType();
@@ -167,6 +165,12 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 
				eventError.getExceptionType(), eventError.getArguments());

	}



	@Override

	protected boolean isSnapshot(String eventType) {



		return VesselTypeEventTypes.isSnapshot(eventType);

	}



	@Override

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

		// En este caso no hay enriquecimiento