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

Añade evento para enriquecer antes de añadir 

Añade test
parent e95de201

vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/create/EnrichCreateVesselEvent.java

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



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.vessel.VesselDTO;

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

import es.redmic.vesselslib.events.vessel.common.VesselEvent;



public class EnrichCreateVesselEvent extends VesselEvent {



	// @formatter:off



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

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

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

			+ getVesselEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselEventTypes.ENRICH_CREATE;



	public EnrichCreateVesselEvent() {

		super(type);

	}



	public EnrichCreateVesselEvent(VesselDTO vessel) {

		super(type);

		this.setVessel(vessel);

	}



	@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
@@ -14,6 +14,7 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselConfirmedEvent; 
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.EnrichCreateVesselEvent;

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

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

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

	}



	@Test

	public void EnrichCreateVesselEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		EnrichCreateVesselEvent event = VesselDataUtil.getEnrichCreateVesselEvent();



		Object result = serializerAndDeserializer(event);



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

				EnrichCreateVesselEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void CreateVesselEnrichedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

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

+9 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselConfirmedEvent; 
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.EnrichCreateVesselEvent;

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

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

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;
@@ -48,6 +49,14 @@ public abstract class VesselDataUtil { 
		return event;

	}



	public static EnrichCreateVesselEvent getEnrichCreateVesselEvent() {



		EnrichCreateVesselEvent event = new EnrichCreateVesselEvent().buildFrom(getCreateEvent());

		event.setVessel(getVessel());



		return event;

	}



	public static CreateVesselEnrichedEvent getCreateVesselEnrichedEvent() {



		CreateVesselEnrichedEvent event = new CreateVesselEnrichedEvent().buildFrom(getCreateEvent());