Commit 6e0e2701 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade evento petición de checkeo antes de borrar 

Tanto para vessel como para vesseltype + tests
parent bde6ccf3

vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/delete/CheckDeleteVesselEvent.java

0 → 100644
+28 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vessel.delete;



import org.apache.avro.Schema;



import es.redmic.brokerlib.avro.common.SimpleEvent;

import es.redmic.vesselslib.events.vessel.VesselEventTypes;



public class CheckDeleteVesselEvent extends SimpleEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

		+ "\"type\":\"record\",\"name\":\"CheckDeleteVesselEvent\","

				+ "\"namespace\":\"es.redmic.vesselslib.events.vessel.delete\",\"fields\":["

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselEventTypes.CHECK_DELETE;



	public CheckDeleteVesselEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltype/delete/CheckDeleteVesselTypeEvent.java

0 → 100644
+28 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltype.delete;



import org.apache.avro.Schema;



import es.redmic.brokerlib.avro.common.SimpleEvent;

import es.redmic.vesselslib.events.vesseltype.VesselTypeEventTypes;



public class CheckDeleteVesselTypeEvent extends SimpleEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

		+ "\"type\":\"record\",\"name\":\"CheckDeleteVesselTypeEvent\","

				+ "\"namespace\":\"es.redmic.vesselslib.events.vesseltype.delete\",\"fields\":["

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTypeEventTypes.CHECK_DELETE;



	public CheckDeleteVesselTypeEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/test/java/es/redmic/vesselslib/unit/events/VesselEventsCheckAvroSchemaTest.java

+14 −0
Original line number Diff line number Diff line
@@ -15,6 +15,7 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselEnrichedEvent; 
import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent;

import es.redmic.vesselslib.events.vessel.create.CreateVesselFailedEvent;

import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;

import es.redmic.vesselslib.events.vessel.delete.CheckDeleteVesselEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckFailedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckedEvent;
@@ -207,6 +208,19 @@ public class VesselEventsCheckAvroSchemaTest extends VesselAvroBaseTest { 
		assertEquals(result, event);

	}



	@Test

	public void CheckDeleteVesselEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		CheckDeleteVesselEvent event = VesselDataUtil.getCheckDeleteVesselEvent();



		Object result = serializerAndDeserializer(event);



		assertTrue("El objeto obtenido debe ser una instancia de CheckDeleteVesselEvent",

				CheckDeleteVesselEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void DeleteVesselCheckedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

vessels-lib/src/test/java/es/redmic/vesselslib/unit/events/VesselTypeEventsCheckAvroSchemaTest.java

+14 −0
Original line number Diff line number Diff line
@@ -10,6 +10,7 @@ import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeConfirmedEv 
import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeEvent;

import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeFailedEvent;

import es.redmic.vesselslib.events.vesseltype.create.VesselTypeCreatedEvent;

import es.redmic.vesselslib.events.vesseltype.delete.CheckDeleteVesselTypeEvent;

import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCancelledEvent;

import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCheckFailedEvent;

import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCheckedEvent;
@@ -176,6 +177,19 @@ public class VesselTypeEventsCheckAvroSchemaTest extends VesselAvroBaseTest { 
		assertEquals(result, event);

	}



	@Test

	public void CheckDeleteVesselTypeEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		CheckDeleteVesselTypeEvent event = VesselTypeDataUtil.getCheckDeleteVesselTypeEvent();



		Object result = serializerAndDeserializer(event);



		assertTrue("El objeto obtenido debe ser una instancia de CheckDeleteVesselTypeEvent",

				CheckDeleteVesselTypeEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void DeleteVesselTypeCheckedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

vessels-lib/src/test/java/es/redmic/vesselslib/unit/utils/VesselDataUtil.java

+6 −0
Original line number Diff line number Diff line
@@ -14,6 +14,7 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselEnrichedEvent; 
import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent;

import es.redmic.vesselslib.events.vessel.create.CreateVesselFailedEvent;

import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;

import es.redmic.vesselslib.events.vessel.delete.CheckDeleteVesselEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckFailedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckedEvent;
@@ -156,6 +157,11 @@ public abstract class VesselDataUtil { 
		return event;

	}



	public static CheckDeleteVesselEvent getCheckDeleteVesselEvent() {



		return new CheckDeleteVesselEvent().buildFrom(getDeleteEvent());

	}



	public static DeleteVesselCheckedEvent getDeleteVesselCheckedEvent() {



		return new DeleteVesselCheckedEvent().buildFrom(getDeleteEvent());