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

Añade nuevo evento al ciclo de edición + test

parent c2e3f6dd
Loading
Loading
Loading
Loading
+3 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.create;

import java.util.UUID;

import org.apache.avro.Schema;

import es.redmic.vesselslib.dto.vessel.VesselDTO;
@@ -21,6 +23,7 @@ public class EnrichCreateVesselEvent extends VesselEvent {

	public EnrichCreateVesselEvent() {
		super(type);
		setSessionId(UUID.randomUUID().toString());
	}

	public EnrichCreateVesselEvent(VesselDTO vessel) {
+39 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.update;

import java.util.UUID;

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 EnrichUpdateVesselEvent extends VesselEvent {

	// @formatter:off

	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"
		+ "\"type\":\"record\",\"name\":\"EnrichUpdateVesselEvent\","
				+ "\"namespace\":\"es.redmic.vesselslib.events.vessel.update\",\"fields\":["
			+ getVesselEventSchema() + ","
			+ getEventBaseSchema() + "]}");
	// @formatter:on

	static String type = VesselEventTypes.ENRICH_UPDATE;

	public EnrichUpdateVesselEvent() {
		super(type);
		setSessionId(UUID.randomUUID().toString());
	}

	public EnrichUpdateVesselEvent(VesselDTO vessel) {
		super(type);
		this.setVessel(vessel);
		setSessionId(UUID.randomUUID().toString());
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
+14 −0
Original line number Diff line number Diff line
@@ -25,6 +25,7 @@ import es.redmic.vesselslib.events.vessel.delete.DeleteVesselEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.EnrichUpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
@@ -145,6 +146,19 @@ public class VesselEventsCheckAvroSchemaTest extends VesselAvroBaseTest {
		assertEquals(result, event);
	}

	@Test
	public void EnrichUpdateVesselEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

		EnrichUpdateVesselEvent event = VesselDataUtil.getEnrichUpdateVesselEvent();

		Object result = serializerAndDeserializer(event);

		assertTrue("El objeto obtenido debe ser una instancia de EnrichUpdateVesselEvent",
				EnrichUpdateVesselEvent.class.isInstance(result));

		assertEquals(result, event);
	}

	@Test
	public void UpdateVesselEnrichedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

+9 −0
Original line number Diff line number Diff line
@@ -24,6 +24,7 @@ import es.redmic.vesselslib.events.vessel.delete.DeleteVesselEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.EnrichUpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
@@ -109,6 +110,14 @@ public abstract class VesselDataUtil {
		return event;
	}

	public static EnrichUpdateVesselEvent getEnrichUpdateVesselEvent() {

		EnrichUpdateVesselEvent event = new EnrichUpdateVesselEvent().buildFrom(getCreateEvent());
		event.setVessel(getVessel());

		return event;
	}

	public static UpdateVesselEnrichedEvent getUpdateVesselEnrichedEvent() {

		UpdateVesselEnrichedEvent event = new UpdateVesselEnrichedEvent().buildFrom(getUpdateEvent());