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

Añade nuevos eventos al ciclo add/edit + tests

parent 01967c55
Loading
Loading
Loading
Loading
+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 CreateVesselEnrichedEvent extends VesselEvent {

	// @formatter:off

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

	static String type = VesselEventTypes.CREATE_ENRICHED;

	public CreateVesselEnrichedEvent() {
		super(type);
	}

	public CreateVesselEnrichedEvent(VesselDTO vessel) {
		super(type);
		this.setVessel(vessel);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
+35 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.update;

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

	// @formatter:off

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

	static String type = VesselEventTypes.UPDATE_ENRICHED;

	public UpdateVesselEnrichedEvent() {
		super(type);
	}

	public UpdateVesselEnrichedEvent(VesselDTO vessel) {
		super(type);
		this.setVessel(vessel);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
+28 −0
Original line number Diff line number Diff line
@@ -11,6 +11,7 @@ import com.fasterxml.jackson.core.JsonProcessingException;

import es.redmic.vesselslib.events.vessel.create.CreateVesselCancelledEvent;
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.VesselCreatedEvent;
@@ -24,6 +25,7 @@ import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.update.VesselUpdatedEvent;
@@ -47,6 +49,19 @@ public class VesselEventsCheckAvroSchemaTest extends VesselAvroBaseTest {
		assertEquals(result, event);
	}

	@Test
	public void CreateVesselEnrichedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

		CreateVesselEnrichedEvent event = VesselDataUtil.getCreateVesselEnrichedEvent();

		Object result = serializerAndDeserializer(event);

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

		assertEquals(result, event);
	}

	@Test
	public void CreateVesselConfirmedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

@@ -115,6 +130,19 @@ public class VesselEventsCheckAvroSchemaTest extends VesselAvroBaseTest {
		assertEquals(result, event);
	}

	@Test
	public void UpdateVesselEnrichedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

		UpdateVesselEnrichedEvent event = VesselDataUtil.getUpdateVesselEnrichedEvent();

		Object result = serializerAndDeserializer(event);

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

		assertEquals(result, event);
	}

	@Test
	public void UpdateVesselConfirmedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

+16 −0
Original line number Diff line number Diff line
@@ -10,6 +10,7 @@ import es.redmic.vesselslib.dto.vesseltype.VesselTypeDTO;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;
import es.redmic.vesselslib.events.vessel.create.CreateVesselCancelledEvent;
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.VesselCreatedEvent;
@@ -23,6 +24,7 @@ import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.update.VesselUpdatedEvent;
@@ -45,6 +47,13 @@ public abstract class VesselDataUtil {
		return event;
	}

	public static CreateVesselEnrichedEvent getCreateVesselEnrichedEvent() {

		CreateVesselEnrichedEvent event = new CreateVesselEnrichedEvent().buildFrom(getCreateEvent());
		event.setVessel(getVessel());
		return event;
	}

	public static CreateVesselConfirmedEvent getCreateConfirmedEvent() {

		CreateVesselConfirmedEvent event = new CreateVesselConfirmedEvent().buildFrom(getCreateEvent());
@@ -90,6 +99,13 @@ public abstract class VesselDataUtil {
		return event;
	}

	public static UpdateVesselEnrichedEvent getUpdateVesselEnrichedEvent() {

		UpdateVesselEnrichedEvent event = new UpdateVesselEnrichedEvent().buildFrom(getUpdateEvent());
		event.setVessel(getVessel());
		return event;
	}

	public static UpdateVesselConfirmedEvent getUpdateVesselConfirmedEvent() {

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